EIPC Developer Documentation v0.1.0

EIPC Frame Layout

 0                   1                   2                   3
 0 1 2 3 4 5 6 7 8 9 0 1 2 3 4 5 6 7 8 9 0 1 2 3 4 5 6 7 8 9 0 1
+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+
|                    Frame Length (4 bytes)                      |
+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+
|    Version    |     Type      |          Flags (2 bytes)      |
+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+
|                   Sequence Number (4 bytes)                    |
+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+
|               Header Length (2 bytes)                          |
+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+
|                    JSON Header (variable)                      |
|                          ...                                   |
+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+
|                 Payload Length (4 bytes)                        |
+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+
|                    JSON Payload (variable)                     |
|                          ...                                   |
+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+
|                 HMAC-SHA256 (32 bytes, optional)               |
|                          ...                                   |
+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+

Go Server

package main

import (
    "fmt"
    "github.com/embeddedos-org/eipc/server"
)

func main() {
    srv := server.New(server.Config{
        Address:  "tcp://0.0.0.0:8421",
        HMACKey:  "my-secret-key-32-bytes-minimum!!",
    })

    srv.OnIntent(func(conn *server.Conn, intent string, confidence float64) {
        fmt.Printf("[%s] Intent: %s (%.0f%%)\n", conn.ServiceID, intent, confidence*100)
        conn.SendAck(conn.LastRequestID(), "ok")
    })

    srv.OnToolRequest(func(conn *server.Conn, tool string, args map[string]string) {
        fmt.Printf("[%s] Tool: %s args=%v\n", conn.ServiceID, tool, args)
        result := executeLocalTool(tool, args)
        conn.SendMessage(server.ToolResult{
            RequestID: conn.LastRequestID(),
            Result:    result,
        })
    })

    fmt.Println("EIPC server listening on :8421")
    srv.ListenAndServe()
}

Go Client

package main

import (
    "fmt"
    "github.com/embeddedos-org/eipc/client"
)

func main() {
    c := client.New("eni-neuralink-1")
    err := c.Connect("tcp://192.168.1.100:8421", "my-secret-key-32-bytes-minimum!!")
    if err != nil {
        panic(err)
    }
    defer c.Close()

    // Send decoded neural intent
    c.SendIntent("move_cursor_left", 0.92)

    // Send tool request and wait for result
    result, err := c.SendToolRequest("gpio_write", map[string]string{
        "pin":   "12",
        "value": "true",
    })
    fmt.Printf("Tool result: %s\n", result)

    // Heartbeat loop
    go func() {
        for {
            c.SendHeartbeat()
            time.Sleep(5 * time.Second)
        }
    }()
}

// C SDK client - connects to EIPC server and sends intents
#include <eipc.h>

int main(void) {
    eipc_client_t client;
    eipc_client_init(&client, "eni-sensor-1");

    eipc_status_t rc = eipc_client_connect(&client,
        "tcp://192.168.1.100:8421",
        "my-secret-key-32-bytes-minimum!!");
    if (rc != EIPC_OK) {
        fprintf(stderr, "Connect failed: %d\n", rc);
        return 1;
    }

    // Send intent
    eipc_client_send_intent(&client, "move_cursor_left", 0.92f);

    // Send tool request
    eipc_kv_t args[] = {
        {"pin", "12"}, {"value", "true"}
    };
    eipc_client_send_tool_request(&client, "gpio_write", args, 2);

    // Receive response
    eipc_message_t msg;
    if (eipc_client_receive(&client, &msg) == EIPC_OK) {
        printf("Response type=%d\n", msg.type);
    }

    eipc_client_close(&client);
    return 0;
}