#!/usr/bin/env python3
"""Original scale writers and genuine reader date-shape failures; never replay writes."""
import hashlib
import json
from pathlib import Path
import subprocess
import sys
import integrate_20261010 as tool
from integrate_20261011_batches46_48 import item

BASE = tool.AI + 'parallel-ai-scale-owned-source-20261011/'

def verify():
    root = tool.ROOT / BASE
    assert hashlib.sha256((root / 'manifest.json').read_bytes()).hexdigest() == '81b122d0bafa6af7652340dd7bcd9a7571d573d8ec5f7c85a11ea0c522dd5bf9'
    r = json.loads(subprocess.run([sys.executable, '-B', str(root / 'execution/audit.py')], check=True, capture_output=True, text=True).stdout)
    assert r['checks'] == 2015
    for lane, sql in [('B', 325), ('C', 459)]:
        facts = r['lanes'][lane]
        assert facts['HTTP'] == facts['AI_UPDATE'] == facts['source_DTO_pass'] == 4
        assert facts['Store_INSERT'] == facts['new_Store_rows'] == 10
        assert facts['prepare'] == facts['DELETE'] == facts['DDL'] == facts['native_errors'] == 0
        assert facts['SQL'] == sql and facts['old_protection'] and facts['resources_cleaned']
    for red in r['cross_date_contract'].values():
        assert red['cross_contract'] == 'FAIL_DATE_STRING_SHAPE_SECONDS_VS_6FRACTION'
        assert not red['normalization_applied'] and red['source_per_side'] == 'PASS'
    seals = json.loads(subprocess.run([sys.executable, '-B', str(root / 'execution/verify_seal.py')], check=True, capture_output=True, text=True).stdout)
    assert seals['all_seals_immutable'] and seals['verified_assets'] == 1243

def targets():
    out = []
    for vendor in ['WellandScale', 'YunkangbaoScale']:
        out.append(item('ai_api', 'POST', '/api/' + vendor + '/add', BASE,
            request_type='application/json-form-original-number-values',
            scope='customer-Store-secondary-measurement10I-and-AI-primary-weight-staff4U-original-nonXA-commits',
            risk='actual-two-customer-database-writes-VARCHAR-health-values-CLOB-raw-DEC-staff',
            success_case='partial-evidence-original-five-Store-inserts-two-AI-updates-per-writer-actual-native-commits',
            parity='partial-evidence-original-full-add-envelope-equal-date-readers-separately-fail',
            cleanup='marked-session-raw-health-retained-own-Weight-Staff-updated-original-protection-and-resources-cleared'))
        out.append(item('ai_api', 'GET', '/api/' + vendor + '/byDate', BASE,
            request_type='GET-date-query',
            dm_state='tested-fail-measured_at-seconds-vs-six-zero-fraction-response-contract',
            scope='customer-Store-secondary-original-nonempty-scale-session-raw-health-independent-projection',
            risk='nonempty-reader-DATETIME0-response-contract',
            success_case='partial-evidence-whole-source-DTO-native-values-pass-cross-date-shape-fails',
            parity='tested-fail-measured_at-string-shape-fixed-Yunkangbao-input-proves-difference',
            cleanup='readonly-old-successful-writers-not-replayed-original-red-wire-immutable-resources-cleared'))
    return out

if __name__ == '__main__':
    audit = Path(__file__).with_name('integration-20261011-batch88.json')
    assert not audit.exists(), 'Preserve one-time original failure integration'
    tool.main(targets(), audit, verify)