Merge branch 'develop' into fix/siwe-cache-bypass

Author: standujar

.github/workflows/cloud-gateway-discord.yml

@@ -446,6 +446,7 @@ jobs:
     if: |
       github.event_name != 'pull_request' &&
       (needs.detect-changes.outputs.app == 'true' || (github.event_name == 'workflow_dispatch' && github.event.inputs.action == 'deploy'))
+    environment: ${{ needs.detect-changes.outputs.environment }}
     permissions:
       contents: read
       packages: write
@@ -462,8 +463,8 @@ jobs:
         uses: docker/login-action@v4
         with:
           registry: ${{ env.REGISTRY }}
-          username: ${{ github.actor }}
-          password: ${{ secrets.GITHUB_TOKEN }}
+          username: ${{ secrets.GHCR_USERNAME }}
+          password: ${{ secrets.GHCR_TOKEN }}
 
       - name: Extract metadata
         id: meta

cloud/packages/tests/unit/providers-vast.test.ts

@@ -1,6 +1,6 @@
 import { afterEach, beforeEach, describe, expect, mock, test } from "bun:test";
-import { VastProvider } from "@/lib/providers/vast";
 import type { OpenAIChatRequest } from "@/lib/providers/types";
+import { VastProvider } from "@/lib/providers/vast";
 
 const baseChatRequest: OpenAIChatRequest = {
   model: "vast/qwen3.6-35b-a3b-awq",

cloud/packages/tests/unit/steward-sync.test.ts

@@ -1,4 +1,3 @@
-
 import { beforeEach, describe, expect, test } from "bun:test";
 import { organizationInvitesRepository } from "@/db/repositories/organization-invites";
 import { apiKeysService } from "@/lib/services/api-keys";

plugins/plugin-wallet/src/analytics/dexscreener/__tests__/service.test.ts

@@ -3,11 +3,13 @@ import {
   describe,
   it,
   expect,
-  mock,
+  vi,
   beforeEach,
   afterEach,
-  spyOn,
-} from "bun:test";
+} from "vitest";
+
+const mock = vi.fn;
+const spyOn = vi.spyOn;
 import axios from "axios";
 import { DexScreenerService } from "../service";
 import { createMockRuntime } from "./test-utils";
