A&R Workflow: Slack Alerts for Competitor Label Drops

// One-off bootstrap: search for each watched label and write down its ID.
const WATCHED = ["Drumcode", "Ninja Tune", "Hospital Records", "Defected"];

async function findLabelId(name: string): Promise<number | null> {
  const res = await fetch(`${BASE}/labels/search?${new URLSearchParams({ name, limit: "1" })}`, {
    headers: { "x-api-key": API_KEY },
  });
  const { results } = await res.json();
  return results[0]?.id ?? null;
}

const ids = await Promise.all(WATCHED.map(findLabelId));
console.log(ids); // [1, 42, 128, 256]

import fs from "node:fs/promises";

const API_KEY     = process.env.SONOVAULT_API_KEY!;
const SLACK_HOOK  = process.env.SLACK_WEBHOOK_URL!;
const BASE        = "https://api.sonovault.now/v1";
const STATE_FILE  = "./.state/seen.json";

interface WatchedLabel { id: number; name: string; }
interface Release {
  id: number; title: string;
  artist: { id: number; name: string };
  release_date: string; catalog_no?: string; track_count: number;
}

const WATCHED: WatchedLabel[] = [
  { id: 1,   name: "Drumcode" },
  { id: 42,  name: "Ninja Tune" },
  { id: 128, name: "Hospital Records" },
  { id: 256, name: "Defected" },
];

// 1. Load the seen-release-IDs state. Empty on first run.
async function loadState(): Promise<Record<number, number[]>> {
  try   { return JSON.parse(await fs.readFile(STATE_FILE, "utf-8")); }
  catch { return {}; }
}

// 2. Pull recent releases for one label (one page is plenty for hourly runs).
async function recent(labelId: number): Promise<Release[]> {
  const res = await fetch(`${BASE}/labels/${labelId}/releases?limit=20`, {
    headers: { "x-api-key": API_KEY },
  });
  const { results } = await res.json();
  return results;
}

// 3. Post a release to Slack as a single block.
async function notify(label: WatchedLabel, r: Release) {
  const text =
    `*New release on ${label.name}:* ${r.artist.name} — ${r.title}` +
    `\nReleased ${r.release_date} · ${r.track_count} tracks` +
    (r.catalog_no ? ` · ${r.catalog_no}` : "");

  await fetch(SLACK_HOOK, {
    method:  "POST",
    headers: { "content-type": "application/json" },
    body:    JSON.stringify({ text }),
  });
}

// 4. The cron entrypoint.
async function main() {
  const state = await loadState();
  let newCount = 0;

  for (const label of WATCHED) {
    const releases = await recent(label.id);
    const seen     = new Set(state[label.id] ?? []);
    const fresh    = releases.filter(r => !seen.has(r.id));

    for (const r of fresh) {
      await notify(label, r);
      newCount++;
    }
    state[label.id] = releases.map(r => r.id);
  }

  await fs.mkdir(".state", { recursive: true });
  await fs.writeFile(STATE_FILE, JSON.stringify(state));
  console.log(`Posted ${newCount} new release(s) to Slack`);
}

main().catch(err => { console.error(err); process.exit(1); });

# Run hourly via crontab. Adjust path to your project.
# Every hour at :05 (give labels time to publish at the top of the hour).

5 * * * * cd /opt/ar-bot && /usr/bin/env node dist/cron.js >> /var/log/ar-bot.log 2>&1