Method batchLookupIdentifiers

server/src/db/catalog-db.ts:693–727

(
    identifiers: Array<{ type: string; value: string }>
  )

  // ═══════════════════════════════════════════════════════════════════════════

  async batchLookupIdentifiers(
    identifiers: Array<{ type: string; value: string }>
  ): Promise<Map<string, { property_rid: string; classification: string; source: string } | null>> {
    if (identifiers.length === 0) return new Map();

    const types = identifiers.map(i => i.type);
    const values = identifiers.map(i => i.value);

    const result = await query<{
      identifier_type: string;
      identifier_value: string;
      property_rid: string;
      classification: string;
      source: string;
    }>(
      `SELECT ci.identifier_type, ci.identifier_value, ci.property_rid, cp.classification, cp.source
       FROM catalog_identifiers ci
       JOIN catalog_properties cp ON cp.property_rid = ci.property_rid
       WHERE ci.disputed = FALSE
         AND (ci.identifier_type, ci.identifier_value) IN (
           SELECT unnest($1::text[]), unnest($2::text[])
         )`,
      [types, values]
    );

    const map = new Map<string, { property_rid: string; classification: string; source: string } | null>();
    for (const row of result.rows) {
      map.set(`${row.identifier_type}:${row.identifier_value}`, {
        property_rid: row.property_rid,
        classification: row.classification,
        source: row.source,
      });
    }
    return map;
  }

  private async batchResolveAliases(rids: string[]): Promise<Map<string, string>> {
    if (rids.length === 0) return new Map();