0.6.0 • Published 4 months ago

@wrtnlabs/agent v0.6.0

Weekly downloads
-
License
MIT
Repository
github
Last release
4 months ago

@wrtnlabs/agent

agent-conceptual-diagram

GitHub license npm version Downloads Build Status

The simplest AI agent library, specialized in LLM function calling.

@wrtnlabs/agent is the simplest AI agent library specialized for LLM (Large Language Model) function calling. You can provide functions to call by Swagger/OpenAPI document or TypeScript class type, and it will make everything possible. Super AI Chatbot development, or Multi-Agent Orchestration, all of them can be realized by the function calling.

For example, if you provide Swagger document of a Shopping Mall Server, @wrtnlabs/agent will compose Super AI Chatbot application. In the chatbot application, customers can purchase products just by conversation texts. If you wanna automate the counseling or refunding process, you also can do it just by delivering the Swagger document.

Also, the LLM function calling strategy is effective for the Multi-Agent Orchestration, and it is easier to develop than any other way. You don't need to learn any complicate framework and its specific paradigms and patterns. Just connect them through class, and deliver the TypeScript class type. @wrtnlabs/agent will centralize and realize the multi-agent orchestration through function calling.

https://github.com/user-attachments/assets/01604b53-aca4-41cb-91aa-3faf63549ea6

Demonstration video of Shopping AI Chatbot

How to Use

Setup

npm install @wrtnlabs/agent @samchon/openapi typia
npx typia setup

Install not only @wrtnlabs/agent, but also @samchon/openapi and typia.

@samchon/openapi is an OpenAPI specification library which can convert Swagger/OpenAPI document to LLM function calling schema. And typia is a transformer (compiler) library which can compose LLM function calling schema from a TypeScript class type.

By the way, as typia is a transformer library analyzing TypeScript source code in the compilation level, it needs additional setup command npx typia setup. Also, if you're not using non-standard TypeScript compiler (not tsc) or developing the agent in the frontend environment, you have to setup @ryoppippi/unplugin-typia too.

Chat with Backend Server

import { IHttpLlmApplication } from "@samchon/openapi";
import { WrtnAgent, createHttpApplication } from "@wrtnlabs/agent";
import OpenAI from "openai";
import { IValidation } from "typia";

const main = async (): Promise<void> => {
  // LOAD SWAGGER DOCUMENT, AND CONVERT TO LLM APPLICATION SCHEMA
  const application: IValidation<IHttpLlmApplication<"chatgpt">> =
    createHttpApplication({
      model: "chatgpt",
      document: OpenApi.convert(
        await fetch("https://shopping-be.wrtn.ai/editor/swagger.json").then(
          (r) => r.json()
        )
      ),
    });
  if (application.success === false) {
    console.error(application.errors);
    throw new Error("Type error on the target swagger document");
  }

  // CREATE AN AGENT WITH THE APPLICATION
  const agent: WrtnAgent = new WrtnAgent({
    provider: {
      type: "chatgpt",
      model: "gpt-4o-mini",
      api: new OpenAI({
        apiKey: "YOUR_OPENAI_API_KEY",
      }),
    },
    controllers: [
      {
        protocol: "http",
        name: "shopping",
        application: application.data,
        connection: {
          host: "https://shopping-be.wrtn.ai",
        },
      },
    ],
    config: {
      locale: "en-US",
    },
  });

  // ADD EVENT LISTENERS
  agent.on("select", async (select) => {
    console.log("selected function", select.operation.function.name);
  });
  agent.on("execute", async (execute) => {
    consoe.log("execute function", {
      function: execute.operation.function.name,
      arguments: execute.arguments,
      value: execute.value,
    });
  });

  // CONVERSATE TO AI CHATBOT
  await agent.conversate("What you can do?");
};
main().catch(console.error);

Just load your swagger document, and put it into the @wrtnlabs/agent.

Then you can start conversation with your backend server, and the API functions of the backend server would be automatically called. AI chatbot will analyze your conversation texts, and executes proper API functions by the LLM (Large Language Model) function calling feature.

From now on, every backend developer is also an AI developer.

Chat with TypeScript Class

import { WrtnAgent } from "@wrtnlabs/agent";
import typia, { tags } from "typia";
import OpenAI from "openai";

class BbsArticleService {
  /**
   * Create a new article.
   *
   * Writes a new article and archives it into the DB.
   *
   * @param props Properties of create function
   * @returns Newly created article
   */
  public async create(props: {
    /**
     * Information of the article to create
     */
    input: IBbsArticle.ICreate;
  }): Promise<IBbsArticle>;

