AI Memory

// MCP Tool Invocation Example
{
  "jsonrpc": "2.0",
  "id": 1,
  "method": "tools/call",
  "params": {
    "name": "memory_create",
    "arguments": {
      "content": "User prefers dark mode for the dashboard",
      "importance_score": 0.8,
      "memory_type": "episodic"
    }
  }
}

# Create a task with dependencies
curl -X POST https://api.example.com/api/v1/mcp \
  -H "Authorization: Bearer YOUR_API_KEY" \
  -H "Content-Type: application/json" \
  -d '{
    "jsonrpc": "2.0",
    "id": 1,
    "method": "tools/call",
    "params": {
      "name": "task_create",
      "arguments": {
        "title": "Deploy to production",
        "description": "Deploy the new feature to production environment",
        "priority": "high",
        "tags": ["deployment", "production"]
      }
    }
  }'

# Link entities in knowledge graph
curl -X POST https://api.example.com/api/v1/mcp \
  -H "Authorization: Bearer YOUR_API_KEY" \
  -H "Content-Type: application/json" \
  -d '{
    "jsonrpc": "2.0",
    "id": 2,
    "method": "tools/call",
    "params": {
      "name": "entity_link",
      "arguments": {
        "from_entity_id": "user_123",
        "to_entity_id": "project_456",
        "relationship_type": "works_on",
        "confidence_score": 0.95
      }
    }
  }'

# Record a decision with reasoning
curl -X POST https://api.example.com/api/v1/mcp \
  -H "Authorization: Bearer YOUR_API_KEY" \
  -H "Content-Type: application/json" \
  -d '{
    "jsonrpc": "2.0",
    "id": 3,
    "method": "tools/call",
    "params": {
      "name": "decision_create",
      "arguments": {
        "title": "Choose database technology",
        "context": "Need to select a database for the new microservice",
        "alternatives": ["PostgreSQL", "MongoDB", "DynamoDB"],
        "selected_alternative": "PostgreSQL",
        "reasoning": "PostgreSQL provides the best balance of features, performance, and team familiarity",
        "confidence_score": 0.85
      }
    }
  }'

# Create multiple memories at once
curl -X POST /api/v1/memories/batch \
  -H "Authorization: Bearer YOUR_API_KEY" \
  -H "Content-Type: application/json" \
  -d '{"memories": [
    {"content": "User prefers dark mode", "importance_score": 0.8},
    {"content": "User likes compact UI", "importance_score": 0.6},
    {"content": "User timezone is UTC-5", "importance_score": 0.7}
  ]}'

# Delete memories older than 90 days
curl -X POST /api/v1/memories/batch-delete \
  -H "Authorization: Bearer YOUR_API_KEY" \
  -H "Content-Type: application/json" \
  -d '{"older_than_days": 90}'

# Get the full OpenAPI specification
curl /api/v1/openapi.json

# OAuth 2.0 Protected Resource Metadata (RFC 9728)
curl /.well-known/oauth-protected-resource

import { Socket } from "phoenix";

// Connect with your API key
const socket = new Socket("/socket", {
  params: { token: "aim_your_api_key_here" }
});
socket.connect();

// Join memory events channel for your organization
const organizationId = "your_org_id_here";
const channel = socket.channel(`memory:events:${organizationId}`, {});

channel.join()
  .receive("ok", () => console.log("Joined memory channel"))
  .receive("error", (err) => console.log("Failed to join", err));

// Listen for memory events
channel.on("memory:created", (payload) => {
  console.log("New memory created:", payload);
});

channel.on("embedding:completed", (payload) => {
  console.log("Embedding ready for memory:", payload.memory_id);
});

channel.on("memory:ready", (payload) => {
  console.log("Memory fully processed:", payload.chunks_count, "chunks");
});

// Streaming search
channel.push("search:stream", {
  query: "user preferences for dashboard",
  limit: 10,
  threshold: 0.7
});

channel.on("search:result", (result) => {
  console.log("Result:", result.content, "(score:", result.score + ")");
});

channel.on("search:complete", (meta) => {
  console.log("Found", meta.total, "results in", meta.query_time_ms + "ms");
});

// Listen for batch operations
channel.on("batch:progress", (update) => {
  console.log("Progress:", update.current, "of", update.total);
});

channel.on("batch:complete", (result) => {
  console.log("Batch complete:", result.succeeded, "succeeded,", result.failed, "failed");
});