Method setSocketIO

js/node_helper.js:103–127

(io)

	 * argument io Socket.io - The Socket io object.
	 */
	setSocketIO (io) {
		this.io = io;

		Log.log(`Connecting socket for: ${this.name}`);

		io.of(this.name).on("connection", (socket) => {
			// register catch all.
			socket.onAny((notification, payload) => {
				if (config?.hideConfigSecrets && payload && typeof payload === "object") {
					try {
						// Calculate exactly which secrets this module is allowed to receive
						const allowedSecrets = getAllowedSecrets(this.name);
						// Expand only these safe, module-specific secrets in the payload
						const payloadStr = replaceSecretPlaceholder(JSON.stringify(payload), allowedSecrets);
						this.socketNotificationReceived(notification, JSON.parse(payloadStr));
					} catch (e) {
						Log.error("Error substituting variables in payload: ", e);
						this.socketNotificationReceived(notification, payload);
					}
				} else {
					this.socketNotificationReceived(notification, payload);
				}
			});
		});
	}

	/**
	 * Check the status of a fetch response.