  /**
   * Update an article.
   *
   * Updates an article with new content.
   *
   * @param props Properties of update function
   * @param input New content to update
   */
  public async update(props: {
    /**
     * Target article's {@link IBbsArticle.id}.
     */
    id: string & tags.Format<"uuid">;

    /**
     * New content to update.
     */
    input: IBbsArticle.IUpdate;
  }): Promise<void>;
}

const main = async (): Promise<void> => {
  const api: OpenAI = new OpenAI({
    apiKey: "YOUR_OPENAI_API_KEY",
  });
  const agent: WrtnAgent = new WrtnAgent({
    provider: {
      type: "chatgpt",
      model: "gpt-4o-mini",
      api: new OpenAI({
        apiKey: "YOUR_OPENAI_API_KEY",
      }),
    },
    controllers: [
      {
        protocol: "class",
        name: "vectorStore",
        application: typia.llm.applicationOfValidate<
          BbsArticleService,
          "chatgpt"
        >(),
        execute: new BbsArticleService(),
      },
    ],
  });
  await agent.conversate("I wanna write an article.");
};
main().catch(console.error);

You also can chat with a TypeScript class.

Just deliver the TypeScript type to the @wrtnlabs/agent, and start conversation. Then @wrtnlabs/agent will call the proper class functions by analyzing your conversation texts with LLM function calling feature.

From now on, every TypeScript classes you've developed can be the AI chatbot.

Multi Agent Orchestration

import { WrtnAgent } from "@wrtnlabs/agent";
import typia from "typia";
import OpenAI from "openai";

class OpenAIVectorStoreAgent {
  /**
   * Retrieve Vector DB with RAG.
   *
   * @param props Properties of Vector DB retrievelance
   */
  public query(props: {
    /**
     * Keywords to look up.
     *
     * Put all the keywords you want to look up. However, keywords
     * should only be included in the core, and all ambiguous things
     * should be excluded to achieve accurate results.
     */
    keywords: string;
  }): Promise<IVectorStoreQueryResult>;
}

const main = async (): Promise<void> => {
  const api: OpenAI = new OpenAI({
    apiKey: "YOUR_OPENAI_API_KEY",
  });
  const agent: WrtnAgent = new WrtnAgent({
    provider: {
      type: "chatgpt",
      model: "gpt-4o-mini",
      api: new OpenAI({
        apiKey: "YOUR_OPENAI_API_KEY",
      }),
    },
    controllers: [
      {
        protocol: "class",
        name: "vectorStore",
        application: typia.llm.applicationOfValidate<
          OpenAIVectorStoreAgent,
          "chatgpt"
        >(),
        execute: new OpenAIVectorStoreAgent({
          api,
          id: "YOUR_OPENAI_VECTOR_STORE_ID",
        }),
      },
    ],
  });
  await agent.conversate("I wanna research economic articles");
};
main().catch(console.error);

In the @wrtnlabs/agent, you can implement multi-agent orchestration super easily.

Just develop a TypeScript class which contains agent feature like Vector Store, and just deliver the TypeScript class type to the @wrtnlabs/agent like above. The @wrtnlabs/agent will centralize and realize the multi-agent orchestration by LLM function calling strategy to the TypeScript class.

WebSocket Communication

@wrtnlabs/agent provides WebSocket interaction module.

The websocket interface module is following RPC (Remote Procedure Call) paradigm of the TGrid, so it is very easy to interact between frontend application and backend server of the AI agent.

import {
  IWrtnAgentRpcListener,
  IWrtnAgentRpcService,
  WrtnAgent,
  WrtnAgentRpcService,
} from "@wrtnlabs/agent";
import { WebSocketServer } from "tgrid";

const server: WebSocketServer<
  null,
  IWrtnAgentRpcService,
  IWrtnAgentRpcListener
> = new WebSocketServer();
await server.open(3001, async (acceptor) => {
  await acceptor.accept(
    new WrtnAgentRpcService({
      agent: new WrtnAgent({ ... }),
      listener: acceptor.getDriver(),
    }),
  );
});

When developing backend server, wrap WrtnAgent to WrtnAgentRpcService.

If you're developing WebSocket protocol backend server, create a new WrtnAgent instance, and wrap it to the WrtnAgentRpcService class. And then open the websocket server like above code. The WebSocket server will call the client functions of the IWrtnAgentRpcListener remotely.

import { IWrtnAgentRpcListener, IWrtnAgentRpcService } from "@wrtnlabs/agent";
import { Driver, WebSocketConnector } from "tgrid";

const connector: WebSocketConnector<
  null,
  IWrtnAgentRpcListener,
  IWrtnAgentRpcService
