From e3e033d2034283ebd1cee30bb277b07458a52ac3 Mon Sep 17 00:00:00 2001
From: =?UTF-8?q?Iv=C3=A1n=20Ovejero?= <ivov.src@gmail.com>
Date: Mon, 26 Aug 2024 11:16:17 +0200
Subject: [PATCH 1/2] refactor(core): Map out pubsub messages (no-changelog)

---
 .../pubsub/pubsub-message-map.ts              | 104 ++++++++++++++++++
 1 file changed, 104 insertions(+)
 create mode 100644 packages/cli/src/services/orchestration/pubsub/pubsub-message-map.ts

diff --git a/packages/cli/src/services/orchestration/pubsub/pubsub-message-map.ts b/packages/cli/src/services/orchestration/pubsub/pubsub-message-map.ts
new file mode 100644
index 0000000000000..f4859ed749c53
--- /dev/null
+++ b/packages/cli/src/services/orchestration/pubsub/pubsub-message-map.ts
@@ -0,0 +1,104 @@
+import type { IPushDataType, IWorkflowDb } from '@/Interfaces';
+import type { RunningJobSummary } from '@/scaling/types';
+
+export type PubSubMessageMap = {
+	// #region Lifecycle
+
+	'reload-license': never;
+
+	'restart-event-bus': {
+		result: 'success' | 'error';
+		error?: string;
+	};
+
+	'reload-external-secrets-providers': {
+		result: 'success' | 'error';
+		error?: string;
+	};
+
+	'stop-worker': never;
+
+	// #endregion
+
+	// #region Community packages
+
+	'community-package-install': {
+		packageName: string;
+		packageVersion: string;
+	};
+
+	'community-package-update': {
+		packageName: string;
+		packageVersion: string;
+	};
+
+	'community-package-uninstall': {
+		packageName: string;
+		packageVersion: string;
+	};
+
+	// #endregion
+
+	// #region Worker view
+
+	'get-worker-id': never;
+
+	'get-worker-status': {
+		workerId: string;
+		runningJobsSummary: RunningJobSummary[];
+		freeMem: number;
+		totalMem: number;
+		uptime: number;
+		loadAvg: number[];
+		cpus: string;
+		arch: string;
+		platform: NodeJS.Platform;
+		hostname: string;
+		interfaces: Array<{
+			family: 'IPv4' | 'IPv6';
+			address: string;
+			internal: boolean;
+		}>;
+		version: string;
+	};
+
+	// #endregion
+
+	// #region Multi-main setup
+
+	'add-webhooks-triggers-and-pollers': {
+		workflowId: string;
+	};
+
+	'remove-triggers-and-pollers': {
+		workflowId: string;
+	};
+
+	'display-workflow-activation': {
+		workflowId: string;
+	};
+
+	'display-workflow-deactivation': {
+		workflowId: string;
+	};
+
+	// currently 'workflow-failed-to-activate'
+	'display-workflow-activation-error': {
+		workflowId: string;
+		errorMessage: string;
+	};
+
+	'relay-execution-lifecycle-event': {
+		type: IPushDataType;
+		args: Record<string, unknown>;
+		pushRef: string;
+	};
+
+	'clear-test-webhooks': {
+		webhookKey: string;
+		workflowEntity: IWorkflowDb;
+		pushRef: string;
+	};
+
+	// #endregion
+};

From 9203ac59489689fa177c602454ad5d9dc9e76121 Mon Sep 17 00:00:00 2001
From: =?UTF-8?q?Iv=C3=A1n=20Ovejero?= <ivov.src@gmail.com>
Date: Tue, 27 Aug 2024 10:15:49 +0200
Subject: [PATCH 2/2] Fix import

---
 .../cli/src/services/orchestration/pubsub/pubsub-message-map.ts | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/packages/cli/src/services/orchestration/pubsub/pubsub-message-map.ts b/packages/cli/src/services/orchestration/pubsub/pubsub-message-map.ts
index f4859ed749c53..d379bc93c0bdd 100644
--- a/packages/cli/src/services/orchestration/pubsub/pubsub-message-map.ts
+++ b/packages/cli/src/services/orchestration/pubsub/pubsub-message-map.ts
@@ -1,5 +1,5 @@
 import type { IPushDataType, IWorkflowDb } from '@/Interfaces';
-import type { RunningJobSummary } from '@/scaling/types';
+import type { RunningJobSummary } from '@/scaling/scaling.types';
 
 export type PubSubMessageMap = {
 	// #region Lifecycle