get client running

Author: monilpat

agent/src/index.ts

@@ -3,7 +3,7 @@ import { SqliteDatabaseAdapter } from "@elizaos/adapter-sqlite";
 import { AutoClientInterface } from "@elizaos/client-auto";
 import { DiscordClientInterface } from "@elizaos/client-discord";
 import { FarcasterAgentClient } from "@elizaos/client-farcaster";
-import { CoinbaseAgentClient } from "@elizaos/client-coinbase";
+import { CoinbaseClient } from "@elizaos/client-coinbase";
 import { LensAgentClient } from "@elizaos/client-lens";
 import { SlackClientInterface } from "@elizaos/client-slack";
 import { TelegramClientInterface } from "@elizaos/client-telegram";
@@ -431,7 +431,7 @@ export async function initializeClients(
 
     if (clientTypes.includes(Clients.COINBASE)) {
         // why is this one different :(
-        const coinbaseClient = new CoinbaseAgentClient(runtime);
+        const coinbaseClient = new CoinbaseClient(runtime);
         if (coinbaseClient) {
             coinbaseClient.start();
             clients.coinbase = coinbaseClient;

packages/client-coinbase/src/index.ts

@@ -10,15 +10,13 @@ import {
 import { postTweet } from "@elizaos/plugin-twitter";
 import express from "express";
 import { WebhookEvent } from "./types";
-import { EventEmitter } from "events";
 
-export class CoinbaseClient extends EventEmitter {
+export class CoinbaseClient implements Client {
     private runtime: IAgentRuntime;
     private server: express.Application;
     private port: number;
 
     constructor(runtime: IAgentRuntime) {
-        super();
 
         this.runtime = runtime;
         this.server = express();
@@ -81,19 +79,21 @@ export class CoinbaseClient extends EventEmitter {
         await this.runtime.ensureRoomExists(roomId);
         await this.runtime.ensureParticipantInRoom(this.runtime.agentId, roomId);
 
+        const amount = this.runtime.getSetting('COINBASE_TRADING_AMOUNT') ?? 1;
         const memory: Memory = {
             id: stringToUuid(`coinbase-${event.timestamp}`),
             userId: this.runtime.agentId,
             agentId: this.runtime.agentId,
             roomId,
             content: {
-                text: `Received ${event.event} signal for ${event.ticker} at price ${event.price}`,
+                text: `Place an advanced market order to ${event.event.toLowerCase()} $${amount} worth of ${event.ticker}`,
                 action: "EXECUTE_ADVANCED_TRADE",
                 source: "coinbase",
                 metadata: {
                     ticker: event.ticker,
                     side: event.event.toUpperCase(),
                     price: event.price,
+                    amount: amount,
                     timestamp: event.timestamp
                 }
             },
@@ -111,12 +111,12 @@ export class CoinbaseClient extends EventEmitter {
         await this.runtime.processActions(memory, [memory], state, callback);
 
         // Generate tweet content
-        const tweetContent = `🚀 I just bought ${event.event.toUpperCase()} for ${event.ticker}! Current price: $${event.price}. #Coinbase #Crypto`;
+        const tweetContent = `🚀 ${event.event.toUpperCase()} for ${event.ticker}! Amount: $${amount}. Current price: $${event.price}. `;
 
-        // Call postTweet
         try {
-            await postTweet(tweetContent);
-            elizaLogger.info("Tweet posted successfully:", tweetContent);
+            elizaLogger.info("Tweet content:", tweetContent);
+            const response = await postTweet(tweetContent);
+            elizaLogger.info("Tweet response:", response);
         } catch (error) {
             elizaLogger.error("Failed to post tweet:", error);
         }

packages/plugin-twitter/src/actions/post.ts

@@ -60,7 +60,7 @@ async function composeTweet(
     }
 }
 
-async function postTweet(content: string): Promise<boolean> {
+export async function postTweet(content: string): Promise<boolean> {
     try {
         const scraper = new Scraper();
         const username = process.env.TWITTER_USERNAME;

packages/plugin-twitter/src/index.ts

@@ -9,4 +9,5 @@ export const twitterPlugin: Plugin = {
     providers: [],
 };
 
+export { postTweet } from "./actions/post";
 export default twitterPlugin;