From 4ba387abfdb0fe2db2a7712ec9f122beaf14a374 Mon Sep 17 00:00:00 2001 From: Jared Pereira Date: Tue, 3 Feb 2026 10:18:17 +0000 Subject: [PATCH] fix bsky post indexing function --- app/api/inngest/functions/index_post_mention.ts | 15 ++++++++++++--- 1 file changed, 12 insertions(+), 3 deletions(-) diff --git a/app/api/inngest/functions/index_post_mention.ts b/app/api/inngest/functions/index_post_mention.ts index 98ebef6d..80ff24f9 100644 --- a/app/api/inngest/functions/index_post_mention.ts +++ b/app/api/inngest/functions/index_post_mention.ts @@ -3,7 +3,10 @@ import { inngest } from "../client"; import { AtpAgent, AtUri } from "@atproto/api"; import { Json } from "supabase/database.types"; import { ids } from "lexicons/api/lexicons"; -import { Notification, pingIdentityToUpdateNotification } from "src/notifications"; +import { + Notification, + pingIdentityToUpdateNotification, +} from "src/notifications"; import { v7 } from "uuid"; import { idResolver } from "app/(home-pages)/reader/idResolver"; import { documentUriFilter } from "src/utils/uriHelpers"; @@ -60,7 +63,11 @@ export const index_post_mention = inngest.createFunction( let { data: pub, error } = await supabaseServerClient .from("publications") .select("*") - .or(`record->>base_path.eq.${url.host},record->>url.eq.https://${url.host}`) + .or( + `record->>base_path.eq.${url.host},record->>url.eq.https://${url.host}`, + ) + .order("uri", { ascending: false }) + .limit(1) .single(); if (!pub) { @@ -80,7 +87,9 @@ export const index_post_mention = inngest.createFunction( const docData = docDataArr?.[0]; if (!docData) { - return { message: `No document found for publication ${url.host}/${path[0]}` }; + return { + message: `No document found for publication ${url.host}/${path[0]}`, + }; } documentUri = docData.uri; -- 2.51.2