Add Discord Client

Author: HazAT

docker-compose.yml

@@ -22,6 +22,7 @@ services:
         - SLACK_TEAM_ID
         - SLACK_REDIRECT_URI
         - SLACK_BOT_USER_OAUTH_TOKEN
+        - DISCORD_BOT_TOKEN
         - SENTRY_BACKEND_DSN
         - SENTRY_FRONTEND_DSN
         - SENTRY_AUTH_TOKEN

src/Event/AbstractEvent.php

@@ -4,6 +4,7 @@
 namespace App\Event;
 
 use App\Http\SlackClient;
+use App\Http\DiscordClient;
 use Cake\ORM\Locator\LocatorAwareTrait;
 
 abstract class AbstractEvent
@@ -20,6 +21,7 @@ abstract class AbstractEvent
     public const TYPE_LINK_SHARED = 'link_shared';
 
     protected SlackClient $slackClient;
+    protected DiscordClient $discordClient;
 
     public string $type;
     public string $eventTimestamp;
@@ -30,6 +32,7 @@ abstract class AbstractEvent
     public function __construct()
     {
         $this->slackClient = new SlackClient();
+        $this->discordClient = new DiscordClient();
     }
 
     /**

src/Event/LinkSharedEvent.php

@@ -3,6 +3,8 @@
 
 namespace App\Event;
 
+use RestCord\DiscordClient;
+
 class LinkSharedEvent extends AbstractEvent
 {
     public string $user;
@@ -38,23 +40,38 @@ public function __construct(array $event)
     public function process(): void
     {
         foreach ($this->links as $link) {
-            $this->slackClient->unfurl(
-                channel: $this->channel,
-                timestamp: $this->messageTimeStamp,
-                unfurls: [
-                    $link['url'] => [
-                        'blocks' => [
-                            [
-                                'type' => 'section',
-                                'text' => [
-                                    'type' => 'mrkdwn',
-                                    'text' => 'asdasdasd',
+            // if Discord link, unfurl and fetch the message and return it
+            if (str_starts_with($link['url'], 'https://discord.com/')) {
+                $message = $this->fetchDiscordMessage($link['url']);
+                $this->slackClient->unfurl(
+                    channel: $this->channel,
+                    timestamp: $this->messageTimeStamp,
+                    unfurls: [
+                        $link['url'] => [
+                            'blocks' => [
+                                [
+                                    'type' => 'section',
+                                    'text' => [
+                                        'type' => 'mrkdwn',
+                                        'text' => $message,
+                                    ],
                                 ],
                             ],
                         ],
                     ],
-                ],
-            );
+                );
+            }
         }
     }
+
+    private function fetchDiscordMessage(string $url): string
+    {
+        $parts = explode('/', $url);
+        $channelId = $parts[5];
+        $messageId = $parts[6];
+        
+        $message = $this->discordClient->getMessage($channelId, $messageId);
+        return $message;
+    }
+
 }

src/Http/DiscordClient.php

@@ -0,0 +1,58 @@
+<?php
+declare(strict_types=1);
+
+namespace App\Http;
+
+use function Cake\Core\env;
+use function Sentry\captureMessage;
+use function Sentry\withScope;
+
+class DiscordClient
+{
+    protected const DISCORD_API_URL = 'discord.com/api/v10';
+
+    protected Client $client;
+
+    /**
+     * Constructor.
+     */
+    public function __construct()
+    {
+        $this->client = new Client([
+            'host' => self::DISCORD_API_URL,
+            'scheme' => 'https',
+            'headers' => [
+                'Authorization' => 'Bot ' . env('DISCORD_BOT_TOKEN'),
+                'Content-Type' => 'application/json',
+            ],
+        ]);
+    }
+
+    /**
+     * Get a message from a channel
+     * 
+     * @param string $channelId The channel ID
+     * @param string $messageId The message ID
+     * @return string The message content
+     */
+    public function getMessage(string $channelId, string $messageId): string
+    {
+        $response = $this->client->get("channels/{$channelId}/messages/{$messageId}");
+
+        if ($response->isSuccess()) {
+            $json = $response->getJson();
+            return $json['content'] ?? '';
+        }
+
+        withScope(function ($scope) use ($response, $channelId, $messageId): void {
+            $scope->setContext('Discord API', [
+                'channel_id' => $channelId,
+                'message_id' => $messageId,
+                'discord_response' => $response->getJson(),
+            ]);
+            captureMessage('Discord API error: Failed to fetch message');
+        });
+
+        return '';
+    }
+}