Connect to AG-UI

# Pull and run the Eliza Telnet server
docker build -t eliza:latest https://docs.ag-ui.io/quickstart/eliza/Dockerfile
docker run --rm -it -p 2323:2323 eliza:latest

telnet localhost 2323

$ telnet localhost 2323
Trying ::1...
Connected to localhost.
Escape character is '^]'.
=====================================================
ELIZA - The first chatbot (1966) by Joseph Weizenbaum
Running via Telnet - Type 'quit' to exit
=====================================================

Hello, I'm Eliza. How can I help you today?
> How are you?
What if I were ?
> What if you were?
What does this speculation lead to ?
> I am not sure to be honest.
Do you enjoy being not sure to be honest ?
> quit
Goodbye. It was nice talking to you!
Connection closed by foreign host.

# Create a directory for your project
mkdir awp-eliza && cd awp-eliza
npm init -y
npm install @ag-ui/client telnetlib
npm install -D typescript ts-node @types/node @types/telnetlib
npx tsc --init --target ES2020 --module CommonJS --strict --esModuleInterop --skipLibCheck --outDir dist --rootDir src
mkdir src

// src/eliza-agent.ts
import {
  AbstractAgent,
  RunAgent,
  RunAgentInput,
  EventType,
  BaseEvent,
  RunStartedEventSchema,
  TextMessageStartEventSchema,
  TextMessageContentEventSchema,
  TextMessageEndEventSchema,
  RunFinishedEventSchema,
} from "@ag-ui/client"
import { Observable } from "rxjs"
import * as telnetlib from "telnetlib"

export class ElizaAgent extends AbstractAgent {
  protected run(input: RunAgentInput): RunAgent {
    // AG-UI calls `run` each time it wants to generate a response.
    return () => {
      // Extract user's latest message

      const lastUserMessage =
        [...input.messages].reverse().find((msg) => msg.role === "user")
          ?.content || "Hello, Eliza"

      return new Observable<BaseEvent>((observer) => {
        // 1) Emit RUN_STARTED
        observer.next(
          RunStartedEventSchema.parse({
            type: EventType.RUN_STARTED,
            threadId: input.threadId,
            runId: input.runId,
          })
        )

        // Create a new telnet client
        const client = telnetlib.createConnection(
          {
            host: "127.0.0.1",
            port: 2323,
          },
          () => {
            console.log("Connected to Eliza telnet server")
          }
        )

        // Wait for initial greeting and prompt
        client.once("data", () => {
          // Once we receive the greeting, send the user message
          client.write(lastUserMessage + "\n")

          // Wait for the response from Eliza
          client.once("data", (data) => {
            // Get the response, removing the prompt
            let response = data.toString().trim()
            // Strip the trailing prompt if present
            if (response.endsWith(">")) {
              response = response.substring(0, response.length - 1).trim()
            }

            // Generate a message ID
            const messageId = Date.now().toString()

            // Emit typical AG-UI message events
            observer.next(
              TextMessageStartEventSchema.parse({
                type: EventType.TEXT_MESSAGE_START,
                messageId,
              })
            )

            observer.next(
              TextMessageContentEventSchema.parse({
                type: EventType.TEXT_MESSAGE_CONTENT,
                messageId,
                delta: response,
              })
            )

            observer.next(
              TextMessageEndEventSchema.parse({
                type: EventType.TEXT_MESSAGE_END,
                messageId,
              })
            )

            // Emit RUN_FINISHED and complete
            observer.next(
              RunFinishedEventSchema.parse({
                type: EventType.RUN_FINISHED,
                threadId: input.threadId,
                runId: input.runId,
              })
            )

            // Close the telnet connection
            client.end()

            observer.complete()
          })
        })

        // Handle errors
        client.on("error", (err) => {
          console.error("Telnet client error:", err)
          observer.error(err)
        })

        // Return a cleanup function
        return () => {
          if (client) {
            client.end()
          }
        }
      })
    }
  }
}

// src/index.ts
import { ElizaAgent } from "./eliza-agent"

// Create an instance of our agent
const elizaAgent = new ElizaAgent()
elizaAgent.messages = [
  { id: "1", role: "user", content: "I feel anxious about my job." },
]

// Example: Make a request to Eliza through AG-UI
const run = elizaAgent.runAgent({
  runId: "run1",
})

npx ts-node src/index.ts