AI Companion

pip install maximem-synap maximem-synap-openai-agents openai-agents

uv add maximem-synap maximem-synap-openai-agents openai-agents
# pip-compatible (existing venv): uv pip install maximem-synap maximem-synap-openai-agents openai-agents

npm install @maximem/synap-js-sdk @maximem/synap-vercel-adk ai @ai-sdk/openai

# .env
SYNAP_API_KEY=...
OPENAI_API_KEY=...

# .env.local
SYNAP_API_KEY=...
OPENAI_API_KEY=...

SESSIONS: dict[str, str] = {}

def conv_for(user_id: str) -> str:
    # One conversation per user. Tune to per-session if you prefer.
    return SESSIONS.setdefault(user_id, str(uuid.uuid4()))

const SESSIONS = new Map<string, string>();

function convFor(userId: string): string {
  if (!SESSIONS.has(userId)) SESSIONS.set(userId, crypto.randomUUID());
  return SESSIONS.get(userId)!;
}

import os, uuid, asyncio
from agents import Agent, FunctionTool, Runner
from maximem_synap import MaximemSynapSDK
from synap_openai_agents import create_search_tool, create_store_tool

sdk = MaximemSynapSDK()
await sdk.initialize()

async def handle_message(user_id: str, text: str) -> str:
    conv_id = conv_for(user_id)

    synap_search = create_search_tool(sdk=sdk, user_id=user_id, customer_id="companion")
    synap_store  = create_store_tool(sdk=sdk, user_id=user_id, customer_id="companion")

    agent = Agent(
        name="companion",
        instructions=SYSTEM,
        tools=[
            FunctionTool(synap_search, name_override="synap_search"),
            FunctionTool(synap_store,  name_override="synap_store"),
        ],
    )

    result = await Runner.run(agent, input=text)
    reply = result.final_output

    asyncio.create_task(sdk.memories.create(
        document=f"User: {text}\nCompanion: {reply}",
        document_type="ai-chat-conversation",
        user_id=user_id,
        customer_id="companion",
        metadata={"conversation_id": conv_id},
    ))
    return reply

import { generateText } from "ai";
import { openai } from "@ai-sdk/openai";
import { createSynap } from "@maximem/synap-vercel-adk";

const synap = await createSynap({ apiKey: process.env.SYNAP_API_KEY! });

export async function handleMessage(userId: string, text: string): Promise<string> {
  const conversationId = convFor(userId);

  const model = synap.wrap(openai("gpt-4o"), {
    userId,
    customerId: "companion",
    conversationId,
  });

  const { text: reply } = await generateText({
    model,
    system: SYSTEM,
    prompt: text,
  });

  return reply;
}

async def forget(user_id: str, query: str) -> int:
    """Delete memories matching a natural-language query for a user."""
    matches = await sdk.memories.search(
        user_id=user_id,
        customer_id="companion",
        query=query,
        max_results=20,
    )
    for m in matches:
        await sdk.memories.delete(m.id)
    return len(matches)

export async function forget(userId: string, query: string): Promise<number> {
  const matches = await synap.sdk.memories.search({
    userId,
    customerId: "companion",
    query,
    maxResults: 20,
  });
  for (const m of matches) await synap.sdk.memories.delete(m.id);
  return matches.length;
}