Something went wrong. Try again.
a tool for shared writing and social publishing
Something went wrong. Try again.
TypeScript
1234567891011121314151617181920212223242526272829303132333435363738import { supabaseServerClient } from "supabase/serverClient";import { inngest } from "../client";
export const batched_update_profiles = inngest.createFunction( { id: "batched_update_profiles", batchEvents: { maxSize: 100, timeout: "10s", }, }, { event: "appview/profile-update" }, async ({ events, step }) => { let existingProfiles = await supabaseServerClient .from("bsky_profiles") .select("did") .in( "did", events.map((event) => event.data.did), ); if (!existingProfiles.data) return { error: existingProfiles.error };
const profileUpdates = events.map((event) => ({ did: event.data.did, record: event.data.record, }));
let { error } = await supabaseServerClient .from("bsky_profiles") .upsert(profileUpdates); return { done: true, profiles_updated: existingProfiles.data.length, error, }; },);