lint: format and lint
This commit is contained in:
26
jetstream.ts
26
jetstream.ts
@@ -1,38 +1,40 @@
|
|||||||
import { Jetstream } from "@skyware/jetstream";
|
import { Jetstream } from "@skyware/jetstream";
|
||||||
import { upsertNote } from "./src/data/db"
|
import { upsertNote } from "./src/data/db.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);
|
console.log("create", event);
|
||||||
const {did, commit: {rkey, record}} = event
|
const { did, commit: { rkey, record } } = event;
|
||||||
|
|
||||||
upsertNote({
|
upsertNote({
|
||||||
did,
|
did,
|
||||||
rkey,
|
rkey,
|
||||||
...record
|
...record,
|
||||||
} as any)
|
// deno-lint-ignore no-explicit-any
|
||||||
|
} as any);
|
||||||
});
|
});
|
||||||
|
|
||||||
jetstream.onUpdate("space.litenote.note", (event) => {
|
jetstream.onUpdate("space.litenote.note", (event) => {
|
||||||
console.log("update", event);
|
console.log("update", event);
|
||||||
const {did, commit: {rkey, record}} = event
|
const { did, commit: { rkey, record } } = event;
|
||||||
|
|
||||||
upsertNote({
|
upsertNote({
|
||||||
did,
|
did,
|
||||||
rkey,
|
rkey,
|
||||||
...record
|
...record,
|
||||||
} as any)
|
// deno-lint-ignore no-explicit-any
|
||||||
|
} as any);
|
||||||
});
|
});
|
||||||
|
|
||||||
jetstream.on("close", () => {
|
jetstream.on("close", () => {
|
||||||
console.log("Connection closed");
|
console.log("Connection closed");
|
||||||
});
|
});
|
||||||
|
|
||||||
jetstream.on("error", (error) => {
|
jetstream.on("error", (error) => {
|
||||||
console.log("Connection closed with error", error);
|
console.log("Connection closed with error", error);
|
||||||
});
|
});
|
||||||
|
|
||||||
console.log("launching jetstream");
|
console.log("launching jetstream");
|
||||||
|
|||||||
@@ -10,4 +10,4 @@ const app = new Application();
|
|||||||
app.use(router.routes());
|
app.use(router.routes());
|
||||||
app.use(router.allowedMethods());
|
app.use(router.allowedMethods());
|
||||||
|
|
||||||
app.listen({port: 8080});
|
app.listen({ port: 8080 });
|
||||||
|
|||||||
@@ -1,9 +1,9 @@
|
|||||||
import { DB } from "https://deno.land/x/sqlite/mod.ts";
|
import { DB } from "https://deno.land/x/sqlite/mod.ts";
|
||||||
import type { Note } from "./note"
|
import type { Note } from "./note.ts";
|
||||||
|
|
||||||
export const db = new DB(Deno.env.get("SQLITE_PATH") ?? "notes.db");
|
export const db = new DB(Deno.env.get("SQLITE_PATH") ?? "notes.db");
|
||||||
|
|
||||||
export const upsertNote = async (note: Note) => {
|
export const upsertNote = (note: Note) => {
|
||||||
db.query(
|
db.query(
|
||||||
`
|
`
|
||||||
INSERT INTO note (
|
INSERT INTO note (
|
||||||
@@ -30,4 +30,4 @@ export const upsertNote = async (note: Note) => {
|
|||||||
note.rkey,
|
note.rkey,
|
||||||
],
|
],
|
||||||
);
|
);
|
||||||
}
|
};
|
||||||
|
|||||||
@@ -1,8 +1,8 @@
|
|||||||
export type Note = {
|
export type Note = {
|
||||||
did: string
|
did: string;
|
||||||
rkey: string
|
rkey: string;
|
||||||
title: string
|
title: string;
|
||||||
content: string
|
content: string;
|
||||||
publishedAt: Date
|
publishedAt: Date;
|
||||||
createdAt: Date
|
createdAt: Date;
|
||||||
}
|
};
|
||||||
|
|||||||
@@ -1,4 +1,4 @@
|
|||||||
import { db } from "../data/db"
|
import { db } from "../data/db";
|
||||||
|
|
||||||
db.execute(`
|
db.execute(`
|
||||||
CREATE TABLE IF NOT EXISTS note (
|
CREATE TABLE IF NOT EXISTS note (
|
||||||
@@ -12,4 +12,4 @@ db.execute(`
|
|||||||
);
|
);
|
||||||
`);
|
`);
|
||||||
|
|
||||||
db.close();
|
db.close();
|
||||||
|
|||||||
Reference in New Issue
Block a user