Alex Patterson Posts - Answer Overflow

Alex Patterson

Explore posts from servers

•Created by Alex Patterson on 3/14/2025 in #workers-help

Can you send a signedurl from R2 to Whisper model?

I am getting a 500 error in production when trying to send the R2 signed URL. I am not sure what string Ai_Cf_Openai_Whisper_Input is expecting? Error:

InferenceUpstreamError: {"httpCode":500,"message":"TypeError: Cannot read properties of undefined (reading 'length')","name":"AiError"}

type Ai_Cf_Openai_Whisper_Input =
  | string
  | {
      audio: number[];
    };

type Ai_Cf_Openai_Whisper_Input =
  | string
  | {
      audio: number[];
    };

Full code

        await step.do("submitting video to Whisper", async () => {
            // Get the video from R2 and upload it to AssemblyAI
            let uploadUrl: Ai_Cf_Openai_Whisper_Input;
            if (this.env.DEV) {
                // Get the video from R2
                const videoR2 = await this.env.FLIPFEEDS_R2.get(videoR2Key);
                if (!videoR2 || !videoR2.httpMetadata) {
                    console.error("Video not found in storage.");
                    throw new NonRetryableError("Video not found in storage.");
                }

                console.log(
                    `processing ${event.payload.videoId} video with ai...`,
                );
                uploadUrl = {
                    audio: [...new Uint8Array(await videoR2.arrayBuffer())],
                };
            } else {
                const R2_URL = `https://${this.env.CLOUDFLARE_ACCOUNT_ID}.r2.cloudflarestorage.com/flipfeeds-r2`;

                const client = new AwsClient({
                    accessKeyId: this.env.CLOUDFLARE_ACCESS_KEY_ID,
                    secretAccessKey: this.env.CLOUDFLARE_SECRET_ACCESS_KEY,
                });

                const signedUrl = await client.sign(
                    new Request(
                        `${R2_URL}/${videoR2Key}?X-Amz-Expires=${3600}`,
                    ),
                    {
                        aws: { signQuery: true },
                    },
                );

                if (!signedUrl.url.toString()) {
                    console.error("Failed to get signed url.");
                    throw new NonRetryableError("Failed to get signed url.");
                }

                uploadUrl = signedUrl.url.toString();
            }
            // Submit to AI Whisper
            const whisper = await this.env.AI.run(
                "@cf/openai/whisper",
                uploadUrl,
            );

            await this.env.FLIPFEEDS_KV.put(
                whisperKvOriginalKey,
                JSON.stringify(whisper),
            );
        });

        await step.do("submitting video to Whisper", async () => {
            // Get the video from R2 and upload it to AssemblyAI
            let uploadUrl: Ai_Cf_Openai_Whisper_Input;
            if (this.env.DEV) {
                // Get the video from R2
                const videoR2 = await this.env.FLIPFEEDS_R2.get(videoR2Key);
                if (!videoR2 || !videoR2.httpMetadata) {
                    console.error("Video not found in storage.");
                    throw new NonRetryableError("Video not found in storage.");
                }

                console.log(
                    `processing ${event.payload.videoId} video with ai...`,
                );
                uploadUrl = {
                    audio: [...new Uint8Array(await videoR2.arrayBuffer())],
                };
            } else {
                const R2_URL = `https://${this.env.CLOUDFLARE_ACCOUNT_ID}.r2.cloudflarestorage.com/flipfeeds-r2`;

                const client = new AwsClient({
                    accessKeyId: this.env.CLOUDFLARE_ACCESS_KEY_ID,
                    secretAccessKey: this.env.CLOUDFLARE_SECRET_ACCESS_KEY,
                });

                const signedUrl = await client.sign(
                    new Request(
                        `${R2_URL}/${videoR2Key}?X-Amz-Expires=${3600}`,
                    ),
                    {
                        aws: { signQuery: true },
                    },
                );

                if (!signedUrl.url.toString()) {
                    console.error("Failed to get signed url.");
                    throw new NonRetryableError("Failed to get signed url.");
                }

                uploadUrl = signedUrl.url.toString();
            }
            // Submit to AI Whisper
            const whisper = await this.env.AI.run(
                "@cf/openai/whisper",
                uploadUrl,
            );

            await this.env.FLIPFEEDS_KV.put(
                whisperKvOriginalKey,
                JSON.stringify(whisper),
            );
        });

