support elevenlabs private agent (#1063)

lib/tasks/llm/llms/elevenlabs_s2s.js

@@ -1,6 +1,7 @@
 const Task = require('../../task');
 const TaskName = 'Llm_Elevenlabs_s2s';
 const {LlmEvents_Elevenlabs} = require('../../../utils/constants');
+const {request} = require('undici');
 const ClientEvent = 'client.event';
 const SessionDelete = 'session.delete';
 
@@ -35,10 +36,11 @@ class TaskLlmElevenlabs_S2S extends Task {
     this.vendor = this.parent.vendor;
     this.auth = this.parent.auth;
 
-    const {agent_id} = this.auth || {};
+    const {agent_id, api_key} = this.auth || {};
     if (!agent_id) throw new Error('auth.agent_id is required for Elevenlabs S2S');
 
     this.agent_id = agent_id;
+    this.api_key = api_key;
     this.actionHook = this.data.actionHook;
     this.eventHook = this.data.eventHook;
     this.toolHook = this.data.toolHook;
@@ -71,6 +73,35 @@ class TaskLlmElevenlabs_S2S extends Task {
 
   get name() { return TaskName; }
 
+  async getSignedUrl() {
+    if (!this.api_key) {
+      return {
+        host: 'api.elevenlabs.io',
+        path: `/v1/convai/conversation?agent_id=${this.agent_id}`,
+      };
+    }
+
+    const {statusCode, body} = await request(
+      `https://api.elevenlabs.io/v1/convai/conversation/get_signed_url?agent_id=${this.agent_id}`, {
+        method: 'GET',
+        headers: {
+          'xi-api-key': this.api_key
+        },
+      }
+    );
+    const data = await body.json();
+    if (statusCode !== 200 || !data?.signed_url) {
+      this.logger.error({statusCode, data}, 'Elevenlabs Error registering call');
+      throw new Error(`Elevenlabs  Error registering call: ${data.message}`);
+    }
+
+    const url = new URL(data.signed_url);
+    return {
+      host: url.hostname,
+      path: url.pathname + url.search,
+    };
+  }
+
   async _api(ep, args) {
     const res = await ep.api('uuid_elevenlabs_s2s', `^^|${args.join('|')}`);
     if (!res.body?.startsWith('+OK')) {
@@ -132,7 +163,8 @@ class TaskLlmElevenlabs_S2S extends Task {
     this._registerHandlers(ep);
 
     try {
-      const args = [ep.uuid, 'session.create', this.input_sample_rate, this.output_sample_rate, this.agent_id];
+      const {host, path} = await this.getSignedUrl();
+      const args = [ep.uuid, 'session.create', this.input_sample_rate, this.output_sample_rate, host, path];
       await this._api(ep, args);
     } catch (err) {
       this.logger.error({err}, 'TaskLlmElevenlabs_S2S:_startListening');