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

refactor: Add lint rule for unsafe property access with lodash get/set (no-changelog) (#8587)

Browse Source
This commit is contained in:
Elias Meire
2024-02-08 15:32:04 +01:00
committed by GitHub
parent 8e392cfc1d
commit de6d466e5e
22 changed files with 90 additions and 71 deletions
Download Patch File Download Diff File Expand all files Collapse all files

4
packages/@n8n/nodes-langchain/nodes/output_parser/OutputParserStructured/OutputParserStructured.node.ts
View File

@@ -28,8 +28,8 @@ class N8nStructuredOutputParser<T extends z.ZodTypeAny> extends StructuredOutput
const parsed = (await super.parse(text)) as object; const parsed = (await super.parse(text)) as object;
return ( return (
get(parsed, `${STRUCTURED_OUTPUT_KEY}.${STRUCTURED_OUTPUT_OBJECT_KEY}`) ?? get(parsed, [STRUCTURED_OUTPUT_KEY, STRUCTURED_OUTPUT_OBJECT_KEY]) ??
get(parsed, `${STRUCTURED_OUTPUT_KEY}.${STRUCTURED_OUTPUT_ARRAY_KEY}`) ?? get(parsed, [STRUCTURED_OUTPUT_KEY, STRUCTURED_OUTPUT_ARRAY_KEY]) ??
get(parsed, STRUCTURED_OUTPUT_KEY) ?? get(parsed, STRUCTURED_OUTPUT_KEY) ??
parsed parsed
); );

5
packages/@n8n_io/eslint-config/base.js
View File

@@ -39,6 +39,9 @@ const config = (module.exports = {
/** https://github.com/sindresorhus/eslint-plugin-unicorn */ /** https://github.com/sindresorhus/eslint-plugin-unicorn */
'eslint-plugin-unicorn', 'eslint-plugin-unicorn',
/** https://github.com/wix-incubator/eslint-plugin-lodash */
'eslint-plugin-lodash',
], ],
extends: [ extends: [
@@ -458,6 +461,8 @@ const config = (module.exports = {
/** https://github.com/sindresorhus/eslint-plugin-unicorn/blob/main/docs/rules/no-useless-promise-resolve-reject.md */ /** https://github.com/sindresorhus/eslint-plugin-unicorn/blob/main/docs/rules/no-useless-promise-resolve-reject.md */
'unicorn/no-useless-promise-resolve-reject': 'error', 'unicorn/no-useless-promise-resolve-reject': 'error',
'lodash/path-style': ['error', 'as-needed'],
}, },
overrides: [ overrides: [

1
packages/@n8n_io/eslint-config/package.json
View File

@@ -13,6 +13,7 @@
"eslint-config-prettier": "^9.0.0", "eslint-config-prettier": "^9.0.0",
"eslint-import-resolver-typescript": "^3.6.1", "eslint-import-resolver-typescript": "^3.6.1",
"eslint-plugin-import": "^2.29.0", "eslint-plugin-import": "^2.29.0",
"eslint-plugin-lodash": "^7.4.0",
"eslint-plugin-n8n-local-rules": "^1.0.0", "eslint-plugin-n8n-local-rules": "^1.0.0",
"eslint-plugin-prettier": "^5.0.1", "eslint-plugin-prettier": "^5.0.1",
"eslint-plugin-unicorn": "^49.0.0", "eslint-plugin-unicorn": "^49.0.0",

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

@@ -2548,7 +2548,7 @@ const addExecutionDataFunctions = async (
runExecutionData.executionData!.metadata = {}; runExecutionData.executionData!.metadata = {};
} }
let sourceTaskData = get(runExecutionData, `executionData.metadata[${sourceNodeName}]`); let sourceTaskData = get(runExecutionData, ['executionData', 'metadata', sourceNodeName]);
if (!sourceTaskData) { if (!sourceTaskData) {
runExecutionData.executionData!.metadata[sourceNodeName] = []; runExecutionData.executionData!.metadata[sourceNodeName] = [];

11
packages/core/src/WorkflowExecute.ts
View File

@@ -337,10 +337,13 @@ export class WorkflowExecute {
): boolean { ): boolean {
// for (const inputConnection of workflow.connectionsByDestinationNode[nodeToAdd].main[0]) { // for (const inputConnection of workflow.connectionsByDestinationNode[nodeToAdd].main[0]) {
for (const inputConnection of inputConnections) { for (const inputConnection of inputConnections) {
const nodeIncomingData = get( const nodeIncomingData = get(runData, [
runData, inputConnection.node,
`[${inputConnection.node}][${runIndex}].data.main[${inputConnection.index}]`, runIndex,
); 'data',
'main',
inputConnection.index,
]);
if (nodeIncomingData !== undefined && (nodeIncomingData as object[]).length !== 0) { if (nodeIncomingData !== undefined && (nodeIncomingData as object[]).length !== 0) {
return false; return false;
} }

4
packages/editor-ui/src/components/CollectionParameter.vue
View File

@@ -176,11 +176,11 @@ function optionSelected(optionName: string) {
// The "fixedCollection" entries are different as they save values // The "fixedCollection" entries are different as they save values
// in an object and then underneath there is an array. So initialize // in an object and then underneath there is an array. So initialize
// them differently. // them differently.
const retrievedObjectValue = get(props.nodeValues, `${props.path}.${optionName}`, {}); const retrievedObjectValue = get(props.nodeValues, [props.path, optionName], {});
newValue = retrievedObjectValue; newValue = retrievedObjectValue;
} else { } else {
// Everything else saves them directly as an array. // Everything else saves them directly as an array.
const retrievedArrayValue = get(props.nodeValues, `${props.path}.${optionName}`, []) as Array< const retrievedArrayValue = get(props.nodeValues, [props.path, optionName], []) as Array<
typeof option.default typeof option.default
>; >;
if (Array.isArray(retrievedArrayValue)) { if (Array.isArray(retrievedArrayValue)) {

2
packages/editor-ui/src/components/FixedCollectionParameter.vue
View File

@@ -297,7 +297,7 @@ export default defineComponent({
// Multiple values are allowed so append option to array // Multiple values are allowed so append option to array
newParameterValue[optionParameter.name] = get( newParameterValue[optionParameter.name] = get(
this.nodeValues, this.nodeValues,
`${this.path}.${optionParameter.name}`, [this.path, optionParameter.name],
[], [],
); );
if (Array.isArray(optionParameter.default)) { if (Array.isArray(optionParameter.default)) {

6
packages/editor-ui/src/components/WorkflowLMChat.vue
View File

@@ -480,15 +480,15 @@ export default defineComponent({
const nodeResponseDataArray = get( const nodeResponseDataArray = get(
this.workflowsStore.getWorkflowExecution?.data?.resultData.runData, this.workflowsStore.getWorkflowExecution?.data?.resultData.runData,
`[${lastNodeExecuted}]`, lastNodeExecuted,
) as ITaskData[]; ) as ITaskData[];
const nodeResponseData = nodeResponseDataArray[nodeResponseDataArray.length - 1]; const nodeResponseData = nodeResponseDataArray[nodeResponseDataArray.length - 1];
let responseMessage: string; let responseMessage: string;
if (get(nodeResponseData, ['error'])) { if (get(nodeResponseData, 'error')) {
responseMessage = '[ERROR: ' + get(nodeResponseData, ['error', 'message']) + ']'; responseMessage = '[ERROR: ' + get(nodeResponseData, 'error.message') + ']';
} else { } else {
const responseData = get(nodeResponseData, 'data.main[0][0].json'); const responseData = get(nodeResponseData, 'data.main[0][0].json');
responseMessage = this.extractResponseMessage(responseData); responseMessage = this.extractResponseMessage(responseData);

9
packages/nodes-base/nodes/Aws/ELB/GenericFunctions.ts
View File

@@ -142,11 +142,8 @@ export async function awsApiRequestSOAPAllItems(
region, region,
); );
if (get(responseData, `${propertyNameArray[0]}.${propertyNameArray[1]}.NextMarker`)) { if (get(responseData, [propertyNameArray[0], propertyNameArray[1], 'NextMarker'])) {
query.Marker = get( query.Marker = get(responseData, [propertyNameArray[0], propertyNameArray[1], 'NextMarker']);
responseData,
`${propertyNameArray[0]}.${propertyNameArray[1]}.NextMarker`,
);
} }
if (get(responseData, propertyName)) { if (get(responseData, propertyName)) {
if (Array.isArray(get(responseData, propertyName))) { if (Array.isArray(get(responseData, propertyName))) {
@@ -156,7 +153,7 @@ export async function awsApiRequestSOAPAllItems(
} }
} }
} while ( } while (
get(responseData, `${propertyNameArray[0]}.${propertyNameArray[1]}.NextMarker`) !== undefined get(responseData, [propertyNameArray[0], propertyNameArray[1], 'NextMarker']) !== undefined
); );
return returnData; return returnData;

14
packages/nodes-base/nodes/Aws/Rekognition/GenericFunctions.ts
View File

@@ -139,11 +139,11 @@ export async function awsApiRequestSOAPAllItems(
); );
//https://forums.aws.amazon.com/thread.jspa?threadID=55746 //https://forums.aws.amazon.com/thread.jspa?threadID=55746
if (get(responseData, `${propertyName.split('.')[0]}.NextContinuationToken`)) { if (get(responseData, [propertyName.split('.')[0], 'NextContinuationToken'])) {
query['continuation-token'] = get( query['continuation-token'] = get(responseData, [
responseData, propertyName.split('.')[0],
`${propertyName.split('.')[0]}.NextContinuationToken`, 'NextContinuationToken',
); ]);
} }
if (get(responseData, propertyName)) { if (get(responseData, propertyName)) {
if (Array.isArray(get(responseData, propertyName))) { if (Array.isArray(get(responseData, propertyName))) {
@@ -157,8 +157,8 @@ export async function awsApiRequestSOAPAllItems(
return returnData; return returnData;
} }
} while ( } while (
get(responseData, `${propertyName.split('.')[0]}.IsTruncated`) !== undefined && get(responseData, [propertyName.split('.')[0], 'IsTruncated']) !== undefined &&
get(responseData, `${propertyName.split('.')[0]}.IsTruncated`) !== 'false' get(responseData, [propertyName.split('.')[0], 'IsTruncated']) !== 'false'
); );
return returnData; return returnData;

14
packages/nodes-base/nodes/Aws/S3/V1/GenericFunctions.ts
View File

@@ -137,11 +137,11 @@ export async function awsApiRequestSOAPAllItems(
); );
//https://forums.aws.amazon.com/thread.jspa?threadID=55746 //https://forums.aws.amazon.com/thread.jspa?threadID=55746
if (get(responseData, `${propertyName.split('.')[0]}.NextContinuationToken`)) { if (get(responseData, [propertyName.split('.')[0], 'NextContinuationToken'])) {
query['continuation-token'] = get( query['continuation-token'] = get(responseData, [
responseData, propertyName.split('.')[0],
`${propertyName.split('.')[0]}.NextContinuationToken`, 'NextContinuationToken',
); ]);
} }
if (get(responseData, propertyName)) { if (get(responseData, propertyName)) {
if (Array.isArray(get(responseData, propertyName))) { if (Array.isArray(get(responseData, propertyName))) {
@@ -155,8 +155,8 @@ export async function awsApiRequestSOAPAllItems(
return returnData; return returnData;
} }
} while ( } while (
get(responseData, `${propertyName.split('.')[0]}.IsTruncated`) !== undefined && get(responseData, [propertyName.split('.')[0], 'IsTruncated']) !== undefined &&
get(responseData, `${propertyName.split('.')[0]}.IsTruncated`) !== 'false' get(responseData, [propertyName.split('.')[0], 'IsTruncated']) !== 'false'
); );
return returnData; return returnData;

14
packages/nodes-base/nodes/Aws/S3/V2/GenericFunctions.ts
View File

@@ -107,11 +107,11 @@ export async function awsApiRequestRESTAllItems(
region, region,
); );
//https://forums.aws.amazon.com/thread.jspa?threadID=55746 //https://forums.aws.amazon.com/thread.jspa?threadID=55746
if (get(responseData, `${propertyName.split('.')[0]}.NextContinuationToken`)) { if (get(responseData, [propertyName.split('.')[0], 'NextContinuationToken'])) {
query['continuation-token'] = get( query['continuation-token'] = get(responseData, [
responseData, propertyName.split('.')[0],
`${propertyName.split('.')[0]}.NextContinuationToken`, 'NextContinuationToken',
); ]);
} }
if (get(responseData, propertyName)) { if (get(responseData, propertyName)) {
if (Array.isArray(get(responseData, propertyName))) { if (Array.isArray(get(responseData, propertyName))) {
@@ -125,8 +125,8 @@ export async function awsApiRequestRESTAllItems(
return returnData; return returnData;
} }
} while ( } while (
get(responseData, `${propertyName.split('.')[0]}.IsTruncated`) !== undefined && get(responseData, [propertyName.split('.')[0], 'IsTruncated']) !== undefined &&
get(responseData, `${propertyName.split('.')[0]}.IsTruncated`) !== 'false' get(responseData, [propertyName.split('.')[0], 'IsTruncated']) !== 'false'
); );
return returnData; return returnData;
} }

13
packages/nodes-base/nodes/Aws/SES/GenericFunctions.ts
View File

@@ -102,11 +102,12 @@ export async function awsApiRequestSOAPAllItems(
do { do {
responseData = await awsApiRequestSOAP.call(this, service, method, path, body, query); responseData = await awsApiRequestSOAP.call(this, service, method, path, body, query);
if (get(responseData, `${propertyNameArray[0]}.${propertyNameArray[1]}.NextToken`)) { if (get(responseData, [propertyNameArray[0], propertyNameArray[1], 'NextToken'])) {
query.NextToken = get( query.NextToken = get(responseData, [
responseData, propertyNameArray[0],
`${propertyNameArray[0]}.${propertyNameArray[1]}.NextToken`, propertyNameArray[1],
); 'NextToken',
]);
} }
if (get(responseData, propertyName)) { if (get(responseData, propertyName)) {
if (Array.isArray(get(responseData, propertyName))) { if (Array.isArray(get(responseData, propertyName))) {
@@ -116,7 +117,7 @@ export async function awsApiRequestSOAPAllItems(
} }
} }
} while ( } while (
get(responseData, `${propertyNameArray[0]}.${propertyNameArray[1]}.NextToken`) !== undefined get(responseData, [propertyNameArray[0], propertyNameArray[1], 'NextToken']) !== undefined
); );
return returnData; return returnData;

13
packages/nodes-base/nodes/Aws/Transcribe/GenericFunctions.ts
View File

@@ -109,11 +109,12 @@ export async function awsApiRequestRESTAllItems(
do { do {
responseData = await awsApiRequestREST.call(this, service, method, path, body, query); responseData = await awsApiRequestREST.call(this, service, method, path, body, query);
if (get(responseData, `${propertyNameArray[0]}.${propertyNameArray[1]}.NextToken`)) { if (get(responseData, [propertyNameArray[0], propertyNameArray[1], 'NextToken'])) {
query.NextToken = get( query.NextToken = get(responseData, [
responseData, propertyNameArray[0],
`${propertyNameArray[0]}.${propertyNameArray[1]}.NextToken`, propertyNameArray[1],
); 'NextToken',
]);
} }
if (get(responseData, propertyName)) { if (get(responseData, propertyName)) {
if (Array.isArray(get(responseData, propertyName))) { if (Array.isArray(get(responseData, propertyName))) {
@@ -123,7 +124,7 @@ export async function awsApiRequestRESTAllItems(
} }
} }
} while ( } while (
get(responseData, `${propertyNameArray[0]}.${propertyNameArray[1]}.NextToken`) !== undefined get(responseData, [propertyNameArray[0], propertyNameArray[1], 'NextToken']) !== undefined
); );
return returnData; return returnData;

2
packages/nodes-base/nodes/CompareDatasets/GenericFunctions.ts
View File

@@ -171,7 +171,7 @@ function combineItems(
entry.json[field] = match.json[field]; entry.json[field] = match.json[field];
} else { } else {
const value = get(match.json, field) || null; const value = get(match.json, field) || null;
set(entry, `json.${field}`, value); set(entry, ['json', field], value);
} }
}); });

2
packages/nodes-base/nodes/Crypto/Crypto.node.ts
View File

@@ -527,7 +527,7 @@ export class Crypto implements INodeType {
newItem.binary = item.binary; newItem.binary = item.binary;
} }
set(newItem, `json.${dataPropertyName}`, newValue); set(newItem, ['json', dataPropertyName], newValue);
returnData.push(newItem); returnData.push(newItem);
} catch (error) { } catch (error) {

4
packages/nodes-base/nodes/CustomerIo/GenericFunctions.ts
View File

@@ -48,9 +48,7 @@ export async function customerIoApiRequest(
export function eventExists(currentEvents: string[], webhookEvents: IDataObject) { export function eventExists(currentEvents: string[], webhookEvents: IDataObject) {
for (const currentEvent of currentEvents) { for (const currentEvent of currentEvents) {
if ( if (get(webhookEvents, [currentEvent.split('.')[0], currentEvent.split('.')[1]]) !== true) {
get(webhookEvents, `${currentEvent.split('.')[0]}.${currentEvent.split('.')[1]}`) !== true
) {
return false; return false;
} }
} }

4
packages/nodes-base/nodes/DateTime/V1/DateTimeV1.node.ts
View File

@@ -521,7 +521,7 @@ export class DateTimeV1 implements INodeType {
newItem.binary = item.binary; newItem.binary = item.binary;
} }
set(newItem, `json.${dataPropertyName}`, newDate); set(newItem, ['json', dataPropertyName], newDate);
returnData.push(newItem); returnData.push(newItem);
} }
@@ -565,7 +565,7 @@ export class DateTimeV1 implements INodeType {
newItem.binary = item.binary; newItem.binary = item.binary;
} }
set(newItem, `json.${dataPropertyName}`, newDate.toISOString()); set(newItem, ['json', dataPropertyName], newDate.toISOString());
returnData.push(newItem); returnData.push(newItem);
} }

6
packages/nodes-base/nodes/Linear/GenericFunctions.ts
View File

@@ -64,9 +64,9 @@ export async function linearApiRequestAllItems(
do { do {
responseData = await linearApiRequest.call(this, body); responseData = await linearApiRequest.call(this, body);
returnData.push.apply(returnData, get(responseData, `${propertyName}.nodes`) as IDataObject[]); returnData.push.apply(returnData, get(responseData, [propertyName, 'nodes']) as IDataObject[]);
body.variables.after = get(responseData, `${propertyName}.pageInfo.endCursor`); body.variables.after = get(responseData, [propertyName, 'pageInfo', 'endCursor']);
} while (get(responseData, `${propertyName}.pageInfo.hasNextPage`)); } while (get(responseData, [propertyName, 'pageInfo', 'hasNextPage']));
return returnData; return returnData;
} }

14
packages/nodes-base/nodes/S3/GenericFunctions.ts
View File

@@ -190,11 +190,11 @@ export async function s3ApiRequestSOAPAllItems(
); );
//https://forums.aws.amazon.com/thread.jspa?threadID=55746 //https://forums.aws.amazon.com/thread.jspa?threadID=55746
if (get(responseData, `${propertyName.split('.')[0]}.NextContinuationToken`)) { if (get(responseData, [propertyName.split('.')[0], 'NextContinuationToken'])) {
query['continuation-token'] = get( query['continuation-token'] = get(responseData, [
responseData, propertyName.split('.')[0],
`${propertyName.split('.')[0]}.NextContinuationToken`, 'NextContinuationToken',
); ]);
} }
if (get(responseData, propertyName)) { if (get(responseData, propertyName)) {
if (Array.isArray(get(responseData, propertyName))) { if (Array.isArray(get(responseData, propertyName))) {
@@ -208,8 +208,8 @@ export async function s3ApiRequestSOAPAllItems(
return returnData; return returnData;
} }
} while ( } while (
get(responseData, `${propertyName.split('.')[0]}.IsTruncated`) !== undefined && get(responseData, [propertyName.split('.')[0], 'IsTruncated']) !== undefined &&
get(responseData, `${propertyName.split('.')[0]}.IsTruncated`) !== 'false' get(responseData, [propertyName.split('.')[0], 'IsTruncated']) !== 'false'
); );
return returnData; return returnData;

4
packages/nodes-base/nodes/WhatsApp/MessageFunctions.ts
View File

@@ -76,9 +76,9 @@ export async function mediaUploadFromItem(
if (!requestOptions.body) { if (!requestOptions.body) {
requestOptions.body = {}; requestOptions.body = {};
} }
set(requestOptions.body as IDataObject, `${operation}.id`, result.id); set(requestOptions.body as IDataObject, [operation, 'id'], result.id);
if (operation === 'document') { if (operation === 'document') {
set(requestOptions.body as IDataObject, `${operation}.filename`, uploadData.fileName); set(requestOptions.body as IDataObject, [operation, 'filename'], uploadData.fileName);
} }
return requestOptions; return requestOptions;

13
pnpm-lock.yaml generated
View File

@@ -340,6 +340,9 @@ importers:
eslint-plugin-import: eslint-plugin-import:
specifier: ^2.29.0 specifier: ^2.29.0
version: 2.29.0(@typescript-eslint/parser@6.12.0)(eslint-import-resolver-typescript@3.6.1)(eslint@8.54.0) version: 2.29.0(@typescript-eslint/parser@6.12.0)(eslint-import-resolver-typescript@3.6.1)(eslint@8.54.0)
eslint-plugin-lodash:
specifier: ^7.4.0
version: 7.4.0(eslint@8.54.0)
eslint-plugin-n8n-local-rules: eslint-plugin-n8n-local-rules:
specifier: ^1.0.0 specifier: ^1.0.0
version: 1.0.0 version: 1.0.0
@@ -15028,6 +15031,16 @@ packages:
- supports-color - supports-color
dev: true dev: true
/eslint-plugin-lodash@7.4.0(eslint@8.54.0):
resolution: {integrity: sha512-Tl83UwVXqe1OVeBRKUeWcfg6/pCW1GTRObbdnbEJgYwjxp5Q92MEWQaH9+dmzbRt6kvYU1Mp893E79nJiCSM8A==}
engines: {node: '>=10'}
peerDependencies:
eslint: '>=2'
dependencies:
eslint: 8.54.0
lodash: 4.17.21
dev: true
/eslint-plugin-n8n-local-rules@1.0.0: /eslint-plugin-n8n-local-rules@1.0.0:
resolution: {integrity: sha512-qe6sVFDP1Vj5eXlqZxYZpIjwYvhuqXlI0P8OfPyhiPOhMkFtr0TpFphD8/6WCzkm7LJCvG1eJEzURCtMIsFTAg==} resolution: {integrity: sha512-qe6sVFDP1Vj5eXlqZxYZpIjwYvhuqXlI0P8OfPyhiPOhMkFtr0TpFphD8/6WCzkm7LJCvG1eJEzURCtMIsFTAg==}
dev: true dev: true