Procedural Human-Guided Aesthetic Extensions

# 1. Syntax check: catch malformed Python
ast.parse(source_code)

# 2. Export check: required interface
assert "EFFECT_META" in module.__dict__
assert callable(module.fx_function)

# 3. Test run: functional verification
result = module.fx_function(
    np.zeros((480, 640, 3), dtype=np.uint8),
    MockAudioFeatures(),
    {}
)

# 4. Shape match: output contract
assert result.shape == (480, 640, 3)
assert result.dtype == np.uint8

// PARENT: Confetti Particle Storm
// Pink body tint, 30 particles, bass-driven downward fall
vec3 body = mix(src.rgb, vec3(1.0, 0.4, 0.7), 0.4 * step(0.15, luma));
for (int i = 0; i < 30; i++) {
    // ...
    vec2 pos = vec2(
        fract(seed + sin(t * 0.3) * 0.3),
        fract(fi * 0.0371 - t * 0.15 * (0.5 + bass))  // downward
    );
    float size = 0.005 + bass * 0.008;
    vec3 cc = 0.5 + 0.5 * cos(6.28 * (seed * 3.0 + vec3(0, 0.33, 0.67)));
}

// MUTATION: Acid Confetti
// Cyan/lime body tint, 90 particles, highs-driven upward float
vec3 body = mix(src.rgb, vec3(0.0, 1.0, 0.7), 0.5 * step(0.15, luma));
for (int i = 0; i < 90; i++) {
    // ...
    vec2 pos = vec2(
        fract(seed + sin(t * 0.3) * 0.4),
        fract(fi * 0.0111 + t * 0.2 * (0.5 + highs))  // upward
    );
    float size = 0.004 + highs * 0.01;
    // Cyan/lime/magenta palette (discrete, not continuous)
    if (sel < 0.33) cc = vec3(0.0, 1.0, 1.0);
    else if (sel < 0.66) cc = vec3(0.5, 1.0, 0.0);
    else cc = vec3(1.0, 0.0, 1.0);
}

MCP_URL = "http://localhost:40404/mcp"

def td_call(tool: str, args: dict, retries: int = 2) -> str:
    """Call a twozero MCP tool and return text content."""
    payload = {
        "jsonrpc": "2.0",
        "id": 1,
        "method": "tools/call",
        "params": {"name": tool, "arguments": args},
    }
    data = json.dumps(payload).encode("utf-8")
    for attempt in range(retries + 1):
        try:
            req = urllib.request.Request(
                MCP_URL, data=data,
                headers={"Content-Type": "application/json"},
            )
            with urllib.request.urlopen(req, timeout=120) as resp:
                result = json.loads(resp.read().decode("utf-8"))
            content = result["result"]["content"]
            return "\n".join(
                c["text"] for c in content if c["type"] == "text"
            )
        except Exception:
            if attempt == retries:
                raise
            time.sleep(1)