REST API Server

import express from "express";
import { AgentRuntime, createMessageMemory, stringToUuid } from "@elizaos/core";
import { openaiPlugin } from "@elizaos/plugin-openai";
import { plugin as sqlPlugin } from "@elizaos/plugin-sql";
import { v4 as uuidv4 } from "uuid";

const app = express();
app.use(express.json());

// Character definition
const character = {
  name: "Eliza",
  bio: "A helpful AI assistant available via REST API.",
  system: "You are a helpful assistant. Provide clear, concise responses.",
};

console.log("🚀 Initializing Eliza API...");

// Initialize runtime
const runtime = new AgentRuntime({
  character,
  plugins: [sqlPlugin, openaiPlugin],
});

await runtime.initialize();
console.log("✅ Runtime initialized");

// Health check endpoint
app.get("/health", (req, res) => {
  res.json({
    status: "healthy",
    runtime: "elizaos",
    character: character.name,
    uptime: process.uptime(),
    timestamp: new Date().toISOString(),
  });
});

// Agent info endpoint
app.get("/", (req, res) => {
  res.json({
    name: character.name,
    bio: character.bio,
    status: "ready",
    endpoints: {
      chat: "POST /chat",
      health: "GET /health",
      info: "GET /",
    },
  });
});

// Chat endpoint
app.post("/chat", async (req, res) => {
  try {
    const { message, userId, conversationId } = req.body;

    // Validate input
    if (!message || typeof message !== "string") {
      return res.status(400).json({
        error: "Message is required and must be a string",
      });
    }

    // Generate or use provided IDs
    const userIdUuid = userId || uuidv4();
    const roomId = stringToUuid(conversationId || "default-room");

    // Create message memory
    const messageMemory = createMessageMemory({
      id: uuidv4(),
      entityId: stringToUuid(userIdUuid),
      roomId,
      content: { text: message },
    });

    // Collect response
    let responseText = "";

    // Handle message with streaming
    await runtime.messageService!.handleMessage(
      runtime,
      messageMemory,
      async (content) => {
        if (content?.text) {
          responseText += content.text;
        }
        return [];
      }
    );

    // Return response
    res.json({
      response: responseText,
      character: character.name,
      userId: userIdUuid,
      conversationId,
      timestamp: new Date().toISOString(),
    });
  } catch (error) {
    console.error("Error processing message:", error);
    res.status(500).json({
      error: "Failed to process message",
      message: error instanceof Error ? error.message : "Unknown error",
    });
  }
});

// Start server
const PORT = process.env.PORT || 3000;
app.listen(PORT, () => {
  console.log(`\n🌐 Eliza API server running on http://localhost:${PORT}`);
  console.log(`\n  Endpoints:`);
  console.log(`  - GET  http://localhost:${PORT}/`);
  console.log(`  - GET  http://localhost:${PORT}/health`);
  console.log(`  - POST http://localhost:${PORT}/chat\n`);
});

// Graceful shutdown
process.on("SIGTERM", async () => {
  console.log("\n🚦 Shutting down gracefully...");
  await runtime.stop();
  process.exit(0);
});

#!/bin/bash

BASE_URL="http://localhost:3000"

echo "Testing health endpoint..."
curl -s "$BASE_URL/health" | jq

echo -e "\n\nTesting chat endpoint..."
curl -s -X POST "$BASE_URL/chat" \
  -H "Content-Type: application/json" \
  -d '{
    "message": "Hello, how are you?",
    "userId": "test-user",
    "conversationId": "test-conv"
  }' | jq

echo -e "\n\nTesting with follow-up..."
curl -s -X POST "$BASE_URL/chat" \
  -H "Content-Type: application/json" \
  -d '{
    "message": "What did we just talk about?",
    "userId": "test-user",
    "conversationId": "test-conv"
  }' | jq