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

add check for arr

Browse Source
This commit is contained in:
Mutasem
2022-08-04 11:27:37 +02:00
parent 43a91b8bd3
commit 40a43f5957
3 changed files with 22 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files

6
packages/cli/src/databases/migrations/mysqldb/1658932910559-AddNodeIds.ts
View File

@@ -20,6 +20,9 @@ export class AddNodeIds1658932910559 implements MigrationInterface {
await runChunked(queryRunner, workflowsQuery, (workflows) => { await runChunked(queryRunner, workflowsQuery, (workflows) => {
workflows.forEach(async (workflow) => { workflows.forEach(async (workflow) => {
const nodes = workflow.nodes; const nodes = workflow.nodes;
if (!Array.isArray(nodes)) {
return;
}
// @ts-ignore // @ts-ignore
nodes.forEach((node) => { nodes.forEach((node) => {
if (!node.id) { if (!node.id) {
@@ -55,6 +58,9 @@ export class AddNodeIds1658932910559 implements MigrationInterface {
await runChunked(queryRunner, workflowsQuery, (workflows) => { await runChunked(queryRunner, workflowsQuery, (workflows) => {
workflows.forEach(async (workflow) => { workflows.forEach(async (workflow) => {
const nodes = workflow.nodes; const nodes = workflow.nodes;
if (!Array.isArray(nodes)) {
return;
}
// @ts-ignore // @ts-ignore
nodes.forEach((node) => delete node.id ); nodes.forEach((node) => delete node.id );

8
packages/cli/src/databases/migrations/postgresdb/1658932090381-AddNodeIds.ts
View File

@@ -26,6 +26,10 @@ export class AddNodeIds1658932090381 implements MigrationInterface {
await runChunked(queryRunner, workflowsQuery, (workflows) => { await runChunked(queryRunner, workflowsQuery, (workflows) => {
workflows.forEach(async (workflow) => { workflows.forEach(async (workflow) => {
const nodes = workflow.nodes; const nodes = workflow.nodes;
if (!Array.isArray(nodes)) {
return;
}
// @ts-ignore // @ts-ignore
nodes.forEach((node) => { nodes.forEach((node) => {
if (!node.id) { if (!node.id) {
@@ -67,6 +71,10 @@ export class AddNodeIds1658932090381 implements MigrationInterface {
await runChunked(queryRunner, workflowsQuery, (workflows) => { await runChunked(queryRunner, workflowsQuery, (workflows) => {
workflows.forEach(async (workflow) => { workflows.forEach(async (workflow) => {
const nodes = workflow.nodes; const nodes = workflow.nodes;
if (!Array.isArray(nodes)) {
return;
}
// @ts-ignore // @ts-ignore
nodes.forEach((node) => delete node.id ); nodes.forEach((node) => delete node.id );

8
packages/cli/src/databases/migrations/sqlite/1658930531669-AddNodeIds.ts
View File

@@ -24,6 +24,10 @@ export class AddNodeIds1658930531669 implements MigrationInterface {
await runChunked(queryRunner, workflowsQuery, (workflows) => { await runChunked(queryRunner, workflowsQuery, (workflows) => {
workflows.forEach(async (workflow) => { workflows.forEach(async (workflow) => {
const nodes = JSON.parse(workflow.nodes); const nodes = JSON.parse(workflow.nodes);
if (!Array.isArray(nodes)) {
return;
}
nodes.forEach((node: INode) => { nodes.forEach((node: INode) => {
if (!node.id) { if (!node.id) {
node.id = uuid(); node.id = uuid();
@@ -61,6 +65,10 @@ export class AddNodeIds1658930531669 implements MigrationInterface {
await runChunked(queryRunner, workflowsQuery, (workflows) => { await runChunked(queryRunner, workflowsQuery, (workflows) => {
workflows.forEach(async (workflow) => { workflows.forEach(async (workflow) => {
const nodes = JSON.parse(workflow.nodes); const nodes = JSON.parse(workflow.nodes);
if (!Array.isArray(nodes)) {
return;
}
// @ts-ignore // @ts-ignore
nodes.forEach((node) => delete node.id ); nodes.forEach((node) => delete node.id );