t1c.dev
forked from
rocksky.app/rocksky
A decentralized music tracking and discovery platform built on AT Protocol 馃幍
tsiry-sandratraina.com
1import chalk from "chalk";
2import { consola } from "consola";
3import { ctx } from "context";
4import lovedTracks from "../schema/loved-tracks";
5
6const likes = await ctx.db.select().from(lovedTracks).execute();
7
8for (const like of likes) {
9 const message = JSON.stringify({
10 uri: like.uri,
11 user_id: { xata_id: like.userId },
12 track_id: { xata_id: like.trackId },
13 xata_createdat: like.createdAt.toISOString(),
14 xata_id: like.id,
15 xata_updatedat: like.createdAt.toISOString(),
16 xata_version: 0,
17 });
18 consola.info("Publishing like:", chalk.cyanBright(like.uri));
19 ctx.nc.publish("rocksky.like", Buffer.from(message));
20}
21
22await ctx.nc.flush();
23
24consola.info("Done");
25
26process.exit(0);