"""Record the client-error observation epoch for confidence scoring.

Revision ID: 477
Revises: 476
"""

import json

import sqlalchemy as sa

from alembic import op

revision = "477"
down_revision = "476"
branch_labels = None
depends_on = None

_KEY = "observability.client_error_telemetry_started"


def upgrade() -> None:
    op.get_bind().execute(
        sa.text(
            "INSERT INTO platform_settings "
            "(`key`, value, description, created_at, updated_at) "
            "VALUES (:key, :value, :description, NOW(), NOW()) "
            "ON DUPLICATE KEY UPDATE description = VALUES(description)"
        ),
        {
            "key": _KEY,
            "value": json.dumps(True),
            "description": (
                "Observation epoch for privacy-safe client error daily counts; "
                "created_at drives Intelligence confidence warm-up."
            ),
        },
    )


def downgrade() -> None:
    op.get_bind().execute(
        sa.text("DELETE FROM platform_settings WHERE `key` = :key"),
        {"key": _KEY},
    )