Method upsertBrandProperties

server/src/crawler.ts:247–318

* Extract properties from brand.json and upsert them into the property catalog. * brand.json = "what I own" — the brand declares its properties.

(domain: string, brandJson: Record<string, unknown>)

   * brand.json = "what I own" — the brand declares its properties.
   */
  private async upsertBrandProperties(domain: string, brandJson: Record<string, unknown>): Promise<void> {
    const brands = Array.isArray(brandJson.brands) ? brandJson.brands as Array<Record<string, unknown>> : [];
    // Also check top-level properties (for simple brand.json without brands array)
    const topProperties = Array.isArray(brandJson.properties) ? brandJson.properties as Array<Record<string, unknown>> : [];

    const allProperties: Array<{ type: string; identifier: string }> = [];
    for (const brand of brands) {
      const props = Array.isArray(brand.properties) ? brand.properties as Array<Record<string, unknown>> : [];
      for (const p of props) {
        if (typeof p.identifier === 'string' && typeof p.type === 'string') {
          allProperties.push({ type: p.type, identifier: p.identifier.toLowerCase() });
        }
      }
    }
    for (const p of topProperties) {
      if (typeof p.identifier === 'string' && typeof p.type === 'string') {
        allProperties.push({ type: p.type, identifier: p.identifier.toLowerCase() });
      }
    }

    if (allProperties.length === 0) return;

    // Map brand.json property types to catalog identifier types
    const typeMap: Record<string, string> = {
      website: 'domain',
      mobile_app: 'bundle_id',
      ctv_app: 'bundle_id',
      desktop_app: 'bundle_id',
      dooh: 'domain',
      podcast: 'domain',
      radio: 'domain',
      streaming_audio: 'domain',
    };

    try {
      const { uuidv7 } = await import('./db/uuid.js');
      for (const prop of allProperties) {
        const identifierType = typeMap[prop.type] || 'domain';

        // Check if this identifier already exists in the catalog
        const existing = await query<{ property_rid: string }>(
          'SELECT property_rid FROM catalog_identifiers WHERE identifier_type = $1 AND identifier_value = $2',
          [identifierType, prop.identifier]
        );

        if (existing.rows.length > 0) {
          // Property already in catalog — just update the source timestamp
          await query(
            'UPDATE catalog_properties SET source_updated_at = NOW(), updated_at = NOW() WHERE property_rid = $1',
            [existing.rows[0].property_rid]
          );
        } else {
          // New property — insert into catalog
          const rid = uuidv7();
          await query(
            `INSERT INTO catalog_properties (property_rid, classification, source, status, created_by)
             VALUES ($1, 'property', 'contributed', 'active', $2)`,
            [rid, `brand_json:${domain}`]