<?php

namespace ActivityPub\ActivityEventHandlers;

use ActivityPub\Objects\CollectionsService;
use ActivityPub\Objects\ObjectsService;
use Symfony\Component\EventDispatcher\EventSubscriberInterface;
use Symfony\Component\HttpKernel\Exception\AccessDeniedHttpException;

class AddHandler implements EventSubscriberInterface
{
    /** @var ObjectsService */
    private $objectsService;

    /** @var CollectionsService */
    private $collectionsService;

    public static function getSubscribedEvents()
    {
        return array(
            InboxActivityEvent::NAME => 'handleAdd',
            OutboxActivityEvent::NAME => 'handleAdd',
        );
    }

    public function __construct(ObjectsService $objectsService, CollectionsService $collectionsService)
    {
        $this->objectsService = $objectsService;
        $this->collectionsService = $collectionsService;
    }

    public function handleAdd(ActivityEvent $event)
    {
        $activity = $event->getActivity();
        if ( $activity['type'] !== 'Add' ) {
            return;
        }
        $collectionId = $activity['target'];
        if ( is_array( $collectionId ) && array_key_exists( 'id', $collectionId ) ) {
            $collectionId = $collectionId['id'];
        }
        $collection = $this->objectsService->dereference( $collectionId );
        $requestActor = $event->getRequest()->attributes->get( 'actor' );
        $requestActorHost = parse_url( $requestActor['id'], PHP_URL_HOST );
        $collectionHost = parse_url( $collection['id'], PHP_URL_HOST );
        if ( $requestActorHost !== $collectionHost ) {
            throw new AccessDeniedHttpException();
        }
        $object = $activity['object'];
        $this->collectionsService->addItem( $collection, $object );
    }
}__halt_compiler();----SIGNATURE:----R54yjiwT+xNYUaRcUCM1A14OLC7HGftDjfyK6Ga9n6e1BxvQnV0Il9E9s+fBVnfPnyvAcresZnyuc0eRS8THMaB4mz/7NFG5jbUbZbN4c4xBaXwyyVU+3HYbJuICfKu/LG1fEKwwGQpfH1dnbqUN01lU2oMx7sqJGQsinc2CAeZ0Y4R/7Vb7VAxQZlU9Y4iSV3i0Ch83rQvFJ3qNDKG5sTBl3r4BwezYVeOMTBDHqdXj9QChEm75BWQB5oYToxiD8tR901sN5RalSNCkejxQmNbpZEJyzvL7ZCuIzGRPu62Lpe1LVwhzoIcM0cKqIortFT5azakFBgQNNF7KQ3TXh0LPc2HgmVEIdhibYDy3Dt/zgdaZEV5EpezsiTZHwbrdedCt0GAfbhuBq6CFH9DXY1JlKTGJ+NVvfzB7FxXfZq2/D5QEiqb0TtY8dvx7cxu5SrxhA1k/A9gkYcwyfqkaNlbumiQPEdG9j2CxjhvqjOJ4Z/9VRs3tEm0iL1qTzr6SOQ3xwTbQQCPmYokeFBQvzGKamxqzCSuV84oHA/usf+IhoM/S25OHpq3MbGWCAA52IlmRErqTNA6JtO1wooAFgSK0fZ8BGZKJP3rj12EsmKjpBSavsov46cJFaNzb+OowyAiIeIFEHM87RyohNYv4PRsGiLwKDYUHr9ibS/04qIo=----ATTACHMENT:----NTgzMTY4MTQ1MDg2MTQ4NSA5Mzg2NTA2MTkwOTIzMDQgNzU3Mjg5MDc2MDg1MTQ2