streams/Zotlabs/Zot6/Receiver.php

<?php

namespace Zotlabs\Zot6;

use Zotlabs\Lib\Config;

class Receiver {

	protected $data;
	protected $encrypted;
	protected $error;
	protected $messagetype;
	protected $sender;
	protected $validated;
	protected $recipients;
	protected $response;
	protected $handler;
	protected $prvkey;
	protected $rawdata;

	function __construct($handler) {

		$this->error       = false;
		$this->validated   = false;
		$this->messagetype = '';
		$this->response    = [ 'success' => false ];
		$this->handler     = $handler;
		$this->data        = null;
		$this->rawdata     = null;
		$this->prvkey      = Config::get('system','prvkey');

		$this->rawdata = file_get_contents('php://input');

		if(! $this->Valid_Httpsig()) {
			logger('signature failed');
			http_status_exit(400);
		}
		else {
			logger('signature valid');
		}

		if($this->rawdata) {
			$this->data = json_decode($this->rawdata,true);
		}
		else {
			$this->error = true;
			$this->response['message'] = 'no data';
		}

		logger('received: ' . print_r($this->data,true), LOGGER_DATA);

		if($this->data && is_array($this->data)) {
			$this->encrypted = ((array_key_exists('encrypted',$this->data)) ? true : false);

			if($this->encrypted && $this->prvkey) {
				$uncrypted = crypto_unencapsulate($this->data,$this->prvkey);
				if($uncrypted) {
					$this->data = json_decode($uncrypted,true);
				}
				else {
					$this->error = true;
					$this->response['message'] = 'no data';
				}
			}
		}
	}


	function run() {

		if($this->error) {
			// make timing attacks on the decryption engine a bit more difficult
			usleep(mt_rand(10000,100000));
			json_return_and_die($this->response);
		}

		if($this->data) {
			if(array_key_exists('type',$this->data))
				$this->messagetype = $this->data['type'];

			if(! $this->messagetype) {
				$this->error = true;
				$this->response['message'] = 'no datatype';
			}

			$this->sender     = ((array_key_exists('sender',$this->data)) ? $this->data['sender'] : null);
			$this->recipients = ((array_key_exists('recipients',$this->data)) ? $this->data['recipients'] : null);
		}

		if($this->sender)
			$this->ValidateSender();

		$this->Dispatch();
	}

	function ValidateSender() {

		$hubs = zot_gethub($this->sender,true);

		if (! $hubs) {

			/* Have never seen this guid or this guid coming from this location. Check it and register it. */
			/* (!!) this will validate the sender. */

        	$result = zot_register_hub($this->sender);

        	if ((! $result['success']) || (! ($hubs = zot_gethub($this->sender,true)))) {
            	$this->response['message'] = 'Hub not available.';
	            json_return_and_die($this->response);
    	    }
		}
		foreach($hubs as $hub) {
			update_hub_connected($hub,((array_key_exists('sitekey',$this->sender)) ? $this->sender['sitekey'] : ''));
		}
		$this->validated = true;
		$this->hubs = $hubs;
    }


	function Valid_Httpsig() {

		$tmp_result = false;

		$verified = \Zotlabs\Web\HTTPSig::verify($this->rawdata);
		if($verified && $verified['header_signed'] && $verified['header_valid']) {
			$tmp_result = true;
			if(($verified['content_signed']) && (! $verified['content_valid'])) {
					$tmp_result = false;
			}
		}
		if($tmp_result) {
			return true;
		}
		return false;
	}	
		
	function Dispatch() {

		if(! $this->validated) {
			$this->response['message'] = 'Sender not valid';
			json_return_and_die($this->response);
		}

		/* Now handle tasks which require sender validation */

		switch($this->messagetype) {

			case 'request':
				$this->handler->Request($this->data,$this->hubs);
				break;

			case 'purge':
				$this->handler->Purge($this->sender,$this->recipients,$this->hubs);
				break;

			case 'refresh':
				$this->handler->Refresh($this->sender,$this->recipients,$this->hubs);
				break;

			case 'notify':
				$this->handler->Notify($this->data,$this->hubs);
				break;

			case 'rekey':
				$this->handler->Rekey($this->sender, $this->data,$this->hubs);
				break;

			default:
				$this->response['message'] = 'Not implemented';
				json_return_and_die($this->response);
				break;
		}

	}
}