ws4kp/server/scripts/modules/currentweather.mjs

// current weather conditions display
import STATUS from './status.mjs';
import { loadImg, preloadImg } from './utils/image.mjs';
import { json } from './utils/fetch.mjs';
import { directionToNSEW } from './utils/calc.mjs';
import { locationCleanup } from './utils/string.mjs';
import { getWeatherIconFromIconLink } from './icons.mjs';
import WeatherDisplay from './weatherdisplay.mjs';
import { registerDisplay } from './navigation.mjs';
import {
	celsiusToFahrenheit, kphToMph, pascalToInHg, metersToFeet, kilometersToMiles,
} from './utils/units.mjs';

// some stations prefixed do not provide all the necessary data
const skipStations = ['U', 'C', 'H', 'W', 'Y', 'T', 'S', 'M', 'O', 'L', 'A', 'F', 'B', 'N', 'V', 'R', 'D', 'E', 'I', 'G', 'J'];

class CurrentWeather extends WeatherDisplay {
	constructor(navId, elemId) {
		super(navId, elemId, 'Current Conditions', true);
		// pre-load background image (returns promise)
		this.backgroundImage = loadImg('images/BackGround1_1.png');
	}

	async getData(_weatherParameters) {
		// always load the data for use in the lower scroll
		const superResult = super.getData(_weatherParameters);
		const weatherParameters = _weatherParameters ?? this.weatherParameters;

		// filter for 4-letter observation stations, only those contain sky conditions and thus an icon
		const filteredStations = weatherParameters.stations.filter((station) => station?.properties?.stationIdentifier?.length === 4 && !skipStations.includes(station.properties.stationIdentifier.slice(0, 1)));

		// Load the observations
		let observations; let
			station;
		// station number counter
		let stationNum = 0;
		while (!observations && stationNum < filteredStations.length) {
			// get the station
			station = filteredStations[stationNum];
			stationNum += 1;
			try {
				// station observations
				// eslint-disable-next-line no-await-in-loop
				observations = await json(`${station.id}/observations`, {
					cors: true,
					data: {
						limit: 2,
					},
					retryCount: 3,
					stillWaiting: () => this.stillWaiting(),
				});

				// test data quality
				if (observations.features[0].properties.temperature.value === null
					|| observations.features[0].properties.windSpeed.value === null
					|| observations.features[0].properties.textDescription === null
					|| observations.features[0].properties.textDescription === ''
					|| observations.features[0].properties.icon === null) {
					observations = undefined;
					throw new Error(`Unable to get observations: ${station.properties.stationIdentifier}, trying next station`);
				}
			} catch (e) {
				console.error(e);
			}
		}
		// test for data received
		if (!observations) {
			console.error('All current weather stations exhausted');
			if (this.isEnabled) this.setStatus(STATUS.failed);
			// send failed to subscribers
			this.getDataCallback(undefined);
			return;
		}

		// we only get here if there was no error above
		this.data = { ...observations, station };
		this.getDataCallback();

		// stop here if we're disabled
		if (!superResult) return;

		// preload the icon
		preloadImg(getWeatherIconFromIconLink(observations.features[0].properties.icon));
		this.setStatus(STATUS.loaded);
	}

	// format the data for use outside this function
	parseData() {
		if (!this.data) return false;
		const data = {};
		const observations = this.data.features[0].properties;
		// values from api are provided in metric
		data.observations = observations;
		data.Temperature = Math.round(observations.temperature.value);
		data.TemperatureUnit = 'C';
		data.DewPoint = Math.round(observations.dewpoint.value);
		data.Ceiling = Math.round(observations.cloudLayers[0]?.base?.value ?? 0);
		data.CeilingUnit = 'm.';
		data.Visibility = Math.round(observations.visibility.value / 1000);
		data.VisibilityUnit = ' km.';
		data.WindSpeed = Math.round(observations.windSpeed.value);
		data.WindDirection = directionToNSEW(observations.windDirection.value);
		data.Pressure = Math.round(observations.barometricPressure.value);
		data.HeatIndex = Math.round(observations.heatIndex.value);
		data.WindChill = Math.round(observations.windChill.value);
		data.WindGust = Math.round(observations.windGust.value);
		data.WindUnit = 'KPH';
		data.Humidity = Math.round(observations.relativeHumidity.value);
		data.Icon = getWeatherIconFromIconLink(observations.icon);
		data.PressureDirection = '';
		data.TextConditions = observations.textDescription;
		data.station = this.data.station;

		// difference since last measurement (pascals, looking for difference of more than 150)
		const pressureDiff = (observations.barometricPressure.value - this.data.features[1].properties.barometricPressure.value);
		if (pressureDiff > 150) data.PressureDirection = 'R';
		if (pressureDiff < -150) data.PressureDirection = 'F';

		data.Temperature = celsiusToFahrenheit(data.Temperature);
		data.TemperatureUnit = 'F';
		data.DewPoint = celsiusToFahrenheit(data.DewPoint);
		data.Ceiling = Math.round(metersToFeet(data.Ceiling) / 100) * 100;
		data.CeilingUnit = 'ft.';
		data.Visibility = kilometersToMiles(observations.visibility.value / 1000);
		data.VisibilityUnit = ' mi.';
		data.WindSpeed = kphToMph(data.WindSpeed);
		data.WindUnit = 'MPH';
		data.Pressure = pascalToInHg(data.Pressure).toFixed(2);
		data.HeatIndex = celsiusToFahrenheit(data.HeatIndex);
		data.WindChill = celsiusToFahrenheit(data.WindChill);
		data.WindGust = kphToMph(data.WindGust);
		return data;
	}

