Implement FollowHandler

2019-02-01 10:23:30 -05:00 · 2019-02-01 10:23:30 -05:00 · efc355b7f9
commit efc355b7f9
parent d320db41a5
1 changed files with 77 additions and 0 deletions
--- a/src/Activities/FollowHandler.php
+++ b/src/Activities/FollowHandler.php
@ -0,0 +1,77 @@
+<?php
+namespace ActivityPub\Activities;
+
+use ActivityPub\Activities\InboxActivityEvent;
+use ActivityPub\Activities\OutboxActivityEvent;
+use ActivityPub\Objects\ContextProvider;
+use GuzzleHttp\Client;
+use Symfony\Component\EventDispatcher\EventDispatcher;
+use Symfony\Component\EventDispatcher\EventSubscriberInterface;
+use Symfony\Component\HttpFoundation\Request;
+
+class FollowHandler implements EventSubscriberInterface
+{
+    /**
+     * @var bool
+     */
+    private $autoAccepts;
+
+    /**
+     * @var Client
+     */
+    private $httpClient;
+
+    /**
+     * @var ContextProvider
+     */
+    private $contextProvider;
+
+    public static function getSubscribedEvents()
+    {
+        return array(
+            InboxActivityEvent::NAME => 'handleInbox',
+        );
+    }
+
+    public function __construct( bool $autoAccepts,
+                                 Client $httpClient,
+                                 ContextProvider $contextProvider )
+    {
+        $this->autoAccepts = $autoAccepts;
+        $this->httpsClient = $httpClient;
+        $this->contextProvider = $contextProvider;
+    }
+
+    public function handleInbox( InboxActivityEvent $event,
+                                 string $eventName,
+                                 EventDispatcher $eventDispatcher )
+    {
+        $activity = $event->getActivity();
+        if ( ! $activity['type'] === 'Follow' ) {
+            return;
+        }
+        if ( $this->autoAccepts ) {
+            $localActor = $event->getActor();
+            $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->set( 'actor', $localActor );
+            $outboxEvent = new OutboxActivityEvent( $accept, $localActor, $request );
+            $eventDispatcher->dispatch( OutboxActivityEvent::NAME, $outboxEvent );
+        }
+    }
+}
+?>