feat(api): integrate Nova3Node into CloudflareNodeRegistry and update tests for successful execution

Author: bchapuis

apps/api/src/nodes/audio/nova-3-node.integration.ts

@@ -7,7 +7,7 @@ import { NodeContext } from "../types";
 import { Nova3Node } from "./nova-3-node";
 
 describe("Nova3Node", () => {
-  it("should return expected error due to AI Gateway incompatibility", async () => {
+  it("should execute successfully with basic parameters", async () => {
     const nodeId = "nova-3";
     const node = new Nova3Node({
       nodeId,
@@ -24,13 +24,17 @@ describe("Nova3Node", () => {
     } as unknown as NodeContext;
 
     const result = await node.execute(context);
-    // Note: Nova-3 is currently not supported by Cloudflare AI Gateway
-    // due to incompatible audio format requirements
-    expect(result.status).toBe("error");
-    expect(result.error).toContain("required properties at '/audio' are 'body,contentType'");
+    expect(result.status).toBe("completed");
+    expect(result.outputs).toBeDefined();
+    expect(result.outputs?.text).toBeDefined();
+    expect(typeof result.outputs?.text).toBe("string");
+    expect(result.outputs?.confidence).toBeDefined();
+    expect(typeof result.outputs?.confidence).toBe("number");
+    expect(result.outputs?.words).toBeDefined();
+    expect(Array.isArray(result.outputs?.words)).toBe(true);
   });
 
-  it("should return expected error with language detection enabled", async () => {
+  it("should execute successfully with language detection enabled", async () => {
     const nodeId = "nova-3";
     const node = new Nova3Node({
       nodeId,
@@ -48,8 +52,17 @@ describe("Nova3Node", () => {
     } as unknown as NodeContext;
 
     const result = await node.execute(context);
-    expect(result.status).toBe("error");
-    expect(result.error).toContain("required properties at '/audio' are 'body,contentType'");
+    expect(result.status).toBe("completed");
+    expect(result.outputs).toBeDefined();
+    expect(result.outputs?.text).toBeDefined();
+    expect(typeof result.outputs?.text).toBe("string");
+    expect(result.outputs?.confidence).toBeDefined();
+    expect(typeof result.outputs?.confidence).toBe("number");
+    expect(result.outputs?.words).toBeDefined();
+    expect(Array.isArray(result.outputs?.words)).toBe(true);
+    if (result.outputs?.language) {
+      expect(typeof result.outputs.language).toBe("string");
+    }
   });
 
   it("should return error when audio is not provided", async () => {

apps/api/src/nodes/audio/nova-3-node.ts

@@ -17,8 +17,6 @@ export class Nova3Node extends ExecutableNode {
     icon: "mic",
     documentation: `This node transcribes speech from audio files using Deepgram's Nova-3 model, providing high-quality speech-to-text conversion with advanced features like speaker diarization, sentiment analysis, and topic detection.
 
-⚠️ **CURRENTLY NOT SUPPORTED**: Nova-3 is not currently compatible with Cloudflare's AI Gateway due to incompatible audio format requirements. The API requires a specific \`{audio: {body, contentType}}\` format that the AI Gateway cannot handle.
-
 ## Usage Example
 
 - **Input**: audio file (MP3, WAV, etc.)
@@ -31,16 +29,7 @@ export class Nova3Node extends ExecutableNode {
 - **Topic Detection**: Automatically detect topics in the audio
 - **Language Detection**: Automatically detect the spoken language
 - **Smart Formatting**: Apply intelligent formatting to improve readability
-- **Entity Detection**: Identify and extract key entities from content
-
-## Pricing
-
-- Regular HTTP: $0.0052 per audio minute
-- WebSocket: $0.0092 per audio minute
-
-## Status
-
-This implementation is complete and ready to work once Cloudflare resolves the AI Gateway compatibility issue.`,
+- **Entity Detection**: Identify and extract key entities from content`,
     computeCost: 5,
     inputs: [
       {
@@ -251,10 +240,18 @@ This implementation is complete and ready to work once Cloudflare resolves the A
       }
 
       // Build parameters object with only provided values
-      // Try using the exact format from the documentation but with Uint8Array directly
+      // Nova-3 requires {body, contentType} format where body is a ReadableStream
+      // Convert Uint8Array to ReadableStream
+      const audioStream = new ReadableStream({
+        start(controller) {
+          controller.enqueue(audio.data);
+          controller.close();
+        }
+      });
+
       const params: any = {
         audio: {
-          body: audio.data,
+          body: audioStream,
           contentType: audio.mimeType || "audio/mpeg",
         },
       };

apps/api/src/nodes/cloudflare-node-registry.ts

@@ -6,6 +6,7 @@ import { GeoTiffQueryNode } from "./3d/geotiff-query-node";
 import { AudioRecorderNode } from "./audio/audio-recorder-node";
 import { Aura1Node } from "./audio/aura-1-node";
 import { MelottsNode } from "./audio/melotts-node";
+import { Nova3Node } from "./audio/nova-3-node";
 import { WhisperLargeV3TurboNode } from "./audio/whisper-large-v3-turbo-node";
 import { WhisperNode } from "./audio/whisper-node";
 import { WhisperTinyEnNode } from "./audio/whisper-tiny-en-node";
@@ -387,6 +388,7 @@ export class CloudflareNodeRegistry extends BaseNodeRegistry {
     this.registerImplementation(ExifReaderNode);
     this.registerImplementation(Aura1Node);
     this.registerImplementation(MelottsNode);
+    this.registerImplementation(Nova3Node);
     this.registerImplementation(WebcamNode);
 
     // String operations