admin/n8n-enterprise-unlocked
1
0
Fork 0
mirror of https://github.com/Abdulazizzn/n8n-enterprise-unlocked.git synced 2025-12-17 10:02:05 +00:00
Code Issues Packages Projects Releases Wiki Activity

feat(editor): Chat Trigger tweaks (#9618)

Browse Source 
Signed-off-by: Oleg Ivaniv <me@olegivaniv.com>
This commit is contained in:
oleg
2024-06-04 17:24:18 +02:00
committed by GitHub
parent 42ceec6879
commit 5322802992
11 changed files with 42 additions and 29 deletions
Download Patch File Download Diff File Expand all files Collapse all files

36
packages/core/src/NodeExecuteFunctions.ts
View File

@@ -1547,11 +1547,11 @@ export async function requestOAuth1(
const credentials = await this.getCredentials(credentialsType);
if (credentials === undefined) {
throw new ApplicationError('No credentials were returned!');
throw new ApplicationError('No credentials were returned');
}
if (credentials.oauthTokenData === undefined) {
throw new ApplicationError('OAuth credentials not connected!');
throw new ApplicationError('OAuth credentials not connected');
}
const oauth = new clientOAuth1({
@@ -1647,7 +1647,7 @@ export async function httpRequestWithAuthentication(
if (credentialsDecrypted === undefined) {
throw new NodeOperationError(
node,
`Node "${node.name}" does not have any credentials of type "${credentialsType}" set!`,
`Node "${node.name}" does not have any credentials of type "${credentialsType}" set`,
{ level: 'warning' },
);
}
@@ -1844,7 +1844,7 @@ export async function requestWithAuthentication(
if (credentialsDecrypted === undefined) {
throw new NodeOperationError(
node,
`Node "${node.name}" does not have any credentials of type "${credentialsType}" set!`,
`Node "${node.name}" does not have any credentials of type "${credentialsType}" set`,
{ level: 'warning' },
);
}
@@ -1990,7 +1990,7 @@ export async function getCredentials(
if (nodeType === undefined) {
throw new NodeOperationError(
node,
`Node type "${node.type}" is not known so can not get credentials!`,
`Node type "${node.type}" is not known so can not get credentials`,
);
}
@@ -2003,7 +2003,7 @@ export async function getCredentials(
if (nodeType.description.credentials === undefined) {
throw new NodeOperationError(
node,
`Node type "${node.type}" does not have any credentials defined!`,
`Node type "${node.type}" does not have any credentials defined`,
{ level: 'warning' },
);
}
@@ -2014,7 +2014,7 @@ export async function getCredentials(
if (nodeCredentialDescription === undefined) {
throw new NodeOperationError(
node,
`Node type "${node.type}" does not have any credentials of type "${type}" defined!`,
`Node type "${node.type}" does not have any credentials of type "${type}" defined`,
{ level: 'warning' },
);
}
@@ -2039,16 +2039,14 @@ export async function getCredentials(
if (nodeCredentialDescription?.required === true) {
// Credentials are required so error
if (!node.credentials) {
throw new NodeOperationError(node, 'Node does not have any credentials set!', {
throw new NodeOperationError(node, 'Node does not have any credentials set', {
level: 'warning',
});
}
if (!node.credentials[type]) {
throw new NodeOperationError(
node,
`Node does not have any credentials set for "${type}"!`,
{ level: 'warning' },
);
throw new NodeOperationError(node, `Node does not have any credentials set for "${type}"`, {
level: 'warning',
});
}
} else {
// Credentials are not required
@@ -2782,7 +2780,7 @@ async function getInputConnectionData(
const nodes = await Promise.all(constParentNodes);
if (inputConfiguration.required && nodes.length === 0) {
throw new NodeOperationError(node, `A ${inputName} processor node must be connected!`);
throw new NodeOperationError(node, `A ${inputName} processor node must be connected`);
}
if (
inputConfiguration.maxConnections !== undefined &&
@@ -2790,7 +2788,7 @@ async function getInputConnectionData(
) {
throw new NodeOperationError(
node,
`Only ${inputConfiguration.maxConnections} ${inputName} processor nodes are/is allowed to be connected!`,
`Only ${inputConfiguration.maxConnections} ${inputName} processor nodes are/is allowed to be connected`,
);
}
@@ -3335,12 +3333,12 @@ export function getExecutePollFunctions(
...getCommonWorkflowFunctions(workflow, node, additionalData),
__emit: (): void => {
throw new ApplicationError(
'Overwrite NodeExecuteFunctions.getExecutePollFunctions.__emit function!',
'Overwrite NodeExecuteFunctions.getExecutePollFunctions.__emit function',
);
},
__emitError() {
throw new ApplicationError(
'Overwrite NodeExecuteFunctions.getExecutePollFunctions.__emitError function!',
'Overwrite NodeExecuteFunctions.getExecutePollFunctions.__emitError function',
);
},
getMode: () => mode,
@@ -3398,12 +3396,12 @@ export function getExecuteTriggerFunctions(
...getCommonWorkflowFunctions(workflow, node, additionalData),
emit: (): void => {
throw new ApplicationError(
'Overwrite NodeExecuteFunctions.getExecuteTriggerFunctions.emit function!',
'Overwrite NodeExecuteFunctions.getExecuteTriggerFunctions.emit function',
);
},
emitError: (): void => {
throw new ApplicationError(
'Overwrite NodeExecuteFunctions.getExecuteTriggerFunctions.emit function!',
'Overwrite NodeExecuteFunctions.getExecuteTriggerFunctions.emit function',
);
},
getMode: () => mode,