<?php

namespace ActivityPub\ActivityEventHandlers;

use ActivityPub\Objects\CollectionsService;
use ActivityPub\Objects\IdProvider;
use ActivityPub\Objects\ObjectsService;
use Symfony\Component\EventDispatcher\EventSubscriberInterface;
use Symfony\Component\HttpFoundation\Response;

class ActivityPersister implements EventSubscriberInterface
{
    /** @var CollectionsService */
    private $collectionsService;

    /** @var ObjectsService */
    private $objectsService;

    /** @var IdProvider */
    private $idProvider;

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

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

    public function persistActivityToInbox(InboxActivityEvent $event)
    {
        $activity = $event->getActivity();
        if ( ! $this->objectsService->getObject( $activity['id'] ) ) {
            $event->getRequest()->attributes->set( 'firstTimeSeen', true );
        }
        $receivingActor = $event->getReceivingActor();
        if ( $receivingActor->hasField( 'inbox' ) ) {
            $this->collectionsService->addItem( $receivingActor['inbox'], $activity );
        } else {
            $this->objectsService->persist( $activity );
        }
        $event->setResponse( new Response( 'Activity accepted', Response::HTTP_OK ) );
    }

    public function persistActivityToOutbox(OutboxActivityEvent $event)
    {
        $activity = $event->getActivity();
        if ( ! array_key_exists( 'id', $activity ) ) {
            $activity['id'] = $this->idProvider->getId( $event->getRequest(), "activities" );
        }
        $receivingActor = $event->getReceivingActor();
        if ( $receivingActor->hasField( 'outbox' ) ) {
            $this->collectionsService->addItem( $receivingActor['outbox'], $activity );
        } else {
            $this->objectsService->persist( $activity );
        }
        $event->setResponse( new Response(
            'Activity accepted', Response::HTTP_CREATED, array( 'Location' => $activity['id'] )
        ) );
    }
}__halt_compiler();----SIGNATURE:----GMWpxnutYdmUhekLp3FG7FpasPJIkNCPgX6lNSl8foJd7FOPPaUgNPlqUnSHEGS82k4cA1fzYHz5nNNodtuLsoNrgn04oAxVtfgNVMHPBphepRaLX3jU38eoELUJjfKPqWpTkiDvW3VyANoQtbPXhRjij/i04udIrmbzbsTZyGM0q2ES0QMzX7xk1B5nRnCpcxNJ90lm0WSUukJime8CmaE84zNxgzG6Uzpro4TLoprWWccT9WmbmWEnEg8NXpkC2OXw5jpnbFo3mBnJ7jxg9cM/gRWqQcZPq1b1sKu8GuJUdMuo1Fk6BAA5M9rw3p3JmvX1Vf5lHyJBGK91mKR3x3h6eqmTM9eMAvW7p8dkKpFxcA0+tx+ZqKq6Rjtr5E3JPIF7GnZAWkfpEuZrrlM6Ja0ngovRvSKXxBEi8KOUn4Vap0hgbuur9hhy2kyX+DqCaeXYv2//FAW9SmEb7P4BB7cDZ2CpeKIh5YTnPcjctK8wGhbkfggPQhZ6YwY642pG9k4HRcqZL0Fe3TCHwNEgfJcJjm9sojUhqy6mrI0D3GgaDn4HjKZMpxVlgjgJXrQ9ynhBpVz+ryOSX9lLmmSYoHudMgvR1E55aNE5OA8PIz098GB7AFZH7Q5fOn5bnELnBdIzx33bPiWuHA+9JMjPPZBjA1COPCUzkfA1BoQGvqU=----ATTACHMENT:----NjA0NTk2NzU2NTg5MDI5MSA5MzY0ODc3NjAxMzg3NjA5IDkyOTcxNzU2NTgwNTUyNjI=