mirror of
https://github.com/n8n-io/n8n.git
synced 2024-12-25 04:34:06 -08:00
🔀 Merge branch 'Jhalter5Stones-feat/webhook-node/response-mode'
This commit is contained in:
commit
064f88cadb
|
@ -204,6 +204,14 @@ export async function executeWebhook(
|
||||||
200,
|
200,
|
||||||
) as number;
|
) as number;
|
||||||
|
|
||||||
|
const responseData = workflow.expression.getSimpleParameterValue(
|
||||||
|
workflowStartNode,
|
||||||
|
webhookData.webhookDescription.responseData,
|
||||||
|
executionMode,
|
||||||
|
additionalKeys,
|
||||||
|
'firstEntryJson',
|
||||||
|
);
|
||||||
|
|
||||||
if (!['onReceived', 'lastNode', 'responseNode'].includes(responseMode as string)) {
|
if (!['onReceived', 'lastNode', 'responseNode'].includes(responseMode as string)) {
|
||||||
// If the mode is not known we error. Is probably best like that instead of using
|
// If the mode is not known we error. Is probably best like that instead of using
|
||||||
// the default that people know as early as possible (probably already testing phase)
|
// the default that people know as early as possible (probably already testing phase)
|
||||||
|
@ -331,7 +339,12 @@ export async function executeWebhook(
|
||||||
// directly if responseMode it set to "onReceived" and a respone should be sent
|
// directly if responseMode it set to "onReceived" and a respone should be sent
|
||||||
if (responseMode === 'onReceived' && !didSendResponse) {
|
if (responseMode === 'onReceived' && !didSendResponse) {
|
||||||
// Return response directly and do not wait for the workflow to finish
|
// Return response directly and do not wait for the workflow to finish
|
||||||
if (webhookResultData.webhookResponse !== undefined) {
|
if (responseData === 'noData') {
|
||||||
|
// Return without data
|
||||||
|
responseCallback(null, {
|
||||||
|
responseCode,
|
||||||
|
});
|
||||||
|
} else if (webhookResultData.webhookResponse !== undefined) {
|
||||||
// Data to respond with is given
|
// Data to respond with is given
|
||||||
responseCallback(null, {
|
responseCallback(null, {
|
||||||
data: webhookResultData.webhookResponse,
|
data: webhookResultData.webhookResponse,
|
||||||
|
@ -508,16 +521,8 @@ export async function executeWebhook(
|
||||||
$executionId: executionId,
|
$executionId: executionId,
|
||||||
};
|
};
|
||||||
|
|
||||||
const responseData = workflow.expression.getSimpleParameterValue(
|
|
||||||
workflowStartNode,
|
|
||||||
webhookData.webhookDescription.responseData,
|
|
||||||
executionMode,
|
|
||||||
additionalKeys,
|
|
||||||
'firstEntryJson',
|
|
||||||
);
|
|
||||||
|
|
||||||
if (!didSendResponse) {
|
if (!didSendResponse) {
|
||||||
let data: IDataObject | IDataObject[];
|
let data: IDataObject | IDataObject[] | undefined;
|
||||||
|
|
||||||
if (responseData === 'firstEntryJson') {
|
if (responseData === 'firstEntryJson') {
|
||||||
// Return the JSON data of the first entry
|
// Return the JSON data of the first entry
|
||||||
|
@ -621,6 +626,9 @@ export async function executeWebhook(
|
||||||
noWebhookResponse: true,
|
noWebhookResponse: true,
|
||||||
});
|
});
|
||||||
}
|
}
|
||||||
|
} else if (responseData === 'noData') {
|
||||||
|
// Return without data
|
||||||
|
data = undefined;
|
||||||
} else {
|
} else {
|
||||||
// Return the JSON data of all the entries
|
// Return the JSON data of all the entries
|
||||||
data = [];
|
data = [];
|
||||||
|
|
|
@ -85,7 +85,7 @@ export class Webhook implements INodeType {
|
||||||
isFullPath: true,
|
isFullPath: true,
|
||||||
responseCode: '={{$parameter["responseCode"]}}',
|
responseCode: '={{$parameter["responseCode"]}}',
|
||||||
responseMode: '={{$parameter["responseMode"]}}',
|
responseMode: '={{$parameter["responseMode"]}}',
|
||||||
responseData: '={{$parameter["responseData"]}}',
|
responseData: '={{$parameter["responseData"] || ($parameter.options.noResponseBody ? "noData" : undefined) }}',
|
||||||
responseBinaryPropertyName: '={{$parameter["responseBinaryPropertyName"]}}',
|
responseBinaryPropertyName: '={{$parameter["responseBinaryPropertyName"]}}',
|
||||||
responseContentType: '={{$parameter["options"]["responseContentType"]}}',
|
responseContentType: '={{$parameter["options"]["responseContentType"]}}',
|
||||||
responsePropertyName: '={{$parameter["options"]["responsePropertyName"]}}',
|
responsePropertyName: '={{$parameter["options"]["responsePropertyName"]}}',
|
||||||
|
@ -227,6 +227,11 @@ export class Webhook implements INodeType {
|
||||||
value: 'firstEntryBinary',
|
value: 'firstEntryBinary',
|
||||||
description: 'Returns the binary data of the first entry of the last node. Always returns a binary file.',
|
description: 'Returns the binary data of the first entry of the last node. Always returns a binary file.',
|
||||||
},
|
},
|
||||||
|
{
|
||||||
|
name: 'No Response Body',
|
||||||
|
value: 'noData',
|
||||||
|
description: 'Returns without a body.',
|
||||||
|
},
|
||||||
],
|
],
|
||||||
default: 'firstEntryJson',
|
default: 'firstEntryJson',
|
||||||
description: 'What data should be returned. If it should return all items as an array or only the first item as object.',
|
description: 'What data should be returned. If it should return all items as an array or only the first item as object.',
|
||||||
|
@ -291,6 +296,42 @@ export class Webhook implements INodeType {
|
||||||
default: false,
|
default: false,
|
||||||
description: 'Set to true to ignore requests from bots like link previewers and web crawlers',
|
description: 'Set to true to ignore requests from bots like link previewers and web crawlers',
|
||||||
},
|
},
|
||||||
|
{
|
||||||
|
displayName: 'No Response Body',
|
||||||
|
name: 'noResponseBody',
|
||||||
|
type: 'boolean',
|
||||||
|
default: false,
|
||||||
|
description: 'Do not send any body in the response',
|
||||||
|
displayOptions: {
|
||||||
|
hide: {
|
||||||
|
'rawBody': [
|
||||||
|
true,
|
||||||
|
],
|
||||||
|
},
|
||||||
|
show: {
|
||||||
|
'/responseMode': [
|
||||||
|
'onReceived',
|
||||||
|
],
|
||||||
|
},
|
||||||
|
},
|
||||||
|
},
|
||||||
|
{
|
||||||
|
displayName: 'Raw Body',
|
||||||
|
name: 'rawBody',
|
||||||
|
type: 'boolean',
|
||||||
|
displayOptions: {
|
||||||
|
hide: {
|
||||||
|
binaryData: [
|
||||||
|
true,
|
||||||
|
],
|
||||||
|
'noResponseBody': [
|
||||||
|
true,
|
||||||
|
],
|
||||||
|
},
|
||||||
|
},
|
||||||
|
default: false,
|
||||||
|
description: 'Raw body (binary)',
|
||||||
|
},
|
||||||
{
|
{
|
||||||
displayName: 'Response Data',
|
displayName: 'Response Data',
|
||||||
name: 'responseData',
|
name: 'responseData',
|
||||||
|
@ -301,6 +342,11 @@ export class Webhook implements INodeType {
|
||||||
'onReceived',
|
'onReceived',
|
||||||
],
|
],
|
||||||
},
|
},
|
||||||
|
hide: {
|
||||||
|
'noResponseBody': [
|
||||||
|
true,
|
||||||
|
],
|
||||||
|
},
|
||||||
},
|
},
|
||||||
default: '',
|
default: '',
|
||||||
placeholder: 'success',
|
placeholder: 'success',
|
||||||
|
@ -374,20 +420,6 @@ export class Webhook implements INodeType {
|
||||||
default: 'data',
|
default: 'data',
|
||||||
description: 'Name of the property to return the data of instead of the whole JSON.',
|
description: 'Name of the property to return the data of instead of the whole JSON.',
|
||||||
},
|
},
|
||||||
{
|
|
||||||
displayName: 'Raw Body',
|
|
||||||
name: 'rawBody',
|
|
||||||
type: 'boolean',
|
|
||||||
displayOptions: {
|
|
||||||
hide: {
|
|
||||||
binaryData: [
|
|
||||||
true,
|
|
||||||
],
|
|
||||||
},
|
|
||||||
},
|
|
||||||
default: false,
|
|
||||||
description: 'Raw body (binary)',
|
|
||||||
},
|
|
||||||
],
|
],
|
||||||
},
|
},
|
||||||
],
|
],
|
||||||
|
|
|
@ -1186,7 +1186,7 @@ export interface IWebhookResponseData {
|
||||||
noWebhookResponse?: boolean;
|
noWebhookResponse?: boolean;
|
||||||
}
|
}
|
||||||
|
|
||||||
export type WebhookResponseData = 'allEntries' | 'firstEntryJson' | 'firstEntryBinary';
|
export type WebhookResponseData = 'allEntries' | 'firstEntryJson' | 'firstEntryBinary' | 'noData';
|
||||||
export type WebhookResponseMode = 'onReceived' | 'lastNode';
|
export type WebhookResponseMode = 'onReceived' | 'lastNode';
|
||||||
|
|
||||||
export interface INodeTypes {
|
export interface INodeTypes {
|
||||||
|
|
Loading…
Reference in a new issue