Method listProperties

server/src/db/catalog-db.ts:330–398

(filters: ListFilters)

  }

  async listProperties(filters: ListFilters): Promise<{ properties: CatalogProperty[]; next_cursor: string | null; total: number }> {
    const conditions: string[] = [];
    const params: any[] = [];
    let paramIdx = 1;

    // Default: active properties only
    conditions.push(`cp.status = $${paramIdx++}`);
    params.push(filters.status ?? 'active');

    if (filters.classification) {
      conditions.push(`cp.classification = $${paramIdx++}`);
      params.push(filters.classification);
    }

    if (filters.source) {
      conditions.push(`cp.source = $${paramIdx++}`);
      params.push(filters.source);
    }

    if (filters.search) {
      conditions.push(`EXISTS (
        SELECT 1 FROM catalog_identifiers ci
        WHERE ci.property_rid = cp.property_rid
          AND ci.identifier_value ILIKE $${paramIdx++} ESCAPE '\\'
          AND ci.disputed = FALSE
      )`);
      params.push(`%${filters.search.replace(/[%_\\]/g, '\\$&')}%`);
    }

    if (filters.identifier_type) {
      conditions.push(`EXISTS (
        SELECT 1 FROM catalog_identifiers ci
        WHERE ci.property_rid = cp.property_rid
          AND ci.identifier_type = $${paramIdx++}
          AND ci.disputed = FALSE
      )`);
      params.push(filters.identifier_type);
    }

    if (filters.cursor) {
      conditions.push(`cp.property_rid > $${paramIdx++}`);
      params.push(filters.cursor);
    }

    const limit = Math.min(filters.limit ?? 100, 1000);
    const where = conditions.length > 0 ? `WHERE ${conditions.join(' AND ')}` : '';

    const countResult = await query<{ count: string }>(
      `SELECT count(*) FROM catalog_properties cp ${where}`,
      params
    );

    params.push(limit);
    const result = await query<CatalogProperty>(
      `SELECT cp.* FROM catalog_properties cp ${where}
       ORDER BY cp.property_rid
       LIMIT $${paramIdx}`,
      params