Function main

apps/cursor/src/scripts/insert-from-jsonl.ts:75–156

()

}

async function main() {
  const args = parseArgs();
  console.log("Args:", args);

  if (!existsSync(args.input)) {
    console.error(`Input not found: ${args.input}`);
    console.error("Run scripts/extract-from-github.ts first.");
    process.exit(1);
  }

  const summary = {
    processed: 0,
    inserted: 0,
    skipped_duplicate: 0,
    skipped_other: 0,
    failed: 0,
    by_source: {} as Record<string, number>,
  };

  for await (const row of readRows(args.input)) {
    if (summary.processed >= args.limit) break;
    summary.processed++;

    const label = `${row.parsed.repository ?? row.github_repo_id} (${row.parsed.name})`;

    if (args.dryRun) {
      console.log(
        `[dry-run] would insert: ${label} (${row.parsed.components.length} components)`,
      );
      summary.inserted++;
      summary.by_source[row.discovery_source] =
        (summary.by_source[row.discovery_source] ?? 0) + 1;
      continue;
    }

    try {
      const { slug } = await insertPlugin(
        {
          name: row.parsed.name,
          description: row.parsed.description,
          logo: row.parsed.logo ?? null,
          repository: row.parsed.repository,
          homepage: row.parsed.homepage ?? null,
          license: row.license ?? row.parsed.license ?? null,
          keywords: row.parsed.keywords,
          author_name: row.parsed.author_name ?? null,
          author_url: row.parsed.author_url ?? null,
          author_avatar: row.parsed.author_avatar ?? null,
          components: row.parsed.components,
        },
        {
          ownerId: null,
          source: row.discovery_source,
          githubRepoId: row.github_repo_id,
          skipScan: true,
        },
      );
      summary.inserted++;