1 replies

CDCloudflare Developers

•Created by Alex Patterson on 3/13/2025 in #workers-help

How to upload from R2 to Cloudflare Stream for large files?

https://discord.com/channels/595317990191398933/893253103695065128/1349612376852533260 I would love for this to work on my local setup as well so I don't have to test on R2 directly on cloudflare, but if that is the only way to test large files let me know. I am developing locally and am trying to transfer large videos from R2 to Stream and hitting the size limit issue. What would be the best way to handle this? can you actually send a tus request via worker without a browser? Would this work on server? https://developers.cloudflare.com/stream/uploading-videos/resumable-uploads/ Or is should I create a R2 link via S3 only on a real R2 bucket, because I don't think we can do this on local testing?? https://developers.cloudflare.com/stream/uploading-videos/upload-via-link/ https://developers.cloudflare.com/r2/examples/aws/aws4fetch/#generate-presigned-urls

// Get the video from R2
const videoR2 = await this.env.COVE_STORAGE.get(
    `${video.organizationId}/${video.id}`,
);
if (!videoR2 || !videoR2.httpMetadata) {
    throw new NonRetryableError("Video not found in storage.");
}

// Upload the video from R2 to Cloudflare Stream
const formData = new FormData();
formData.append(
    "file",
    new Blob([await videoR2.blob()]),
    `${video.organizationId}/${video.id}`,
);

const streamResponse = await fetch(streamEndpoint, {
    method: "POST",
    headers: {
        Authorization: `Bearer ${this.env.CLOUDFLARE_API_TOKEN}`,
        // No Content-Type header - FormData will set it automatically with the boundary
    },
    body: formData,
});

// Get the video from R2
const videoR2 = await this.env.COVE_STORAGE.get(
    `${video.organizationId}/${video.id}`,
);
if (!videoR2 || !videoR2.httpMetadata) {
    throw new NonRetryableError("Video not found in storage.");
}

// Upload the video from R2 to Cloudflare Stream
const formData = new FormData();
formData.append(
    "file",
    new Blob([await videoR2.blob()]),
    `${video.organizationId}/${video.id}`,
);

const streamResponse = await fetch(streamEndpoint, {
    method: "POST",
    headers: {
        Authorization: `Bearer ${this.env.CLOUDFLARE_API_TOKEN}`,
        // No Content-Type header - FormData will set it automatically with the boundary
    },
    body: formData,
});

2 replies

CDCloudflare Developers

•Created by Alex Patterson on 3/6/2025 in #workers-help

[observability.logs]logs enabled cleared on build

Anytime I build my workers logs are getting disabled. I have this set in my wrangler.toml

[observability.logs]
enabled = true

[observability.logs]
enabled = true

my wrangler version is 3.112.0 Would this impact anything?

#:schema node_modules/wrangler/config-schema.json
compatibility_date = "2025-01-24"
compatibility_flags = [ "nodejs_compat" ]

#:schema node_modules/wrangler/config-schema.json
compatibility_date = "2025-01-24"
compatibility_flags = [ "nodejs_compat" ]

4 replies

CDCloudflare Developers

•Created by Alex Patterson on 3/5/2025 in #workers-help

AI Worker form Workflow throws Network connection lost Name: AiError

1 replies

CDCloudflare Developers

•Created by Alex Patterson on 1/27/2025 in #workers-help

Correct TypeScript from WorkerEntrypoint Binding

14 replies

CDCloudflare Developers

•Created by Alex Patterson on 1/25/2025 in #workers-help

PartyKit vs WebSocket server with WebSocket Hibernation

2 replies

Gaming

Programming