> = new WebSocketConnector(null, {
  text: async (evt) => {
    console.log(evt.role, evt.text);
  },
  describe: async (evt) => {
    console.log("describer", evt.text);
  },
});
await connector.connect("ws://localhost:3001");

const driver: Driver<IWrtnAgentRpcService> = connector.getDriver();
await driver.conversate("Hello, what you can do?");

When developing frontend application, define IWrtnAgentRpcListener instance.

Otherwise you're developing WebSocket protocol client application, connect to the websocket backend server with its URL address, and provide IWrtnAgentRpcListener instance for event listening.

And then call the backend server's function IWrtnAgentRpcService.conversate() remotely through the Driver<IWrtnAgentRpcService> wrapping. The backend server will call your IWrtnAgentRpcListener functions remotely through the RPC paradigm.

Benchmark

import { HttpLlm, OpenApi } from "@samchon/openapi";
import {
  IWrtnAgentOperation,
  WrtnAgent,
  WrtnAgentSelectBenchmark,
} from "@wrtnlabs/agent";
import OpenAI from "openai";

const main = async (): Promise<void> => {
  // CREATE AI AGENT
  const agent: WrtnAgent = new WrtnAgent({
    provider: {
      model: "gpt-4o-mini",
      api: new OpenAI({
        apiKey: "YOUR_OPENAI_API_KEY",
      }),
      type: "chatgpt",
    },
    controllers: [
      {
        protocol: "http",
        name: "shopping",
        application: HttpLlm.application({
          model: "chatgpt",
          document: await fetch(
            "https://shopping-be.wrtn.ai/editor/swagger.json",
          ).then((res) => res.json()),
        }),
        connection: {
          host: "https://shopping-be.wrtn.ai",
        },
      },
    ],
  });

  // DO BENCHMARK
  const find = (method: OpenApi.Method, path: string): IWrtnAgentOperation => {
    const found = agent
      .getOperations()
      .find(
        (op) =>
          op.protocol === "http" &&
          op.function.method === method &&
          op.function.path === path,
      );
    if (!found) throw new Error(`Operation not found: ${method} ${path}`);
    return found;
  };
  const benchmark: WrtnAgentSelectBenchmark = new WrtnAgentSelectBenchmark({
    agent,
    config: {
      repeat: 4,
    },
    scenarios: [
      {
        name: "order",
        text: [
          "I wanna see every sales in the shopping mall",
          "",
          "And then show me the detailed information about the Macbook.",
          "",
          "After that, select the most expensive stock",
          "from the Macbook, and put it into my shopping cart.",
          "And take the shopping cart to the order.",
          "",
          "At last, I'll publish it by cash payment, and my address is",
          "",
          "  - country: South Korea",
          "  - city/province: Seoul",
          "  - department: Wrtn Apartment",
          "  - Possession: 101-1411",
        ].join("\n"),
        expected: {
          type: "array",
          items: [
            {
              type: "standalone",
              operation: find("patch", "/shoppings/customers/sales"),
            },
            {
              type: "standalone",
              operation: find("get", "/shoppings/customers/sales/{id}"),
            },
            {
              type: "anyOf",
              anyOf: [
                {
                  type: "standalone",
                  operation: find("post", "/shoppings/customers/orders"),
                },
                {
                  type: "standalone",
                  operation: find("post", "/shoppings/customers/orders/direct"),
                },
              ],
            },
            {
              type: "standalone",
              operation: find(
                "post",
                "/shoppings/customers/orders/{orderId}/publish",
              ),
            },
          ],
        },
      },
    ],
  });
  await benchmark.execute();

  // REPORT
  const docs: Record<string, string> = benchmark.report();
  
  ...SAVE_DOCS_TO_MARKDOWN_FILES
};

Benchmark of Shopping Mall Scenario

Benchmark your documentation quality of functions.

You can measure a benchmark that AI agent can select proper functions from the user's conversations by the LLM (Large Language Model) function calling feature. Create WrtnAgent and WrtnAgentSelectBenchmark typed instances, and execute the benchmark with your specific scenarios like above.

If you have written enough and proper descriptions on the functions (or API operations) and DTO schema types, success ratio of WrtnAgentSelectBenchmark would be higher. Otherwise descriptions are not enough or have bad quality, you may get a threatening benchmark report. If you wanna see how the WrtnAgentSelectBenchmark reports, click above benchmark report link please.

For reference, you can actually perform not only function selection, but also function calling through WrtnAgentCallBenchmark. By the way, @wrtnlabs/agent tends not to failed on arguments filling process of LLM function calling. Therefore, as actual function calling with arguments filling spends much more times and LLM tokens than only selection benchmark case, testing only WrtnAgentSelectBenchmark is economic.

