<?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:----GPYShq0SRx9onACys+JslL6cCFwjBVVutS53NRw7MF6vVnt52cePv38XCWV8UKcje428ce6CU2MrcwsUOi9GwuJMetXYmBHSx+9eZHoUVADCcNDC9bxlzPXfaSyOcojMxMgu5E37h7cXdZenAffo6LQj8/tgmE10bDuKztSJEx/nwuRwfgvKIbSpkeS9vTYm/xrJuKm2oo8hNWsqJGSnfI5KsQ1xqCslyoKwH4zzkRdrgxYS4Euu+S6HFPBMvNg8kP+sASmHDpHRc/gZbgUi3WDiH7c1pYVq/4y8vk2NNcFI3S6NG2SQ4R5mjnJZ0fin7ZRNicJvA/na6Pl00alTuAYda/kpoZVfKRbezkPTEMliV2mvVMFsjfmTRlYsQTk9Au9qD64BCqr8QLNhoHNyoUpdMoAwbEvkE7i7XWRRmvf4KYW4Xms6kywd5pOGJly1Bxr09fiyJHseoLrFbSaqJmSxmutBbsZIxWcvzCd0FQtj+ShELPpr96uoPwLd7M4DMr3+57MEOO8NjQ4XCRs4AwJxnf3XLURmMEEawiEZgyaKeygmyoystqvJsUqxcwDEPA5yMSTOn6KPFx0w058CVnB9RcQjCczLi8mTTfl7Ut30ZHcpflSb+NScKEuIXnFqInecw+O5yiga4YCTOu9gC2AYxCM1zaO6Ubw+bzUmj18=----ATTACHMENT:----MTc0NjU5MDYyNzYyMTM3NSAxMTA5MDUwMjUwMjU4NDAzIDg3NTc2MDI2MDM1NjM1NjY=