Page MenuHomePhabricator
Differential D13754

[keyserver] accept webhook cast created events tagging comm
ClosedPublic
Actions

Authored by will on Oct 20 2024, 9:52 PM.
Tags
None
Referenced Files
Unknown Object (File)
Sat, Mar 8, 11:55 AM
Unknown Object (File)
Sat, Mar 8, 11:55 AM
Unknown Object (File)
Fri, Feb 28, 2:26 PM
Unknown Object (File)
Fri, Feb 28, 2:24 PM
Unknown Object (File)
Feb 18 2025, 12:21 AM
Unknown Object (File)
Feb 6 2025, 10:40 AM
Unknown Object (File)
Feb 6 2025, 3:56 AM
Unknown Object (File)
Feb 6 2025, 3:55 AM
View All 83 Files
Subscribers
tomek

Details

Reviewers
ashoat
varun
Commits
rCOMMccb5664fb0dd: [keyserver] accept webhook cast created events tagging comm
Summary

Implement initial taggedCommFarcasterResponder with dummy logic

Depends on D13701

Test Plan

Triggered webhook event on warpcast and successfully received created cast event which passed validation

Diff Detail

Repository
rCOMM Comm
Lint
No Lint Coverage
Unit
No Test Coverage

Event Timeline

will created this revision.Oct 20 2024, 9:52 PM
Herald added a subscriber: tomek. · View Herald TranscriptOct 20 2024, 9:52 PM
will added inline comments.Oct 20 2024, 9:56 PM
keyserver/src/responders/farcaster-webhook-responders.js
17 ↗(On Diff #45284)

This is a dummy statement. This will be removed in a future diff and replaced with relevant logic

lib/types/farcaster-types.js
65 ↗(On Diff #45284)

Originally tried to using NeynarChannel for this but backtracked as it meant loosening constraints. The webhook event neynar channel object does not include description, follower_count, and lead

will mentioned this in D13755: [keyserver] moving getting neynar config to function.Oct 20 2024, 10:04 PM
will added a child revision: D13755: [keyserver] moving getting neynar config to function.
Harbormaster completed remote builds in B32310: Diff 45284.Oct 20 2024, 10:09 PM
will requested review of this revision.Oct 20 2024, 10:09 PM
ashoat requested changes to this revision.Oct 21 2024, 8:54 AM
ashoat added inline comments.
keyserver/src/responders/handlers.js
129 ↗(On Diff #45284)

What's the point of this line? Seems like we could just spread responderResult directly on line 130

lib/types/farcaster-types.js
45–75 ↗(On Diff #45284)

3/4 of these types fully enumerate all of their properties. But in the validator code below, you use t.interface for all of them.

Either the types are incorrect (you need to add ... to some of them), or some of the validators should use tShape.

52 ↗(On Diff #45284)

Can we be more specific than Object?

60 ↗(On Diff #45284)

Can we be more specific than Object?

This revision now requires changes to proceed.Oct 21 2024, 8:54 AM
will added inline comments.Oct 21 2024, 1:15 PM
keyserver/src/responders/handlers.js
129 ↗(On Diff #45284)

Yes. This was unnecessary. Going to directly spread responderResult in next rebase.

lib/types/farcaster-types.js
45–75 ↗(On Diff #45284)

It's the former. We likely shouldn't rely on Neynar/Farcaster to not add additional fields, so I plan to add ... to the next rebase

52 ↗(On Diff #45284)

I'm actually thinking I'll remove this for now

60 ↗(On Diff #45284)

We're not using embeds for my current work. Removing

will updated this revision to Diff 45334.Oct 22 2024, 9:46 PM

review feedback and fixing types

will marked 3 inline comments as done.Oct 22 2024, 9:48 PM
Harbormaster completed remote builds in B32345: Diff 45334.Oct 22 2024, 10:03 PM
ashoat accepted this revision.Oct 23 2024, 6:30 AM
ashoat added inline comments.
keyserver/src/responders/handlers.js
129 ↗(On Diff #45334)

You still have this unnecessary line

This revision is now accepted and ready to land.Oct 23 2024, 6:30 AM
will updated this revision to Diff 45349.Oct 23 2024, 6:54 AM
will marked an inline comment as done.

remove unnecessary line

Harbormaster completed remote builds in B32347: Diff 45349.Oct 23 2024, 7:12 AM
will updated this revision to Diff 45490.Oct 30 2024, 1:41 PM

rebase

Harbormaster completed remote builds in B32457: Diff 45490.Oct 30 2024, 2:35 PM
will added a child revision: D13841: [keyserver] add regex #createathread check.Oct 31 2024, 7:14 AM
will removed a child revision: D13755: [keyserver] moving getting neynar config to function.Oct 31 2024, 7:15 AM
Closed by commit rCOMMccb5664fb0dd: [keyserver] accept webhook cast created events tagging comm (authored by will). · Explain WhyOct 31 2024, 12:18 PM
This revision was automatically updated to reflect the committed changes.
will added a commit: rCOMMccb5664fb0dd: [keyserver] accept webhook cast created events tagging comm.

Revision Contents
Changeset List

PathSize
keyserver/
src/
7 lines
responders/
20 lines
23 lines
lib/
types/
35 lines
validators/
45 lines

Diff 45349

View Options

keyserver/src/keyserver.js

Show First 20 Lines • Show All 59 Lines • ▼ Show 20 Linesfunction useFetchEntries(): (
calendarQuery: CalendarQuery, calendarQuery: CalendarQuery,
) => Promise<FetchEntryInfosResult> { ) => Promise<FetchEntryInfosResult> {
return useKeyserverCall(fetchEntries); return useKeyserverCall(fetchEntries);
} }
export type UpdateCalendarQueryInput = { export type UpdateCalendarQueryInput = {
+calendarQuery: CalendarQuery, +calendarQuery: CalendarQuery,
+reduxAlreadyUpdated?: boolean, +reduxAlreadyUpdated?: boolean,
+keyserverIDs?: $ReadOnlyArray<string>,
}; };
const updateCalendarQueryActionTypes = Object.freeze({ const updateCalendarQueryActionTypes = Object.freeze({
started: 'UPDATE_CALENDAR_QUERY_STARTED', started: 'UPDATE_CALENDAR_QUERY_STARTED',
success: 'UPDATE_CALENDAR_QUERY_SUCCESS', success: 'UPDATE_CALENDAR_QUERY_SUCCESS',
failed: 'UPDATE_CALENDAR_QUERY_FAILED', failed: 'UPDATE_CALENDAR_QUERY_FAILED',
}); });
const updateCalendarQuery = const updateCalendarQuery =
( (
callKeyserverEndpoint: CallKeyserverEndpoint, callKeyserverEndpoint: CallKeyserverEndpoint,
allKeyserverIDs: $ReadOnlyArray<string>, allKeyserverIDs: $ReadOnlyArray<string>,
): (( ): ((
input: UpdateCalendarQueryInput, input: UpdateCalendarQueryInput,
) => Promise<CalendarQueryUpdateResult>) => ) => Promise<CalendarQueryUpdateResult>) =>
async input => { async input => {
const { calendarQuery, reduxAlreadyUpdated = false } = input; const { calendarQuery, reduxAlreadyUpdated = false } = input;
const keyserverIDs = input.keyserverIDs ?? allKeyserverIDs;
const calendarQueries = sortCalendarQueryPerKeyserver( const calendarQueries = sortCalendarQueryPerKeyserver(
calendarQuery, calendarQuery,
allKeyserverIDs, keyserverIDs,
); );
const requests: { [string]: CalendarQuery } = {}; const requests: { [string]: CalendarQuery } = {};
for (const keyserverID of allKeyserverIDs) { for (const keyserverID of keyserverIDs) {
requests[keyserverID] = calendarQueries[keyserverID]; requests[keyserverID] = calendarQueries[keyserverID];
} }
const responses = await callKeyserverEndpoint( const responses = await callKeyserverEndpoint(
'update_calendar_query', 'update_calendar_query',
requests, requests,
); );
let rawEntryInfos: $ReadOnlyArray<RawEntryInfo> = []; let rawEntryInfos: $ReadOnlyArray<RawEntryInfo> = [];
let deletedEntryIDs: $ReadOnlyArray<string> = []; let deletedEntryIDs: $ReadOnlyArray<string> = [];
for (const keyserverID in responses) { for (const keyserverID in responses) {
rawEntryInfos = rawEntryInfos.concat( rawEntryInfos = rawEntryInfos.concat(
responses[keyserverID].rawEntryInfos, responses[keyserverID].rawEntryInfos,
); );
deletedEntryIDs = deletedEntryIDs.concat( deletedEntryIDs = deletedEntryIDs.concat(
responses[keyserverID].deletedEntryIDs, responses[keyserverID].deletedEntryIDs,
); );
} }
return { return {
rawEntryInfos, rawEntryInfos,
deletedEntryIDs, deletedEntryIDs,
calendarQuery, calendarQuery,
calendarQueryAlreadyUpdated: reduxAlreadyUpdated, calendarQueryAlreadyUpdated: reduxAlreadyUpdated,
keyserverIDs,
}; };
}; };
function useUpdateCalendarQuery(): ( function useUpdateCalendarQuery(): (
input: UpdateCalendarQueryInput, input: UpdateCalendarQueryInput,
) => Promise<CalendarQueryUpdateResult> { ) => Promise<CalendarQueryUpdateResult> {
return useKeyserverCall(updateCalendarQuery); return useKeyserverCall(updateCalendarQuery);
} }
▲ Show 20 Lines • Show All 223 Lines • Show Last 20 Lines
View Options

keyserver/src/responders/farcaster-webhook-responders.js

Show First 20 Lines • Show All 59 Lines • ▼ Show 20 Linesfunction useFetchEntries(): (
calendarQuery: CalendarQuery, calendarQuery: CalendarQuery,
) => Promise<FetchEntryInfosResult> { ) => Promise<FetchEntryInfosResult> {
return useKeyserverCall(fetchEntries); return useKeyserverCall(fetchEntries);
} }
export type UpdateCalendarQueryInput = { export type UpdateCalendarQueryInput = {
+calendarQuery: CalendarQuery, +calendarQuery: CalendarQuery,
+reduxAlreadyUpdated?: boolean, +reduxAlreadyUpdated?: boolean,
+keyserverIDs?: $ReadOnlyArray<string>,
}; };
const updateCalendarQueryActionTypes = Object.freeze({ const updateCalendarQueryActionTypes = Object.freeze({
started: 'UPDATE_CALENDAR_QUERY_STARTED', started: 'UPDATE_CALENDAR_QUERY_STARTED',
success: 'UPDATE_CALENDAR_QUERY_SUCCESS', success: 'UPDATE_CALENDAR_QUERY_SUCCESS',
failed: 'UPDATE_CALENDAR_QUERY_FAILED', failed: 'UPDATE_CALENDAR_QUERY_FAILED',
}); });
const updateCalendarQuery = const updateCalendarQuery =
( (
callKeyserverEndpoint: CallKeyserverEndpoint, callKeyserverEndpoint: CallKeyserverEndpoint,
allKeyserverIDs: $ReadOnlyArray<string>, allKeyserverIDs: $ReadOnlyArray<string>,
): (( ): ((
input: UpdateCalendarQueryInput, input: UpdateCalendarQueryInput,
) => Promise<CalendarQueryUpdateResult>) => ) => Promise<CalendarQueryUpdateResult>) =>
async input => { async input => {
const { calendarQuery, reduxAlreadyUpdated = false } = input; const { calendarQuery, reduxAlreadyUpdated = false } = input;
const keyserverIDs = input.keyserverIDs ?? allKeyserverIDs;
const calendarQueries = sortCalendarQueryPerKeyserver( const calendarQueries = sortCalendarQueryPerKeyserver(
calendarQuery, calendarQuery,
allKeyserverIDs, keyserverIDs,
); );
const requests: { [string]: CalendarQuery } = {}; const requests: { [string]: CalendarQuery } = {};
for (const keyserverID of allKeyserverIDs) { for (const keyserverID of keyserverIDs) {
requests[keyserverID] = calendarQueries[keyserverID]; requests[keyserverID] = calendarQueries[keyserverID];
} }
const responses = await callKeyserverEndpoint( const responses = await callKeyserverEndpoint(
'update_calendar_query', 'update_calendar_query',
requests, requests,
); );
let rawEntryInfos: $ReadOnlyArray<RawEntryInfo> = []; let rawEntryInfos: $ReadOnlyArray<RawEntryInfo> = [];
let deletedEntryIDs: $ReadOnlyArray<string> = []; let deletedEntryIDs: $ReadOnlyArray<string> = [];
for (const keyserverID in responses) { for (const keyserverID in responses) {
rawEntryInfos = rawEntryInfos.concat( rawEntryInfos = rawEntryInfos.concat(
responses[keyserverID].rawEntryInfos, responses[keyserverID].rawEntryInfos,
); );
deletedEntryIDs = deletedEntryIDs.concat( deletedEntryIDs = deletedEntryIDs.concat(
responses[keyserverID].deletedEntryIDs, responses[keyserverID].deletedEntryIDs,
); );
} }
return { return {
rawEntryInfos, rawEntryInfos,
deletedEntryIDs, deletedEntryIDs,
calendarQuery, calendarQuery,
calendarQueryAlreadyUpdated: reduxAlreadyUpdated, calendarQueryAlreadyUpdated: reduxAlreadyUpdated,
keyserverIDs,
}; };
}; };
function useUpdateCalendarQuery(): ( function useUpdateCalendarQuery(): (
input: UpdateCalendarQueryInput, input: UpdateCalendarQueryInput,
) => Promise<CalendarQueryUpdateResult> { ) => Promise<CalendarQueryUpdateResult> {
return useKeyserverCall(updateCalendarQuery); return useKeyserverCall(updateCalendarQuery);
} }
▲ Show 20 Lines • Show All 223 Lines • Show Last 20 Lines
View Options

keyserver/src/responders/handlers.js

Show First 20 Lines • Show All 59 Lines • ▼ Show 20 Linesfunction useFetchEntries(): (
calendarQuery: CalendarQuery, calendarQuery: CalendarQuery,
) => Promise<FetchEntryInfosResult> { ) => Promise<FetchEntryInfosResult> {
return useKeyserverCall(fetchEntries); return useKeyserverCall(fetchEntries);
} }
export type UpdateCalendarQueryInput = { export type UpdateCalendarQueryInput = {
+calendarQuery: CalendarQuery, +calendarQuery: CalendarQuery,
+reduxAlreadyUpdated?: boolean, +reduxAlreadyUpdated?: boolean,
+keyserverIDs?: $ReadOnlyArray<string>,
}; };
const updateCalendarQueryActionTypes = Object.freeze({ const updateCalendarQueryActionTypes = Object.freeze({
started: 'UPDATE_CALENDAR_QUERY_STARTED', started: 'UPDATE_CALENDAR_QUERY_STARTED',
success: 'UPDATE_CALENDAR_QUERY_SUCCESS', success: 'UPDATE_CALENDAR_QUERY_SUCCESS',
failed: 'UPDATE_CALENDAR_QUERY_FAILED', failed: 'UPDATE_CALENDAR_QUERY_FAILED',
}); });
const updateCalendarQuery = const updateCalendarQuery =
( (
callKeyserverEndpoint: CallKeyserverEndpoint, callKeyserverEndpoint: CallKeyserverEndpoint,
allKeyserverIDs: $ReadOnlyArray<string>, allKeyserverIDs: $ReadOnlyArray<string>,
): (( ): ((
input: UpdateCalendarQueryInput, input: UpdateCalendarQueryInput,
) => Promise<CalendarQueryUpdateResult>) => ) => Promise<CalendarQueryUpdateResult>) =>
async input => { async input => {
const { calendarQuery, reduxAlreadyUpdated = false } = input; const { calendarQuery, reduxAlreadyUpdated = false } = input;
const keyserverIDs = input.keyserverIDs ?? allKeyserverIDs;
const calendarQueries = sortCalendarQueryPerKeyserver( const calendarQueries = sortCalendarQueryPerKeyserver(
calendarQuery, calendarQuery,
allKeyserverIDs, keyserverIDs,
); );
const requests: { [string]: CalendarQuery } = {}; const requests: { [string]: CalendarQuery } = {};
for (const keyserverID of allKeyserverIDs) { for (const keyserverID of keyserverIDs) {
requests[keyserverID] = calendarQueries[keyserverID]; requests[keyserverID] = calendarQueries[keyserverID];
} }
const responses = await callKeyserverEndpoint( const responses = await callKeyserverEndpoint(
'update_calendar_query', 'update_calendar_query',
requests, requests,
); );
let rawEntryInfos: $ReadOnlyArray<RawEntryInfo> = []; let rawEntryInfos: $ReadOnlyArray<RawEntryInfo> = [];
let deletedEntryIDs: $ReadOnlyArray<string> = []; let deletedEntryIDs: $ReadOnlyArray<string> = [];
for (const keyserverID in responses) { for (const keyserverID in responses) {
rawEntryInfos = rawEntryInfos.concat( rawEntryInfos = rawEntryInfos.concat(
responses[keyserverID].rawEntryInfos, responses[keyserverID].rawEntryInfos,
); );
deletedEntryIDs = deletedEntryIDs.concat( deletedEntryIDs = deletedEntryIDs.concat(
responses[keyserverID].deletedEntryIDs, responses[keyserverID].deletedEntryIDs,
); );
} }
return { return {
rawEntryInfos, rawEntryInfos,
deletedEntryIDs, deletedEntryIDs,
calendarQuery, calendarQuery,
calendarQueryAlreadyUpdated: reduxAlreadyUpdated, calendarQueryAlreadyUpdated: reduxAlreadyUpdated,
keyserverIDs,
}; };
}; };
function useUpdateCalendarQuery(): ( function useUpdateCalendarQuery(): (
input: UpdateCalendarQueryInput, input: UpdateCalendarQueryInput,
) => Promise<CalendarQueryUpdateResult> { ) => Promise<CalendarQueryUpdateResult> {
return useKeyserverCall(updateCalendarQuery); return useKeyserverCall(updateCalendarQuery);
} }
▲ Show 20 Lines • Show All 223 Lines • Show Last 20 Lines
View Options

lib/types/farcaster-types.js

Show First 20 Lines • Show All 59 Lines • ▼ Show 20 Linesfunction useFetchEntries(): (
calendarQuery: CalendarQuery, calendarQuery: CalendarQuery,
) => Promise<FetchEntryInfosResult> { ) => Promise<FetchEntryInfosResult> {
return useKeyserverCall(fetchEntries); return useKeyserverCall(fetchEntries);
} }
export type UpdateCalendarQueryInput = { export type UpdateCalendarQueryInput = {
+calendarQuery: CalendarQuery, +calendarQuery: CalendarQuery,
+reduxAlreadyUpdated?: boolean, +reduxAlreadyUpdated?: boolean,
+keyserverIDs?: $ReadOnlyArray<string>,
}; };
const updateCalendarQueryActionTypes = Object.freeze({ const updateCalendarQueryActionTypes = Object.freeze({
started: 'UPDATE_CALENDAR_QUERY_STARTED', started: 'UPDATE_CALENDAR_QUERY_STARTED',
success: 'UPDATE_CALENDAR_QUERY_SUCCESS', success: 'UPDATE_CALENDAR_QUERY_SUCCESS',
failed: 'UPDATE_CALENDAR_QUERY_FAILED', failed: 'UPDATE_CALENDAR_QUERY_FAILED',
}); });
const updateCalendarQuery = const updateCalendarQuery =
( (
callKeyserverEndpoint: CallKeyserverEndpoint, callKeyserverEndpoint: CallKeyserverEndpoint,
allKeyserverIDs: $ReadOnlyArray<string>, allKeyserverIDs: $ReadOnlyArray<string>,
): (( ): ((
input: UpdateCalendarQueryInput, input: UpdateCalendarQueryInput,
) => Promise<CalendarQueryUpdateResult>) => ) => Promise<CalendarQueryUpdateResult>) =>
async input => { async input => {
const { calendarQuery, reduxAlreadyUpdated = false } = input; const { calendarQuery, reduxAlreadyUpdated = false } = input;
const keyserverIDs = input.keyserverIDs ?? allKeyserverIDs;
const calendarQueries = sortCalendarQueryPerKeyserver( const calendarQueries = sortCalendarQueryPerKeyserver(
calendarQuery, calendarQuery,
allKeyserverIDs, keyserverIDs,
); );
const requests: { [string]: CalendarQuery } = {}; const requests: { [string]: CalendarQuery } = {};
for (const keyserverID of allKeyserverIDs) { for (const keyserverID of keyserverIDs) {
requests[keyserverID] = calendarQueries[keyserverID]; requests[keyserverID] = calendarQueries[keyserverID];
} }
const responses = await callKeyserverEndpoint( const responses = await callKeyserverEndpoint(
'update_calendar_query', 'update_calendar_query',
requests, requests,
); );
let rawEntryInfos: $ReadOnlyArray<RawEntryInfo> = []; let rawEntryInfos: $ReadOnlyArray<RawEntryInfo> = [];
let deletedEntryIDs: $ReadOnlyArray<string> = []; let deletedEntryIDs: $ReadOnlyArray<string> = [];
for (const keyserverID in responses) { for (const keyserverID in responses) {
rawEntryInfos = rawEntryInfos.concat( rawEntryInfos = rawEntryInfos.concat(
responses[keyserverID].rawEntryInfos, responses[keyserverID].rawEntryInfos,
); );
deletedEntryIDs = deletedEntryIDs.concat( deletedEntryIDs = deletedEntryIDs.concat(
responses[keyserverID].deletedEntryIDs, responses[keyserverID].deletedEntryIDs,
); );
} }
return { return {
rawEntryInfos, rawEntryInfos,
deletedEntryIDs, deletedEntryIDs,
calendarQuery, calendarQuery,
calendarQueryAlreadyUpdated: reduxAlreadyUpdated, calendarQueryAlreadyUpdated: reduxAlreadyUpdated,
keyserverIDs,
}; };
}; };
function useUpdateCalendarQuery(): ( function useUpdateCalendarQuery(): (
input: UpdateCalendarQueryInput, input: UpdateCalendarQueryInput,
) => Promise<CalendarQueryUpdateResult> { ) => Promise<CalendarQueryUpdateResult> {
return useKeyserverCall(updateCalendarQuery); return useKeyserverCall(updateCalendarQuery);
} }
▲ Show 20 Lines • Show All 223 Lines • Show Last 20 Lines
View Options

lib/types/validators/farcaster-webhook-validators.js

Show First 20 Lines • Show All 59 Lines • ▼ Show 20 Linesfunction useFetchEntries(): (
calendarQuery: CalendarQuery, calendarQuery: CalendarQuery,
) => Promise<FetchEntryInfosResult> { ) => Promise<FetchEntryInfosResult> {
return useKeyserverCall(fetchEntries); return useKeyserverCall(fetchEntries);
} }
export type UpdateCalendarQueryInput = { export type UpdateCalendarQueryInput = {
+calendarQuery: CalendarQuery, +calendarQuery: CalendarQuery,
+reduxAlreadyUpdated?: boolean, +reduxAlreadyUpdated?: boolean,
+keyserverIDs?: $ReadOnlyArray<string>,
}; };
const updateCalendarQueryActionTypes = Object.freeze({ const updateCalendarQueryActionTypes = Object.freeze({
started: 'UPDATE_CALENDAR_QUERY_STARTED', started: 'UPDATE_CALENDAR_QUERY_STARTED',
success: 'UPDATE_CALENDAR_QUERY_SUCCESS', success: 'UPDATE_CALENDAR_QUERY_SUCCESS',
failed: 'UPDATE_CALENDAR_QUERY_FAILED', failed: 'UPDATE_CALENDAR_QUERY_FAILED',
}); });
const updateCalendarQuery = const updateCalendarQuery =
( (
callKeyserverEndpoint: CallKeyserverEndpoint, callKeyserverEndpoint: CallKeyserverEndpoint,
allKeyserverIDs: $ReadOnlyArray<string>, allKeyserverIDs: $ReadOnlyArray<string>,
): (( ): ((
input: UpdateCalendarQueryInput, input: UpdateCalendarQueryInput,
) => Promise<CalendarQueryUpdateResult>) => ) => Promise<CalendarQueryUpdateResult>) =>
async input => { async input => {
const { calendarQuery, reduxAlreadyUpdated = false } = input; const { calendarQuery, reduxAlreadyUpdated = false } = input;
const keyserverIDs = input.keyserverIDs ?? allKeyserverIDs;
const calendarQueries = sortCalendarQueryPerKeyserver( const calendarQueries = sortCalendarQueryPerKeyserver(
calendarQuery, calendarQuery,
allKeyserverIDs, keyserverIDs,
); );
const requests: { [string]: CalendarQuery } = {}; const requests: { [string]: CalendarQuery } = {};
for (const keyserverID of allKeyserverIDs) { for (const keyserverID of keyserverIDs) {
requests[keyserverID] = calendarQueries[keyserverID]; requests[keyserverID] = calendarQueries[keyserverID];
} }
const responses = await callKeyserverEndpoint( const responses = await callKeyserverEndpoint(
'update_calendar_query', 'update_calendar_query',
requests, requests,
); );
let rawEntryInfos: $ReadOnlyArray<RawEntryInfo> = []; let rawEntryInfos: $ReadOnlyArray<RawEntryInfo> = [];
let deletedEntryIDs: $ReadOnlyArray<string> = []; let deletedEntryIDs: $ReadOnlyArray<string> = [];
for (const keyserverID in responses) { for (const keyserverID in responses) {
rawEntryInfos = rawEntryInfos.concat( rawEntryInfos = rawEntryInfos.concat(
responses[keyserverID].rawEntryInfos, responses[keyserverID].rawEntryInfos,
); );
deletedEntryIDs = deletedEntryIDs.concat( deletedEntryIDs = deletedEntryIDs.concat(
responses[keyserverID].deletedEntryIDs, responses[keyserverID].deletedEntryIDs,
); );
} }
return { return {
rawEntryInfos, rawEntryInfos,
deletedEntryIDs, deletedEntryIDs,
calendarQuery, calendarQuery,
calendarQueryAlreadyUpdated: reduxAlreadyUpdated, calendarQueryAlreadyUpdated: reduxAlreadyUpdated,
keyserverIDs,
}; };
}; };
function useUpdateCalendarQuery(): ( function useUpdateCalendarQuery(): (
input: UpdateCalendarQueryInput, input: UpdateCalendarQueryInput,
) => Promise<CalendarQueryUpdateResult> { ) => Promise<CalendarQueryUpdateResult> {
return useKeyserverCall(updateCalendarQuery); return useKeyserverCall(updateCalendarQuery);
} }
▲ Show 20 Lines • Show All 223 Lines • Show Last 20 Lines