Hi, is it possible to make several external HTTP requests when calling a worker via RPC? My worker d

Hi, is it possible to make several external HTTP requests when calling a worker via RPC?
My worker doesn't want to wait for a response from my other worker even though everything is in await and I've tried putting Promises everywhere.
I'm making requests in a for loop, the first request is done correctly but doesn't want to wait for the response to this one

// Worker A
// Warning : 'await' has no effect on the type of this expression.
const result = await this.#ctx.env.MAIL_AUTH.mailVerify(mails);

// Worker A
// Warning : 'await' has no effect on the type of this expression.
const result = await this.#ctx.env.MAIL_AUTH.mailVerify(mails);

// Worker A
// Warning : 'await' has no effect on the type of this expression.
const result = await this.#ctx.env.MAIL_AUTH.mailVerify(mails);

// Worker A
// Warning : 'await' has no effect on the type of this expression.
const result = await this.#ctx.env.MAIL_AUTH.mailVerify(mails);

// Worker B
async mailVerify(mails: any): Promise<ReturnMailType> {
  return await new AuthManager(this.env).sendMailVerify(mails);
}

... // Deeper in the code ( in sendMailVerify(mails: any) ) in a for loop
const response = await fetch("https://api.brevo.com/v3/smtp/email", {
  method: "POST",
  headers: {
    "Content-Type": "application/json",
    "api-key": env.BREVO_API_KEY,
  },
  body: JSON.stringify(requestBody),
});

// No response
console.log("Response : ", response);

// Worker B
async mailVerify(mails: any): Promise<ReturnMailType> {
  return await new AuthManager(this.env).sendMailVerify(mails);
}

... // Deeper in the code ( in sendMailVerify(mails: any) ) in a for loop
const response = await fetch("https://api.brevo.com/v3/smtp/email", {
  method: "POST",
  headers: {
    "Content-Type": "application/json",
    "api-key": env.BREVO_API_KEY,
  },
  body: JSON.stringify(requestBody),
});

// No response
console.log("Response : ", response);

// Worker B
async mailVerify(mails: any): Promise<ReturnMailType> {
  return await new AuthManager(this.env).sendMailVerify(mails);
}

... // Deeper in the code ( in sendMailVerify(mails: any) ) in a for loop
const response = await fetch("https://api.brevo.com/v3/smtp/email", {
  method: "POST",
  headers: {
    "Content-Type": "application/json",
    "api-key": env.BREVO_API_KEY,
  },
  body: JSON.stringify(requestBody),
});

// No response
console.log("Response : ", response);

// Worker B
async mailVerify(mails: any): Promise<ReturnMailType> {
  return await new AuthManager(this.env).sendMailVerify(mails);
}

... // Deeper in the code ( in sendMailVerify(mails: any) ) in a for loop
const response = await fetch("https://api.brevo.com/v3/smtp/email", {
  method: "POST",
  headers: {
    "Content-Type": "application/json",
    "api-key": env.BREVO_API_KEY,
  },
  body: JSON.stringify(requestBody),
});

// No response
console.log("Response : ", response);

I'm getting a typescript alert that the “await” is not required when calling my entrypoint when it should be.
The request is correct, I have no errors and it is carried out correctly.

kian•5/7/24, 10:20 AM

Goooooooogle

kian•5/7/24, 10:20 AM

Thanks for pointing it out - https://github.com/cloudflare/cloudflare-docs/pull/14433

Chief•5/7/24, 12:58 PM

How can I use wrangler tail locally? It always looks for the deployed version of whatever env that I give it.

Also, is there a way to see correct stack traces for errors when running locally?

CChief How can I use wrangler tail locally? It always looks for the deployed version of...

Hello, I’m Allie!•5/7/24, 1:00 PM

Like tailing a local Worker?

HHello, I’m Allie!Like tailing a local Worker?

Chief•5/7/24, 1:00 PM

yeah

CChief yeah

Hello, I’m Allie!•5/7/24, 1:00 PM

wrangler dev

wrangler dev

should be logging it automatically, at least any console info

HHello, I’m Allie!`wrangler dev` should be logging it automatically, at least any console info

Chief•5/7/24, 1:01 PM

So it does log it, but I'm looking to get things like stack traces

 [wrangler:inf] POST /trpc/snapshots.getSnapshot 500 Internal Server Error (1795ms)

 [wrangler:inf] POST /trpc/snapshots.getSnapshot 500 Internal Server Error (1795ms)

I'd want more info while developing locally