	async drawCanvas() {
		super.drawCanvas();
		const fill = {};
		// parse each time to deal with a change in units if necessary
		const data = this.parseData();

		fill.temp = data.Temperature + String.fromCharCode(176);

		let Conditions = data.observations.textDescription;
		if (Conditions.length > 15) {
			Conditions = shortConditions(Conditions);
		}
		fill.condition = Conditions;

		fill.wind = data.WindDirection.padEnd(3, '') + data.WindSpeed.toString().padStart(3, ' ');
		if (data.WindGust) fill['wind-gusts'] = `Gusts to ${data.WindGust}`;

		fill.location = locationCleanup(this.data.station.properties.name).substr(0, 20);

		fill.humidity = `${data.Humidity}%`;
		fill.dewpoint = data.DewPoint + String.fromCharCode(176);
		fill.ceiling = (data.Ceiling === 0 ? 'Unlimited' : data.Ceiling + data.CeilingUnit);
		fill.visibility = data.Visibility + data.VisibilityUnit;
		fill.pressure = `${data.Pressure} ${data.PressureDirection}`;

		if (data.observations.heatIndex.value && data.HeatIndex !== data.Temperature) {
			fill['heat-index-label'] = 'Heat Index:';
			fill['heat-index'] = data.HeatIndex + String.fromCharCode(176);
		} else if (data.observations.windChill.value && data.WindChill !== '' && data.WindChill < data.Temperature) {
			fill['heat-index-label'] = 'Wind Chill:';
			fill['heat-index'] = data.WindChill + String.fromCharCode(176);
		}

		fill.icon = { type: 'img', src: data.Icon };

		const area = this.elem.querySelector('.main');

		area.innerHTML = '';
		area.append(this.fillTemplate('weather', fill));

		this.finishDraw();
	}

	// make data available outside this class
	// promise allows for data to be requested before it is available
	async getCurrentWeather(stillWaiting) {
		if (stillWaiting) this.stillWaitingCallbacks.push(stillWaiting);
		return new Promise((resolve) => {
			if (this.data) resolve(this.parseData());
			// data not available, put it into the data callback queue
			this.getDataCallbacks.push(() => resolve(this.parseData()));
		});
	}
}

const shortConditions = (_condition) => {
	let condition = _condition;
	condition = condition.replace(/Light/g, 'L');
	condition = condition.replace(/Heavy/g, 'H');
	condition = condition.replace(/Partly/g, 'P');
	condition = condition.replace(/Mostly/g, 'M');
	condition = condition.replace(/Few/g, 'F');
	condition = condition.replace(/Thunderstorm/g, 'T\'storm');
	condition = condition.replace(/ in /g, '');
	condition = condition.replace(/Vicinity/g, '');
	condition = condition.replace(/ and /g, ' ');
	condition = condition.replace(/Freezing Rain/g, 'Frz Rn');
	condition = condition.replace(/Freezing/g, 'Frz');
	condition = condition.replace(/Unknown Precip/g, '');
	condition = condition.replace(/L Snow Fog/g, 'L Snw/Fog');
	condition = condition.replace(/ with /g, '/');
	return condition;
};

const display = new CurrentWeather(1, 'current-weather');
registerDisplay(display);

export default display.getCurrentWeather.bind(display);