Method rollbackProperty

server/src/db/property-db.ts:697–776

* Rollback a property to a previous revision.

(
    domain: string,
    toRevisionNumber: number,
    editor: { user_id: string; email?: string; name?: string }
  )

   * Rollback a property to a previous revision.
   */
  async rollbackProperty(
    domain: string,
    toRevisionNumber: number,
    editor: { user_id: string; email?: string; name?: string }
  ): Promise<{ property: HostedProperty; revision_number: number }> {
    const client = await getClient();
    try {
      await client.query('BEGIN');

      // Get target revision
      const targetResult = await client.query<{ snapshot: string }>(
        'SELECT snapshot FROM property_revisions WHERE publisher_domain = $1 AND revision_number = $2',
        [domain.toLowerCase(), toRevisionNumber]
      );
      if (targetResult.rows.length === 0) {
        throw new Error(`Revision ${toRevisionNumber} not found for ${domain}`);
      }

      const snapshot = typeof targetResult.rows[0].snapshot === 'string'
        ? JSON.parse(targetResult.rows[0].snapshot)
        : targetResult.rows[0].snapshot;

      // Lock current row
      const currentResult = await client.query<HostedProperty>(
        'SELECT * FROM hosted_properties WHERE publisher_domain = $1 FOR UPDATE',
        [domain.toLowerCase()]
      );
      if (currentResult.rows.length === 0) {
        throw new Error(`Property not found: ${domain}`);
      }

      // Get next revision number
      const revResult = await client.query<{ next_rev: number }>(
        'SELECT COALESCE(MAX(revision_number), 0) + 1 as next_rev FROM property_revisions WHERE publisher_domain = $1',
        [domain.toLowerCase()]
      );
      const revisionNumber = revResult.rows[0].next_rev;

      // Create rollback revision
      await client.query(
        `INSERT INTO property_revisions (
          publisher_domain, revision_number, snapshot,
          editor_user_id, editor_email, editor_name,
          edit_summary, is_rollback, rolled_back_to
        ) VALUES ($1, $2, $3, $4, $5, $6, $7, true, $8)`,
        [
          domain.toLowerCase(),
          revisionNumber,
          JSON.stringify(currentResult.rows[0]),
          editor.user_id,
          editor.email || null,
          editor.name || null,
          `Rollback to revision ${toRevisionNumber}`,
          toRevisionNumber,
        ]
      );

      // Restore from snapshot