<?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:----OzXBcuBmn3mmpAY+ps9QU4FdEETV6aV15DIM5FB+mud8Kmp61zpqI0u68eqArXWO4/m+maHGuS0m3lBjM9sBHxOy0kBfRE4r7slPixu7syF+qfugs6NhLGsz8CNPiENnxEol9AaKfT6SZtLQGaZS6POHt6DBLKMHjl7LtEQkQO48QbcsII5YpjiYLh4ewu3jA47JfOEb1pRz8p62FTvbH8mg1wuRy/Ia7AhxxUc1NKFTQqw01HqeRfSetdBphkwTh981qrFzA/x63zT+3nf+/fYtPmkGA6Bf7g97952tR7rhwThJRASNjuh217mXa4axWBUa1M0Idk4OkBUJezcKLXg4HBIxkCGSn2sIrOuB+d22w6jOXDIaOXMCEtOSSqhctyglTXclNHVIH7W1v+xM3D3NMsZkyJAByLRur1D4PDeBbQo+FAkcWGKBDYk8DJ3UX5SQywwFXi4KxSuTJQvs2f+ezyK5+kHVmEB91SQN93fkirEIPXcSlwBywfn4PgkkkoafM+c7R8RyC1m9c9JdF0ALY1y1kxW0ggW/QwiAqlIINz6GdEuWIYZ7leWgRzKd5hxFGD2NxdsgKs0tyBcx2dA18e3+c6/JNknU56bqEsjGDDMlNwiLYVfC4vSYGstNPqoYxjE3MJSDOax7K12TkflV3D0D/tZS8YQg+UWMWRM=----ATTACHMENT:----ODAyNjY0NjI4NjMyNDc5NyA5MzYxODcxODA3MzE1MTA2IDc4MDEyMzg5MDM2NDI4NzU=