<?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:----EveS7JXI3kfzsxHM83fTjgyiBMljd7+kzTCJbLwVEO/7/1g/arNJKkpg3YJn1hYNb5SURJzcRa+9b3YQrlg4EldMV4fSwkC0wOREsjD5oGZJ+saLw74WTJqaE5CbRYypatwOfVJ8HBK4KG3pm+m5M5wulsxMYmKOI0QQ2jRVwISI+1TpqNWJ7GhiM+ERktyv99Vh7PLFVu3aAKJFeYNcdQm7TuWRrz86zGChdNzeZVksGvcja0utJqlYaiZvgExg67MsN3ijtNPdOc4YVQE4IOlzfCCgrIm39hzJ4orD0M2MMMNTU/0PPA/5qKqqwNxc9g5bdhmC/ynfMOG9BzSjVEvdmNTkIwOQTAT5fbFtu6jKpRWLgbonkvlS1xLt6+JI/DSi5+34p1akn0fVAmqjms/jdcHmHbHisK0NnTF4W9JJ2as0zoZRG1aB7bb7XbLzjCDkmzUVPEXDXohVofNTFWTS8bedSxM249S6+m3HCGOu5i04dn3LpKD5EUSUx+MyqC3PvIFLXCEHBjFCf/5GWdGIBknDzhtvWKiv4pHsVH2yeLgxhl8403Z+rwsAO5QhhZjDo2Jy1MK04oQTL+M8cUMqJckwP7BFlLgw3I7bDU9V3MOAKZRTOyVsBho1MQa8NLwRMQ02fpumK3LCia8vS88nuJz1RFv3y7y4qfB4WqY=----ATTACHMENT:----ODQwNTM2MzAzODI0OTI2NCA0MjU4ODE2MzM2OTQzNDg2IDU1OTE5NDE3ODMzODI5MTM=