Function initWeatherProvider

defaultmodules/weather/node_helper.js:28–94

* Initialize a weather provider * @param {object} config The configuration object

(config)

	 * @param {object} config The configuration object
	 */
	async initWeatherProvider (config) {
		const identifier = config.weatherProvider.toLowerCase();
		const instanceId = config.instanceId;

		Log.log(`Attempting to initialize provider ${identifier} for instance ${instanceId}`);

		if (this.providers[instanceId]) {
			Log.log(`Weather provider ${identifier} already initialized for instance ${instanceId}, re-sending WEATHER_INITIALIZED`);
			// Client may have restarted (e.g. page reload) - re-send so it recovers location name
			this.sendSocketNotification("WEATHER_INITIALIZED", {
				instanceId,
				locationName: this.providers[instanceId].locationName
			});
			// Push cached data immediately so reconnecting clients don't wait for next scheduled fetch
			if (this.lastData[instanceId]) {
				this.sendSocketNotification("WEATHER_DATA", this.lastData[instanceId]);
			}
			return;
		}

		try {
			// Dynamically load the provider module
			const providerPath = path.join(__dirname, "providers", `${identifier}.js`);
			Log.log(`Loading provider from: ${providerPath}`);
			const ProviderClass = require(providerPath);

			// Create provider instance
			const provider = new ProviderClass(config);

			// Set up callbacks before initializing
			provider.setCallbacks(
				(data) => {
					// On data received
					const payload = { instanceId, type: config.type, data };
					this.lastData[instanceId] = payload;
					this.sendSocketNotification("WEATHER_DATA", payload);
				},
				(errorInfo) => {
					// On error
					this.sendSocketNotification("WEATHER_ERROR", {
						instanceId,
						error: errorInfo.message || "Unknown error",
						translationKey: errorInfo.translationKey
					});
				}
			);

			await provider.initialize();
			this.providers[instanceId] = provider;

			this.sendSocketNotification("WEATHER_INITIALIZED", {
				instanceId,
				locationName: provider.locationName
			});

			// Start periodic fetching
			provider.start();