Something went wrong. Try again.
A decentralized music tracking and discovery platform built on AT Protocol 🎵 rocksky.app
spotify atproto lastfm musicbrainz scrobbling listenbrainz
Something went wrong. Try again.
123456789101112131415161718192021222324252627import chalk from "chalk";import { consola } from "consola";import { ctx } from "context";import lovedTracks from "../schema/loved-tracks";
const likes = await ctx.db.select().from(lovedTracks).execute();
for (const like of likes) { const message = JSON.stringify({ uri: like.uri, user_id: { xata_id: like.userId }, track_id: { xata_id: like.trackId }, xata_createdat: like.createdAt.toISOString(), xata_id: like.id, xata_updatedat: like.createdAt.toISOString(), xata_version: 0, }); consola.info("Publishing like:", chalk.cyanBright(like.uri)); ctx.nc.publish("rocksky.like", Buffer.from(message));}
await ctx.nc.flush();
consola.info("Done");
process.exit(0);