<?php

namespace ActivityPub\ActivityEventHandlers;

use ActivityPub\Entities\ActivityPubObject;
use ActivityPub\Objects\CollectionsService;
use ActivityPub\Objects\ContextProvider;
use ActivityPub\Objects\ObjectsService;
use Symfony\Component\EventDispatcher\EventSubscriberInterface;
use Symfony\Component\HttpKernel\Exception\BadRequestHttpException;

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

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

    /** @var ContextProvider */
    private $contextProvider;

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

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

    public function handleInbox(InboxActivityEvent $event)
    {
        $activity = $event->getActivity();
        if ( $activity['type'] !== 'Announce' ) {
            return;
        }
        $objectId = $activity['object'];
        if ( is_array( $objectId ) && array_key_exists( 'id', $objectId ) ) {
            $objectId = $objectId['id'];
        }
        if ( ! is_string( $objectId ) ) {
            throw new BadRequestHttpException( 'Invalid object' );
        }
        $object = $this->objectsService->dereference( $objectId );
        if ( ! $object->hasField( 'shares' ) ) {
            $object = $this->addCollectionToObject( $object, 'shares' );

        }
        $shares = $object['shares'];
        $this->collectionsService->addItem( $shares, $activity );
    }

    private function addCollectionToObject(ActivityPubObject $object, $collectionName)
    {
        $updatedObject = $object->asArray();
        $updatedObject[$collectionName] = array(
            '@context' => $this->contextProvider->getContext(),
            'id' => rtrim( $updatedObject['id'], '/' ) . '/' . $collectionName,
            'type' => 'Collection',
            'items' => array(),
        );
        return $this->objectsService->update( $object['id'], $updatedObject );
    }
}__halt_compiler();----SIGNATURE:----ZA9SsTUmUI8zZSW8cOPDhLj3EiIO/qb2nMuzRhCOpk2TXuUWlkTBufXOeUVV5iPXB7TgFbLyqGSmbEvtzvoUItBboD+Q5EXB5Oksr6xPEf/JbOLaDYXNDbQe08LLkLgy0TS5qpDJTt3mteoe+YF69WzzHZk3/1xlcT/WDpp4tWAr60E9vhSBqmq8ubRyieZs5za/c7qZYz9WCBwyfG1ZVa7cjp8XrVS4p3sQWR1AB2yRu6E8ThOs444/jwVBszErf+mrLkFxUDEj/juOjFzYFPHH2cfrUmas2X+12OHjKYx/1xr4/DpxL9ywK4rJr7FosIf2djCiC7BM6aXQnO60UbblnB9aHI27oB8cwpzDUmtQ3R1tF7OCcpSKMOOh3WleO09dpvFgrGrAzo7qwyum5N9yj9hRukmyjmh/q4YYQjFa6i/Sxgdgl++BUb7tB+UttujBmFXnSZvfsnOA0fetxzQAE3MT2mBXAekGGZnE+KCLb8nNfqZEouBNQl3Z+/HKGOR5m2EnI/mO2ozk6aFKQVV8dKSDdgiHSM+gdQ43bM8I3y9AFM4gGoIc+aYL3A/HVbrNbo6jbu7yxvTmAt3xqlzixLUmi6PsmX9x11l+y+g7arhn8R286YMNwXt3qAcWBTADMiZRPQIKT1tZn66GCbH/LPehHJ3thNWjeAmISsQ=----ATTACHMENT:----NDk3MzEwODU1MTM0Mjg5MyA2NTk0NjQ0MjM1MTUzODQ4IDM2NzQxMDMwNzMyNzUwNjM=