Browse Source

Merge pull request #2244 from mslourens/headers_in_webhook_automation_step

add headers input in outgoing webhook automation step
master
Martin McKeaveney 5 years ago
committed by GitHub
parent
commit
7864f75a14
  1. 17
      packages/server/src/automations/steps/outgoingWebhook.js

17
packages/server/src/automations/steps/outgoingWebhook.js

@ -27,6 +27,7 @@ module.exports.definition = {
requestMethod: "POST", requestMethod: "POST",
url: "http://", url: "http://",
requestBody: "{}", requestBody: "{}",
headers: "{}",
}, },
schema: { schema: {
inputs: { inputs: {
@ -45,6 +46,11 @@ module.exports.definition = {
title: "JSON Body", title: "JSON Body",
customType: "wide", customType: "wide",
}, },
headers: {
type: "string",
title: "Headers",
customType: "wide",
},
}, },
required: ["requestMethod", "url"], required: ["requestMethod", "url"],
}, },
@ -65,7 +71,7 @@ module.exports.definition = {
} }
module.exports.run = async function ({ inputs }) { module.exports.run = async function ({ inputs }) {
let { requestMethod, url, requestBody } = inputs let { requestMethod, url, requestBody, headers } = inputs
if (!url.startsWith("http")) { if (!url.startsWith("http")) {
url = `http://${url}` url = `http://${url}`
} }
@ -84,6 +90,15 @@ module.exports.run = async function ({ inputs }) {
request.headers = { request.headers = {
"Content-Type": "application/json", "Content-Type": "application/json",
} }
if (headers && headers.length !== 0) {
try {
const customHeaders = JSON.parse(headers)
request.headers = { ...request.headers, ...customHeaders }
} catch (err) {
console.error(err)
}
}
} }
try { try {

Loading…
Cancel
Save