mirror of
https://github.com/n8n-io/n8n.git
synced 2024-12-25 04:34:06 -08:00
3137de2585
* ✨ change FE to handle new object type * 🚸 improve UX of handling invalid credentials * 🚧 WIP * 🎨 fix typescript issues * 🐘 add migrations for all supported dbs * ✏️ add description to migrations * ⚡ add credential update on import * ⚡ resolve after merge issues * 👕 fix lint issues * ⚡ check credentials on workflow create/update * update interface * 👕 fix ts issues * ⚡ adaption to new credentials UI * 🐛 intialize cache on BE for credentials check * 🐛 fix undefined oldCredentials * 🐛 fix deleting credential * 🐛 fix check for undefined keys * 🐛 fix disabling edit in execution * 🎨 just show credential name on execution view * ✏️ remove TODO * ⚡ implement review suggestions * ⚡ add cache to getCredentialsByType * ⏪ use getter instead of cache * ✏️ fix variable name typo * 🐘 include waiting nodes to migrations * 🐛 fix reverting migrations command * ⚡ update typeorm command * ✨ create db:revert command * 👕 fix lint error Co-authored-by: Mutasem <mutdmour@gmail.com>
54 lines
1.6 KiB
TypeScript
54 lines
1.6 KiB
TypeScript
/* eslint-disable no-prototype-builtins */
|
|
import { INode, IWorkflowCredentials } from 'n8n-workflow';
|
|
// eslint-disable-next-line import/no-cycle
|
|
import { Db } from '.';
|
|
|
|
// eslint-disable-next-line @typescript-eslint/naming-convention
|
|
export async function WorkflowCredentials(nodes: INode[]): Promise<IWorkflowCredentials> {
|
|
// Go through all nodes to find which credentials are needed to execute the workflow
|
|
const returnCredentials: IWorkflowCredentials = {};
|
|
|
|
let node;
|
|
let type;
|
|
let nodeCredentials;
|
|
let foundCredentials;
|
|
// eslint-disable-next-line no-restricted-syntax
|
|
for (node of nodes) {
|
|
if (node.disabled === true || !node.credentials) {
|
|
// eslint-disable-next-line no-continue
|
|
continue;
|
|
}
|
|
|
|
// eslint-disable-next-line no-restricted-syntax
|
|
for (type of Object.keys(node.credentials)) {
|
|
if (!returnCredentials[type]) {
|
|
returnCredentials[type] = {};
|
|
}
|
|
nodeCredentials = node.credentials[type];
|
|
|
|
if (!nodeCredentials.id) {
|
|
throw new Error(
|
|
`Credentials with name "${nodeCredentials.name}" for type "${type}" miss an ID.`,
|
|
);
|
|
}
|
|
|
|
if (!returnCredentials[type][nodeCredentials.id]) {
|
|
// eslint-disable-next-line no-await-in-loop, @typescript-eslint/no-non-null-assertion
|
|
foundCredentials = await Db.collections.Credentials!.findOne({
|
|
id: nodeCredentials.id,
|
|
type,
|
|
});
|
|
if (!foundCredentials) {
|
|
throw new Error(
|
|
`Could not find credentials for type "${type}" with ID "${nodeCredentials.id}".`,
|
|
);
|
|
}
|
|
// eslint-disable-next-line prefer-destructuring
|
|
returnCredentials[type][nodeCredentials.id] = foundCredentials;
|
|
}
|
|
}
|
|
}
|
|
|
|
return returnCredentials;
|
|
}
|