diff --git a/keyserver/src/scripts/get-community-ids.js b/keyserver/src/scripts/get-community-ids.js index 94287a80a..3912a933d 100644 --- a/keyserver/src/scripts/get-community-ids.js +++ b/keyserver/src/scripts/get-community-ids.js @@ -1,47 +1,51 @@ // @flow import { main } from './utils.js'; import { dbQuery, SQL } from '../database/database.js'; -async function fetchCommunityIDsByNames( - communityNames: $ReadOnlyArray, +async function fetchCommCommunityIDsByFarcasterChannelIDs( + farcasterChannelIDs: $ReadOnlyArray, ): Promise<{ communityIDs: $ReadOnlyArray, - unresolvedNames: $ReadOnlyArray, + unresolvedFarcasterChannelIDs: $ReadOnlyArray, }> { - if (communityNames.length === 0) { - return { communityIDs: [], unresolvedNames: [] }; + if (farcasterChannelIDs.length === 0) { + return { communityIDs: [], unresolvedFarcasterChannelIDs: [] }; } const query = SQL` - SELECT t.name, c.id - FROM communities c - INNER JOIN threads t - ON c.id = t.id - WHERE t.name IN (${communityNames}) - AND c.farcaster_channel_id IS NOT NULL + SELECT id, farcaster_channel_id + FROM communities + WHERE farcaster_channel_id IN (${farcasterChannelIDs}) `; const [result] = await dbQuery(query); - const resolvedNames = result.map(row => row.name); + const resolvedFarcasterChannelIDs = result.map( + row => row.farcaster_channel_id, + ); const communityIDs = result.map(row => row.id.toString()); - const unresolvedNames = communityNames.filter( - name => !resolvedNames.includes(name), + const unresolvedFarcasterChannelIDs = farcasterChannelIDs.filter( + farcasterChannelID => + !resolvedFarcasterChannelIDs.includes(farcasterChannelID), ); - return { communityIDs, unresolvedNames }; + return { communityIDs, unresolvedFarcasterChannelIDs }; } -async function fetchCommunityIDsByNamesScript() { - const communityNames: $ReadOnlyArray = []; // Replace with actual community names - const { communityIDs, unresolvedNames } = - await fetchCommunityIDsByNames(communityNames); - console.log('Fetched Community IDs:', communityIDs); - - if (unresolvedNames.length > 0) { - console.log('Unresolved Community Names:', unresolvedNames); +async function fetchCommunityIDsByFarcasterChannelIDsScript() { + // Replace with actual community names + const farcasterChannelIDs: $ReadOnlyArray = []; + const { communityIDs, unresolvedFarcasterChannelIDs } = + await fetchCommCommunityIDsByFarcasterChannelIDs(farcasterChannelIDs); + console.log('Comm community IDs:', communityIDs); + + if (unresolvedFarcasterChannelIDs.length > 0) { + console.log( + 'Unresolved Farcaster channel IDs:', + unresolvedFarcasterChannelIDs, + ); } } -main([fetchCommunityIDsByNamesScript]); +main([fetchCommunityIDsByFarcasterChannelIDsScript]);