Method insertFacts

server/src/db/catalog-db.ts:465–489

(facts: Array<Omit<CatalogFact, 'fact_id' | 'created_at' | 'superseded_by'>>)

  }

  async insertFacts(facts: Array<Omit<CatalogFact, 'fact_id' | 'created_at' | 'superseded_by'>>): Promise<string[]> {
    if (facts.length === 0) return [];

    const client = await getClient();
    const ids: string[] = [];
    try {
      await client.query('BEGIN');
      for (const fact of facts) {
        const factId = uuidv7();
        ids.push(factId);
        await client.query(
          `INSERT INTO catalog_facts (fact_id, fact_type, subject_type, subject_value, predicate, object_value, source, confidence, actor, provenance_type, provenance_context, expires_at)
           VALUES ($1, $2, $3, $4, $5, $6, $7, $8, $9, $10, $11, $12)`,
          [factId, fact.fact_type, fact.subject_type, fact.subject_value, fact.predicate, fact.object_value, fact.source, fact.confidence, fact.actor, fact.provenance_type, fact.provenance_context, fact.expires_at]
        );
      }
      await client.query('COMMIT');
    } catch (err) {
      await client.query('ROLLBACK');
      throw err;
    } finally {
      client.release();
    }
    return ids;
  }

  // ═══════════════════════════════════════════════════════════════════════════
  // Identifier linking