# 1. Confirm latest Cloud Run revision carries the post-dispatch wiring (#1398)
gcloud run revisions list --service=curaway-backend \
  --project=curaway-dev --region=asia-south1 --limit=3
# Expect: most recent revision is ACTIVE and the image SHA matches main HEAD.

# 2. Audit the Flagsmith flag state — must be OFF in BOTH envs pre-flip
# (per [[feedback_flagsmith_dual_env]] — both Production AND Development)
# Production: https://flagsmith.curaway.ai/...
# Development: ditto, ensure dual-env consistency

# 3. Spot-check a v6.2_flexible message in prod via the rename-aware filter
export DATABASE_URL_ADMIN="$(gcloud secrets versions access latest \
  --secret=DATABASE_URL_ADMIN --project=curaway-dev)"
python -c "
import os, asyncio, asyncpg
async def main():
    conn = await asyncpg.connect(os.environ['DATABASE_URL_ADMIN'].replace('postgresql+asyncpg://','postgresql://'))
    n = await conn.fetchval(\"SELECT COUNT(*) FROM messages WHERE role='assistant' AND metadata->>'prompt_version'='v6.2_flexible' AND created_at > NOW() - INTERVAL '24 hours'\")
    print(f'v6.2_flexible messages last 24h (canonical filter): {n}')
asyncio.run(main())
"

# 4. Confirm Sentry events are arriving (catches the SDK-init regression
# orchestrator flagged earlier)
# Check: any unresolved Sentry issue created in last 24h on prod environment.

# Save as scripts/v6_2_canary_health.py — run locally with DATABASE_URL_ADMIN set
# export DATABASE_URL_ADMIN=$(gcloud secrets versions access latest --secret=DATABASE_URL_ADMIN --project=curaway-dev)
import os, asyncio, asyncpg
async def main():
    url = os.environ['DATABASE_URL_ADMIN'].replace('postgresql+asyncpg://','postgresql://')
    conn = await asyncpg.connect(url)

    # 1. Bold-formatting adherence rate (last 24h, v6.2_flexible only)
    r = await conn.fetchrow("""
        SELECT
          COUNT(*) AS n,
          COUNT(*) FILTER (WHERE position('**' in content) > 0) AS bold,
          ROUND(100.0 * COUNT(*) FILTER (WHERE position('**' in content) > 0) / NULLIF(COUNT(*),0), 1) AS pct
        FROM messages
        WHERE role='assistant'
          AND metadata->>'prompt_version'='v6.2_flexible'
          AND created_at > NOW() - INTERVAL '24 hours'
    """)
    print(f"Bold adherence (24h): {r['bold']}/{r['n']} = {r['pct']}% — target >90%")

    # 2. Voice-rule violations
    n_glad = await conn.fetchval("""
        SELECT COUNT(*) FROM messages
        WHERE role='assistant'
          AND metadata->>'prompt_version'='v6.2_flexible'
          AND created_at > NOW() - INTERVAL '24 hours'
          AND (content ILIKE '%glad you%reach%')
    """)
    print(f"'glad you reach...' opener hits (24h): {n_glad} — target 0")

    # 3. matching_complete + forwarded flip counts
    flip_rows = await conn.fetch("""
        SELECT
          (workflow_state ? 'matching_complete') AS has_match,
          (workflow_state ? 'forwarded') AS has_fwd,
          COUNT(*) AS n
        FROM cases
        WHERE workflow_state->>'prompt_arch'='v6.2_flexible'
          AND created_at > NOW() - INTERVAL '24 hours'
        GROUP BY 1, 2
    """)
    print("v6.2_flexible cases last 24h:")
    for r in flip_rows:
        print(f"  matching_complete={r['has_match']} forwarded={r['has_fwd']}: {r['n']}")

    await conn.close()

asyncio.run(main())