From 63ab3ba67652f60d2dcfee8345b45409b17b54a2 Mon Sep 17 00:00:00 2001
From: Tsiry Sandratraina <tsiry.sndr@rocksky.app>
Date: Tue, 30 Dec 2025 08:38:05 +0300
Subject: [PATCH] Add logging and NATS flush to likes script

---
 apps/api/src/scripts/likes.ts | 8 ++++++++
 1 file changed, 8 insertions(+)

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);
-- 
2.51.2