<?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:----Bp78mshOYdCnty8nNUejY8Rvq2KdLKzHK7xF7tEN5un5riiIP8tPHpLtr7v8OUGGXKVAooKzrg3e2c1CJFq+MwNtiet+3Nx4JxiHuK3zEJTF6b9sClIyktmczBzLBJ2LKjfRXuC0ONpigfEq1d1tGaWpIApWYI+xn2Wi1MybLtswxBVsb+N9qk1mEwBpeZ7mgBKpjmMe9SyfU7u2V4o137dWrExFpAUmVy2L6KqOwfObr1VreR44PGl2krfKn7i3t8btogk+UZzz/7HrfH3JlmNmZDK37lutKalkscW3A/6qHobrhnPKD9qD5sylSvs+L27yay1BluSKQqG7vDiUuVpP+0zqdSXOFic82L2/L8ndOcQ+sU8bJ1GlL60Y0a5nSGTQeEPrQl/FRtRszawJg7yZ6AJhu4D6WpBARbSpa/tukkGrInG65AGA5PznRsdrHgrTBEt3Bi7hzBWAolXfMFKJfXulv7qHtzV59Y2UYFPRiOumII01WhlWLf+P7S7Ulon4l74jvDMJVretnS+obK5dYEuzvoG6zVp2qWBSsbxzAJxrVX94mgVQyEYPzsOtM7PRmVbyWMkF1geKOyu97oGy4AlSluWsFbr8MKAJZlJCKm8+nqv9YbgU3uug7H3nZKWFwrhTs2dsd4VMgTdiplf7eFCji7aXVXkl3EjQ9wQ=----ATTACHMENT:----NjE0MTQ0MjcyODgyMTg3NyA4MjY1MTAzODI0MDE5MDM5IDM1NTk5MzI2MDE1ODgyOA==