CChief So it does log it, but I'm looking to get things like stack traces ``` [wrangler...

Hello, I’m Allie!•5/7/24, 1:03 PM

It should be logging stack traces by default. If it isn't, then you may be using a framework/middleware that is swallowing the errors

Hello, I’m Allie!•5/7/24, 1:04 PM

Only Uncaught Errors are loggged to the console, unless whatever is catching the errors is also logging them

Chief•5/7/24, 1:05 PM

That makes a lot of sense, i've added an OnErrorOnError to my TRPC server and it shows up now. Thanks for the help!

YYakuzo Hi, is it possible to make several external HTTP requests when calling a worker ...

YakuzoOP•5/7/24, 1:07 PM

Sorry, it was me who did a few things wrong... it's easy to get lost with several inter worker communications.

Nbc66•5/7/24, 4:08 PM

made a small worker script that can route statuspage.io website updates to discord webhooks

would love to see feedback on this. Thank you
https://gist.github.com/Nbc66/42cb525102be73a8d67f253fc84a9dcd

Gist

A Cloudflare Worker script to be used with statuspage.io websites t...

A Cloudflare Worker script to be used with statuspage.io websites that allow you to subscibe to updates using a webhook - GItHub_status_to_discord_webhook.js

Nbc66•5/7/24, 4:13 PM

here is how it would look like in discord
https://i.imgur.com/hmoMOrY.png
https://i.imgur.com/plsuami.png

Imgur

Imgur

Samir•5/7/24, 5:10 PM

Can I deploy Go API to cf workers?

SSamir Can I deploy Go API to cf workers?

Cyb3r-Jak3•5/7/24, 5:41 PM

You’d have to use something like https://github.com/syumai/workers.

codebam•5/7/24, 6:07 PM

hey can someone help me figure out why this action isn't working? https://github.com/kevinJ045/makibotto/actions/runs/8990189612/job/24694968263

GitHub

.... · kevinJ045/makibotto@2360aed

Contribute to kevinJ045/makibotto development by creating an account on GitHub.

codebam•5/7/24, 6:07 PM

it just says

 Error: Failed to upload secrets.
Error: 🚨 Action failed

 Error: Failed to upload secrets.
Error: 🚨 Action failed

codebam•5/7/24, 6:08 PM

there's an API key in secrets and variables -> actions -> repository secretssecrets and variables -> actions -> repository secrets

haters daddyhd from bulgaria•5/8/24, 12:17 AM

I want to make Wokers able to access banned foreign URLs for my country, how do I do it and I'm confused in this video session?

BallisticSwami•5/8/24, 10:20 AM

Currently what is the easiest way to connect workers to a MySQL db? Tried using the cloudflare-mysql npm package and even tried cloudflared tunneling but couldn't get it to work.

AAdam Cloudflare Workers can’t create TCP connections to port 25, so you’d likely stru...

Sheng•5/8/24, 11:12 AM

Hmm, which means I only can build the app somewhere else but not with Cloudflare :NotLikeThis:

Vvcoder Hello, Can anyone help how to use npm packages that uses node runtime core packa...

Hello, I’m Allie!•5/8/24, 2:21 PM

What packages do you need, specifically?

Vvcoder https://www.npmjs.com/package/ssh2

Hello, I’m Allie!•5/8/24, 2:25 PM

Sorry, I meant which Node-built-ins

Vvcoder It's using a lot more,e.g crypto, events and many more, It gives me error like t...

Hello, I’m Allie!•5/8/24, 2:29 PM

A lot of those aren’t supported by Workers

az•5/8/24, 7:31 PM

does anyone know what could be causing this?

az•5/8/24, 7:31 PM

my requests have just become painfully slow for some reason

az•5/8/24, 7:32 PM

worker is pretty much just doing a url rewrite and fetching

az•5/8/24, 7:33 PM

to googleapis which is perfectly fine when requesting without the worker

Aaz worker is pretty much just doing a url rewrite and fetching

Hello, I’m Allie!•5/8/24, 7:33 PM

The fact that the CPU Time is low while the Wall Time is high means your origin is responding slow

Hello, I’m Allie!•5/8/24, 7:33 PM

Or at least the call to your origin

HHello, I’m Allie!Or at least the call to your origin

az•5/8/24, 7:33 PM

the origin call without the proxy

Aaz the origin call without the proxy

Hello, I’m Allie!•5/8/24, 7:34 PM

Can you post your code?

az•5/8/24, 7:35 PM

