<?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:----s8Ncm0pnQpwfVqWTWjxmhpDVu6HuBLkio1KUxSZohqunZAzTuvWeILKT2+9Piji/XR0H/pdfJIZoRnwWUjIrV8K1/hwwby22ONEPjPuYiCPiOJfG0cSdarMXaAJ4aoRPVWXpMIjLsFzdyG4HOhjS8fsPV0hT+QktGeQYeFOyNTvtquqwGnaGi/qufR4rcSYcl37q1QeVIr1zw65EjCNJ4asRYHkm6GBTMTBtcxhbwd+96cPpwRStByjabREOIXFbnb7TFn/RQqfTczNBv1mZuZpmJgSyIz6hir20sUnhffjDLxjWcjO/xgFsEWBToGtllNLUvThK3/V3cQHAUqeYxtA4zNAhMhCUToNUugfOj32clULMvnP3DplUdIhdEAwUpcDRC8LhhN9aKozy+4jIROc9oN3IVNMwubUrf+zbYtkKBwfW3o4NGVx7R7cLmGs78t4BIFCngLghSsms+7qrp8zZDGwFzIVEYI4Stzqbb87rgB/ZDI59Q+VZUc2hKmZa+0TAe/9/iSNQ6f/uUkh+9yO2LgERKOLBshYmcpWLhyeg/cGhn+jMKbdk5KlXv9IRmlGHRX3tksm/41WIplZ3EBicFWWnWlebxPnUx/MEaSkFJykNc8lr+i9KiRQ+USHzWcinclNWeHRHY2YqpdD+Ht5r4DMT0R1OkxR34dA7ww4=----ATTACHMENT:----MzMyMjU1MDcxNjQ0OTcyOSA3OTU1NDIzMTA4MjYxMzMgNTE1MjMzNzg2NzA3ODAw