include saving cid, uri and rkey to database

apps/tapper/index.ts

···
 import { SimpleIndexer, Tap } from "@atproto/tap";
 import { env } from "@tealfmbot/common/constants";
-// import { db } from "./kysely/db.ts"
+// import { isTealRecord } from "./utils";
+// import { db } from "@tealfmbot/database/db"
 
 const tap = new Tap("https://tap.xero.systems", {
   adminPassword: env.TAP_ADMIN_PASSWORD,
···
 
 indexer.record(async (evt, opts) => {
   const uri = `at://${evt.did}/${evt.collection}/${evt.rkey}`;
-  if (evt.action === "create" || evt.action === "update") {
+  if (evt.action === "create") {
+    // if (isTealRecord(evt.record) && typeof evt !== "undefined" && typeof evt.record !== 'undefined') {
+    //   await db.insertInto("plays").values({
+    //     release_name: evt?.record?.releaseName,
+    //     played_time: evt?.record?.playedTime,
+    //     track_name: evt?.record?.trackName,
+    //     indexed_at: new Date().toJSON(),
+    //     live: evt.live
+    //   }).execute()
+    // }
     // await db.insertInto("plays").values({
     //   played_time: evt?.record?.playedTime,
     //   release_name: evt?.record?.releaseName,
     //   track_name: evt?.record?.trackName,
     //   user_id: 4
-    // }).execute()
+    // }).execute
     console.log(evt.record);
   } else {
     console.log(`deleted: ${uri}`);

apps/tapper/package.json

···
   },
   "dependencies": {
     "@atproto/tap": "^0.0.2",
-    "@tealfmbot/common": "workspace:*"
+    "@tealfmbot/common": "workspace:*",
+    "@tealfmbot/database": "workspace:*"
   },
   "devDependencies": {
     "@tealfmbot/tsconfig": "workspace:*",

apps/tapper/utils.ts

···
+type TealRecord = {
+  $type: "fm.teal.alpha.feed.play";
+  trackName: string;
+  trackMbId?: string;
+  recordingMbId?: string;
+  duration?: number;
+  releaseName?: string;
+  releaseMbId?: string;
+  isrc?: string;
+  originUrl?: string;
+  musicServiceBaseDomain?: string;
+  submissionClientAgent?: string;
+  playedTime?: Date;
+  artists: Artist[];
+};
+
+type Artist = {
+  artistMbId?: string;
+  artistName?: string;
+};
+
+export function isTealRecord(record: unknown): record is TealRecord {
+  return (record as TealRecord).$type === "fm.teal.alpha.feed.play";
+}

packages/database/database.d.ts

···
 }
 
 export interface Plays {
+  cid: string | null;
   id: Generated<number>;
   indexed_at: Generated<Timestamp>;
   live: boolean | null;
   played_time: Timestamp;
   release_name: string;
+  rkey: string | null;
   track_name: string;
+  uri: string | null;
   user_id: number;
 }
 

packages/database/migrations/1767553973566_add_cid_uri_rkey.ts

···
+import type { Kysely } from 'kysely'
+
+// `any` is required here since migrations should be frozen in time. alternatively, keep a "snapshot" db interface.
+export async function up(db: Kysely<any>): Promise<void> {
+	// up migration code goes here...
+	// note: up migrations are mandatory. you must implement this function.
+	// For more info, see: https://kysely.dev/docs/migrations
+	await db.schema.alterTable("plays").addColumn("cid", "varchar").addColumn("uri", "varchar").addColumn("rkey", "varchar").execute()
+}
+
+// `any` is required here since migrations should be frozen in time. alternatively, keep a "snapshot" db interface.
+export async function down(db: Kysely<any>): Promise<void> {
+	// down migration code goes here...
+	// note: down migrations are optional. you can safely delete this function.
+	// For more info, see: https://kysely.dev/docs/migrations
+	await db.schema.alterTable("plays").dropColumn("cid").dropColumn("uri").dropColumn("rkey").execute()
+}

pnpm-lock.yaml

···
       '@tealfmbot/common':
         specifier: workspace:*
         version: link:../../packages/common
+      '@tealfmbot/database':
+        specifier: workspace:*
+        version: link:../../packages/database
     devDependencies:
       '@tealfmbot/tsconfig':
         specifier: workspace:*