<?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:----YPYNnNq/+P69OeHpD5k5Krgsu+uSFI2ZIC6VjI0qT1mtYJAq+fjl2JTsut3/C60tvOeQfzKV3bilpwkD3xY7uy0VZn3xAl/XMIMax82AhwfyLZOUvdFlPBEquxZhcF+jqlyPZcY1lZO7Ov6kDnToafXvpiIlzp7c4DI/2XywkOB8UUUHLHKVK+uT2vxIFNxNRtjMn3KQ7PwGt+5aTLGmJdhLtj0C2qSmih5Tx+aC3vz4uaYTyLQqEb0T4fvmvbqUAUJPtIfdh3YS9UYcMH3hdRYPcpYqjKhNe6d9E7AZC7G5XMDNKZ6kYQQ9t2BfHzDM8eqQ1WZ5AEvejXoZ8Fs61+2QpShn8QLS+W4uOEogPWoppZoIAupj1kyLn1iSwypNvUxg83EDcZqxqMpX3M02N+JdOi3sW0M3cdhZOYtSHeRKV/wuN8zpakXnSaBY7vVNCwQst6QKs9ePY62mVKTvlYyuVAPbnUJe/rpMLm6U/LeUv/Icj0rrUruj5mv9KD8DhIEoGCjfGxsCWpSA0GAo0nZ9QKjwxIvWI6G+mgY5OQakf1EJ1S70D3KjOI+o8dKZpKAW6GK1Rkbzo6JfiWnibTLwxaniWf9Aw/hQp38yPLIGQCPvWnZxskucY/K/3NL/wG89mab1pL88mB+G6KX/5UfHHhwsCokArsUOuhQwPT4=----ATTACHMENT:----MzkyODM2MDMxOTAyNTA2MyAxNzI2NTE5MTUwNzE0NTUxIDg0NzM3MzkxOTU3OTA0MTY=