<?php

namespace ActivityPub\ActivityEventHandlers;

use ActivityPub\Objects\ContextProvider;
use Symfony\Component\EventDispatcher\EventDispatcher;
use Symfony\Component\EventDispatcher\EventSubscriberInterface;
use Symfony\Component\HttpFoundation\Request;

class FollowHandler implements EventSubscriberInterface
{
    /** @var bool */
    private $autoAccepts;

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

    public function __construct($autoAccepts, ContextProvider $contextProvider)
    {
        $this->autoAccepts = $autoAccepts;
        $this->contextProvider = $contextProvider;
    }

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

    public function handleInbox(
        InboxActivityEvent $event,
        /** @noinspection PhpUnusedParameterInspection */
        $eventName,
        EventDispatcher $eventDispatcher,
    ) {
        $activity = $event->getActivity();
        if ( !$activity['type'] === 'Follow' ) {
            return;
        }
        if ( $this->autoAccepts ) {
            $localActor = $event->getReceivingActor();
            $objectId = $activity['object'];
            if ( is_array( $objectId ) && array_key_exists( 'id', $objectId ) ) {
                $objectId = $objectId['id'];
            }
            if ( $localActor['id'] !== $objectId ) {
                return;
            }
            $accept = array(
                '@context' => $this->contextProvider->getContext(),
                'type' => 'Accept',
                'actor' => $localActor['id'],
                'object' => $activity['id'],
            );
            $request = Request::create(
                $localActor['outbox'],
                Request::METHOD_POST,
                array(), array(), array(),
                array(
                    'HTTP_ACCEPT' => 'application/ld+json',
                    'CONTENT_TYPE' => 'application/json'
                ),
                json_encode( $accept )
            );
            $request->attributes->add( array(
                'actor' => $localActor,
                'follow' => $activity,
            ) );
            $outboxEvent = new OutboxActivityEvent( $accept, $localActor, $request );
            $eventDispatcher->dispatch( OutboxActivityEvent::NAME, $outboxEvent );
        }
    }
}__halt_compiler();----SIGNATURE:----OF59qZxiRWfgBQK8CK/1VFgwRco1aADBfKXM/Jw4HY/eDHo5oLfMN74QGeCc25DuIa65UVuOe36ASYMp+XXJEmx2IwegxX4anbXr6hb1jhwcWm8NcsULVYs6vdgQvy5AckIYMNox/Z3ldR4XC8XC4188j0FnAh0uebEkt8v2WqAXuH6y01Gfk/pOy2v+QZ5yR/hOIsU5k70p/aNEe1l6pyjqLe3YgZmxZt8kgp858KckKmKyCQt9VEbEnCTpFSxSPXfQZ1rCKXlV+v7IEke/soYsU03YphshmMCKmbt27nu1P7Dtk1XoC5vJoFHY2V4dsAH3lE8+E5nYvAsxM/8x3jJmhNHw+PFTgfMKxYDRMIhfCJccOp/yfFgPfZrZ79mwP1WVjbuMUXwM/MPigMIoZomMzJRgoF2j7rQwFpdSivmjO3uyQIDcua6Ne0yojcxp7YYPBYHJGBEGUrfVlmqDaNLcfQzxQy11Mo83S8NOg4oRQ2NrNm911e91bnTrCAkNZQGE59BxhP65rJ3Hl+SLH4PXSyfdrPLN1AmcaVpQ/CIb35s1dT3rJc02RY/nJAoZNKCpWzZ16eRxEekLe1d91PubCfxDYo4F6yCq4B9oKNKrrnGW04nqGSJIj18MbbtadBxw40MGsAbN+bIx5HFY4aSiLo5eq+Of+CRaS49pibI=----ATTACHMENT:----MjY4MzkzNjIxMDk0MzAzNCA2MDE5MTMwODAxNDc0NzkzIDk3Nzc5NDc5MjkwODI4Mjc=