tangled
alpha
login
or
join now
leaflet.pub
/
leaflet
291
fork
atom
a tool for shared writing and social publishing
291
fork
atom
overview
issues
27
pulls
pipelines
remove debug logging
awarm.space
7 months ago
f0c26643
3e4eccd4
+4
-3
1 changed file
expand all
collapse all
unified
split
appview
index.ts
+4
-3
appview/index.ts
···
17
17
import { AtUri } from "@atproto/syntax";
18
18
import { writeFile, readFile } from "fs/promises";
19
19
import { createIdentity } from "actions/createIdentity";
20
20
-
import { supabaseServerClient } from "supabase/serverClient";
21
20
import postgres from "postgres";
22
21
import { drizzle } from "drizzle-orm/postgres-js";
23
22
import { inngest } from "app/api/inngest/client";
···
169
168
? record.value.embed.external.uri
170
169
: null;
171
170
if (embed) {
171
171
+
console.log(
172
172
+
"processing post mention: " + embed + " in " + evt.uri.toString(),
173
173
+
);
172
174
await inngest.send({
173
175
name: "appview/index-bsky-post-mention",
174
176
data: { post_uri: evt.uri.toString(), document_link: embed },
···
210
212
startCursor,
211
213
setCursor: async (cursor) => {
212
214
await writeFile(cursorFile, cursor.toString());
213
213
-
console.log("Wrote cursor: " + cursor.toString());
214
215
// persist cursor
215
216
},
216
217
});
···
227
228
// ids.AppBskyActorProfile,
228
229
"app.bsky.feed.post",
229
230
],
230
230
-
handleEvent: timedHandleEvent,
231
231
+
handleEvent,
231
232
onError: (err) => {
232
233
console.error(err);
233
234
},