From 7c1d2c47ec672c30482c9d0ab82d4e3f1d74cfd6 Mon Sep 17 00:00:00 2001
From: =?UTF-8?q?R=C4=B1dvan=20Akca?= <akca.ridvann@gmail.com>
Date: Mon, 27 May 2024 17:22:47 +0200
Subject: [PATCH] feat(bluesky): add reply to post action

---
 .../backend/src/apps/bluesky/actions/index.js |  3 +-
 .../bluesky/actions/reply-to-post/index.js    | 55 ++++++++++++++++++
 .../src/apps/bluesky/common/get-reply-refs.js | 58 +++++++++++++++++++
 packages/docs/pages/apps/bluesky/actions.md   |  2 +
 4 files changed, 117 insertions(+), 1 deletion(-)
 create mode 100644 packages/backend/src/apps/bluesky/actions/reply-to-post/index.js
 create mode 100644 packages/backend/src/apps/bluesky/common/get-reply-refs.js

diff --git a/packages/backend/src/apps/bluesky/actions/index.js b/packages/backend/src/apps/bluesky/actions/index.js
index 5e160da2..b4e1c5d3 100644
--- a/packages/backend/src/apps/bluesky/actions/index.js
+++ b/packages/backend/src/apps/bluesky/actions/index.js
@@ -1,4 +1,5 @@
 import createPost from './create-post/index.js';
+import replyToPost from './reply-to-post/index.js';
 import searchPostByUrl from './search-post-by-url/index.js';
 
-export default [createPost, searchPostByUrl];
+export default [createPost, replyToPost, searchPostByUrl];
diff --git a/packages/backend/src/apps/bluesky/actions/reply-to-post/index.js b/packages/backend/src/apps/bluesky/actions/reply-to-post/index.js
new file mode 100644
index 00000000..ec1605a5
--- /dev/null
+++ b/packages/backend/src/apps/bluesky/actions/reply-to-post/index.js
@@ -0,0 +1,55 @@
+import { BskyAgent, RichText } from '@atproto/api';
+
+import defineAction from '../../../../helpers/define-action.js';
+import getReplyRefs from '../../common/get-reply-refs.js';
+
+export default defineAction({
+  name: 'Reply to post',
+  key: 'replyToPost',
+  description: 'Replies to a post.',
+  arguments: [
+    {
+      label: 'Post Url',
+      key: 'postUrl',
+      type: 'string',
+      required: true,
+      variables: true,
+      description: 'Enter whole post url you want to reply here.',
+    },
+    {
+      label: 'Text',
+      key: 'text',
+      type: 'string',
+      required: true,
+      variables: true,
+      description: 'Your post.',
+    },
+  ],
+
+  async run($) {
+    const text = $.step.parameters.text;
+    const postUrl = $.step.parameters.postUrl;
+
+    const replyRefs = await getReplyRefs($, postUrl);
+
+    const agent = new BskyAgent({ service: 'https://bsky.social/xrpc' });
+    const richText = new RichText({ text });
+    await richText.detectFacets(agent);
+
+    const body = {
+      repo: $.auth.data.did,
+      collection: 'app.bsky.feed.post',
+      record: {
+        $type: 'app.bsky.feed.post',
+        text: richText.text,
+        facets: richText.facets,
+        createdAt: new Date().toISOString(),
+        reply: replyRefs,
+      },
+    };
+
+    const { data } = await $.http.post('/com.atproto.repo.createRecord', body);
+
+    $.setActionItem({ raw: data });
+  },
+});
diff --git a/packages/backend/src/apps/bluesky/common/get-reply-refs.js b/packages/backend/src/apps/bluesky/common/get-reply-refs.js
new file mode 100644
index 00000000..b39ddb8f
--- /dev/null
+++ b/packages/backend/src/apps/bluesky/common/get-reply-refs.js
@@ -0,0 +1,58 @@
+const parseUri = (uri) => {
+  const parts = uri.split('/');
+
+  return {
+    repo: parts[4],
+    collection: 'app.bsky.feed.post',
+    rkey: parts[6],
+  };
+};
+
+const getReplyRefs = async ($, parentUri) => {
+  const uriParts = parseUri(parentUri);
+
+  try {
+    const { data: parent } = await $.http.get('/com.atproto.repo.getRecord', {
+      params: uriParts,
+    });
+
+    const parentReply = parent.value?.reply;
+    let root;
+
+    if (parentReply) {
+      const rootUri = parentReply.root.uri;
+      const [rootRepo, rootCollection, rootRkey] = rootUri
+        .split('/')
+        .slice(2, 5);
+
+      const params = {
+        repo: rootRepo,
+        collection: rootCollection,
+        rkey: rootRkey,
+      };
+
+      const rootResp = await $.http.get('/com.atproto.repo.getRecord', {
+        params,
+      });
+
+      root = rootResp.data;
+    } else {
+      root = parent;
+    }
+
+    return {
+      root: {
+        uri: root.uri,
+        cid: root.cid,
+      },
+      parent: {
+        uri: parent.uri,
+        cid: parent.cid,
+      },
+    };
+  } catch (error) {
+    throw new Error('Error while fetching records');
+  }
+};
+
+export default getReplyRefs;
diff --git a/packages/docs/pages/apps/bluesky/actions.md b/packages/docs/pages/apps/bluesky/actions.md
index b5e73c8c..4f087ea7 100644
--- a/packages/docs/pages/apps/bluesky/actions.md
+++ b/packages/docs/pages/apps/bluesky/actions.md
@@ -3,6 +3,8 @@ favicon: /favicons/bluesky.svg
 items:
   - name: Create post
     desc: Creates a new post.
+  - name: Reply to post
+    desc: Replies to a post.
   - name: Search post by url
     desc: Searches a post in a thread by url.
 ---