diff --git a/apps/api/src/scripts/likes.ts b/apps/api/src/scripts/likes.ts index 7275e833..18bbfdb0 100644 --- a/apps/api/src/scripts/likes.ts +++ b/apps/api/src/scripts/likes.ts @@ -1,5 +1,6 @@ import { ctx } from "context"; import lovedTracks from "../schema/loved-tracks"; +import chalk from "chalk"; const likes = await ctx.db.select().from(lovedTracks).execute(); @@ -13,5 +14,12 @@ for (const like of likes) { xata_updatedat: like.createdAt.toISOString(), xata_version: 0, }); + console.log("Publishing like:", chalk.cyanBright(like.uri)); ctx.nc.publish("rocksky.like", Buffer.from(message)); } + +await ctx.nc.flush(); + +console.log("Done"); + +process.exit(0);