logs: simplify logs
This commit is contained in:
19
jetstream.ts
19
jetstream.ts
@@ -1,32 +1,33 @@
|
|||||||
import { Jetstream } from "@skyware/jetstream";
|
import { Jetstream } from "@skyware/jetstream";
|
||||||
import { upsertNote } from "./src/data/db.ts";
|
import { upsertNote } from "./src/data/db.ts";
|
||||||
|
import { Note } from "./src/data/note.ts";
|
||||||
|
|
||||||
const jetstream = new Jetstream({
|
const jetstream = new Jetstream({
|
||||||
wantedCollections: ["space.litenote.note"],
|
wantedCollections: ["space.litenote.note"],
|
||||||
});
|
});
|
||||||
|
|
||||||
jetstream.onCreate("space.litenote.note", (event) => {
|
jetstream.onCreate("space.litenote.note", (event) => {
|
||||||
console.log("create", event);
|
|
||||||
const { did, commit: { rkey, record } } = event;
|
const { did, commit: { rkey, record } } = event;
|
||||||
|
const note = record as unknown as Omit<Note, "did" | "rkey">
|
||||||
|
console.log(`create ${did}/${rkey}: ${note.title}`);
|
||||||
|
|
||||||
upsertNote({
|
upsertNote({
|
||||||
did,
|
did,
|
||||||
rkey,
|
rkey,
|
||||||
...record,
|
...note,
|
||||||
// deno-lint-ignore no-explicit-any
|
});
|
||||||
} as any);
|
|
||||||
});
|
});
|
||||||
|
|
||||||
jetstream.onUpdate("space.litenote.note", (event) => {
|
jetstream.onUpdate("space.litenote.note", (event) => {
|
||||||
console.log("update", event);
|
|
||||||
const { did, commit: { rkey, record } } = event;
|
const { did, commit: { rkey, record } } = event;
|
||||||
|
const note = record as unknown as Omit<Note, "did" | "rkey">
|
||||||
|
console.log(`update ${did}/${rkey}: ${note.title}`);
|
||||||
|
|
||||||
upsertNote({
|
upsertNote({
|
||||||
did,
|
did,
|
||||||
rkey,
|
rkey,
|
||||||
...record,
|
...note,
|
||||||
// deno-lint-ignore no-explicit-any
|
});
|
||||||
} as any);
|
|
||||||
});
|
});
|
||||||
|
|
||||||
jetstream.on("close", () => {
|
jetstream.on("close", () => {
|
||||||
|
|||||||
Reference in New Issue
Block a user