async function handleRequest(request) {

  // url rewriting
  let url = request.url;
  let host = request.headers.get("Host");
  let path = new URL(request.url).pathname; 

  // redirect www.
  if (url.startsWith("https://www.")) {
    return Response.redirect(url.replace("https://www.", "https://"));
  }



  // if we are api
  let isApiOrigin = (path.startsWith("/api/") || path == "/api");
  if (isApiOrigin) {
    url = url.replace(`https://${host}/api`, `https://api.${host}`);
  } else {

    // throw out query params for static pages
    url = url.split("?")[0];
    url = url.replace("https://","https://storage.googleapis.com/");

  
      // if path does not contain an extension (eg /dashboard but not /script.js)
      // or is explicitly a directory (eg /dashboard/) add the index.html
      if (path.endsWith("/")) {
        url = url.concat("index.html");
      } else if (!path.split("/").pop().includes(".")) {
        return Response.redirect(`https://${host}${path}/`, 308);
      };


  }

  const response = await fetch(new Request(url,
    {
      body:request.body,
      method:request.method,
      headers:request.headers,
      redirect:request.redirect,
    }
  ));

async function handleRequest(request) {

  // url rewriting
  let url = request.url;
  let host = request.headers.get("Host");
  let path = new URL(request.url).pathname; 

  // redirect www.
  if (url.startsWith("https://www.")) {
    return Response.redirect(url.replace("https://www.", "https://"));
  }



  // if we are api
  let isApiOrigin = (path.startsWith("/api/") || path == "/api");
  if (isApiOrigin) {
    url = url.replace(`https://${host}/api`, `https://api.${host}`);
  } else {

    // throw out query params for static pages
    url = url.split("?")[0];
    url = url.replace("https://","https://storage.googleapis.com/");

  
      // if path does not contain an extension (eg /dashboard but not /script.js)
      // or is explicitly a directory (eg /dashboard/) add the index.html
      if (path.endsWith("/")) {
        url = url.concat("index.html");
      } else if (!path.split("/").pop().includes(".")) {
        return Response.redirect(`https://${host}${path}/`, 308);
      };


  }

  const response = await fetch(new Request(url,
    {
      body:request.body,
      method:request.method,
      headers:request.headers,
      redirect:request.redirect,
    }
  ));

az•5/8/24, 7:36 PM

this is pretty much it

az•5/8/24, 7:36 PM

its been working fine for ages with no code changes

az•5/8/24, 7:37 PM

but just slowed down recentlyt

Aaz ```js async function handleRequest(request) { // url rewriting let url = re...

Hello, I’m Allie!•5/8/24, 7:39 PM

Try wrapping the fetch()fetch() in Date.now()Date.now()s like so, then check the x-elapsedx-elapsed header:

const start = Date.now();
let response = await fetch(new Request(url,
  {
    body:request.body,
    method:request.method,
    headers:request.headers,
    redirect:request.redirect,
  }
));
response = new Response(response.body, response);
response.headers.set("x-elapsed", Date.now() - start);

const start = Date.now();
let response = await fetch(new Request(url,
  {
    body:request.body,
    method:request.method,
    headers:request.headers,
    redirect:request.redirect,
  }
));
response = new Response(response.body, response);
response.headers.set("x-elapsed", Date.now() - start);

HHello, I’m Allie!Try wrapping the `fetch()` in `Date.now()`s like so, then check the `x-elapsed` ...

az•5/8/24, 7:47 PM

az•5/8/24, 7:48 PM

the entire duration is just the subrequest

az•5/8/24, 7:49 PM

but the subrequest works fine from my browser

Aaz but the subrequest works fine from my browser

Hello, I’m Allie!•5/8/24, 7:50 PM

Not entirely sure. Might be your origin doing some really weird routing

az•5/8/24, 7:51 PM

my origin is google so

az•5/8/24, 7:51 PM

i assume cloudflare and google have a peering agreement

Aaz my origin is google so

Hello, I’m Allie!•5/8/24, 7:52 PM

Maybe? Is whatever service you are using load-balanced?

az•5/8/24, 7:52 PM

its literally just the public endpoint to a gcp storage bucket

Unsmart•5/8/24, 7:54 PM

Fwiw Date.now()Date.now() only changes on I/O, so if theres something behind using heavy CPU doing a Date.now() -> fetch -> Date.now() would not only track the fetch time.

Hi, is it possible to make several external HTTP requests when calling a worker via RPC? My worker d

Similar Threads

Similar Threads

Similar Threads