Skip to main content

SDK for building proxy servers for integration between user applications and the SPLX Platform

Project description

SPLX Proxy SDK

A Python SDK for building proxy servers that connect your applications to the SPLX Platform. It handles authentication, request routing, structured logging, and error handling so you can focus on your integration logic.

Built on FastAPI — your proxy server is a standard ASGI app with full access to FastAPI's ecosystem.

Installation

# poetry
poetry add splx-proxy-sdk

# pip
pip install splx-proxy-sdk

Requires Python 3.11+.

Quick Start

from uuid import uuid4

from fastapi import Request

from splx_proxy_sdk import (
    CloseSessionRequest,
    CloseSessionResponse,
    OpenSessionRequest,
    OpenSessionResponse,
    SendMessageRequest,
    SendMessageResponse,
    Server,
)


class MyProxy(Server):
    async def open_session(
        self, request: OpenSessionRequest, raw: Request
    ) -> OpenSessionResponse:
        session_id = request.session_id or str(uuid4())
        return OpenSessionResponse(session_id=session_id)

    async def close_session(
        self, request: CloseSessionRequest, raw: Request
    ) -> CloseSessionResponse:
        return CloseSessionResponse()

    async def send_message(
        self, request: SendMessageRequest, raw: Request
    ) -> SendMessageResponse:
        return SendMessageResponse(
            session_id=request.session_id,
            message=f"Echo: {request.message}",
        )


# Set SPLX_PROXY_API_KEY env variable before starting
app = MyProxy()

Run it:

export SPLX_PROXY_API_KEY="your-secret-key"
uvicorn main:app --reload

The SPLX Platform must be able to reach the host and port you expose.

Testing App

The SDK ships with a lightweight testing app mounted at / so you can test your proxy endpoints without leaving the browser. Launch your server locally, then open http://localhost:8000/ to see the UI.

How It Works

The SDK defines three endpoints that the SPLX Platform calls on your proxy:

Endpoint Method Purpose
/open-session POST Initialize a new session. Return a session_id.
/send-message POST Handle a user message. Return the response.
/close-session POST Clean up when a session ends.

You subclass Server and implement these three methods. The SDK handles authentication, request parsing, logging, and error serialization.

Since Server extends FastAPI, you can add your own routes, middleware, startup/shutdown events, and anything else FastAPI supports.

Features

Authentication

Every request from the SPLX Platform includes an x-api-key header. The SDK validates it automatically against the SPLX_PROXY_API_KEY environment variable. Invalid keys get a 401 Unauthorized response.

This variable must be set before the server starts — the SDK raises a RuntimeError on startup if it's missing.

Extra Arguments

You can pass custom, typed arguments to any endpoint using generics. Define a Pydantic model and parametrize your Server:

from pydantic import BaseModel

class ExtraArgs(BaseModel):
    tone: str = "friendly"
    max_tokens: int = 1000

class MyProxy(Server[ExtraArgs]):
    async def send_message(
        self, request: SendMessageRequest[ExtraArgs], raw: Request
    ) -> SendMessageResponse:
        if request.extra_args:
            print(f"Tone: {request.extra_args.tone}")
            print(f"Max tokens: {request.extra_args.max_tokens}")
        # ...

The extra_args field is optional and defaults to None. If omitted, Server works without any type parameter — Server is equivalent to Server[None].

Multimodal Content

The SDK supports sending and receiving images, audio, and documents. Multimodal content is sent as base64-encoded Data URIs.

from splx_proxy_sdk import MultiModal, MultiModalType

async def send_message(self, request, raw):
    if request.multimodal:
        for name, modal in request.multimodal.items():
            # modal.type is one of: MultiModalType.IMAGE, AUDIO, DOCUMENT
            # modal.content is the base64 Data URI string
            mime_type, base64_data = MultiModal.parse_content(modal.content)
            # mime_type: e.g. "image/png"
            # base64_data: the raw base64 string

Logging

All requests and responses are logged as structured JSON via Loguru. Sensitive headers and fields are redacted by default.

Configure via LoggingConfig in code:

from splx_proxy_sdk import LoggingConfig

app = MyProxy(logging_config=LoggingConfig(
    enabled=True,
    log_request_body=True,
    log_response_body=False,
    max_body_length=2048,
    redact_headers=("x-api-key", "authorization"),
    redact_fields=("password", "secret", "token"),
))

