/**
 * Live probe: pnpm tsx connectors/api/discogs/_smoke.ts [--save]
 * Crawls a few records through the real router and prints normalized output; --save writes fixtures.
 */
import { createRouter, createCrawlContext, getConnectorMeta } from '@rareindex/connectors';
import { saveFixture } from '@rareindex/connectors/testing';
import createConnector from './index.js';

const save = process.argv.includes('--save');
const meta = getConnectorMeta('discogs');
const connector = createConnector(meta);
const router = createRouter({});
const ctx = createCrawlContext({ router, meta, options: { mode: 'probe', limit: 4, seeds: ['Nirvana Nevermind'] } });
let n = 0;
for await (const raw of connector.crawl(ctx)) {
  const out = await connector.normalize({ ...raw, externalId: raw.externalId ?? null, fetchedAt: raw.fetchedAt ?? new Date() });
  console.log(`raw ${raw.kind} ${raw.externalId} → ${out.length} records`);
  for (const r of out.slice(0, 2)) console.log('  ', JSON.stringify(r).slice(0, 400));
  if (save && n < 2) {
    saveFixture('discogs', raw.kind === 'catalog_item' ? 'nevermind-versions' : 'nevermind-release-stats', {
      raw: { url: raw.url, externalId: raw.externalId ?? null, kind: raw.kind, engine: raw.engine, fetchedAt: raw.fetchedAt ?? new Date(), payload: raw.payload },
      expect: raw.kind === 'catalog_item' ? { minCount: 5, kinds: ['catalog_item'], requiredFields: ['attributes.identifiers.discogs_release_id', 'attributes.name'] } : { minCount: 1, kinds: ['catalog_item', 'price_observation'] },
      note: 'Captured live from api.discogs.com',
    });
  }
  n++;
}
const lk = await connector.lookup('https://www.discogs.com/release/367084-Nirvana-Nevermind', ctx);
console.log('lookup →', lk.length, lk[0] ? JSON.stringify((await connector.normalize({ ...lk[0], externalId: lk[0].externalId ?? null, fetchedAt: lk[0].fetchedAt ?? new Date() }))[0]).slice(0, 300) : '');
console.log('engineStats', ctx.engineStats, 'anomalies', ctx.anomalies);