updaets

Author: Shaw

cloud/package.json

@@ -109,14 +109,14 @@
     "@elizaos/billing": "workspace:*",
     "@elizaos/cloud-ui": "workspace:*",
     "@elizaos/core": "alpha",
-    "@elizaos/plugin-elevenlabs": "workspace:*",
-    "@elizaos/plugin-elizacloud": "workspace:*",
-    "@elizaos/plugin-knowledge": "workspace:*",
-    "@elizaos/plugin-mcp": "workspace:*",
-    "@elizaos/plugin-n8n-workflow": "workspace:*",
-    "@elizaos/plugin-sql": "workspace:*",
-    "@elizaos/plugin-web-search": "workspace:*",
-    "@elizaos/shared": "workspace:*",
+    "@elizaos/plugin-elevenlabs": "^1.6.0",
+    "@elizaos/plugin-elizacloud": "^2.0.0-alpha.8",
+    "@elizaos/plugin-knowledge": "^1.6.1",
+    "@elizaos/plugin-mcp": "^1.8.2",
+    "@elizaos/plugin-n8n-workflow": "^1.2.3",
+    "@elizaos/plugin-sql": "^1.7.1",
+    "@elizaos/plugin-web-search": "^1.0.1",
+    "@elizaos/shared": "alpha",
     "@fal-ai/client": "^1.10.0",
     "@fal-ai/server-proxy": "^1.2.1",
     "@modelcontextprotocol/sdk": "^1.29.0",

packages/examples/twitter-xai/agent.ts

@@ -1,6 +1,6 @@
 #!/usr/bin/env bun
 
-import { AgentRuntime, type Plugin } from "@elizaos/core";
+import { AgentRuntime } from "@elizaos/core";
 import { config as loadDotEnv } from "dotenv";
 
 import { character } from "./character";
@@ -53,14 +53,9 @@ async function main(): Promise<void> {
   const { XAIPlugin } = await import("@elizaos/plugin-xai");
   const twitterPlugin = (await import("@elizaos/plugin-twitter")).default;
 
-  // Cast: published @elizaos/plugin-* packages carry their own bundled
-  // @elizaos/core types, which TypeScript treats as a different Plugin shape
-  // than the one resolved from the workspace.
-  const plugins = [sqlPlugin, XAIPlugin, twitterPlugin] as unknown as Plugin[];
-
   const runtime = new AgentRuntime({
     character,
-    plugins,
+    plugins: [sqlPlugin, XAIPlugin, twitterPlugin],
   });
 
   console.log("⏳ Initializing runtime...");

plugins/plugin-elevenlabs/build.ts

@@ -108,7 +108,7 @@ export { default } from "../index.browser";
   );
 }
 
