From e9395bcfd22c2546081c3edb1fffa31e59b84261 Mon Sep 17 00:00:00 2001 From: Devang Bhuva Date: Fri, 26 Nov 2021 16:18:32 +0530 Subject: [PATCH] Use task request headers in queue request --- index.js | 4 +++- 1 file changed, 3 insertions(+), 1 deletion(-) diff --git a/index.js b/index.js index 4cb8566..5bd157e 100644 --- a/index.js +++ b/index.js @@ -48,7 +48,9 @@ queue.process('taskqueue', function(job, done) { console.log(`Executing ${job.id}`); const appEngineHttpRequest = job.data.task.appEngineHttpRequest; const queueName = job.data.parent.queueName; - const headers = { 'x-appengine-queuename': queueName, 'x-appengine-taskname': job.id.toString() }; + let headers = {}; + if (appEngineHttpRequest.headers) headers = { ...headers, ...appEngineHttpRequest.headers }; + headers = { ...headers, 'x-appengine-queuename': queueName, 'x-appengine-taskname': job.id.toString() } const options = { baseUrl: appEngineHttpRequest.baseUrl, method: appEngineHttpRequest.httpMethod }; if (appEngineHttpRequest.body) { options.body = Buffer.from(appEngineHttpRequest.body, 'base64').toString('utf-8');