import { pool } from '../db/pool.js';
import * as queue from '../jobs/queue.js';

export async function runSync() {
  const { rows } = await pool.query(
    `SELECT id FROM source_docs WHERE sync_source = 'url'`
  );
  for (const r of rows) {
    await queue.enqueue('sync.source_doc', { source_doc_id: r.id });
  }
  return rows.length;
}