Or via environment variables:

Variable Default Description
SPLX_PROXY_LOG_ENABLED True Enable/disable logging
SPLX_PROXY_LOG_REQUEST_BODY True Log request bodies
SPLX_PROXY_LOG_RESPONSE_BODY True Log response bodies
SPLX_PROXY_LOG_MAX_BODY_LENGTH 4096 Truncate bodies beyond this length
SPLX_PROXY_LOG_REDACT_HEADERS x-api-key Comma-separated headers to redact
SPLX_PROXY_LOG_REDACT_FIELDS api_key,access_token,refresh_token,token,secret,password,authorization Comma-separated JSON fields to redact

Error Handling

The SDK provides typed exception classes that produce structured JSON error responses understood by the SPLX Platform:

Exception Status Code Default Code
BadRequestException 400 BAD_REQUEST
UnauthorizedException 401 UNAUTHORIZED
ForbiddenException 403 FORBIDDEN
NotFoundException 404 NOT_FOUND
TooManyRequestsException 429 TOO_MANY_REQUESTS
SessionClosedException 452 SESSION_CLOSED
InternalServerErrorException 500 INTERNAL_SERVER_ERROR

Basic usage:

from splx_proxy_sdk import NotFoundException, SessionClosedException

# Session doesn't exist
raise NotFoundException(details="Session not found.")

# Session has been closed
raise SessionClosedException(details="This session has ended.")

Exception Configuration

Use ProxyExceptionConfig to attach metadata that the SPLX Platform (Probe) understands:

from datetime import timedelta
from splx_proxy_sdk import ProxyExceptionConfig, TooManyRequestsException

raise TooManyRequestsException(
    details="Rate limit exceeded.",
    config=ProxyExceptionConfig(
        session_closed=False,        # Session is still open
        retry_after=timedelta(seconds=30),  # Retry-After header
        headers={"X-Custom": "value"},      # Additional headers
    ),
)
  • session_closed — tells Probe whether the session was closed as a result of this error (sets X-Splx-Session-Status header)
  • retry_after — tells Probe when to retry (sets Retry-After header)
  • headers — any additional headers to include in the response

Examples

The examples/ directory contains five proxy implementations, each demonstrating a different integration pattern. Every example is a standalone project you can run locally.

echo — Standalone Stateful Proxy

The simplest starting point. A self-contained proxy with no external dependencies that manages sessions in memory and echoes messages back with a counter.

What it demonstrates:

  • In-memory session management (open, close, lookup)
  • Typed extra_args with defaults (repeat: int = 1)
  • Conversation history tracking
  • Error handling with NotFoundException and SessionClosedException

Run it:

cd examples/echo
poetry install
cp proxy/.env.example proxy/.env
uvicorn proxy.main:app --reload

echo_rest — REST API Integration

A proxy that bridges the SPLX protocol to a standard REST API with Bearer token authentication. Includes both the proxy and a sample backend API.

What it demonstrates:

  • Calling an external REST API with httpx
  • Bearer token authentication with the downstream service
  • Mapping SPLX session IDs to API-specific thread IDs
  • Translating between SPLX and REST request/response formats

Architecture:

SPLX Platform --> Proxy (:8000) --> REST API (:8001)

Run it:

cd examples/echo_rest
poetry install
cp proxy/.env.example proxy/.env
# Terminal 1: Start the backend API
uvicorn app.main:app --port 8001 --reload
# Terminal 2: Start the proxy
uvicorn proxy.main:app --port 8000 --reload

echo_sse — Server-Sent Events Integration

A proxy that consumes SSE (Server-Sent Events) from a downstream app and assembles the streamed chunks into a single response for the SPLX protocol.

What it demonstrates:

  • Consuming SSE streams with httpx streaming
  • JWT-based authentication with periodic token refresh
  • Background tasks (FastAPI startup/shutdown events) for token rotation
  • Assembling streamed chunks into a single synchronous response

Architecture:

SPLX Platform --> Proxy (:8000) --> SSE App (:8001)
                    |
            Background auth loop
            refreshes JWT every 8min

Run it:

