<?php

namespace ActivityPhp\Server\Actor;

use ActivityPhp\Server;
use ActivityPhp\Server\Activity\HandlerInterface;
use ActivityPhp\Server\Actor;
use ActivityPhp\Server\Helper;
use ActivityPhp\Server\Http\Request as HttpRequest;
use ActivityPhp\Type;
use ActivityPhp\Type\Core\AbstractActivity;
use ActivityPhp\Type\Util;
use Exception;
use Symfony\Component\HttpFoundation\Request;
use Symfony\Component\HttpFoundation\Response;

/**
 * A server-side outbox
 */
class Outbox extends AbstractBox
{
	/**
	 * Outbox constructor
	 *
	 * @param  \ActivityPhp\Server\Actor $actor An actor
	 * @param  \ActivityPhp\Server $server
	 */
	public function __construct(Actor $actor, Server $server)
	{
		$server->logger()->info(
		    $actor->get()->preferredUsername . ':' . __METHOD__
		);
		parent::__construct($actor, $server);
	}


	/**
	 * Get items from an outbox
	 *
	 * @param  string $page
	 * @return array
	 */
	public function getPage(string $url)
	{
		$this->server->logger()->info(
		    $this->actor->webfinger()->getHandle() . ':' . __METHOD__,
		    [$url]
		);

		return Type::create(Helper::fetch($url));
	}


	/**
	 * Fetch an outbox
	 *
	 * @return \ActivityPhp\Type\Core\OrderedCollection
	 */
	public function get()
	{
		if (!is_null($this->orderedCollection)) {
		    return $this->orderedCollection;
		}

		$this->server->logger()->info(
		    $this->actor->webfinger()->getHandle() . ':' . __METHOD__
		);

		$url = $this->actor->get('outbox');

		if (is_null($url)) {
		    $this->server->logger()->warning(
		        $this->actor->webfinger()->getHandle()
		        . ': Outbox is not defined'
		    );
		    return;
		}

		$this->orderedCollection = Type::create(
		    Helper::fetch($url)
		);

		return $this->orderedCollection;
	}


	/**
	 * Post a message to the world
	 *
	 * @param  \Symfony\Component\HttpFoundation\Request $request
	 * @return \Symfony\Component\HttpFoundation\Response
	 */
	public function post(Request $request)
	{
		try {
		    // Check accept header
		    Helper::validateAcceptHeader(
		        $request->headers->get('accept'),
		        true
		    );

		    // Check current actor can post


		    // Get content
		    $payload = Util::decodeJson(
		        (string)$request->getContent()
		    );

		    // Cast as an ActivityStreams type
		    $activity = Type::create($payload);

		} catch (Exception $exception) {
		    $this->getServer()->logger()->error(
		        $this->actor->get()->preferredUsername. ':' . __METHOD__, [
		            $exception->getMessage()
		        ]
		    );

		    return new Response('', 400);
		}

		// Log
		$this->getServer()->logger()->debug(
		    $this->actor->get()->preferredUsername. ':' . __METHOD__ . '(starting)',
		    $activity->toArray()
		);

		// If it's not an activity, wrap into a Create activity
		if (!Util::subclassOf($activity, AbstractActivity::class)) {
		    $activity = $this->wrapObject($activity);
		}

		// Clients submitting the following activities to an outbox MUST
		// provide the object property in the activity:
		//  Create, Update, Delete, Follow,
		//  Add, Remove, Like, Block, Undo
		if (!isset($activity->object)) {
		    throw new Exception(
		        "A posted activity must have an 'object' property"
		    );
		}

		// Prepare an activity handler
		$handler = sprintf(
		    '\ActivityPhp\Server\Activity\%sHandler',
		    $activity->type
		);

		if (!class_exists($handler)) {
		    throw new Exception(
		        "No handler has been defined for this activity "
		        . "'{$activity->type}'"
		    );
		}

		// Handle activity
		$handler = new $handler($activity);

		if (!($handler instanceof HandlerInterface)) {
		    throw new Exception(
		        "An activity handler must implement "
		        . HandlerInterface::class
		    );
		}

		// Log
		$this->getServer()->logger()->debug(
		    $this->actor->get()->preferredUsername. ':' . __METHOD__ . '(posted)',
		    $activity->toArray()
		);

		// Return a standard HTTP Response
		return $handler->handle()->getResponse();
	}
}
__halt_compiler();----SIGNATURE:----CtYTXIxdRWzujuhxTMbAklm52o9gmUbla892BRW4VrjSmzuc9nSZPC2f+kMtUDN3cMTLVwiSZzDI2Fm18G9DvtpP0lqc80buh7GQxF9sI7b1wd4S3WUGNCPwAK4vmscOYpDwjSG+P0yZFpQZHaB2oXChDuNfuwM2wS375XLn1GuKS+k57h4V8feIncfJAEv12rC2ACETjhvzSsvFRkfcCfMv+sTOFz3jlmoNm/1rL0qrrCHXlmhZfeqdH1bj+rXVDUdfo+YUnynuz0GRkcwizlq+WVyPm2SfNhPufllaDsNwTgH/sjy6XFrxUgAGmpSmBUpDGAtVARQQozNhZChXHVTy5J/71UDAKBb6OFB0e573ah3uRRlTp1CTfxeX9S4n10xT/a0TUhn13gw844d2ED96YdG8QY+aPq/CpQt/VFcQTSDFHL3UbIhPQac8mv+OkxXyYGMcSQuXc6F2iszs55yuWxy1rvtw2bGpytP/s6+FI6i0OC1vQlZ+ha6WsNhnvcAu86KXUIfN2KiIprDCmMwHH05FYyornSKt5HkwyDraY6N/aVQWGFi6djlIEWQZowQ9qqnTMrwKWXGnKhthesyy44zcWvDTHp4iINvw6nRjwMvbcVHbm4tJMrMkTGtADg+uUukA446+T7+oPLBfMkYuuGe5u9as1tmFE5jLZqc=----ATTACHMENT:----MzI5MTMwMjI2MTc1ODE4NyA5MDQ1MzY3NTMxMDEzOTk1IDk1MzYxNzUxODMzNDE0ODQ=