export default {
async fetch(request, env, ctx): Promise<Response> {
console.log("Converting webhook request...");
const webhookRequest = await request.json() as unknown as WebhookRequest;
console.log("Processing webhook request...");
const dealId = [webhookRequest]
.filter(isWebhookRequest)
.filter(isValidWebhook)
.map(getDealId)[0];
const dealDetails = await getDetailAndAttachmentDataFromId(dealId, env);
const payload = await transformToPayload(dealDetails, env);
//send to queue
console.log("[5/5] Completed. Checking payload...");
if (!payload) {
console.log("No payload to send!");
return new Response(
JSON.stringify({
message: "Bad request",
}), {
status: 400,
});
}
try {
console.log("Sending to queue..."); // <-- last log to appear in worker logs
await env.QUEUE.send(payload); // <-- didn't send to queue
console.log(payload);
return new Response("Success", {
status: 200
});
} catch (err) {
console.error("Error sending to queue:", err);
return new Response(
JSON.stringify({
message: "Failed to send to queue",
error: (<any>err).message,
}), {
status: 500,
});
}
}
} satisfies ExportedHandler<Env>;
export default {
async fetch(request, env, ctx): Promise<Response> {
console.log("Converting webhook request...");
const webhookRequest = await request.json() as unknown as WebhookRequest;
console.log("Processing webhook request...");
const dealId = [webhookRequest]
.filter(isWebhookRequest)
.filter(isValidWebhook)
.map(getDealId)[0];
const dealDetails = await getDetailAndAttachmentDataFromId(dealId, env);
const payload = await transformToPayload(dealDetails, env);
//send to queue
console.log("[5/5] Completed. Checking payload...");
if (!payload) {
console.log("No payload to send!");
return new Response(
JSON.stringify({
message: "Bad request",
}), {
status: 400,
});
}
try {
console.log("Sending to queue..."); // <-- last log to appear in worker logs
await env.QUEUE.send(payload); // <-- didn't send to queue
console.log(payload);
return new Response("Success", {
status: 200
});
} catch (err) {
console.error("Error sending to queue:", err);
return new Response(
JSON.stringify({
message: "Failed to send to queue",
error: (<any>err).message,
}), {
status: 500,
});
}
}
} satisfies ExportedHandler<Env>;
