vcg_client – Python helper for Gen1 workloads

import socket
import json
import os
 
BUFFER_SIZE = 65535
VCG_ROUTE_SOCK = "/run/vcg/vcg_route.sock"
 
def await_window(sock_path: str):
    """Block until a WINDOW_TICK is received."""
    with socket.socket(socket.AF_UNIX, socket.SOCK_DGRAM) as s:
        s.connect(sock_path)
        while True:
            data = s.recv(BUFFER_SIZE)
            msg = json.loads(data.decode())
            if msg.get("type") == "WINDOW_TICK":
                return
 
def send_route(from_d: str, to_d: str, payload: str):
    """Send a payload to another dimension."""
    msg = {
        "type": "VCG_ROUTE",
        "from_d": from_d,
        "to_d": to_d,
        "payload": payload
    }
    with socket.socket(socket.AF_UNIX, socket.SOCK_DGRAM) as s:
        s.connect(VCG_ROUTE_SOCK)
        s.send(json.dumps(msg).encode())
 
def recv_route(dimension_id: str):
    """Receive the next routed payload for this dimension."""
    sock_path = f"/run/vcg/{dimension_id.lower()}.sock"
    if not os.path.exists(sock_path):
        raise FileNotFoundError(f"Socket {sock_path} not found")
    with socket.socket(socket.AF_UNIX, socket.SOCK_DGRAM) as s:
        s.connect(sock_path)
        data = s.recv(BUFFER_SIZE)
        msg = json.loads(data.decode())
        if msg.get("type") == "VCG_ROUTE":
            return json.loads(msg["payload"])
        return None

from vcg_client import await_window, send_route, recv_route
 
DIM_ID = "D2"
SOCK_PATH = f"/run/vcg/{DIM_ID.lower()}.sock"
 
await_window(SOCK_PATH)
send_route(from_d=DIM_ID, to_d="D4", payload='{"msg": "hello"}')
msg = recv_route(DIM_ID)