Execution Lifecycle: Stream, Dispatch, Retrieve

Every interaction with the Lexera Protocol follows the same asynchronous lifecycle. You open a persistent Server-Sent Events connection, the server assigns you a session, you POST a JSON-RPC tool call, and the result streams back over the same connection. This design keeps your agent or enterprise system responsive while human attorneys perform verification.

Initialize the SSE stream

Open a persistent GET request to the MCP server endpoint. Include your Bearer token in the Authorization header. The connection stays open for the duration of the session.

curl -N -H "Authorization: Bearer lex_82bea57b8c3fd39f..." \
     -H "Accept: text/event-stream" \
     https://lexera.dev/mcp-server/sse

Receive the session ID

The server streams an event: endpoint message containing your unique session URL. Parse the data line to extract the path and prepend the base URL.

event: endpoint
data: /mcp-server/messages?sessionId=550e8400-e29b-41d4-a716-446655440000

Your session URL becomes:

https://lexera.dev/mcp-server/messages?sessionId=550e8400-e29b-41d4-a716-446655440000

Dispatch the JSON-RPC call

POST your JSON-RPC 2.0 payload to the session URL. The server immediately returns HTTP 202 Accepted. The actual result, such as a DISPATCH_SUCCESS payload or a completed order, arrives later as an SSE message on the open stream.

curl -X POST \
     -H "Authorization: Bearer lex_82bea57b8c3fd39f..." \
     -H "Content-Type: application/json" \
     -d '{
       "jsonrpc": "2.0",
       "id": 1,
       "method": "tools/call",
       "params": {
         "name": "lexera_route_to_specialist",
         "arguments": {
           "document_text": "Vendor contract with uncapped liability clause...",
           "target_jurisdiction": "UAE",
           "specialist_instructions": "Cap liability at 100% of contract value."
         }
       }
     }' \
     https://lexera.dev/mcp-server/messages?sessionId=550e8400-e29b-41d4-a716-446655440000

JavaScript example: opening the stream and extracting the session URL

The following example uses the native fetch API to open the SSE stream, read chunks, and extract the session URL with a regular expression.

const response = await fetch("https://lexera.dev/mcp-server/sse", {
  headers: { "Authorization": "Bearer lex_82bea57b8c3fd39f..." }
});

const reader = response.body.getReader();
const decoder = new TextDecoder();

while (true) {
  const { value, done } = await reader.read();
  if (done) break;

  const text = decoder.decode(value);
  if (text.includes("event: endpoint")) {
    const match = text.match(/data: (\/mcp-server\/messages\?sessionId=[\w-]+)/);
    const sessionUrl = `https://lexera.dev${match[1]}`;
    // Proceed to dispatch tool...
  }
}

Keep the SSE connection open until the final result arrives. Closing the stream prematurely disconnects your session and you will not receive the tool call result.

What happens after dispatch

After the POST returns 202 Accepted, the server processes the request asynchronously. For a human-in-the-loop tool such as lexera_route_to_specialist, this means:

The server places a temporary AED wallet hold.
The document enters the assigned law firm’s triage queue.
Once the attorney completes review, the server streams the finalized payload back over your open SSE connection.

Because the result arrives as an SSE event, your integration should listen continuously after every dispatch.

Next steps

Browse the available MCP tools in Tools Overview
Understand how pricing and wallet holds work in Wallet & Pricing

Get Started

Core Concepts

Guides

Execution Lifecycle: Stream, Dispatch, Retrieve

JavaScript example: opening the stream and extracting the session URL

What happens after dispatch

Next steps

​JavaScript example: opening the stream and extracting the session URL

​What happens after dispatch

​Next steps

JavaScript example: opening the stream and extracting the session URL

What happens after dispatch

Next steps