cd examples/echo_sse
poetry install
cp proxy/.env.example proxy/.env
# Terminal 1: Start the SSE app
uvicorn app.main:app --port 8001 --reload
# Terminal 2: Start the proxy
uvicorn proxy.main:app --port 8000 --reload

echo_ws — WebSocket Integration

A proxy that maintains persistent WebSocket connections to a backend app, with one connection per session.

What it demonstrates:

  • Persistent WebSocket connections per session using websockets
  • REST call to create a backend conversation, then upgrading to WebSocket
  • Consuming chunked WebSocket responses (JSON frames with a "done" signal)
  • Graceful connection cleanup on session close and server shutdown

Architecture:

SPLX Platform --> Proxy (:8000) --> REST /create-conversation
                                --> WS   /chat (one connection per session)

Run it:

cd examples/echo_ws
poetry install
cp proxy/.env.example proxy/.env
# Terminal 1: Start the WebSocket app
uvicorn app.main:app --port 8001 --reload
# Terminal 2: Start the proxy
uvicorn proxy.main:app --port 8000 --reload

echo_multimodal — Multimodal File Handling

A proxy that handles multimodal content (images, audio, documents) by decoding base64 Data URIs and forwarding them as multipart file uploads to a downstream API.

What it demonstrates:

  • Decoding base64 Data URIs using MultiModal.parse_content()
  • Converting Data URIs to multipart file uploads for a downstream REST API
  • MIME type detection and file extension mapping
  • Handling image, audio, and document attachments

Architecture:

SPLX Platform --> Proxy (:8000) --> Multimodal App (:8001)
              (base64 Data URI)   (multipart file upload)

Run it:

cd examples/echo_multimodal
poetry install
cp proxy/.env.example proxy/.env
# Terminal 1: Start the multimodal app
uvicorn app.main:app --port 8001 --reload
# Terminal 2: Start the proxy
uvicorn proxy.main:app --port 8000 --reload

Links

License

MIT

Project details


Download files

Download the file for your platform. If you're not sure which to choose, learn more about installing packages.

Source Distribution

splx_proxy_sdk-1.5.2.tar.gz (26.8 kB view details)

Uploaded Source

Built Distribution

If you're not sure about the file name format, learn more about wheel file names.

splx_proxy_sdk-1.5.2-py3-none-any.whl (26.0 kB view details)

Uploaded Python 3

File details

Details for the file splx_proxy_sdk-1.5.2.tar.gz.

File metadata

  • Download URL: splx_proxy_sdk-1.5.2.tar.gz
  • Upload date:
  • Size: 26.8 kB
  • Tags: Source
  • Uploaded using Trusted Publishing? No
  • Uploaded via: poetry/2.3.1 CPython/3.11.15 Linux/6.12.88-119.157.amzn2023.x86_64

File hashes

Hashes for splx_proxy_sdk-1.5.2.tar.gz
Algorithm Hash digest
SHA256 0067c17e8584032564c551b60284198ed010e196a71cffd85e3b758edc37a9b0
MD5 a8cfb678c9e40791327b4c5615b398a5
BLAKE2b-256 cef59fec83d3cf89e9e9d8c686cffa6a8817c083dfb9faba61bc830d91ee4c87

See more details on using hashes here.

File details

Details for the file splx_proxy_sdk-1.5.2-py3-none-any.whl.

File metadata

  • Download URL: splx_proxy_sdk-1.5.2-py3-none-any.whl
  • Upload date:
  • Size: 26.0 kB
  • Tags: Python 3
  • Uploaded using Trusted Publishing? No
  • Uploaded via: poetry/2.3.1 CPython/3.11.15 Linux/6.12.88-119.157.amzn2023.x86_64

File hashes

Hashes for splx_proxy_sdk-1.5.2-py3-none-any.whl
Algorithm Hash digest
SHA256 7ce8c2d7e935bf36867faeaa41f212279ac2f09dc56220b2ad6cd5c889570038
MD5 947f00fc6ac1f918747f0b076035a1f9
BLAKE2b-256 19d1ca52fb150ace29e028523bcbb782be661720e951e2bebf38ff6f828916bb

See more details on using hashes here.

Supported by

AWS Cloud computing and Security Sponsor Datadog Monitoring Depot Continuous Integration Fastly CDN Google Download Analytics Pingdom Monitoring Sentry Error logging StatusPage Status page