julien/remanso-jetstream
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

logs: add logs for jetstream

Browse Source
This commit is contained in:
Julien Calixte
2026-02-13 20:13:51 +01:00
parent de92a554ee
commit c44c2bac3f
3 changed files with 8 additions and 6 deletions
Download Patch File Download Diff File Expand all files Collapse all files

1
docker-compose.yml
View File

@@ -1,5 +1,6 @@
services: services:
api: api:
# build: .
image: docker.li212.fr/litenote:latest image: docker.li212.fr/litenote:latest
restart: unless-stopped restart: unless-stopped
ports: ports:

12
jetstream.ts
View File

@@ -9,7 +9,7 @@ const jetstream = new Jetstream({
jetstream.onCreate("space.litenote.note", (event) => { jetstream.onCreate("space.litenote.note", (event) => {
const { did, commit: { rkey, record } } = event; const { did, commit: { rkey, record } } = event;
const note = record as unknown as Omit<Note, "did" | "rkey"> const note = record as unknown as Omit<Note, "did" | "rkey">
console.log(`create ${did}/${rkey}: ${note.title}`); console.log(`[jetstream] create ${did}/${rkey}: ${note.title}`);
upsertNote({ upsertNote({
did, did,
@@ -21,7 +21,7 @@ jetstream.onCreate("space.litenote.note", (event) => {
jetstream.onUpdate("space.litenote.note", (event) => { jetstream.onUpdate("space.litenote.note", (event) => {
const { did, commit: { rkey, record } } = event; const { did, commit: { rkey, record } } = event;
const note = record as unknown as Omit<Note, "did" | "rkey"> const note = record as unknown as Omit<Note, "did" | "rkey">
console.log(`update ${did}/${rkey}: ${note.title}`); console.log(`[jetstream] update ${did}/${rkey}: ${note.title}`);
upsertNote({ upsertNote({
did, did,
@@ -32,19 +32,19 @@ jetstream.onUpdate("space.litenote.note", (event) => {
jetstream.onDelete("space.litenote.note", (event) => { jetstream.onDelete("space.litenote.note", (event) => {
const { did, commit: { rkey } } = event; const { did, commit: { rkey } } = event;
console.log(`delete ${did}/${rkey}`); console.log(`[jetstream] delete ${did}/${rkey}`);
deleteNote({ did, rkey }); deleteNote({ did, rkey });
}); });
jetstream.on("close", () => { jetstream.on("close", () => {
console.log("Connection closed"); console.log("[jetstream] connection closed");
}); });
jetstream.on("error", (error) => { jetstream.on("error", (error) => {
console.log("Connection closed with error", error); console.log("[jetstream] connection closed with error", error);
}); });
console.log("launching jetstream"); console.log("[jetstream] launching");
jetstream.start(); jetstream.start();

1
server.ts
View File

@@ -36,4 +36,5 @@ app.use(async (ctx, next) => {
app.use(router.routes()); app.use(router.routes());
app.use(router.allowedMethods()); app.use(router.allowedMethods());
console.log("[server] listening on port 8080");
app.listen({ port: 8080 }); app.listen({ port: 8080 });