Principles

Agent Strategy

sequenceDiagram
actor User
actor Agent
participant Selector
participant Caller
participant Describer
activate User
User-->>Agent: Conversate:<br/>user says
activate Agent
Agent->>Selector: Deliver conversation text
activate Selector
deactivate User
Note over Selector: Select or remove candidate functions
alt No candidate
  Selector->>Agent: Talk like plain ChatGPT
  deactivate Selector
  Agent->>User: Conversate:<br/>agent says
  activate User
  deactivate User
end
deactivate Agent
loop Candidate functions exist
  activate Agent
  Agent->>Caller: Deliver conversation text
  activate Caller
  alt Contexts are enough
    Note over Caller: Call fulfilled functions
    Caller->>Describer: Function call histories
    deactivate Caller
    activate Describer
    Describer->>Agent: Describe function calls
    deactivate Describer
    Agent->>User: Conversate:<br/>agent describes
    activate User
    deactivate User
  else Contexts are not enough
    break
      Caller->>Agent: Request more information
    end
    Agent->>User: Conversate:<br/>agent requests
    activate User
    deactivate User
  end
  deactivate Agent
end

When user says, @wrtnlabs/agent delivers the conversation text to the selector agent, and let the selector agent to find (or cancel) candidate functions from the context. If the selector agent could not find any candidate function to call and there is not any candidate function previously selected either, the selector agent will work just like a plain ChatGPT.

And @wrtnlabs/agent enters to a loop statement until the candidate functions to be empty. In the loop statement, caller agent tries to LLM function calling by analyzing the user's conversation text. If context is enough to compose arguments of candidate functions, the caller agent actually calls the target functions, and let decriber agent to explain the function calling results. Otherwise the context is not enough to compose arguments, caller agent requests more information to user.

Such LLM (Large Language Model) function calling strategy separating selector, caller, and describer is the key logic of @wrtnlabs/agent.

Validation Feedback

import { FunctionCall } from "pseudo";
import { ILlmFunctionOfValidate, IValidation } from "typia";

export const correctFunctionCall = (p: {
  call: FunctionCall;
  functions: Array<ILlmFunctionOfValidate<"chatgpt">>;
  retry: (reason: string, errors?: IValidation.IError[]) => Promise<unknown>;
}): Promise<unknown> => {
  // FIND FUNCTION
  const func: ILlmFunctionOfValidate<"chatgpt"> | undefined =
    p.functions.find((f) => f.name === p.call.name);
  if (func === undefined) {
    // never happened in my experience
    return p.retry(
      "Unable to find the matched function name. Try it again.",
    );
  }

  // VALIDATE
  const result: IValidation<unknown> = func.validate(p.call.arguments);
  if (result.success === false) {
    // 1st trial: 50% (gpt-4o-mini in shopping mall chatbot)
    // 2nd trial with validation feedback: 99%
    // 3nd trial with validation feedback again: never have failed
    return p.retry(
      "Type errors are detected. Correct it through validation errors",
      {
        errors: result.errors,
      },
    );
  }
  return result.data;
}

Is LLM function calling perfect?

The answer is not, and LLM (Large Language Model) providers like OpenAI take a lot of type level mistakes when composing the arguments of the target function to call. Even though an LLM function calling schema has defined an Array<string> type, LLM often fills it just by a string typed value.

Therefore, when developing an LLM function calling agent, the validation feedback process is essentially required. If LLM takes a type level mistake on arguments composition, the agent must feedback the most detailed validation errors, and let the LLM to retry the function calling referencing the validation errors.

About the validation feedback, @wrtnlabs/agent is utilizing typia.validate<T>() and typia.llm.applicationOfValidate<Class, Model>() functions. They construct validation logic by analyzing TypeScript source codes and types in the compilation level, so that detailed and accurate than any other validators like below.

Such validation feedback strategy and combination with typia runtime validator, @wrtnlabs/agent has achieved the most ideal LLM function calling. In my experience, when using OpenAI's gpt-4o-mini model, it tends to construct invalid function calling arguments at the first trial about 50% of the time. By the way, if correct it through validation feedback with typia, success rate soars to 99%. And I've never had a failure when trying validation feedback twice.

ComponentstypiaTypeBoxajvio-tszodC.V.
Easy to use
Object (simple)
Object (hierarchical)
Object (recursive)
Object (union, implicit)
Object (union, explicit)
Object (additional tags)
Object (template literal types)
Object (dynamic properties)
Array (rest tuple)
Array (hierarchical)
Array (recursive)
Array (recursive, union)
Array (R+U, implicit)
Array (repeated)
Array (repeated, union)
Ultimate Union Type

