chatAgent negotiation

Author: jxx016

examples/acp_base/test/buyer-test.ts

@@ -0,0 +1,108 @@
+import AcpClient, { 
+  AcpContractClient, 
+  AcpJobPhases, 
+  AcpJob, 
+  baseSepoliaAcpConfig 
+} from '@virtuals-protocol/acp-node';
+
+import * as dotenv from "dotenv";
+import { Address } from "viem";
+
+// Load environment variables
+dotenv.config({ override: true });
+
+async function testBuyer() {
+  console.log("Starting buyer test...");
+
+  // Define the onNewTask callback
+  const onNewTask = async (job: AcpJob) => {
+    console.log(`Received job update for job ${job.id}, phase: ${job.phase}`);
+    
+    if (job.phase === AcpJobPhases.NEGOTIATION) {
+      // Check if there's a memo that indicates next phase is TRANSACTION
+      for (const memo of job.memos) {
+        if (memo.nextPhase === AcpJobPhases.TRANSACTION) {
+          console.log("Paying job", job.id);
+          // await job.pay(2); // Pay 2 ETH
+          break;
+        }
+      }
+    } else if (job.phase === AcpJobPhases.COMPLETED) {
+      console.log("Job completed", job);
+    }
+  };
+
+  // Initialize AcpClient
+  const acpClient = new AcpClient({
+    acpContractClient: await AcpContractClient.build(
+      process.env.WHITELISTED_WALLET_PRIVATE_KEY as `0x${string}`,
+      Number(process.env.WHITELISTED_WALLET_ENTITY_ID),
+      process.env.BUYER_WALLET_ADDRESS as Address,
+      baseSepoliaAcpConfig
+    ),
+    onNewTask: onNewTask
+  });
+
+  // Browse agents
+  console.log("Browsing agents...");
+  const agents = await acpClient.browseAgents("aixbt", "hedgefund");
+  console.log(`Found ${agents.length} agents`);
+
+  // Look for aixbt agent
+  let aixbtAgent = null;
+  let selectedOffering = null;
+
+  // Iterate through all agents to find aixbt
+  for (const agent of agents) {
+    console.log(`Checking agent: ${agent.name}`);
+    
+    // Check if this agent has "aixbt" in its name or description
+    if (
+      agent.name.toLowerCase().includes("aixbt") || 
+      (agent.description && agent.description.toLowerCase().includes("aixbt"))
+    ) {
+      console.log(`Found aixbt agent: ${agent.name}`);
+      aixbtAgent = agent;
+      
+      // If the agent has offerings, select the first one
+      if (agent.offerings && agent.offerings.length > 0) {
+        selectedOffering = agent.offerings[0];
+        console.log("Selected offering:", selectedOffering);
+        break;
+      }
+    }
+  }
+
+  if (aixbtAgent && selectedOffering) {
+    // Calculate expiration date (1 day from now)
+    const expiredAt = new Date();
+    expiredAt.setDate(expiredAt.getDate() + 1);
+
+    // Initiate job with the correct parameters
+    const serviceRequirement = "Get top 1 project pick from aixbt agent to invest in";
+    const jobId = await acpClient.initiateJob(
+      aixbtAgent.walletAddress,
+      serviceRequirement,
+      0.02,
+      undefined,
+      expiredAt
+    );
+
+    console.log(`Job ${jobId} initiated with aixbt agent`);
+  } else {
+    console.log("No aixbt agent or offerings found");
+  }
+
+  // Keep the process running to listen for events
+  console.log("Listening for next steps...");
+  while (true) {
+    await new Promise(resolve => setTimeout(resolve, 30000)); // Wait 30 seconds
+    console.log("Still listening...");
+  }
+}
+
+// Run the test
+testBuyer().catch(error => {
+  console.error("Error in buyer test:", error);
+  process.exit(1);
+});