API-Luminatedata

Método: POST
Headers:
  Accept: application/json
  Content-Type: application/json
Body JSON:
{
  "isrc": "US-CM5-16-00028",
  "tracked": true
}
Notas:
- isrc es obligatorio (12 alfanuméricos, guiones opcionales)
- tracked es opcional (default true)
- También acepta formulario POST (isrc/tracked)
- ★ v2: asigna ingest_mode=single internamente (BOT1); no se envía en el body

Método: POST
Headers:
  Accept: application/json
  Content-Type: application/json
Body JSON:
{
  "isrcs": ["US-CM5-16-00028", "TLREW2210595"],
  "tracked": true
}
Notas:
- isrcs: array obligatorio, no vacío, máx. 500
- tracked: opcional (default true)
- ★ v2: cada ISRC nuevo recibe ingest_mode=batch

Método: GET
Headers:
  Accept: application/json
Query params (opcionales):
- status: pending | syncing | ready | error
- limit: int (1..200, default 50)
- page: int (>=1, default 1)
- min_id: int (>=1) ★ v2 — solo registros con id >= min_id
Ejemplo:
GET /api/list.php?status=ready&limit=25&page=1

Método: GET
Headers:
  Accept: application/json
Query params:
- isrc (obligatorio): 12 alfanuméricos, con o sin guiones
Ejemplo:
GET /api/detail.php?isrc=USCM51600028

Método: GET
Headers:
  Accept: application/json
Query params:
- isrc (obligatorio)
- start_date (opcional, YYYY-MM-DD)
- end_date (opcional, YYYY-MM-DD)
Regla:
- Si envías start_date debes enviar end_date (y viceversa).
- start_date no puede ser mayor que end_date.

Método: POST
Body JSON:
{
  "isrc": "TL-REW-22-10595",
  "tracked": true
}
Notas:
- El ISRC debe existir previamente (404 si no)
- ★ v2: guarda restore_ingest_mode (single o batch) para restaurar al terminar

{
  "success": true,
  "message": "ISRC reseteado y encolado para re-ingesta completa (bot3).",
  "isrc": "TL-REW-22-10595",
  "isrc_normalized": "TLREW2210595",
  "id": 12,
  "status": "pending",
  "ingest_mode": "retrack",
  "restore_ingest_mode": "single",
  "created_at": "2026-03-25 17:25:19.541009-04"
}

★ v2 en respuesta: ingest_mode · restore_ingest_mode · status vuelve a pending

404 · ISRC no encontrado
422 · ISRC inválido
500 · Error al retrack

Método: POST
Headers:
  Accept: application/json
  Content-Type: application/json
Body JSON:
{
  "start_date": "2026-07-07"
}
Notas:
- start_date obligatorio (YYYY-MM-DD)
- No puede ser fecha futura
- Solo un job pending/running a la vez

{
  "success": true,
  "message": "Job retrack masivo encolado. BOT5 borrará activity >= start_date...",
  "job": {
    "id": 12,
    "kind": "retrack_from_date",
    "start_date": "2026-07-07",
    "status": "pending",
    "created_at": "2026-07-14 12:00:00-04"
  }
}

★ v2 en job: kind = retrack_from_date (antes no existía este tipo de job)

409 · Conflict
{
  "success": false,
  "error": "Ya hay un job retrack masivo en cola o en ejecución..."
}

422 · start_date inválido o fecha futura
500 · Error al encolar

GET /api/retrack_job.php?id=12

{
  "success": true,
  "job": {
    "id": 12,
    "kind": "retrack_from_date",
    "start_date": "2026-07-07",
    "status": "running",
    "error_message": null,
    "created_at": "2026-07-14 12:00:00-04",
    "updated_at": "2026-07-14 12:05:00-04"
  }
}

★ v2 status: pending · running · completed · failed

422 · id inválido
404 · Job no encontrado
500 · Error al consultar

1) POST api/submit.php  → encolar ISRC (ingest_mode=single, BOT1)
2) Conectar wss://hub.rebelmusic.dev/ws
3) Enviar subscribe con canal isrc:CODIGO
4) Recibir isrc_progress hasta isrc_completed
5) GET api/detail.php cuando is_complete = true

{
  "event": "hello",
  "hub": "RebelMusic WebHub",
  "version": "0.1.0",
  "ts": "2026-07-14T18:00:00+00:00",
  "poll_seconds": 3.0,
  "auth_required": false,
  "subscribe_example": {
    "action": "subscribe",
    "channels": ["bots", "all_isrc", "isrc:TLREW2210595"]
  }
}

{"action":"subscribe","channels":["bots"]}
{"action":"subscribe","channels":["all_isrc"]}
{"action":"subscribe","channels":["isrc:TLREW2210595"]}
{"action":"subscribe","channels":["bots","all_isrc","isrc:USUM71912345"]}

