Page MenuHomePhabricator
Files F3385100

D13782.id45486.diff
No OneTemporary
Actions

D13782.id45486.diff
View Options

diff --git a/keyserver/src/responders/farcaster-webhook-responders.js b/keyserver/src/responders/farcaster-webhook-responders.js
--- a/keyserver/src/responders/farcaster-webhook-responders.js
+++ b/keyserver/src/responders/farcaster-webhook-responders.js
@@ -2,14 +2,17 @@
import { createHmac } from 'crypto';
import type { $Request } from 'express';
+import invariant from 'invariant';
import bots from 'lib/facts/bots.js';
import { extractKeyserverIDFromID } from 'lib/keyserver-conn/keyserver-call-utils.js';
import { type NeynarWebhookCastCreatedEvent } from 'lib/types/farcaster-types.js';
+import { messageTypes } from 'lib/types/message-types-enum.js';
import { threadTypes } from 'lib/types/thread-types-enum.js';
import { type NewThreadResponse } from 'lib/types/thread-types.js';
import { neynarWebhookCastCreatedEventValidator } from 'lib/types/validators/farcaster-webhook-validators.js';
import { ServerError } from 'lib/utils/errors.js';
+import { trimText } from 'lib/utils/text-utils.js';
import { assertWithValidator } from 'lib/utils/validation-utils.js';
import {
@@ -17,10 +20,16 @@
createOrUpdateFarcasterChannelTag,
farcasterChannelTagBlobValidator,
} from '../creators/farcaster-channel-tag-creator.js';
+import createMessages from '../creators/message-creator.js';
import { createThread } from '../creators/thread-creator.js';
import { fetchServerThreadInfos } from '../fetchers/thread-fetchers.js';
import { createBotViewer } from '../session/bots.js';
-import { updateRole } from '../updaters/thread-updaters.js';
+import { createScriptViewer } from '../session/scripts.js';
+import {
+ changeRole,
+ commitMembershipChangeset,
+} from '../updaters/thread-permission-updaters.js';
+import { updateRole, joinThread } from '../updaters/thread-updaters.js';
import { thisKeyserverAdmin, thisKeyserverID } from '../user/identity.js';
import { getFarcasterBotConfig } from '../utils/farcaster-bot.js';
import { getVerifiedUserIDForFID } from '../utils/farcaster-utils.js';
@@ -34,6 +43,70 @@
const { commbot } = bots;
const commbotViewer = createBotViewer(commbot.userID);
+async function createCastSidebar(
+ sidebarCastHash: string,
+ channelName: ?string,
+ channelCommunityID: string,
+ taggerUserID: ?string,
+): Promise<?NewThreadResponse> {
+ const sidebarCast =
+ await neynarClient?.fetchFarcasterCastByHash(sidebarCastHash);
+
+ if (!sidebarCast) {
+ return null;
+ }
+
+ const castAuthor = sidebarCast.author.username;
+ const channelText = channelName ? ` in channel ${channelName}` : '';
+ const messageText = `${castAuthor} said "${sidebarCast.text}"${channelText}`;
+
+ let viewer = commbotViewer;
+ if (taggerUserID) {
+ viewer = createScriptViewer(taggerUserID);
+ await joinThread(viewer, {
+ threadID: channelCommunityID,
+ });
+ } else {
+ const changeset = await changeRole(
+ channelCommunityID,
+ [commbot.userID],
+ -1,
+ );
+ await commitMembershipChangeset(viewer, changeset);
+ }
+
+ const [{ id: messageID }] = await createMessages(viewer, [
+ {
+ type: messageTypes.TEXT,
+ threadID: channelCommunityID,
+ creatorID: viewer.id,
+ time: Date.now(),
+ text: messageText,
+ },
+ ]);
+
+ invariant(
+ messageID,
+ 'message returned from createMessages always has ID set',
+ );
+ const sidebarName = trimText(messageText, 30);
+ console.log('creating sidebar from source message');
+ const response = await createThread(
+ viewer,
+ {
+ type: threadTypes.SIDEBAR,
+ parentThreadID: channelCommunityID,
+ name: sidebarName,
+ sourceMessageID: messageID,
+ },
+ {
+ addViewerAsGhost: !taggerUserID,
+ },
+ );
+
+ return response;
+}
+
async function createTaggedFarcasterCommunity(
channelID: string,
taggerUserID: ?string,
@@ -185,7 +258,23 @@
throw new ServerError('blob_fetch_failed');
}
}
- console.log(channelCommunityID);
+
+ const { hash: castHash, parent_hash: parentHash } = event.data;
+
+ // we use the parent cast to create the sidebar source message if it exists
+ const sidebarCastHash = parentHash ?? castHash;
+ const sidebarThreadResponse = await createCastSidebar(
+ sidebarCastHash,
+ event.data.channel?.name,
+ channelCommunityID,
+ taggerUserID,
+ );
+
+ if (!sidebarThreadResponse) {
+ return;
+ }
+
+ console.log(sidebarThreadResponse);
}
export { taggedCommFarcasterResponder, taggedCommFarcasterInputValidator };

File Metadata

Mime Type
text/plain
Expires
Fri, Nov 29, 11:25 PM (18 h, 28 m)
Storage Engine
blob
Storage Format
Raw Data
Storage Handle
2598573
Default Alt Text
D13782.id45486.diff (4 KB)

Event Timeline