<?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:----xmvvZhEzQMjn0UsSeV1mkRMgzgvzkzpG7DQQdipSiGixUdgMH+Y9yIAvGoAWkmb8HupfoRNYOaH7/b+HCqcV4KyZw8fzDo/bRkllvMXNaNMKq5afSQNgJu2crT9CLIe64wm7dxu7ur3J2f4+/VA1OWNh3lObDvOVMNuhBUdvJQwyFTSnnNzqVi2BXVhKgHm0QksV/woG+zk58FqYTVGvyYd1gMHvjH0wObJe6Wlf0tqbc2p16rT0m0JGkCCy1rArbf+qOE0fPjtiV4InFstZeS/tjncc2fGvEoQH5t6fHiGHMHVu4Lofz6bGMVr+igBo5/fWWndnwGiB8x3Bgc1X80+nEwwcopuz16I3r0H8GUJyiJh7+L4GLkur9Rd0o72GnYW3mP2WqjWJONvh+YSjzizU8UstQDNxe7Dgb9BUPO0m5OqhH+NBCCGJqEJueF6QGcVllmGllW+2Oy6JrHnbtu3SXfVuf0yzTREsz/dibkg6HT5RHjIpS2a0GJG/6Dv3r16YlzS/TZHoDMftdJR15bv+fkYcyET6TRPuN8RxKKXFYiXQRFmWU7lsvKqpFtOAgNObJdBP0pLiToYkBgkWxTP2/8dKyCsR9PbDtlmR6+QBuVexuPs7Efw/5menAPRe1Gt7LiCxmUNmEme9tsPaZ6FZgtDBwVyR/+JgO5iOYKA=----ATTACHMENT:----OTkxMjMzNDc0NTAxNzUyOSA3NzM0Nzg4MDE3MTA0NTM0IDQ1NTg1NDg2MzI4MzQxNDY=