From 40a43f59577abc581aa60dedfd006a0a59e867f8 Mon Sep 17 00:00:00 2001
From: Mutasem <mutdmour@gmail.com>
Date: Thu, 4 Aug 2022 11:27:37 +0200
Subject: [PATCH] add check for arr

---
 .../migrations/mysqldb/1658932910559-AddNodeIds.ts        | 6 ++++++
 .../migrations/postgresdb/1658932090381-AddNodeIds.ts     | 8 ++++++++
 .../migrations/sqlite/1658930531669-AddNodeIds.ts         | 8 ++++++++
 3 files changed, 22 insertions(+)

diff --git a/packages/cli/src/databases/migrations/mysqldb/1658932910559-AddNodeIds.ts b/packages/cli/src/databases/migrations/mysqldb/1658932910559-AddNodeIds.ts
index 6dbc16623a..7aea6da484 100644
--- a/packages/cli/src/databases/migrations/mysqldb/1658932910559-AddNodeIds.ts
+++ b/packages/cli/src/databases/migrations/mysqldb/1658932910559-AddNodeIds.ts
@@ -20,6 +20,9 @@ export class AddNodeIds1658932910559 implements MigrationInterface {
 		await runChunked(queryRunner, workflowsQuery, (workflows) => {
 			workflows.forEach(async (workflow) => {
 				const nodes = workflow.nodes;
+				if (!Array.isArray(nodes)) {
+					return;
+				}
 				// @ts-ignore
 				nodes.forEach((node) => {
 					if (!node.id) {
@@ -55,6 +58,9 @@ export class AddNodeIds1658932910559 implements MigrationInterface {
 		await runChunked(queryRunner, workflowsQuery, (workflows) => {
 			workflows.forEach(async (workflow) => {
 				const nodes = workflow.nodes;
+				if (!Array.isArray(nodes)) {
+					return;
+				}
 				// @ts-ignore
 				nodes.forEach((node) => delete node.id );
 
diff --git a/packages/cli/src/databases/migrations/postgresdb/1658932090381-AddNodeIds.ts b/packages/cli/src/databases/migrations/postgresdb/1658932090381-AddNodeIds.ts
index 3571693fa4..93a7f2396c 100644
--- a/packages/cli/src/databases/migrations/postgresdb/1658932090381-AddNodeIds.ts
+++ b/packages/cli/src/databases/migrations/postgresdb/1658932090381-AddNodeIds.ts
@@ -26,6 +26,10 @@ export class AddNodeIds1658932090381 implements MigrationInterface {
 		await runChunked(queryRunner, workflowsQuery, (workflows) => {
 			workflows.forEach(async (workflow) => {
 				const nodes = workflow.nodes;
+				if (!Array.isArray(nodes)) {
+					return;
+				}
+
 				// @ts-ignore
 				nodes.forEach((node) => {
 					if (!node.id) {
@@ -67,6 +71,10 @@ export class AddNodeIds1658932090381 implements MigrationInterface {
 		await runChunked(queryRunner, workflowsQuery, (workflows) => {
 			workflows.forEach(async (workflow) => {
 				const nodes = workflow.nodes;
+				if (!Array.isArray(nodes)) {
+					return;
+				}
+
 				// @ts-ignore
 				nodes.forEach((node) => delete node.id );
 
diff --git a/packages/cli/src/databases/migrations/sqlite/1658930531669-AddNodeIds.ts b/packages/cli/src/databases/migrations/sqlite/1658930531669-AddNodeIds.ts
index d772d5c47b..25504d5bf6 100644
--- a/packages/cli/src/databases/migrations/sqlite/1658930531669-AddNodeIds.ts
+++ b/packages/cli/src/databases/migrations/sqlite/1658930531669-AddNodeIds.ts
@@ -24,6 +24,10 @@ export class AddNodeIds1658930531669 implements MigrationInterface {
 		await runChunked(queryRunner, workflowsQuery, (workflows) => {
 			workflows.forEach(async (workflow) => {
 				const nodes = JSON.parse(workflow.nodes);
+				if (!Array.isArray(nodes)) {
+					return;
+				}
+
 				nodes.forEach((node: INode) => {
 					if (!node.id) {
 						node.id = uuid();
@@ -61,6 +65,10 @@ export class AddNodeIds1658930531669 implements MigrationInterface {
 		await runChunked(queryRunner, workflowsQuery, (workflows) => {
 			workflows.forEach(async (workflow) => {
 				const nodes = JSON.parse(workflow.nodes);
+				if (!Array.isArray(nodes)) {
+					return;
+				}
+
 				// @ts-ignore
 				nodes.forEach((node) => delete node.id );