<?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:----ztZRG5Uw7k/oY+LtNgldHrJq/yxwvhrD0YrDj9hMFg4kU0g4u1eD+RSrw5EsfioglMIR9EGyBVeLtUYvPbFArwASmIDrPtxumzWGKxQ4Y3tCwNUyQDSKViUPIyp6RYEczKyh+PBFPXrye+rPa1+Lv90WYqFK/MHQU62JWbw5bW94xeK+GS2Zls87VlvZxR9RtRS9d6wwl/EERNZZ5c9bcg81u8D8+8sGVB6C1haF7TcqCYAqrEd6G6JCSrLmkW270Nb4Vj/wAcqymcIdgf/Ux3xoXvwNpgMR0RVVsvMTep2aJtmonHcn666iA/mpbDyrNcPfP+I7Eq9uPYGHtr8Yt6nzrRpSGBs/7AqQh9lx2zCqu+jpxM+bdNZdlyX0oFuY8rceXbG2HcgAhYVcJ2mpQbXSFzeVW1/OtkVN7hL6nK5LhtsD2paPAyVznA5Ssk5DxPZgcU9fx4o8vaLFOEte2zGv4eaSRtF+exOFxNNjRTtGzlcJ0eTN/UPeTSMSXZKjrfkpLgfsr0q4ha/kjV8WcsZMoWtbiRo9ywt+R8QYkloUpu2RJUeyles8+X35VdoEPfi2rkfVgRXQlTzRiI2uHAEavsr70Y6FaIyP7nbZ70b8JUzpN7zyabv7lkfSRA0Jb5cHMsSLLAY0XVmZe4HUN8j0QNjvJwf+QXAhopF4P5c=----ATTACHMENT:----NTE2MDA5MDk0MDM2Nzk3NCA1NzAyMzgwNjgxMzg3MjkgNDcyNjgzNzAzNzI0ODA2Mg==