feat(new-plugin): deva client integration

.env.example

@@ -313,6 +313,10 @@ AWS_REGION=
 AWS_S3_BUCKET=
 AWS_S3_UPLOAD_PATH=
 
+# Deva Configuration
+DEVA_API_KEY= # You can get the API key from the created application in deva.me/settings/apps
+DEVA_API_BASE_URL=https://api.deva.me # Default server url is production https://api-staging.deva.me
+
 # Deepgram
 DEEPGRAM_API_KEY=
 

.gitignore

@@ -50,5 +50,7 @@ tsup.config.bundled_*.mjs
 
 .turbo
 
+.idea
+
 coverage
 .eslintcache

agent/package.json

@@ -50,6 +50,7 @@
     "@ai16z/plugin-multiversx": "workspace:*",
     "@ai16z/plugin-near": "workspace:*",
     "@ai16z/plugin-zksync-era": "workspace:*",
+    "@ai16z/client-deva": "workspace:*",
     "readline": "1.3.0",
     "ws": "8.18.0",
     "yargs": "17.7.2"

agent/src/index.ts

@@ -7,6 +7,7 @@ import { LensAgentClient } from "@ai16z/client-lens";
 import { SlackClientInterface } from "@ai16z/client-slack";
 import { TelegramClientInterface } from "@ai16z/client-telegram";
 import { TwitterClientInterface } from "@ai16z/client-twitter";
+import { DevaClientInterface } from "@ai16z/client-deva";
 import {
     AgentRuntime,
     CacheManager,
@@ -401,6 +402,11 @@ export async function initializeClients(
         if (slackClient) clients.push(slackClient);
     }
 
+    if (clientTypes.includes("deva")) {
+        const devaClients = await DevaClientInterface.start(runtime);
+        clients.push(devaClients);
+    }
+
     if (character.plugins?.length > 0) {
         for (const plugin of character.plugins) {
             // if plugin has clients, add those..

docs/api/enumerations/Clients.md

@@ -83,3 +83,12 @@ Available client platforms
 #### Defined in
 
 [packages/core/src/types.ts:619](https://github.com/ai16z/eliza/blob/main/packages/core/src/types.ts#L619)
+
+***
+
+### DEVA
+
+> **DEVA**: `"deva"`
+#### Defined in
+
+[packages/core/src/types.ts:620](https://github.com/ai16z/eliza/blob/main/packages/core/src/types.ts#L620)

packages/client-deva/.npmignore

@@ -0,0 +1,6 @@
+*
+
+!dist/**
+!package.json
+!readme.md
+!tsup.config.ts

packages/client-deva/eslint.config.mjs

@@ -0,0 +1,3 @@
+import eslintGlobalConfig from "../../eslint.config.mjs";
+
+export default [...eslintGlobalConfig];

packages/client-deva/package.json

@@ -0,0 +1,24 @@
+{
+    "name": "@ai16z/client-deva",
+    "version": "0.1.4-alpha.3",
+    "main": "dist/index.js",
+    "type": "module",
+    "types": "dist/index.d.ts",
+    "dependencies": {
+        "@ai16z/eliza": "workspace:*",
+        "agent-twitter-client": "0.0.16",
+        "glob": "11.0.0",
+        "zod": "3.23.8"
+    },
+    "devDependencies": {
+        "tsup": "8.3.5"
+    },
+    "scripts": {
+        "build": "tsup --format esm --dts",
+        "dev": "tsup --watch",
+        "lint": "eslint . --fix"
+    },
+    "peerDependencies": {
+        "whatwg-url": "7.1.0"
+    }
+}

packages/client-deva/src/base.ts

@@ -0,0 +1,60 @@
+import { IAgentRuntime } from "@ai16z/eliza";
+import { DevaPersona, DevaPost } from "./types";
+
+export class ClientBase {
+    private readonly runtime: IAgentRuntime;
+    private readonly accessToken: string;
+    private readonly apiBaseUrl: string;
+    private readonly defaultHeaders: Record<string, string>;
+
+    constructor(runtime: IAgentRuntime, accessToken: string, baseUrl: string) {
+        this.runtime = runtime;
+        this.accessToken = accessToken;
+        this.apiBaseUrl = baseUrl;
+        this.defaultHeaders = {
+            Authorization: `Bearer ${this.accessToken}`,
+            "Content-Type": "application/json",
+        };
+    }
+
+    public async getMe(): Promise<DevaPersona | null> {
+        return await fetch(`${this.apiBaseUrl}/persona`, {
+            headers: { ...this.defaultHeaders },
+        })
+            .then((res) => res.json())
+            .catch(() => null);
+    }
+
+    public async getPersonaPosts(personaId: string): Promise<DevaPost[]> {
+        const res = await fetch(
+            `${this.apiBaseUrl}/post?filter_persona_id=${personaId}`,
+            {
+                headers: {
+                    Authorization: `Bearer ${this.accessToken}`,
+                    "Content-Type": "application/json",
+                },
+            }
+        ).then((res) => res.json());
+        return res.items;
+    }
+
+    public async makePost({
+        text,
+        in_reply_to_id,
+    }: {
+        text: string;
+        in_reply_to_id: string;
+    }): Promise<DevaPost> {
+        const res = await fetch(`${this.apiBaseUrl}/post`, {
+            method: "POST",
+            headers: {
+                Authorization: `Bearer ${this.accessToken}`,
+                "Content-Type": "application/json",
+            },
+            body: JSON.stringify({ text, in_reply_to_id, author_type: "BOT" }),
+        }).then((res) => res.json());
+
+        console.log(res);
+        return res;
+    }
+}