fix: Invert conditional logic for Cloudflare task queueing based on environment presence.
This commit is contained in:
@@ -79,7 +79,18 @@ export async function queueTask(
|
|||||||
// Otherwise, queue directly
|
// Otherwise, queue directly
|
||||||
const contentType =
|
const contentType =
|
||||||
headers["Content-Type"] === "application/json" ? "json" : "text";
|
headers["Content-Type"] === "application/json" ? "json" : "text";
|
||||||
if (!env) {
|
if (env) {
|
||||||
|
console.debug(
|
||||||
|
`Queueing task in queue ${queueName}: ${JSON.stringify(body)}`,
|
||||||
|
);
|
||||||
|
await env[queueName].send(
|
||||||
|
{ body, headers },
|
||||||
|
{
|
||||||
|
contentType,
|
||||||
|
delaySeconds: scheduleTime,
|
||||||
|
},
|
||||||
|
);
|
||||||
|
} else {
|
||||||
const Cloudflare = await import("cloudflare").then(
|
const Cloudflare = await import("cloudflare").then(
|
||||||
({ Cloudflare }) => Cloudflare,
|
({ Cloudflare }) => Cloudflare,
|
||||||
);
|
);
|
||||||
@@ -103,17 +114,6 @@ export async function queueTask(
|
|||||||
delay_seconds: scheduleTime,
|
delay_seconds: scheduleTime,
|
||||||
account_id: env.CLOUDFLARE_ACCOUNT_ID,
|
account_id: env.CLOUDFLARE_ACCOUNT_ID,
|
||||||
});
|
});
|
||||||
} else {
|
|
||||||
console.debug(
|
|
||||||
`Queueing task in queue ${queueName}: ${JSON.stringify(body)}`,
|
|
||||||
);
|
|
||||||
await env[queueName].send(
|
|
||||||
{ body, headers },
|
|
||||||
{
|
|
||||||
contentType,
|
|
||||||
delaySeconds: scheduleTime,
|
|
||||||
},
|
|
||||||
);
|
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
function buildTask(
|
function buildTask(
|
||||||
|
|||||||
Reference in New Issue
Block a user