c-two/examples/python/relay_client.py at main · world-in-progress/c-two · GitHub

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
"""HTTP client — connects to the Grid CRM via the relay.

Demonstrates that the CRM proxy works identically over HTTP as it
does over IPC — only the address changes.

Usage (3-terminal workflow):

    # Terminal 1 — start the HTTP relay
    c3 relay -b 0.0.0.0:8300

    # Terminal 2 — start the Grid CRM and register it with the relay
    uv run python examples/python/relay_resource.py --relay-url http://127.0.0.1:8300

    # Terminal 3 — run this client
    uv run python examples/python/relay_client.py --relay-url http://127.0.0.1:8300
"""
import argparse
import sys
from pathlib import Path

EXAMPLES_ROOT = Path(__file__).resolve().parent
sys.path.insert(0, str(EXAMPLES_ROOT))

import c_two as cc
from grid.grid_py_crm import GridAttribute, GridPython
from relay_config import ensure_http_relay_url, resolved_relay_url

DEFAULT_RELAY_URL = 'http://127.0.0.1:8300'


def _relay_url(value: str) -> str:
    try:
        return ensure_http_relay_url(value)
    except ValueError as exc:
        raise argparse.ArgumentTypeError(str(exc)) from exc


def parse_args(argv: list[str] | None = None) -> argparse.Namespace:
    parser = argparse.ArgumentParser(
        description='Connect to the Grid CRM through an HTTP relay.',
    )
    parser.add_argument(
        '--relay-url',
        type=_relay_url,
        default=resolved_relay_url(DEFAULT_RELAY_URL),
        help=(
            'HTTP relay URL used for name resolution '
            f'(default: C2_RELAY_ANCHOR_ADDRESS or {DEFAULT_RELAY_URL}).'
        ),
    )
    args = parser.parse_args(argv)
    try:
        args.relay_url = ensure_http_relay_url(args.relay_url)
    except ValueError as exc:
        parser.error(str(exc))
    return args


def main() -> None:
    args = parse_args()
    cc.set_relay_anchor(args.relay_url)

    # Connect via HTTP relay — same API as IPC, different address.
    grid = cc.connect(GridPython, name='examples/grid')
    print(f'[Client] Connected via HTTP (mode: {grid.client._mode})\n')

    # ── Hello ─────────────────────────────────────────────────────
    msg = grid.hello('HTTP Client (standalone relay)')
    print(f'[Client] hello → {msg}')

    # ── Grid info ─────────────────────────────────────────────────
    infos: list[GridAttribute] = grid.get_grid_infos(1, [0])
    attr = infos[0]
    print(f'[Client] Grid 1-0: activate={attr.activate}, level={attr.level}, '
          f'global_id={attr.global_id}, '
          f'bounds=({attr.min_x}, {attr.min_y}, {attr.max_x}, {attr.max_y})')

    # ── Subdivide ─────────────────────────────────────────────────
    keys = grid.subdivide_grids([1], [0])
    print(f'[Client] Subdivided 1-0 → {len(keys)} children: {keys[:4]}…')

    child_ids = [int(k.split('-')[1]) for k in keys]
    children = grid.get_grid_infos(2, child_ids[:4])
    for c in children:
        print(f'  Child 2-{c.global_id}: '
              f'bounds=({c.min_x:.1f}, {c.min_y:.1f}, {c.max_x:.1f}, {c.max_y:.1f})')

    # ── Active grids ──────────────────────────────────────────────
    levels, global_ids = grid.get_active_grid_infos()
    print(f'[Client] Active grids: {len(levels)} total')

    # ── Cleanup ───────────────────────────────────────────────────
    cc.close(grid)
    print('\n[Client] Done.')


if __name__ == '__main__':
    main()