@axiom-lattice/gateway

Fastify-based HTTP API gateway exposing REST endpoints for agent execution, thread management, and configuration.

Store Consumption

The gateway reads all stores from StoreLatticeManager at startup — no manual wiring needed. Register stores via configureStores before calling startAsHttpEndpoint():

import { configureStores } from "@axiom-lattice/core";
import { createPgStoreConfig } from "@axiom-lattice/pg-stores";
import { LatticeGateway } from "@axiom-lattice/gateway";

const stores = createPgStoreConfig(process.env.DATABASE_URL);
await configureStores({ ...stores });

// Gateway picks up stores from StoreLatticeManager automatically
LatticeGateway.startAsHttpEndpoint({ port: 4001 });

How it works

The gateway internally calls getStoreLattice("default", type) for each store it needs:

• channelBinding — used by MessageRouter for sender-to-agent binding resolution
• channelInstallation — used for channel instance lookup
• database — SqlDatabaseManager reads configs lazily on first query
• metrics — MetricsServerManager loads configs on first access
• All other stores — consumed by controllers via getStoreLattice("default", type)

No setConfigStore() or loadConfigsFromStore() calls needed — each manager reads directly from StoreLatticeManager.

Quick Start

import { LatticeGateway } from "@axiom-lattice/gateway";

LatticeGateway.startAsHttpEndpoint({
  port: 4001,
});

Logger Configuration

import { LatticeGateway } from "@axiom-lattice/gateway";
import { LoggerType } from "@axiom-lattice/protocols";

LatticeGateway.startAsHttpEndpoint({
  port: 4001,
  loggerConfig: {
    name: "default",
    type: LoggerType.PINO,
    serviceName: "my-service",
  },
});

API Endpoints

• POST /api/v1/run — Execute agent
• POST /api/v1/run/stream — Stream agent execution
• GET /api/v1/run/:thread_id — Get run status
• GET /api/v1/run/:thread_id/messages — Get message history