-build().catch((err: Error) => {
+build().catch((err) => {
   console.error("Build failed:", err);
   process.exit(1);
 });

plugins/plugin-elevenlabs/src/index.ts

@@ -7,9 +7,9 @@ import {
 } from "@elizaos/core";
 import { ElevenLabsClient } from "@elevenlabs/elevenlabs-js";
 import {
-  SpeechToTextConvertRequestModelId,
-  SpeechToTextConvertRequestTimestampsGranularity,
-  TextToSpeechStreamRequestOutputFormat,
+  SpeechToTextConvertRequestModelId as SttModelIdEnum,
+  SpeechToTextConvertRequestTimestampsGranularity as SttTimestampsGranularityEnum,
+  TextToSpeechStreamRequestOutputFormat as TtsOutputFormatEnum,
 } from "@elevenlabs/elevenlabs-js/api";
 import type {
   BodySpeechToTextV1SpeechToTextPost,
@@ -23,14 +23,14 @@ import type {
 function parseTtsOutputFormat(
   format: string,
 ): TextToSpeechStreamRequestOutputFormat {
-  for (const allowed of Object.values(TextToSpeechStreamRequestOutputFormat)) {
+  for (const allowed of Object.values(TtsOutputFormatEnum)) {
     if (allowed === format) return allowed;
   }
   throw new Error(`Unsupported ElevenLabs TTS output format: ${format}`);
 }
 
 function parseSttModelId(id: string): SpeechToTextConvertRequestModelId {
-  for (const allowed of Object.values(SpeechToTextConvertRequestModelId)) {
+  for (const allowed of Object.values(SttModelIdEnum)) {
     if (allowed === id) return allowed;
   }
   throw new Error(`Unsupported ElevenLabs STT model: ${id}`);
@@ -39,9 +39,7 @@ function parseSttModelId(id: string): SpeechToTextConvertRequestModelId {
 function parseSttTimestampsGranularity(
   value: string,
 ): SpeechToTextConvertRequestTimestampsGranularity {
-  for (const allowed of Object.values(
-    SpeechToTextConvertRequestTimestampsGranularity,
-  )) {
+  for (const allowed of Object.values(SttTimestampsGranularityEnum)) {
     if (allowed === value) return allowed;
   }
   throw new Error(
@@ -86,47 +84,57 @@ interface TranscriptionSettings {
 }
 
 function isBrowser(): boolean {
-  return (
-    typeof globalThis !== "undefined" &&
-    typeof (globalThis as unknown as { document?: unknown }).document !==
-      "undefined"
-  );
+  return typeof globalThis.document !== "undefined";
 }
 
+function getSetting(runtime: IAgentRuntime, key: string): string | undefined;
+function getSetting(
+  runtime: IAgentRuntime,
+  key: string,
+  fallback: string,
+): string;
 function getSetting(
   runtime: IAgentRuntime,
   key: string,
   fallback?: string,
-): string {
+): string | undefined {
+  const rawRuntime = runtime.getSetting(key);
+  const fromRuntime =
+    rawRuntime === null || rawRuntime === undefined
+      ? undefined
+      : String(rawRuntime);
+
   const envValue =
     typeof process !== "undefined" &&
-    (process as { env?: Record<string, string> }).env
-      ? (process as { env: Record<string, string> }).env[key]
+    process.env &&
+    typeof process.env[key] === "string"
+      ? process.env[key]
       : undefined;
-  return (
-    (runtime.getSetting(key) as string) ??
-    (envValue as string) ??
-    (fallback as string)
-  );
+
+  return fromRuntime ?? envValue ?? fallback;
 }
 
 function getBaseURL(runtime: IAgentRuntime): string {
-  const browserURL = runtime.getSetting("ELEVENLABS_BROWSER_URL") as
-    | string
-    | undefined;
+  const browserRaw = runtime.getSetting("ELEVENLABS_BROWSER_URL");
+  const browserURL =
+    browserRaw === null || browserRaw === undefined
+      ? undefined
+      : String(browserRaw);
   if (isBrowser() && browserURL) return browserURL;
   return "https://api.elevenlabs.io/v1";
 }
 
 function getApiKey(runtime: IAgentRuntime): string | undefined {
-  const env =
-    (typeof process !== "undefined" &&
-      (process as { env?: Record<string, string> }).env) ||
-    {};
-  return (
-    (runtime.getSetting("ELEVENLABS_API_KEY") as string | undefined) ||
-    (env.ELEVENLABS_API_KEY as string | undefined)
-  );
+  const raw = runtime.getSetting("ELEVENLABS_API_KEY");
+  const fromRuntime =
+    raw === null || raw === undefined ? undefined : String(raw);
+  const fromEnv =
+    typeof process !== "undefined" &&
+    process.env &&
+    typeof process.env.ELEVENLABS_API_KEY === "string"
+      ? process.env.ELEVENLABS_API_KEY
+      : undefined;
+  return fromRuntime ?? fromEnv;
 }
 
 /**
@@ -154,7 +162,7 @@ function getVoiceSettings(runtime: IAgentRuntime): VoiceSettings {
     ),
     style: getSetting(runtime, "ELEVENLABS_VOICE_STYLE", "0"),
     speakerBoost: parseBooleanFromText(
-      `${getSetting(runtime, "ELEVENLABS_VOICE_USE_SPEAKER_BOOST", "true")}` as string,
+      `${getSetting(runtime, "ELEVENLABS_VOICE_USE_SPEAKER_BOOST", "true") ?? "true"}`,
     ),
   };
 }
@@ -175,11 +183,11 @@ function getTranscriptionSettings(
       "word",
     ),
     diarize: parseBooleanFromText(
-      `${getSetting(runtime, "ELEVENLABS_STT_DIARIZE", "false")}` as string,
+      `${getSetting(runtime, "ELEVENLABS_STT_DIARIZE", "false") ?? "false"}`,
     ),
     numSpeakers: numSpeakersStr ? Number(numSpeakersStr) : undefined,
     tagAudioEvents: parseBooleanFromText(
-      `${getSetting(runtime, "ELEVENLABS_STT_TAG_AUDIO_EVENTS", "false")}` as string,
+      `${getSetting(runtime, "ELEVENLABS_STT_TAG_AUDIO_EVENTS", "false") ?? "false"}`,
     ),
   };
 }
@@ -241,7 +249,7 @@ async function fetchSpeech(
     const stream = await client.textToSpeech.stream(params.voiceId, {
       text: params.text,
       modelId: params.modelId,
-      outputFormat: params.outputFormat as any,
+      outputFormat: parseTtsOutputFormat(params.outputFormat),
       optimizeStreamingLatency: Number(params.latency) || 0,
       voiceSettings: {
         stability: Number(params.stability) || 0,
@@ -283,48 +291,39 @@ async function fetchTranscription(
       baseUrl,
     });
 
-    const requestParams: any = {
-      modelId: params.modelId,
-      audio: params.audioFile,
+    const body: BodySpeechToTextV1SpeechToTextPost = {
+      modelId: parseSttModelId(params.modelId),
+      file: params.audioFile,
     };
 
     if (params.languageCode) {
-      requestParams.languageCode = params.languageCode;
+      body.languageCode = params.languageCode;
     }
 
     if (params.timestampsGranularity !== "none") {
-      requestParams.timestampsGranularity = params.timestampsGranularity;
+      body.timestampsGranularity = parseSttTimestampsGranularity(
+        params.timestampsGranularity,
+      );
     }
 
     if (params.diarize) {
-      requestParams.diarize = true;
-      if (params.numSpeakers) {
-        requestParams.numSpeakers = params.numSpeakers;
+      body.diarize = true;
+      if (params.numSpeakers !== undefined) {
+        body.numSpeakers = params.numSpeakers;
       }
     }
 
     if (params.tagAudioEvents) {
-      requestParams.tagAudioEvents = true;
+      body.tagAudioEvents = true;
     }
 
-    const response = await client.speechToText.convert(requestParams);
+    const response = await client.speechToText.convert(body);
 
     if (!response) {
       throw new Error("Empty response from ElevenLabs STT API");
     }
 
-    let transcript = "";
-    if ("transcript" in response && response.transcript) {
-      const transcriptObj = response.transcript as { text?: string };
-      transcript = transcriptObj.text || "";
-    } else if ("transcripts" in response && response.transcripts) {
-      const transcriptsArray = response.transcripts as Array<{ text?: string }>;
-      transcript = transcriptsArray
-        .map((t: { text?: string }) => t.text || "")
-        .join("\n");
-    }
-
-    return transcript;
+    return extractTranscript(response);
   } catch (error: unknown) {
     const msg = error instanceof Error ? error.message : String(error);
     logger.error(`ElevenLabs fetchTranscription error: ${msg}`);
@@ -392,8 +391,7 @@ export const elevenLabsPlugin: Plugin = {
       const settings = getVoiceSettings(runtime);
       const resolvedModel = options.model || settings.model;
       // Prefer explicit ElevenLabs voiceId param; fall back to configured voiceId.
-      const resolvedVoiceId =
-        (options.voiceId as string | undefined) || settings.voiceId;
+      const resolvedVoiceId = options.voiceId ?? settings.voiceId;
       // Honor explicit caller-provided format (e.g., "pcm_16000", "mp3_22050_64").
       // Gracefully map generic "mp3" to a valid ElevenLabs enum, otherwise pass through.
       // Only default to settings.outputFormat when absent.
@@ -561,26 +559,26 @@ export const elevenLabsPlugin: Plugin = {
 
             const testText = "Hello from ElevenLabs test.";
             try {
-              const audioStream = (await runtime.useModel(
+              const audio = await runtime.useModel(
                 ModelType.TEXT_TO_SPEECH,
                 testText,
-              )) as ReadableStream<Uint8Array>;
-
-              if (
-                !audioStream ||
-                typeof (audioStream as { getReader?: unknown }).getReader !==
-                  "function"
-              ) {
-                throw new Error("TTS output is not a Web ReadableStream");
-              }
+              );
+
+              const bytes: Uint8Array | null =
+                audio instanceof Uint8Array
+                  ? audio
+                  : Buffer.isBuffer(audio)
+                    ? new Uint8Array(audio)
+                    : audio instanceof ArrayBuffer
+                      ? new Uint8Array(audio)
+                      : null;
 
-              const reader = audioStream.getReader();
-              const { value, done } = await reader.read();
-              reader.releaseLock();
-              if (done && !value) {
-                throw new Error("Received empty audio stream");
+              if (!bytes || bytes.byteLength === 0) {
+                throw new Error(
+                  "TTS output must be non-empty Uint8Array, Buffer, or ArrayBuffer",
+                );
               }
-              logger.success("Received audio stream chunk successfully");
+              logger.success("Received TTS binary payload successfully");
             } catch (error: unknown) {
               const msg =
                 error instanceof Error ? error.message : String(error);

plugins/plugin-elevenlabs/tsconfig.json

@@ -2,7 +2,6 @@
   "compilerOptions": {
     "outDir": "dist",
     "rootDir": "src",
-    "baseUrl": "../..",
     "lib": ["ESNext", "DOM"],
     "target": "ESNext",
     "module": "Preserve",
@@ -15,11 +14,7 @@
     "emitDeclarationOnly": true,
     "resolveJsonModule": true,
     "moduleDetection": "force",
-    "allowArbitraryExtensions": true,
-    "paths": {
-      "@elizaos/core": ["packages/core/src"],
-      "@elizaos/core/*": ["packages/core/src/*"]
-    }
+    "allowArbitraryExtensions": true
   },
   "include": ["src/**/*.ts"]
 }