a tool for shared writing and social publishing
leaflet.pub
fix bsky post indexing function
awarm.space
+12
-3
app/api/inngest/functions/index_post_mention.ts
+12
-3
app/api/inngest/functions/index_post_mention.ts
···
3
import { AtpAgent, AtUri } from "@atproto/api";
4
import { Json } from "supabase/database.types";
5
import { ids } from "lexicons/api/lexicons";
6
-
import { Notification, pingIdentityToUpdateNotification } from "src/notifications";
7
import { v7 } from "uuid";
8
import { idResolver } from "app/(home-pages)/reader/idResolver";
9
import { documentUriFilter } from "src/utils/uriHelpers";
···
60
let { data: pub, error } = await supabaseServerClient
61
.from("publications")
62
.select("*")
63
-
.or(`record->>base_path.eq.${url.host},record->>url.eq.https://${url.host}`)
64
.single();
65
66
if (!pub) {
···
80
const docData = docDataArr?.[0];
81
82
if (!docData) {
83
-
return { message: `No document found for publication ${url.host}/${path[0]}` };
84
}
85
86
documentUri = docData.uri;
···
3
import { AtpAgent, AtUri } from "@atproto/api";
4
import { Json } from "supabase/database.types";
5
import { ids } from "lexicons/api/lexicons";
6
+
import {
7
+
Notification,
8
+
pingIdentityToUpdateNotification,
9
+
} from "src/notifications";
10
import { v7 } from "uuid";
11
import { idResolver } from "app/(home-pages)/reader/idResolver";
12
import { documentUriFilter } from "src/utils/uriHelpers";
···
63
let { data: pub, error } = await supabaseServerClient
64
.from("publications")
65
.select("*")
66
+
.or(
67
+
`record->>base_path.eq.${url.host},record->>url.eq.https://${url.host}`,
68
+
)
69
+
.order("uri", { ascending: false })
70
+
.limit(1)
71
.single();
72
73
if (!pub) {
···
87
const docData = docDataArr?.[0];
88
89
if (!docData) {
90
+
return {
91
+
message: `No document found for publication ${url.host}/${path[0]}`,
92
+
};
93
}
94
95
documentUri = docData.uri;