{"action":"unsubscribe","channels":["bots"]}

{"action":"ping"}  → respuesta {"event":"pong","ts":"..."}

Canales disponibles:
bots — estado de colas BOT1..BOT5 (~cada 3 s)
all_isrc — solo cuando un ISRC termina (is_complete: true)
isrc:CODIGO — progreso y finalización de un ISRC concreto

{
  "event": "subscribed",
  "channels": ["bots", "isrc:TLREW2210595"],
  "ts": "2026-07-14T18:00:01+00:00"
}

{
  "event": "bots_status",
  "ts": "2026-07-14T18:00:03+00:00",
  "bots": [
    {
      "bot": "BOT1",
      "label": "Single",
      "queue": "single",
      "pending": 2,
      "running": 1,
      "occupancy_percent": 30
    },
    {
      "bot": "BOT2",
      "label": "Batch",
      "queue": "batch",
      "pending": 0,
      "running": 0,
      "occupancy_percent": 0
    },
    {
      "bot": "BOT3",
      "label": "Retrack individual",
      "queue": "retrack",
      "pending": 1,
      "running": 1,
      "occupancy_percent": 30
    },
    {
      "bot": "BOT4",
      "label": "Daily update",
      "queue": "daily",
      "pending": 0,
      "running": 0,
      "occupancy_percent": 0,
      "note": "Ejecucion programada; no usa cola ISRC"
    },
    {
      "bot": "BOT5",
      "label": "Retrack masivo por fecha",
      "queue": "retrack_from_date",
      "pending": 0,
      "running": 1,
      "occupancy_percent": 20
    }
  ],
  "summary": {
    "total_pending": 3,
    "tracked_isrc": 142,
    "completed_isrc": 98
  }
}

Relación con ingest_mode (API REST):
single → BOT1 · batch → BOT2 · retrack → BOT3
retrack_from_date (job) → BOT5 · BOT4 = daily programado

{
  "event": "isrc_progress",
  "ts": "2026-07-14T18:01:00+00:00",
  "isrc": "TL-REW-22-10595",
  "isrc_normalized": "TLREW2210595",
  "status": "syncing",
  "ingest_mode": "single",
  "progress": {
    "percent": 50,
    "percent_remaining": 50,
    "phases_total": 6,
    "phases_completed": 3,
    "phases_pending": 3,
    "completed": ["search", "metadata", "kpi"],
    "pending": ["activity", "location", "recordings"],
    "completed_detail": [
      {"key": "search", "label": "Busqueda ISRC"},
      {"key": "metadata", "label": "Metadata cancion"}
    ],
    "pending_detail": [
      {"key": "activity", "label": "Activity over time"}
    ],
    "current_phase": "activity",
    "current_phase_label": "Activity over time",
    "is_complete": false,
    "has_artist_phases": true
  }
}

{
  "event": "isrc_completed",
  "ts": "2026-07-14T18:05:00+00:00",
  "isrc": "TL-REW-22-10595",
  "isrc_normalized": "TLREW2210595",
  "status": "ready",
  "ingest_mode": "single",
  "progress": {
    "percent": 100,
    "is_complete": true,
    "current_phase": null,
    "current_phase_label": null
  }
}

Importante: all_isrc no recibe isrc_progress; solo notifica cuando progress.is_complete pasa a true.

GET https://hub.rebelmusic.dev/api/snapshot.php
Headers: Accept: application/json

{
  "success": true,
  "ts": "2026-07-14T18:00:00+00:00",
  "websocket": {
    "url": "wss://hub.rebelmusic.dev/ws",
    "subscribe": {
      "action": "subscribe",
      "channels": ["bots", "all_isrc"]
    }
  },
  "bots": [ ... ],
  "isrcs": [
    {
      "id": 42,
      "isrc": "TL-REW-22-10595",
      "isrc_normalized": "TLREW2210595",
      "status": "syncing",
      "ingest_mode": "single",
      "progress": { "percent": 50, "is_complete": false }
    }
  ]
}

const ws = new WebSocket("wss://hub.rebelmusic.dev/ws");

ws.onopen = () => {
  ws.send(JSON.stringify({
    action: "subscribe",
    channels: ["bots", "isrc:TLREW2210595"]
  }));
};

ws.onmessage = (ev) => {
  const data = JSON.parse(ev.data);
  if (data.event === "isrc_completed") {
    console.log("ISRC listo:", data.isrc_normalized);
  }
};

import asyncio, json, websockets

async def main():
    async with websockets.connect("wss://hub.rebelmusic.dev/ws") as ws:
        await ws.recv()  # hello
        await ws.send(json.dumps({
            "action": "subscribe",
            "channels": ["bots", "all_isrc"]
        }))
        async for msg in ws:
            print(json.loads(msg))

asyncio.run(main())