First commit

2025-12-10 03:05:26 +00:00 · 2024-12-11 13:13:07 -06:00
commit 8725f3e022
11 changed files with 339 additions and 0 deletions
--- a/src/index.ts
+++ b/src/index.ts
@@ -0,0 +1,123 @@
+import {
+    BadBotHandler,
+    CreateSkeetHandler,
+    DebugLog,
+    GoodBotHandler,
+    HandlerAgent,
+    InputEqualsValidator,
+    JetstreamSubscription,
+    LogMessageAction,
+    ReplyingToBotValidator,
+    MessageHandler,
+    IntervalSubscription,
+    IntervalSubscriptionHandlers,
+    AbstractHandler,
+    IsSpecifiedTimeValidator,
+    CreateSkeetAction,
+    ActionTakenByUserValidator,
+    LogInputTextAction,
+    JetstreamEventCommit,
+    JetstreamSubject,
+    JetstreamRecord, TestValidator
+} from 'bsky-event-handlers';
+
+const testAgent = new HandlerAgent(
+    'test-bot',
+    <string>Bun.env.TRACKER_BSKY_HANDLE,
+    <string>Bun.env.TRACKER_BSKY_PASSWORD
+);
+
+
+/**
+ * Jetstream Subscription setup
+ */
+let jetstreamSubscription: JetstreamSubscription;
+
+
+let handlers = {
+    post: {
+        c: [
+            new MessageHandler(
+                // @ts-ignore
+                [ActionTakenByUserValidator.make(<string>Bun.env.USER_DID)],
+                [
+                    CreateSkeetAction.make("Aaron posted:", undefined, (handler: HandlerAgent, commit: JetstreamEventCommit): JetstreamSubject =>{
+                    return {
+                        cid: MessageHandler.getCidFromMessage(handler, commit),
+                        uri: MessageHandler.getUriFromMessage(handler, commit)
+                    }
+                }),
+                    LogInputTextAction.make("Post")
+                ],
+                testAgent
+            ),
+            GoodBotHandler.make(testAgent)
+        ]
+    },
+    like: {
+        c: [
+            new MessageHandler(
+                // @ts-ignore
+                [ActionTakenByUserValidator.make(<string>Bun.env.USER_DID)],
+                [
+                    CreateSkeetAction.make("Aaron liked:", undefined, (handler: HandlerAgent, commit: JetstreamEventCommit): JetstreamSubject =>{
+                        return commit.commit.record.subject as JetstreamSubject;
+                    }),
+                    LogInputTextAction.make("Like")
+                ],
+                testAgent
+            )
+        ]
+    },
+    repost: {
+        c: [
+            new MessageHandler(
+                // @ts-ignore
+                [ActionTakenByUserValidator.make(<string>Bun.env.USER_DID)],
+                [
+                    CreateSkeetAction.make("Aaron reposted:", undefined, (handler: HandlerAgent, commit: JetstreamEventCommit): JetstreamSubject =>{
+                        return commit.commit.record.subject as JetstreamSubject;
+                    }),
+                    LogInputTextAction.make("Repost")
+                ],
+                testAgent
+            )
+        ]
+    },
+    block: {
+        c: [
+            new MessageHandler(
+                // @ts-ignore
+                [
+                    ActionTakenByUserValidator.make(<string>Bun.env.USER_DID)
+                ],
+                [
+                    CreateSkeetAction.make((handler: HandlerAgent, event: JetstreamEventCommit): string => {
+                        const blockedDid = event.commit.record.subject
+                        return "Aaron blocked a user: " + blockedDid;
+                    }, undefined, undefined),
+                    LogInputTextAction.make("Block"),
+                ],
+                testAgent
+            )
+        ]
+    }
+}
+
+
+
+async function initialize() {
+    await testAgent.authenticate()
+    jetstreamSubscription = new JetstreamSubscription(
+        handlers,
+        <string>Bun.env.JETSTREAM_URL
+    );
+
+}
+
+initialize().then(() =>{
+    jetstreamSubscription.createSubscription()
+    DebugLog.info("INIT", 'Initialized!')
+});
+
+