feat: add post to bluesky feed command

Author: ebiggz

src/interactions/commands/command-manager.ts

@@ -24,6 +24,7 @@ import { backupRequestCommand } from './handlers/backup-request';
 import { createVoicechat } from './handlers/voicechat/voice-slash';
 import { removeBlueskyPostFromFeedSlashCommand } from './handlers/remove-bluesky-post-from-feed-slash';
 import { supportedVersionsSlashCommand } from './handlers/supported-versions-slash';
+import { addBlueskyPostToFeedSlashCommand } from './handlers/add-bluesky-post-to-feed-slash';
 
 class CommandManager implements IInteractionManager {
     private handlers: ICommandHandler[] = [];
@@ -49,6 +50,7 @@ class CommandManager implements IInteractionManager {
             backupRequestCommand,
             createVoicechat,
             removeBlueskyPostFromFeedSlashCommand,
+            addBlueskyPostToFeedSlashCommand,
             supportedVersionsSlashCommand
         ];
 

src/interactions/commands/handlers/add-bluesky-post-to-feed-slash.ts

@@ -0,0 +1,36 @@
+import { EmbedBuilder, SlashCommandBuilder } from 'discord.js';
+import { CommandType, ICommandHandler } from '../command-handler.interface';
+import { addPostToFeed, removePostFromFeed } from '../../../services/firebot-atproto-feed.service';
+
+const config = new SlashCommandBuilder()
+    .setName('addtofeed')
+    .setDescription('Add a post to the Firebot Bluesky feed')
+    .addStringOption((option) =>
+        option
+            .setName('posturl')
+            .setDescription('The url of the post to add to the feed')
+            .setRequired(true)
+    )
+    .setDefaultMemberPermissions(0);
+
+export const addBlueskyPostToFeedSlashCommand: ICommandHandler = {
+    type: CommandType.SlashCommand,
+    config,
+    async onTrigger(interaction) {
+        await interaction.deferReply();
+
+        const postUrl = interaction.options.getString('posturl', true);
+
+        const { success, errorMessage } = await addPostToFeed(postUrl);
+
+        if (success) {
+            await interaction.followUp({
+                content: `Successfully added post to Firebot Bluesky feed!`,
+            });
+        } else {
+            await interaction.followUp({
+                content: `Could not add post to feed: ${errorMessage ?? 'Unknown error'}`,
+            });
+        }
+    },
+};

src/services/firebot-atproto-feed.service.ts

@@ -25,11 +25,44 @@ export async function removePostFromFeed(
                 errorMessage: error?.response?.data?.error,
             };
         } else {
-            console.log('Error getting featured streams', error);
+            console.log('Error removing post from feed', error);
             return {
                 success: false,
                 errorMessage: 'An error occurred removing post from feed',
             };
         }
     }
 }
+
+export async function addPostToFeed(
+    postUrl: string
+): Promise<{ success: boolean; errorMessage?: string }> {
+    try {
+        const response = await axios.post(
+            'https://atprotofeed.firebot.app/post',
+            {
+                params: {
+                    postUrl,
+                    token: config.firebot.atProtoFeedApiToken,
+                },
+            }
+        );
+        return {
+            success: response?.status === 200,
+            errorMessage: response?.data?.error,
+        };
+    } catch (error) {
+        if (error && error.response) {
+            return {
+                success: false,
+                errorMessage: error?.response?.data?.error,
+            };
+        } else {
+            console.log('Error adding post to feed', error);
+            return {
+                success: false,
+                errorMessage: 'An error occurred adding post to feed',
+            };
+        }
+    }
+}