Differential D13694

[keyserver] move async iife to standalone function
ClosedPublic
Actions

Authored by varun on Oct 10 2024, 11:31 AM.

Details

Reviewers

ashoat

Commits

rCOMM8a98670d7370: [keyserver] move async iife to standalone function

Summary

keyserver.js is already massive, and the async iife in the middle makes it harder to follow

Depends on D13667

Test Plan

cleared the access token from the metadata table and ran keyserver as a secondary node. confirmed that node polled every 5 seconds for identity info.

killed and ran keyserver as primary. access token was added to metadata table.

killed and ran keyserver as secondary again. node was able to fetch access token and did not get stuck in loop

Diff Detail

Repository

rCOMM Comm

Branch

keyserver-platform-details (branched from master)

Lint

No Lint Coverage

Unit

No Test Coverage

Event Timeline

varun created this revision.Oct 10 2024, 11:31 AM

Herald added a subscriber: tomek. · View Herald TranscriptOct 10 2024, 11:31 AM

Harbormaster completed remote builds in B32188: Diff 45071.Oct 10 2024, 11:49 AM

varun requested review of this revision.Oct 10 2024, 11:49 AM

Thanks for doing this cleanup! I'm assuming it's a clean refactor, so I didn't review very closely

This revision is now accepted and ready to land.Oct 10 2024, 11:54 AM

use full line length for comments

This revision was landed with ongoing or failed builds.Oct 10 2024, 12:07 PM

Closed by commit rCOMM8a98670d7370: [keyserver] move async iife to standalone function (authored by varun). · Explain Why

This revision was automatically updated to reflect the committed changes.

varun added a commit: rCOMM8a98670d7370: [keyserver] move async iife to standalone function.

Harbormaster completed remote builds in B32192: Diff 45075.Oct 10 2024, 12:22 PM

Revision Contents
Changeset List

Path

Size

keyserver/

src/

keyserver.js

41 lines

utils/

keyserver-services-setup.js

49 lines

Diff 45071

View Options

keyserver/src/keyserver.js

// @flow		// @flow

import { createHmac } from 'crypto';		import { createHmac } from 'crypto';
import type { $Request } from 'express';		import type { $Request } from 'express';
import invariant from 'invariant';		import invariant from 'invariant';

import bots from 'lib/facts/bots.js';		import bots from 'lib/facts/bots.js';
		import { inviteLinkURL } from 'lib/facts/links.js';
import { extractKeyserverIDFromID } from 'lib/keyserver-conn/keyserver-call-utils.js';		import { extractKeyserverIDFromID } from 'lib/keyserver-conn/keyserver-call-utils.js';
import { createSidebarThreadName } from 'lib/shared/sidebar-utils.js';		import { createSidebarThreadName } from 'lib/shared/sidebar-utils.js';
import { type NeynarWebhookCastCreatedEvent } from 'lib/types/farcaster-types.js';		import { type NeynarWebhookCastCreatedEvent } from 'lib/types/farcaster-types.js';
import { messageTypes } from 'lib/types/message-types-enum.js';		import { messageTypes } from 'lib/types/message-types-enum.js';
import { threadTypes } from 'lib/types/thread-types-enum.js';		import { threadTypes } from 'lib/types/thread-types-enum.js';
import { type NewThreadResponse } from 'lib/types/thread-types.js';		import { type NewThreadResponse } from 'lib/types/thread-types.js';
import { neynarWebhookCastCreatedEventValidator } from 'lib/types/validators/farcaster-webhook-validators.js';		import { neynarWebhookCastCreatedEventValidator } from 'lib/types/validators/farcaster-webhook-validators.js';
import { ServerError } from 'lib/utils/errors.js';		import { ServerError } from 'lib/utils/errors.js';
▲ Show 20 Lines • Show All 179 Lines • ▼ Show 20 Lines
}		}

async function taggedCommFarcasterResponder(req: $Request): Promise<void> {		async function taggedCommFarcasterResponder(req: $Request): Promise<void> {
const { body } = req;		const { body } = req;

const event = assertWithValidator(body, taggedCommFarcasterInputValidator);		const event = assertWithValidator(body, taggedCommFarcasterInputValidator);
const eventTaggerFID = event.data.author.fid;		const eventTaggerFID = event.data.author.fid;

		const neynarConfigPromise = getNeynarConfig();
const taggerUserIDPromise = getVerifiedUserIDForFID(		const taggerUserIDPromise = getVerifiedUserIDForFID(
eventTaggerFID.toString(),		eventTaggerFID.toString(),
);		);

const threadHashTagRegex: RegExp = new RegExp('#createathread', 'i');		const threadHashTagRegex: RegExp = new RegExp('#createathread', 'i');
const foundCreateThreadHashTag = threadHashTagRegex.test(event.data.text);		const foundCreateThreadHashTag = threadHashTagRegex.test(event.data.text);
if (!foundCreateThreadHashTag) {		if (!foundCreateThreadHashTag) {
return;		return;
▲ Show 20 Lines • Show All 69 Lines • ▼ Show 20 Lines	const sidebarThreadResponse = await createCastSidebar(
taggerUserID,		taggerUserID,
);		);

if (!sidebarThreadResponse) {		if (!sidebarThreadResponse) {
return;		return;
}		}

const inviteLinkName = Math.random().toString(36).slice(-9);		const inviteLinkName = Math.random().toString(36).slice(-9);
const inviteLink = await createOrUpdatePublicLink(commbotViewer, {
		const [inviteLink, neynarConfig] = await Promise.all([
		createOrUpdatePublicLink(commbotViewer, {
name: inviteLinkName,		name: inviteLinkName,
communityID: channelCommunityID,		communityID: channelCommunityID,
threadID: sidebarThreadResponse.newThreadID,		threadID: sidebarThreadResponse.newThreadID,
});		}),
		neynarConfigPromise,
		]);

console.log(inviteLink);		const introText = 'I created a thread on Comm. Join the conversation here:';
		const replyText = `${introText} ${inviteLinkURL(inviteLink.name)}`;

		if (!neynarConfig?.signerUUID) {
		throw new ServerError('missing_signer_uuid');
		}

		const postCastResponse = await neynarClient?.postCast(
		neynarConfig.signerUUID,
		castHash,
		replyText,
		);

		if (!postCastResponse?.success) {
		throw new ServerError('post_cast_failed');
		}
}		}

export { taggedCommFarcasterResponder, taggedCommFarcasterInputValidator };		export { taggedCommFarcasterResponder, taggedCommFarcasterInputValidator };