@@ -44,8 +46,7 @@ describe("DexScreenerService", () => {
   });
 
   afterEach(() => {
-    // Restore mocks
-    mock.restore();
+    vi.restoreAllMocks();
   });
 
   describe("constructor", () => {

plugins/plugin-wallet/src/analytics/dexscreener/__tests__/test-utils.ts

@@ -3,11 +3,11 @@ import {
   describe,
   expect,
   it,
-  mock,
+  vi,
   beforeEach,
   afterEach,
-  spyOn,
-} from "bun:test";
+  type Mock,
+} from "vitest";
 import {
   type IAgentRuntime,
   type Memory,
@@ -20,7 +20,10 @@ import {
   ChannelType,
 } from "@elizaos/core";
 
-// Re-export bun test utilities for convenience
+const mock = vi.fn;
+const spyOn = vi.spyOn;
+
+// Re-export vitest utilities for convenience
 export { describe, it, expect, mock, beforeEach, afterEach, spyOn };
 
 // Create a valid UUID for testing
@@ -30,23 +33,23 @@ export const testUUID = "550e8400-e29b-41d4-a716-446655440000" as UUID;
 export type MockRuntime = Partial<IAgentRuntime> & {
   agentId: UUID;
   character: Character;
-  getSetting: ReturnType<typeof mock>;
-  useModel: ReturnType<typeof mock>;
-  composeState: ReturnType<typeof mock>;
-  createMemory: ReturnType<typeof mock>;
-  getMemories: ReturnType<typeof mock>;
-  searchMemories: ReturnType<typeof mock>;
-  updateMemory: ReturnType<typeof mock>;
-  getRoom: ReturnType<typeof mock>;
-  getParticipantUserState: ReturnType<typeof mock>;
-  setParticipantUserState: ReturnType<typeof mock>;
-  emitEvent: ReturnType<typeof mock>;
-  getTasks: ReturnType<typeof mock>;
+  getSetting: Mock;
+  useModel: Mock;
+  composeState: Mock;
+  createMemory: Mock;
+  getMemories: Mock;
+  searchMemories: Mock;
+  updateMemory: Mock;
+  getRoom: Mock;
+  getParticipantUserState: Mock;
+  setParticipantUserState: Mock;
+  emitEvent: Mock;
+  getTasks: Mock;
   providers: any[];
   actions: any[];
   evaluators: any[];
   services: any[];
-  getService: ReturnType<typeof mock>;
+  getService: Mock;
 };
 
 // Create Mock Runtime

plugins/plugin-wallet/src/chains/solana/dex/meteora/services/__tests__/MeteoraLpService.test.ts

@@ -6,6 +6,10 @@ import { Keypair as SolanaKeypair } from "@solana/web3.js";
 import { beforeEach, describe, expect, it, type Mock, type MockInstance, vi } from "vitest";
 import { MeteoraLpService } from "../MeteoraLpService.ts";
 
+vi.mock("@meteora-ag/dlmm", () => ({
+  default: { create: vi.fn() },
+}));
+
 // Mock fetch
 const mockFetch = vi.fn();
 global.fetch = mockFetch as unknown as typeof fetch;

plugins/plugin-wallet/src/lp/actions/LpManagementAgentAction.ts

@@ -162,86 +162,45 @@ export const LpManagementAgentAction: Action = {
 
   examples: [] as ActionExample[][], // Empty for now - add examples when specific LP workflows are documented
 
-  validate: async (runtime: IAgentRuntime, message: Memory, state?: State): Promise<boolean> => {
-    const __avTextRaw = typeof message?.content?.text === "string" ? message.content.text : "";
-    const __avText = __avTextRaw.toLowerCase();
-    const __avKeywords = ["management"];
-    const __avKeywordOk =
-      __avKeywords.length > 0 && __avKeywords.some((kw) => kw.length > 0 && __avText.includes(kw));
-    const __avRegex = /\b(?:management)\b/i;
-    const __avRegexOk = __avRegex.test(__avText);
-    const __avSource = String(message?.content?.source ?? "");
-    const __avExpectedSource = "";
-    const __avSourceOk = __avExpectedSource
-      ? __avSource === __avExpectedSource
-      : Boolean(__avSource || state || runtime?.agentId || runtime?.getService);
-    const __avInputOk =
-      __avText.trim().length > 0 ||
-      Boolean(message?.content && typeof message.content === "object");
-
-    if (!(__avKeywordOk && __avRegexOk && __avSourceOk && __avInputOk)) {
+  validate: async (_runtime: IAgentRuntime, message: Memory, _state?: State): Promise<boolean> => {
+    if (!message?.content?.text) {
       return false;
     }
 
-    const __avLegacyValidate = async (
-      _runtime: IAgentRuntime,
-      message: Memory,
-      _state?: State
-    ): Promise<boolean> => {
-      console.info(
-        "[LpManagementAgentAction] Validate called with message:",
-        message?.content?.text || "No text"
-      );
-
-      // If there's no message content, validation fails
-      if (!message?.content?.text) {
-        console.info("[LpManagementAgentAction] No message text, returning false");
-        return false;
-      }
-
-      const text = message.content.text.toLowerCase();
-
-      // Check for LP-related keywords in the message
-      const lpKeywords = [
-        "liquidity",
-        "lp",
-        "pool",
-        "dex",
-        "vault",
-        "slippage",
-        "apr",
-        "apy",
-        "tvl",
-        "swap",
-        "balance",
-        "position",
-        "yield",
-        "deposit",
-        "withdraw",
-        "rebalance",
-        "auto-rebalance",
-        "auto rebalance",
-        "enable rebalance",
-        "preference",
-        "slippage",
-        "concentrated",
-        "range",
-        "price range",
-        "narrow",
-        "tight",
-        "out of range",
-      ];
-
-      const hasLpKeyword = lpKeywords.some((keyword) => text.includes(keyword));
-      console.info("[LpManagementAgentAction] Has LP keyword:", hasLpKeyword);
-
-      return hasLpKeyword;
-    };
-    try {
-      return Boolean(await __avLegacyValidate(runtime, message, state));
-    } catch {
-      return false;
-    }
+    const text = message.content.text.toLowerCase();
+
+    const lpKeywords = [
+      "liquidity",
+      "lp",
+      "pool",
+      "dex",
+      "vault",
+      "slippage",
+      "apr",
+      "apy",
+      "tvl",
+      "swap",
+      "balance",
+      "position",
+      "yield",
+      "deposit",
+      "withdraw",
+      "rebalance",
+      "auto-rebalance",
+      "auto rebalance",
+      "enable rebalance",
+      "preference",
+      "concentrated",
+      "range",
+      "price range",
+      "narrow",
+      "tight",
+      "out of range",
+      "management",
+      "intent",
+    ];
+
+    return lpKeywords.some((keyword) => text.includes(keyword));
   },
 
   handler: async (runtime, message, _state) => {

plugins/plugin-wallet/src/lp/services/__tests__/EvmLpServices.test.ts

@@ -15,7 +15,7 @@ const createMockRuntime = (settings: Record<string, string> = {}): IAgentRuntime
     getCache: vi.fn(),
   }) as unknown as IAgentRuntime;
 
-describe("UniswapV3LpService", () => {
+describe.skip("UniswapV3LpService", () => {
   let mockRuntime: IAgentRuntime;
 
   beforeEach(() => {
@@ -52,7 +52,7 @@ describe("UniswapV3LpService", () => {
   });
 });
 
-describe("PancakeSwapV3LpService", () => {
+describe.skip("PancakeSwapV3LpService", () => {
   let mockRuntime: IAgentRuntime;
 
   beforeEach(() => {
@@ -82,7 +82,7 @@ describe("PancakeSwapV3LpService", () => {
   });
 });
 
-describe("AerodromeLpService", () => {
+describe.skip("AerodromeLpService", () => {
   let mockRuntime: IAgentRuntime;
 
   beforeEach(() => {