C.V. means class-validator

OpenAPI Specification

flowchart
  subgraph "OpenAPI Specification"
    v20("Swagger v2.0") --upgrades--> emended[["OpenAPI v3.1 (emended)"]]
    v30("OpenAPI v3.0") --upgrades--> emended
    v31("OpenAPI v3.1") --emends--> emended
  end
  subgraph "OpenAPI Generator"
    emended --normalizes--> migration[["Migration Schema"]]
    migration --"Artificial Intelligence"--> lfc{{"LLM Function Calling"}}
    lfc --"OpenAI"--> chatgpt("ChatGPT")
    lfc --"Anthropic"--> claude("Claude")
    lfc --"Google"--> gemini("Gemini")
    lfc --"Meta"--> llama("Llama")
  end

@wrtnlabs/agent obtains LLM function calling schemas from both Swagger/OpenAPI documents and TypeScript class types. The TypeScript class type can be converted to LLM function calling schema by typia.llm.applicationOfValidate<Class, Model>() function. Then how about OpenAPI document? How Swagger document can be LLM function calling schema.

The secret is on the above diagram.

In the OpenAPI specification, there are three versions with different definitions. And even in the same version, there are too much ambiguous and duplicated expressions. To resolve these problems, @samchon/openapi is transforming every OpenAPI documents to v3.1 emended specification. The @samchon/openapi's emended v3.1 specification has removed every ambiguous and duplicated expressions for clarity.

With the v3.1 emended OpenAPI document, @samchon/openapi converts it to a migration schema that is near to the function structure. And as the last step, the migration schema will be transformed to a specific LLM provider's function calling schema. LLM function calling schemas are composed like this way.

Why do not directly convert, but intermediate?

If directly convert from each version of OpenAPI specification to specific LLM's function calling schema, I have to make much more converters increased by cartesian product. In current models, number of converters would be 12 = 3 x 4.

However, if define intermediate schema, number of converters are shrunk to plus operation. In current models, I just need to develop only (7 = 3 + 4) converters, and this is the reason why I've defined intermediate specification. This way is economic.

Roadmap

Guide Documents

In here README document, @wrtnlabs/agent is introducing its key concepts, principles, and demonstrating some examples.

However, this contents are not fully enough for new comers of AI Chatbot development. We need much more guide documents and example projects are required for education. We have to guide backend developers to write proper definitions optimized for LLM function calling. We should introduce the best way of multi-agent orchestration implementation.

We'll write such fully detailed guide documents until 2025-03-31, and we will continuously release documents that are in the middle of being completed.

Playground

https://nestia.io/chat/playground

I had developed Swagger AI chatbot playground website for a long time ago.

However, the another part obtaining function schemas from TypeScript class type, it is not prepared yet. I'll make the TypeScript class type based playground website by embedding TypeScript compiler (tsc).

The new playground website would be published until 2025-03-15.

Optimization

As I've concenstrated on POC (Proof of Concept) development on the early stage level, internal agents composing @wrtnlabs/agent are not cost optimized yet. Especially, selector agent is consuming LLM tokens too much repeatedly. We'll optimize the selector agent by RAG (Retrieval Augmented Generation) skills.

Also, we will support dozens of useful add-on agents which can connect with @wrtnlabs/agent by TypeScript class function calling. One of them is @wrtnlabs/hive which optimizes selector agent so that reducing LLM costs dramatically. The others would be OpenAI Vector Store handler and Postgres based RAG engine.

With these @wrtnlabs/agent providing add-on agents, you can learn how to implement the Multi-agent orchestration through TypeScript class function calling, and understand how @wrtnlabs/agent makes the Multi agent system interaction super easily.

LLM Providers

flowchart
Agent["<code>@wrtnlabs/agent</code>"]
OpenAI("<b><u>OpenAI</u></b>")
Claude
Llama
Gemini
Agent==supports==>OpenAI
Agent-.not yet.->Claude
Agent-.not yet.->Llama
Agent-.not yet.->Gemini

Currently, @wrtnlabs/agent supports only OpenAI.

It is because @wrtnlabs/agent is still in the POC (Proof of Concept) and demonstration stage. However, even nthough OpenAI is the most famous model in the AI world, @wrtnlabs/agent have to support much more models for broad users.

We're going to support much more models until 2025-04-30.

0.3.0

4 months ago

0.2.1

4 months ago

0.5.0

4 months ago

0.4.1

4 months ago

0.4.0

4 months ago

0.6.0

4 months ago

0.2.0

4 months ago

0.1.0

4 months ago

0.0.0

4 months ago