Voice Memory Quickstart

# Python
pip install "memoair-voice>=0.3.2"
 
# Node / TypeScript
npm install memoair-voice

MEMOAIR_API_KEY=memoair_pk_...
MEMOAIR_PROJECT_ID=proj_...
MEMOAIR_AGENT_ID=agent_...

import asyncio
import os
from memoair_voice import MemoAirVoiceClient
 
 
async def run_turn(
    client: MemoAirVoiceClient,
    user_text: str,
    *,
    participant_identity: str,
) -> str:
    # 1. Recall context locally for THIS end-user. SearchResult.contextText is
    #    a ready-to-splice system-message string (profile + working +
    #    permanent + org composed).
    ctx = await client.search_memory(
        user_text,
        user={"id": participant_identity},  # add name/metadata when available
        timeout_ms=250,
    )
    system_prompt = (
        "You are a helpful assistant.\n\n"
        f"## Memory\n{ctx.contextText}"
        if ctx.contextText
        else "You are a helpful assistant."
    )
 
    # 2. Call your LLM with system_prompt + user_text. (Stand-in below.)
    assistant_text = await your_llm_call(system_prompt, user_text)
 
    # 3. Persist the completed turn so memory grows over time. Best-effort;
    #    transient errors are swallowed so audio is never blocked.
    await client.save_response(
        user_text=user_text,
        assistant_text=assistant_text,
        user={"id": participant_identity},
        metadata={"framework": "custom"},
    )
    return assistant_text
 
 
async def main() -> None:
    # Construct the client ONCE at boot. Internally the SDK keeps a pool of
    # voice-runtime processes keyed by (project_id, user.id) — pass user_id
    # per call and the pool routes (or spawns) the right runtime.
    client = MemoAirVoiceClient(
        api_key=os.environ["MEMOAIR_API_KEY"],
        project_id=os.environ["MEMOAIR_PROJECT_ID"],
        agent_id=os.environ["MEMOAIR_AGENT_ID"],
    )
    try:
        reply = await run_turn(
            client,
            "How long do I have to return something?",
            participant_identity="user_42",
        )
        print(reply)
    finally:
        await client.aclose()
 
 
asyncio.run(main())