Substrate Engine API & IPC Integration

Win32 Named Pipe Connection Protocol

The Justified Assistant micro-kernel runs as a background service or standalone daemon listening on a local duplex Win32 Named Pipe. Zero TCP ports are opened, requiring no firewall exemptions.

Integration Wrapper Code Examples

C# / .NET (P/Invoke & NamedPipeClientStream)

using System.IO.Pipes;
using System.IO;

using var pipe = new NamedPipeClientStream(".", "JustifiedEnginePipe", PipeDirection.InOut);
pipe.Connect(5000);
using var writer = new StreamWriter(pipe) { AutoFlush = true };
using var reader = new StreamReader(pipe);

// Dispatch raw query (ChatML formatting handled transparently by engine gateway)
writer.WriteLine("{\"prompt\": \"Refactor local control module to eliminate memory leaks.\"}");

while (pipe.IsConnected && !reader.EndOfStream) {
    string? line = reader.ReadLine();
    if (line == null) break;
    Console.WriteLine($"[STREAM] {line}");
    if (line.Contains("\"type\":\"done\"")) break;
}

Python (pywin32)

import win32pipe, win32file, json

handle = win32file.CreateFile(
    r'\\.\pipe\JustifiedEnginePipe',
    win32file.GENERIC_READ | win32file.GENERIC_WRITE,
    0, None, win32file.OPEN_EXISTING, 0, None
)

payload = json.dumps({"prompt": "Verify assembly boundary constraints."}) + "\n"
win32file.WriteFile(handle, payload.encode('utf-8'))

while True:
    err, result = win32file.ReadFile(handle, 4096)
    lines = result.decode('utf-8').split('\n')
    for line in lines:
        if line.strip():
            print(f"[RECV] {line}")
            if '"type":"done"' in line:
                breakHook = True
    if 'breakHook' in locals(): break