Conversation Storage

// typescript
const sessionStore = context.store.claudeSessionStore()

// python
session_store = context.store.claude_session_store()

// typescript
const session = context.store.openaiSession(context.conversation_id)

// python
session = context.store.openai_session(context.conversation_id)

// typescript
const checkpointer = context.store.langgraphCheckpointer
const store = context.store.langgraphStore

// python
checkpointer = context.store.langgraph_checkpointer
store = context.store.langgraph_store

// typescript
const checkpointer = context.store.langgraphCheckpointer
const store = context.store.langgraphStore

// python
checkpointer = context.store.langgraph_checkpointer
store = context.store.langgraph_store

const messageId = await context.store.appendMessage({
  conversationId: context.conversation_id,
  role: 'user',
  content: context.request.body.message,
  userId: context.request.body.userId,
  metadata: { source: 'web' },
})

message_id = await context.store.append_message(
    conversation_id=context.conversation_id,
    role="user",
    content=context.request.body["message"],
    user_id=context.request.body.get("user_id"),
    metadata={"source": "web"},
)

const messages = await context.store.getMessages({
  conversationId: context.conversation_id,
  limit: 50,
})
const reply = await openai.chat.completions.create({
  model: 'gpt-4o',
  messages: context.store.toOpenAIInput(messages),
})

messages = await context.store.get_messages(
    conversation_id=context.conversation_id,
    limit=50,
)
reply = await openai_client.chat.completions.create(
    model="gpt-4o",
    messages=context.store.to_openai_input(messages),
)

const updated = await context.store.updateMessage({
  conversationId: context.conversation_id,
  messageId: 'msg_abc123',
  content: 'corrected answer',
  metadata: { edited: true },
})

updated = await context.store.update_message(
    conversation_id=context.conversation_id,
    message_id="msg_abc123",
    content="corrected answer",
    metadata={"edited": True},
)

await context.store.deleteMessage({
  conversationId: context.conversation_id,
  messageId: 'msg_abc123',
})

await context.store.delete_message(
    conversation_id=context.conversation_id,
    message_id="msg_abc123",
)

await context.store.clearMessages({ conversationId: context.conversation_id })

await context.store.clear_messages(conversation_id=context.conversation_id)

const meta = await context.store.getConversation({
  conversationId: context.conversation_id,
})
console.log(meta.messageCount, meta.metadata?.title)

meta = await context.store.get_conversation(
    conversation_id=context.conversation_id,
)
print(meta.message_count, (meta.metadata or {}).get("title"))

const { items, nextCursor } = await context.store.listConversations({
  userId: 'u_123',
  limit: 20,
})

result = await context.store.list_conversations(user_id="u_123", limit=20)
items, next_cursor = result.items, result.next_cursor

await context.store.updateConversation({
  conversationId: context.conversation_id,
  metadata: { title: 'Product Inquiry', tag: null },  // Sets the title and removes the tag.
})

await context.store.update_conversation(
    conversation_id=context.conversation_id,
    metadata={"title": "Product Inquiry", "tag": None},
)

await context.store.deleteConversation({
  conversationId: context.conversation_id,
})

await context.store.delete_conversation(
    conversation_id=context.conversation_id,
)

const history = await context.store.getMessages({
  conversationId: context.conversation_id,
})
const resp = await anthropic.messages.create({
  model: 'claude-sonnet-4',
  max_tokens: 1024,
  messages: context.store.toAnthropicMessages(history),
})

history = await context.store.get_messages(
    conversation_id=context.conversation_id,
)
resp = await anthropic_client.messages.create(
    model="claude-sonnet-4",
    max_tokens=1024,
    messages=context.store.to_anthropic_messages(history),
)

const history = await context.store.getMessages({
  conversationId: context.conversation_id,
})
const resp = await openai.chat.completions.create({
  model: 'gpt-4o',
  messages: context.store.toOpenAIInput(history),
})

history = await context.store.get_messages(
    conversation_id=context.conversation_id,
)
resp = await openai_client.chat.completions.create(
    model="gpt-4o",
    messages=context.store.to_openai_input(history),
)

interface Message {
  messageId: string                       // msg_xxx (automatically generated by appendMessage)
  role: 'user' | 'assistant' | 'system' | 'tool'
  content: any                            // string / array / object (multimodal)
  createdAt: number                       // Timestamp in milliseconds
  metadata?: Record<string, any>          // Custom (e.g., token count, tool_call, etc.)
  updatedAt?: number                      // Present only after updateMessage
}

interface ConversationMeta {
  conversationId: string
  createdAt: number                       // Timestamp in milliseconds
  lastMessageAt: number                   // Timestamp in milliseconds
  messageCount: number
  metadata?: Record<string, any>          // Business-defined (e.g., title, user, tags, etc.)
}

interface ListConversationsResult {
  items: ConversationMeta[]
  nextCursor?: string                     // The cursor for the next page, to be passed to the after parameter.
  previousCursor?: string                 // The cursor for the previous page, to be passed to the before parameter.
}

async function summarizeWithLLM(previousSummary, newMessages) {
  const transcript = newMessages
    .filter(m => m.role === 'user' || m.role === 'assistant')
    .map(m => `${m.role}: ${
      typeof m.content === 'string' ? m.content : JSON.stringify(m.content)
    }`)
    .join('\n')
  const prompt = previousSummary
    ? `Below are the [Existing Summary] and [New Dialogue] of a conversation. Please merge them into a new summary.
Requirements:
- Retain: key facts, user preferences, incomplete tasks, and important contextual settings.
- Delete: casual greetings, acknowledgments of receipt, duplicate content, and tool invocation details.
- Write in the same language as the most recent conversation.
- Keep it within 500 words.

[Existing Summary]
${previousSummary}

[New Dialogue]
${transcript}

[New Summary]`
    : `Please summarize the following conversation into a summary.
Requirements:
- Retain: key facts, user preferences, incomplete tasks, and important contextual settings.
- Delete: casual greetings, acknowledgments of receipt, duplicate content, and tool invocation details.
- Write in the same language as the conversation.
- Keep it within 500 words.

[Dialogue]
${transcript}
[Summary]`
  const { text } = await generateText({
    model: openai('gpt-4o-mini'),
    prompt,
    maxTokens: 800,
  })
  return text.trim()
}