feat: Add retries option and DLQ support

pigri · Mar 14, 2024 · 7a75bf0 · 7a75bf0
1 parent 6bdddbc
commit 7a75bf0
Show file tree

Hide file tree

Showing 3 changed files with 5 additions and 2 deletions.
diff --git a/README.md b/README.md
@@ -35,6 +35,7 @@ cp wrangler.toml_example wrangler.toml
 ### Create queue
 ```
 wrangler queues create cf-n8n-proxy-production -e production
+wrangler queues create dlq-cf-n8n-proxy-production -e production
 ```
 
 ### Deploy your service

diff --git a/src/index.ts b/src/index.ts
@@ -5,7 +5,7 @@ const { preflight, corsify } = createCors({
 });
 const router = Router();
 
-async function proxy (request: Request, env: Env) {
+export async function proxy (request: Request, env: Env) {
   let url = new URL(request.url);
   const proxyUrl = `${env.PROXY_DOMAIN}${url.pathname}`;
   switch (request.method) {
@@ -48,7 +48,7 @@ async function proxy (request: Request, env: Env) {
   }
 }
 
-async function createNewRequest(request: Request): Promise<Request> {
+export async function createNewRequest(request: Request): Promise<Request> {
   const { url, method, headers } = request;
   if (method === 'GET' || method === 'HEAD') {
     return new Request(url, { method, headers });

diff --git a/wrangler.toml_example b/wrangler.toml_example
@@ -27,6 +27,8 @@ binding = "ERROR_QUEUE"
 queue = "cf-n8n-proxy-production"
 max_batch_size = 100
 max_batch_timeout = 30
+max_retries = 100
+dead_letter_queue = "dlq-cf-n8n-proxy-production"
 
 [env.production]
 workers_dev = false