Method createDiscoveredBrand

server/src/db/brand-db.ts:833–890

* Create a new community brand with pending review status and initial revision.

(
    input: UpsertDiscoveredBrandInput,
    editor: { user_id: string; email?: string; name?: string }
  )

   * Create a new community brand with pending review status and initial revision.
   */
  async createDiscoveredBrand(
    input: UpsertDiscoveredBrandInput,
    editor: { user_id: string; email?: string; name?: string }
  ): Promise<DiscoveredBrand> {
    const client = await getClient();
    try {
      await client.query('BEGIN');

      const insertResult = await client.query<DiscoveredBrand>(
        `INSERT INTO brands (
          domain, 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, review_status, last_validated, expires_at
        ) VALUES ($1, $2, $3, $4, $5, $6, $7, $8, $9, $10, $11, $12, 'pending', NOW(), $13)
        RETURNING *`,
        [
          input.domain.toLowerCase(),
          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 ?? false,
          input.brand_manifest ? JSON.stringify(input.brand_manifest) : null,
          input.source_type,
          input.expires_at || null,
        ]
      );

      const brand = insertResult.rows[0];

      // Create revision #1
      await client.query(
        `INSERT INTO brand_revisions (
          brand_domain, revision_number, snapshot,
          editor_user_id, editor_email, editor_name, edit_summary
        ) VALUES ($1, 1, $2, $3, $4, $5, 'Initial record')`,
        [
          brand.domain,
          JSON.stringify(brand),
          editor.user_id,
          editor.email || null,
          editor.name || null,
        ]
      );

      await client.query('COMMIT');
      return this.deserializeDiscoveredBrand(brand);
    } catch (error) {
      await client.query('ROLLBACK');
      throw error;
    } finally {
      client.release();
    }
  }