Method upsertDiscoveredBrand

server/src/db/brand-db.ts:537–578

* Upsert a discovered brand (insert or update on conflict)

(input: UpsertDiscoveredBrandInput)

   * Upsert a discovered brand (insert or update on conflict)
   */
  async upsertDiscoveredBrand(input: UpsertDiscoveredBrandInput): Promise<DiscoveredBrand> {
    const result = await query<DiscoveredBrand>(
      `INSERT INTO brands (
        domain, brand_id, canonical_domain, house_domain, brand_name, brand_names,
        keller_type, parent_brand, brand_agent_url, brand_agent_capabilities,
        has_brand_manifest, brand_manifest, source_type, last_validated, expires_at
      ) VALUES ($1, $2, $3, $4, $5, $6, $7, $8, $9, $10, $11, $12, $13, NOW(), $14)
      ON CONFLICT (domain) DO UPDATE SET
        brand_id = COALESCE(EXCLUDED.brand_id, brands.brand_id),
        canonical_domain = EXCLUDED.canonical_domain,
        house_domain = EXCLUDED.house_domain,
        brand_name = EXCLUDED.brand_name,
        brand_names = EXCLUDED.brand_names,
        keller_type = EXCLUDED.keller_type,
        parent_brand = EXCLUDED.parent_brand,
        brand_agent_url = EXCLUDED.brand_agent_url,
        brand_agent_capabilities = EXCLUDED.brand_agent_capabilities,
        has_brand_manifest = COALESCE(EXCLUDED.has_brand_manifest, brands.has_brand_manifest),
        brand_manifest = COALESCE(EXCLUDED.brand_manifest, brands.brand_manifest),
        source_type = EXCLUDED.source_type,
        last_validated = NOW(),
        expires_at = EXCLUDED.expires_at
      RETURNING *`,
      [
        input.domain.toLowerCase(),
        input.brand_id || null,
        input.canonical_domain || null,
        input.house_domain || null,
        input.brand_name || null,
        input.brand_names ? JSON.stringify(input.brand_names) : '[]',
        input.keller_type || null,
        input.parent_brand || null,
        input.brand_agent_url || null,
        input.brand_agent_capabilities || null,
        input.has_brand_manifest != null ? input.has_brand_manifest : null,
        input.brand_manifest ? JSON.stringify(input.brand_manifest) : null,
        input.source_type,
        input.expires_at || null,
      ]
    );
    return this.deserializeDiscoveredBrand(result.rows[0]);
  }

  /**
   * Get discovered brand by domain