"""
E2E: Nested-create regression test
- Creates an `event_person` under demo event `pjrcghqwert` then creates an
  `event_badge` under that person using the nested CRUD endpoints.
- Cleans up created records on success.

Usage:
    ./environment/bin/python3 tests/e2e/test_e2e_v3_nested_create_event_badge.py

This test uses the standard Agent API Key defined in the project README.
"""

import os
import requests
import sys
import time

BASE = os.environ.get('AE_API_BASE', 'https://dev-api.oneskyit.com')
API_BASE = BASE.rstrip('/') + '/v3/crud'
AGENT_API_KEY = os.environ.get('AE_AGENT_API_KEY', 'nT0jPeiCfxSifkiDZur9jA')
EVENT_ID = os.environ.get('AE_TEST_EVENT', 'pjrcghqwert')
ACCOUNT_ID = os.environ.get('AE_ACCOUNT', '_XY7DXtc9MY')

HEADERS = {'x-aether-api-key': AGENT_API_KEY, 'x-account-id': ACCOUNT_ID, 'Content-Type': 'application/json'}


def print_result(label, success, message=""):
    mark = '✅ PASS' if success else '❌ FAIL'
    print(f"{mark} - {label}: {message}")


def run():
    created = {}
    try:
        # 1) Create event_person under event
        url = f"{API_BASE}/event/{EVENT_ID}/event_person/?return_obj=false"
        r = requests.post(url, headers=HEADERS, json={})
        if r.status_code != 200:
            print_result('create event_person', False, f'status={r.status_code} body={r.text}')
            return 2
        data = r.json().get('data') or {}
        person_id = data.get('obj_id') or data.get('obj_id_random')
        if not person_id:
            print_result('create event_person', False, f'missing obj_id in response {r.json()}')
            return 2
        created['person'] = person_id
        print_result('create event_person', True, f'person_id={person_id}')

        # small delay to let DB/indexing settle on remote dev
        time.sleep(0.5)

        # 2) Create event_badge under event_person
        url = f"{API_BASE}/event_person/{person_id}/event_badge/?return_obj=false"
        r2 = requests.post(url, headers=HEADERS, json={})
        if r2.status_code != 200:
            print_result('create event_badge', False, f'status={r2.status_code} body={r2.text}')
            return 2
        data2 = r2.json().get('data') or {}
        badge_id = data2.get('obj_id') or data2.get('obj_id_random')
        if not badge_id:
            print_result('create event_badge', False, f'missing obj_id in response {r2.json()}')
            return 2
        created['badge'] = badge_id
        print_result('create event_badge', True, f'badge_id={badge_id}')

        # 3) Cleanup: delete badge then person
        # Delete badge
        del_url = f"{API_BASE}/event_person/{person_id}/event_badge/{badge_id}?method=delete"
        rd = requests.delete(del_url, headers=HEADERS)
        if rd.status_code == 200:
            print_result('delete event_badge', True, '')
        else:
            print_result('delete event_badge', False, f'status={rd.status_code} body={rd.text}')

        # Delete person (as child of event)
        delp_url = f"{API_BASE}/event/{EVENT_ID}/event_person/{person_id}?method=delete"
        rp = requests.delete(delp_url, headers=HEADERS)
        if rp.status_code == 200:
            print_result('delete event_person', True, '')
        else:
            print_result('delete event_person', False, f'status={rp.status_code} body={rp.text}')

        return 0

    except Exception as e:
        print_result('exception', False, str(e))
        return 2


if __name__ == '__main__':
    sys.exit(run())