Refactor and get tests work again

Author: KristjanESPERANTO

js/server_functions.js

@@ -30,6 +30,7 @@ function getStartup (req, res) {
  * Only the url-param of the input request url is required. It must be the last parameter.
  * @param {Request} req - the request
  * @param {Response} res - the result
+ * @returns {Promise<void>} A promise that resolves when the response is sent
  */
 async function cors (req, res) {
 	try {
@@ -40,27 +41,26 @@ async function cors (req, res) {
 		if (!match) {
 			url = `invalid url: ${req.url}`;
 			Log.error(url);
-			res.send(url);
-			return;
-		}
-		url = match[1];
-
-		const headersToSend = getHeadersToSend(req.url);
-		const expectedReceivedHeaders = geExpectedReceivedHeaders(req.url);
-		Log.log(`cors url: ${url}`);
-
-		const response = await fetch(url, { headers: headersToSend });
-		if (response.ok) {
-			for (const header of expectedReceivedHeaders) {
-				const headerValue = response.headers.get(header);
-				if (header) res.set(header, headerValue);
-			}
-			const data = await response.text();
-			res.send(data);
+			return res.status(400).send(url);
 		} else {
-			res.status(response.status).json({ message: response.statusText });
+			url = match[1];
+
+			const headersToSend = getHeadersToSend(req.url);
+			const expectedReceivedHeaders = geExpectedReceivedHeaders(req.url);
+			Log.log(`cors url: ${url}`);
+
+			const response = await fetch(url, { headers: headersToSend });
+			if (response.ok) {
+				for (const header of expectedReceivedHeaders) {
+					const headerValue = response.headers.get(header);
+					if (header) res.set(header, headerValue);
+				}
+				const data = await response.text();
+				res.send(data);
+			} else {
+				throw new Error(`Response status: ${response.status}`);
+			}
 		}
-
 	} catch (error) {
 		// Only log errors in non-test environments to keep test output clean
 		if (process.env.mmTestMode !== "true") {

modules/default/utils.js

@@ -39,6 +39,7 @@ async function performWebRequest (url, type = "json", useCorsProxy = false, requ
 		}
 	} catch (error) {
 		Log.error(`Error fetching data from ${url}: ${error}`);
+		return undefined;
 	}
 }
 

modules/default/weather/providers/pirateweather.js

@@ -22,38 +22,36 @@ WeatherProvider.register("pirateweather", {
 		lon: 0
 	},
 
-	fetchCurrentWeather () {
-		this.fetchData(this.getUrl())
-			.then((data) => {
-				if (!data || !data.currently || typeof data.currently.temperature === "undefined") {
-					// No usable data?
-					return;
-				}
+	async fetchCurrentWeather () {
+		try {
+			const data = await this.fetchData(this.getUrl());
+			if (!data || !data.currently || typeof data.currently.temperature === "undefined") {
+				throw new Error("No usable data received from Pirate Weather API.");
+			}
 
-				const currentWeather = this.generateWeatherDayFromCurrentWeather(data);
-				this.setCurrentWeather(currentWeather);
-			})
-			.catch(function (request) {
-				Log.error("[weatherprovider.pirateweather] Could not load data ... ", request);
-			})
-			.finally(() => this.updateAvailable());
+			const currentWeather = this.generateWeatherDayFromCurrentWeather(data);
+			this.setCurrentWeather(currentWeather);
+		} catch (error) {
+			Log.error("Could not load data ... ", error);
+		} finally {
+			this.updateAvailable();
+		}
 	},
 
-	fetchWeatherForecast () {
-		this.fetchData(this.getUrl())
-			.then((data) => {
-				if (!data || !data.daily || !data.daily.data.length) {
-					// No usable data?
-					return;
-				}
+	async fetchWeatherForecast () {
+		try {
+			const data = await this.fetchData(this.getUrl());
+			if (!data || !data.daily || !data.daily.data.length) {
+				throw new Error("No usable data received from Pirate Weather API.");
+			}
 
-				const forecast = this.generateWeatherObjectsFromForecast(data.daily.data);
-				this.setWeatherForecast(forecast);
-			})
-			.catch(function (request) {
-				Log.error("[weatherprovider.pirateweather] Could not load data ... ", request);
-			})
-			.finally(() => this.updateAvailable());
+			const forecast = this.generateWeatherObjectsFromForecast(data.daily.data);
+			this.setWeatherForecast(forecast);
+		} catch (error) {
+			Log.error("Could not load data ... ", error);
+		} finally {
+			this.updateAvailable();
+		}
 	},
 
 	// Create a URL from the config and base URL.

tests/unit/functions/server_functions_spec.js

@@ -16,7 +16,8 @@ describe("server_functions tests", () => {
 				headers: {
 					get: fetchResponseHeadersGet
 				},
-				text: fetchResponseHeadersText
+				text: fetchResponseHeadersText,
+				ok: true
 			};
 
 			fetch = vi.fn();
@@ -26,7 +27,12 @@ describe("server_functions tests", () => {
 
 			corsResponse = {
 				set: vi.fn(() => {}),
-				send: vi.fn(() => {})
+				send: vi.fn(() => {}),
+				status: vi.fn(function (code) {
+					this.statusCode = code;
+					return this;
+				}),
+				json: vi.fn(() => {})
 			};
 
 			request = {
@@ -91,15 +97,11 @@ describe("server_functions tests", () => {
 				throw error;
 			});
 
-			let sentData;
-			corsResponse.send = vi.fn((input) => {
-				sentData = input;
-			});
-
 			await cors(request, corsResponse);
 
 			expect(fetchResponseHeadersText.mock.calls).toHaveLength(1);
-			expect(sentData).toBe(error);
+			expect(corsResponse.status).toHaveBeenCalledWith(500);
+			expect(corsResponse.json).toHaveBeenCalledWith({ error: error.message });
 		});
 
 		it("Fetches with user agent by default", async () => {