mirror of
https://github.com/netbymatt/ws4kp.git
synced 2026-04-16 08:39:29 -07:00
Compare commits
20 Commits
| Author | SHA1 | Date | |
|---|---|---|---|
|
|
d8e0399e92 | ||
|
|
f456897520 | ||
|
|
9303035bb9 | ||
|
|
3c40219003 | ||
|
|
392b339727 | ||
|
|
852eff8de6 | ||
|
|
c74a15c40c | ||
|
|
5419425834 | ||
|
|
f3a386079b | ||
|
|
aa43713943 | ||
|
|
1dece10679 | ||
|
|
c4f16d786a | ||
|
|
36b8adc019 | ||
|
|
bfe0b4757d | ||
|
|
2b61e55783 | ||
|
|
36c4f451b3 | ||
|
|
268d4ae7fa | ||
|
|
1b49e02cd8 | ||
|
|
9a55a6ec39 | ||
|
|
974a061b44 |
2
.github/workflows/build-docker.yaml
vendored
2
.github/workflows/build-docker.yaml
vendored
@@ -49,7 +49,7 @@ jobs:
|
||||
with:
|
||||
context: .
|
||||
pull: true
|
||||
push: ${{ github.ref == 'refs/heads/main' }}
|
||||
push: ${{ github.ref == 'refs/heads/main' || startsWith(github.ref, 'refs/tags/') }}
|
||||
platforms: linux/amd64,linux/arm64/v8
|
||||
tags: ${{ steps.meta.outputs.tags }}
|
||||
labels: ${{ steps.meta.outputs.labels }}
|
||||
|
||||
@@ -139,6 +139,11 @@ Ws4kp is muted by default, but if it was unmuted on the last visit it is coded t
|
||||
|
||||
Chrome seems to be more lenient on auto play and will eventually let a site auto-play music if you're visited it enough recently and manually clicked to start playing music on each visit. It also has a flag you can add to the command line when launching Chrome: `chrome.exe --autoplay-policy=no-user-gesture-required`. This is the best solution when using Kiosk-style setup.
|
||||
|
||||
If you're unable to pre-set the play state before entering kiosk mode (such as with a home dashboard implemenation) you can add the query string value below to the url. The browser will still follow the auto play rules outlined above.
|
||||
```
|
||||
?settings-mediaPlaying-boolean=true
|
||||
```
|
||||
|
||||
## Community Notes
|
||||
|
||||
Thanks to the WeatherStar community for providing these discussions to further extend your retro forecasts!
|
||||
|
||||
@@ -1,45 +0,0 @@
|
||||
// pass through api requests
|
||||
|
||||
// http(s) modules
|
||||
import https from 'https';
|
||||
|
||||
// url parsing
|
||||
import queryString from 'querystring';
|
||||
|
||||
// return an express router
|
||||
const cors = (req, res) => {
|
||||
// add out-going headers
|
||||
const headers = {};
|
||||
headers['user-agent'] = '(WeatherStar 4000+, ws4000@netbymatt.com)';
|
||||
headers.accept = req.headers.accept;
|
||||
|
||||
// get query paramaters if the exist
|
||||
const queryParams = Object.keys(req.query).reduce((acc, key) => {
|
||||
// skip the paramater 'u'
|
||||
if (key === 'u') return acc;
|
||||
// add the paramter to the resulting object
|
||||
acc[key] = req.query[key];
|
||||
return acc;
|
||||
}, {});
|
||||
let query = queryString.encode(queryParams);
|
||||
if (query.length > 0) query = `?${query}`;
|
||||
|
||||
// get the page
|
||||
https.get(`https://api.weather.gov${req.path}${query}`, {
|
||||
headers,
|
||||
}, (getRes) => {
|
||||
// pull some info
|
||||
const { statusCode } = getRes;
|
||||
// pass the status code through
|
||||
res.status(statusCode);
|
||||
|
||||
// set headers
|
||||
res.header('content-type', getRes.headers['content-type']);
|
||||
// pipe to response
|
||||
getRes.pipe(res);
|
||||
}).on('error', (e) => {
|
||||
console.error(e);
|
||||
});
|
||||
};
|
||||
|
||||
export default cors;
|
||||
@@ -1,46 +0,0 @@
|
||||
// pass through api requests
|
||||
|
||||
// http(s) modules
|
||||
import https from 'https';
|
||||
|
||||
// url parsing
|
||||
import queryString from 'querystring';
|
||||
|
||||
// return an express router
|
||||
const outlook = (req, res) => {
|
||||
// add out-going headers
|
||||
const headers = {};
|
||||
headers['user-agent'] = '(WeatherStar 4000+, ws4000@netbymatt.com)';
|
||||
headers.accept = req.headers.accept;
|
||||
|
||||
// get query paramaters if the exist
|
||||
const queryParams = Object.keys(req.query).reduce((acc, key) => {
|
||||
// skip the paramater 'u'
|
||||
if (key === 'u') return acc;
|
||||
// add the paramter to the resulting object
|
||||
acc[key] = req.query[key];
|
||||
return acc;
|
||||
}, {});
|
||||
let query = queryString.encode(queryParams);
|
||||
if (query.length > 0) query = `?${query}`;
|
||||
|
||||
// get the page
|
||||
https.get(`https://www.cpc.ncep.noaa.gov/${req.path}${query}`, {
|
||||
headers,
|
||||
}, (getRes) => {
|
||||
// pull some info
|
||||
const { statusCode } = getRes;
|
||||
// pass the status code through
|
||||
res.status(statusCode);
|
||||
|
||||
// set headers
|
||||
res.header('content-type', getRes.headers['content-type']);
|
||||
res.header('last-modified', getRes.headers['last-modified']);
|
||||
// pipe to response
|
||||
getRes.pipe(res);
|
||||
}).on('error', (e) => {
|
||||
console.error(e);
|
||||
});
|
||||
};
|
||||
|
||||
export default outlook;
|
||||
@@ -1,46 +0,0 @@
|
||||
// pass through api requests
|
||||
|
||||
// http(s) modules
|
||||
import https from 'https';
|
||||
|
||||
// url parsing
|
||||
import queryString from 'querystring';
|
||||
|
||||
// return an express router
|
||||
const radar = (req, res) => {
|
||||
// add out-going headers
|
||||
const headers = {};
|
||||
headers['user-agent'] = '(WeatherStar 4000+, ws4000@netbymatt.com)';
|
||||
headers.accept = req.headers.accept;
|
||||
|
||||
// get query paramaters if the exist
|
||||
const queryParams = Object.keys(req.query).reduce((acc, key) => {
|
||||
// skip the paramater 'u'
|
||||
if (key === 'u') return acc;
|
||||
// add the paramter to the resulting object
|
||||
acc[key] = req.query[key];
|
||||
return acc;
|
||||
}, {});
|
||||
let query = queryString.encode(queryParams);
|
||||
if (query.length > 0) query = `?${query}`;
|
||||
|
||||
// get the page
|
||||
https.get(`https://radar.weather.gov${req.path}${query}`, {
|
||||
headers,
|
||||
}, (getRes) => {
|
||||
// pull some info
|
||||
const { statusCode } = getRes;
|
||||
// pass the status code through
|
||||
res.status(statusCode);
|
||||
|
||||
// set headers
|
||||
res.header('content-type', getRes.headers['content-type']);
|
||||
res.header('last-modified', getRes.headers['last-modified']);
|
||||
// pipe to response
|
||||
getRes.pipe(res);
|
||||
}).on('error', (e) => {
|
||||
console.error(e);
|
||||
});
|
||||
};
|
||||
|
||||
export default radar;
|
||||
@@ -96,6 +96,19 @@ const buildJs = () => src(mjsSources)
|
||||
.pipe(webpack(webpackOptions))
|
||||
.pipe(dest(RESOURCES_PATH));
|
||||
|
||||
const workerSources = [
|
||||
'server/scripts/modules/radar-worker.mjs',
|
||||
];
|
||||
|
||||
const buildWorkers = () => {
|
||||
// update the file name in the webpack options
|
||||
const output = { filename: 'radar-worker.mjs' };
|
||||
const workerWebpackOptions = { ...webpackOptions, output };
|
||||
return src(workerSources)
|
||||
.pipe(webpack(workerWebpackOptions))
|
||||
.pipe(dest(RESOURCES_PATH));
|
||||
};
|
||||
|
||||
const cssSources = [
|
||||
'server/styles/main.css',
|
||||
];
|
||||
@@ -137,6 +150,8 @@ const s3 = s3Upload({
|
||||
const uploadSources = [
|
||||
'dist/**',
|
||||
'!dist/**/*.map',
|
||||
'!dist/images/**/*',
|
||||
'!dist/fonts/**/*',
|
||||
];
|
||||
const upload = () => src(uploadSources, { base: './dist', encoding: false })
|
||||
.pipe(s3({
|
||||
@@ -167,6 +182,9 @@ const uploadImages = () => src(imageSources, { base: './server', encoding: false
|
||||
}),
|
||||
);
|
||||
|
||||
const copyImageSources = () => src(imageSources, { base: './server', encoding: false })
|
||||
.pipe(dest('./dist'));
|
||||
|
||||
const invalidate = () => cloudfront.send(new CreateInvalidationCommand({
|
||||
DistributionId: process.env.DISTRIBUTION_ID,
|
||||
InvalidationBatch: {
|
||||
@@ -184,7 +202,7 @@ const buildPlaylist = async () => {
|
||||
return file('playlist.json', JSON.stringify(playlist)).pipe(dest('./dist'));
|
||||
};
|
||||
|
||||
const buildDist = series(clean, parallel(buildJs, compressJsData, compressJsVendor, copyCss, compressHtml, copyOtherFiles, buildPlaylist));
|
||||
const buildDist = series(clean, parallel(buildJs, buildWorkers, compressJsData, compressJsVendor, copyCss, compressHtml, copyOtherFiles, copyImageSources, buildPlaylist));
|
||||
|
||||
// upload_images could be in parallel with upload, but _images logs a lot and has little changes
|
||||
// by running upload last the majority of the changes will be at the bottom of the log for easy viewing
|
||||
|
||||
14
index.mjs
14
index.mjs
@@ -1,9 +1,6 @@
|
||||
import 'dotenv/config';
|
||||
import express from 'express';
|
||||
import fs from 'fs';
|
||||
import corsPassThru from './cors/index.mjs';
|
||||
import radarPassThru from './cors/radar.mjs';
|
||||
import outlookPassThru from './cors/outlook.mjs';
|
||||
import playlist from './src/playlist.mjs';
|
||||
import OVERRIDES from './src/overrides.mjs';
|
||||
|
||||
@@ -13,12 +10,6 @@ const port = process.env.WS4KP_PORT ?? 8080;
|
||||
// template engine
|
||||
app.set('view engine', 'ejs');
|
||||
|
||||
// cors pass-thru to api.weather.gov
|
||||
app.get('/stations/*station', corsPassThru);
|
||||
app.get('/Conus/*radar', radarPassThru);
|
||||
app.get('/products/*product', outlookPassThru);
|
||||
app.get('/playlist.json', playlist);
|
||||
|
||||
// version
|
||||
const { version } = JSON.parse(fs.readFileSync('package.json'));
|
||||
|
||||
@@ -81,8 +72,6 @@ const geoip = (req, res) => {
|
||||
// debugging
|
||||
if (process.env?.DIST === '1') {
|
||||
// distribution
|
||||
app.use('/images', express.static('./server/images'));
|
||||
app.use('/fonts', express.static('./server/fonts'));
|
||||
app.use('/scripts', express.static('./server/scripts'));
|
||||
app.use('/geoip', geoip);
|
||||
app.use('/', express.static('./dist'));
|
||||
@@ -90,8 +79,11 @@ if (process.env?.DIST === '1') {
|
||||
// debugging
|
||||
app.get('/index.html', index);
|
||||
app.use('/geoip', geoip);
|
||||
app.use('/resources', express.static('./server/scripts/modules'));
|
||||
app.get('/', index);
|
||||
app.get('*name', express.static('./server'));
|
||||
// cors pass-thru to api.weather.gov
|
||||
app.get('/playlist.json', playlist);
|
||||
}
|
||||
|
||||
const server = app.listen(port, () => {
|
||||
|
||||
4
package-lock.json
generated
4
package-lock.json
generated
@@ -1,12 +1,12 @@
|
||||
{
|
||||
"name": "ws4kp",
|
||||
"version": "5.23.2",
|
||||
"version": "5.24.0",
|
||||
"lockfileVersion": 3,
|
||||
"requires": true,
|
||||
"packages": {
|
||||
"": {
|
||||
"name": "ws4kp",
|
||||
"version": "5.23.2",
|
||||
"version": "5.24.0",
|
||||
"license": "MIT",
|
||||
"dependencies": {
|
||||
"dotenv": "^16.5.0",
|
||||
|
||||
@@ -1,6 +1,6 @@
|
||||
{
|
||||
"name": "ws4kp",
|
||||
"version": "5.23.2",
|
||||
"version": "5.24.0",
|
||||
"description": "Welcome to the WeatherStar 4000+ project page!",
|
||||
"main": "index.mjs",
|
||||
"type": "module",
|
||||
|
||||
@@ -42,7 +42,6 @@ class CurrentWeather extends WeatherDisplay {
|
||||
// station observations
|
||||
// eslint-disable-next-line no-await-in-loop
|
||||
observations = await json(`${station.id}/observations`, {
|
||||
cors: true,
|
||||
data: {
|
||||
limit: 2,
|
||||
},
|
||||
|
||||
@@ -47,6 +47,9 @@ const enableMediaPlayer = () => {
|
||||
if (mediaPlaying.value === true) {
|
||||
startMedia();
|
||||
}
|
||||
// add the volume control to the page
|
||||
const settingsSection = document.querySelector('#settings');
|
||||
settingsSection.append(mediaVolume.generate());
|
||||
}
|
||||
};
|
||||
|
||||
@@ -123,6 +126,25 @@ const randomizePlaylist = () => {
|
||||
playlist.availableFiles = randomPlaylist;
|
||||
};
|
||||
|
||||
const setVolume = (newVolume) => {
|
||||
if (player) {
|
||||
player.volume = newVolume;
|
||||
}
|
||||
};
|
||||
|
||||
const mediaVolume = new Setting('mediaVolume', {
|
||||
name: 'Volume',
|
||||
type: 'select',
|
||||
defaultValue: 0.75,
|
||||
values: [
|
||||
[1, '100%'],
|
||||
[0.75, '75%'],
|
||||
[0.50, '50%'],
|
||||
[0.25, '25%'],
|
||||
],
|
||||
changeAction: setVolume,
|
||||
});
|
||||
|
||||
const initializePlayer = () => {
|
||||
// basic sanity checks
|
||||
if (!playlist.availableFiles || playlist?.availableFiles.length === 0) {
|
||||
@@ -145,6 +167,7 @@ const initializePlayer = () => {
|
||||
player.src = `music/${playlist.availableFiles[currentTrack]}`;
|
||||
setTrackName(playlist.availableFiles[currentTrack]);
|
||||
player.type = 'audio/mpeg';
|
||||
setVolume(mediaVolume.value);
|
||||
};
|
||||
|
||||
const playerCanPlay = async () => {
|
||||
|
||||
@@ -92,7 +92,7 @@ const updateStatus = (value) => {
|
||||
if (displays[0].status === STATUS.loading) return;
|
||||
|
||||
// calculate first enabled display
|
||||
const firstDisplayIndex = displays.findIndex((display) => display.enabled && display.timing.totalScreens > 0);
|
||||
const firstDisplayIndex = displays.findIndex((display) => display?.enabled && display?.timing?.totalScreens > 0);
|
||||
|
||||
// value.id = 0 is hazards, if they fail to load hot-wire a new value.id to the current display to see if it needs to be loaded
|
||||
// typically this plays out as current conditions loads, then hazards fails.
|
||||
|
||||
@@ -14,7 +14,7 @@ class Progress extends WeatherDisplay {
|
||||
|
||||
// setup event listener for dom-required initialization
|
||||
document.addEventListener('DOMContentLoaded', () => {
|
||||
this.version = document.querySelector('#version').innerHTML;
|
||||
this.version = document.querySelector('#version').innerHTML.replace(/\s/g, '');
|
||||
this.elem.querySelector('.container').addEventListener('click', this.lineClick.bind(this));
|
||||
});
|
||||
|
||||
@@ -91,3 +91,10 @@ class Progress extends WeatherDisplay {
|
||||
// register our own display
|
||||
const progress = new Progress(-1, 'progress');
|
||||
registerProgress(progress);
|
||||
|
||||
const version = () => progress.version;
|
||||
|
||||
export default progress;
|
||||
export {
|
||||
version,
|
||||
};
|
||||
|
||||
@@ -206,6 +206,11 @@ const mapSizeToFinalSize = (x, y) => ({
|
||||
y: Math.round(y * scaling.width),
|
||||
});
|
||||
|
||||
const fetchAsBlob = async (url) => {
|
||||
const response = await fetch(url);
|
||||
return response.blob();
|
||||
};
|
||||
|
||||
export {
|
||||
getXYFromLatitudeLongitudeDoppler,
|
||||
getXYFromLatitudeLongitudeMap,
|
||||
@@ -217,4 +222,5 @@ export {
|
||||
tileSize,
|
||||
radarFinalSize,
|
||||
radarFullSize,
|
||||
fetchAsBlob,
|
||||
};
|
||||
|
||||
139
server/scripts/modules/radar-worker-bg-fg.mjs
Normal file
139
server/scripts/modules/radar-worker-bg-fg.mjs
Normal file
@@ -0,0 +1,139 @@
|
||||
import {
|
||||
radarFinalSize, pixelToFile, modTile, tileSize, mapSizeToFinalSize, fetchAsBlob,
|
||||
} from './radar-utils.mjs';
|
||||
|
||||
// creates the radar background map image and overlay transparency
|
||||
// which remain fixed on the page as the radar image changes in layered divs
|
||||
// it returns 4 ImageBitmaps that represent the base map, and 4 ImageBitmaps that are the overlay
|
||||
// the main thread pushes these ImageBitmaps into the image placeholders on the page
|
||||
|
||||
const baseMapImages = (tile) => new Promise((resolve) => {
|
||||
if (tile === false) resolve(false);
|
||||
fetchAsBlob(`/images/maps/radar-tiles/${tile}.webp`).then((blob) => {
|
||||
createImageBitmap(blob).then((imageBitmap) => {
|
||||
// extract the black pixels to overlay on to the final image (boundaries)
|
||||
const canvas = new OffscreenCanvas(imageBitmap.width, imageBitmap.height);
|
||||
const context = canvas.getContext('2d');
|
||||
context.drawImage(imageBitmap, 0, 0);
|
||||
const imageData = context.getImageData(0, 0, imageBitmap.width, imageBitmap.height);
|
||||
|
||||
// go through the image data and preserve the black pixels, making the rest transparent
|
||||
for (let i = 0; i < imageData.data.length; i += 4) {
|
||||
if (imageData.data[i + 0] >= 116 || imageData.data[i + 1] >= 116 || imageData.data[i + 2] >= 116) {
|
||||
// make it transparent
|
||||
imageData.data[i + 3] = 0;
|
||||
}
|
||||
}
|
||||
// write the image data back
|
||||
context.putImageData(imageData, 0, 0);
|
||||
|
||||
resolve({
|
||||
base: imageBitmap,
|
||||
overlay: canvas.transferToImageBitmap(),
|
||||
});
|
||||
});
|
||||
});
|
||||
});
|
||||
|
||||
onmessage = async (e) => {
|
||||
const {
|
||||
sourceXY, offsetX, offsetY,
|
||||
} = e.data;
|
||||
|
||||
// determine the basemap images needed
|
||||
const baseMapTiles = [
|
||||
pixelToFile(sourceXY.x, sourceXY.y),
|
||||
pixelToFile(sourceXY.x + offsetX * 2, sourceXY.y),
|
||||
pixelToFile(sourceXY.x, sourceXY.y + offsetY * 2),
|
||||
pixelToFile(sourceXY.x + offsetX * 2, sourceXY.y + offsetY * 2),
|
||||
];
|
||||
|
||||
// get the base maps
|
||||
const baseMapsPromise = Promise.allSettled(baseMapTiles.map(baseMapImages));
|
||||
|
||||
// do some more calculations for assembling the tiles
|
||||
// the tiles are arranged as follows, with the horizontal axis as x, and correlating with the second set of digits in the image file number
|
||||
// T[0] T[1]
|
||||
// T[2] T[3]
|
||||
// tile 0 gets special treatment, it's placement is the basis for all downstream calculations
|
||||
const t0Source = modTile(sourceXY.x, sourceXY.y);
|
||||
const t0Width = tileSize.x - t0Source.x;
|
||||
const t0Height = tileSize.y - t0Source.y;
|
||||
const t0FinalSize = mapSizeToFinalSize(t0Width, t0Height);
|
||||
|
||||
// these will all be used again for the overlay, calculate them once here
|
||||
const mapCoordinates = [];
|
||||
// t[0]
|
||||
mapCoordinates.push({
|
||||
sx: t0Source.x,
|
||||
sw: t0Width,
|
||||
dx: 0,
|
||||
dw: t0FinalSize.x,
|
||||
|
||||
sy: t0Source.y,
|
||||
sh: t0Height,
|
||||
dy: 0,
|
||||
dh: t0FinalSize.y,
|
||||
});
|
||||
// t[1]
|
||||
mapCoordinates.push({
|
||||
sx: 0,
|
||||
sw: tileSize.x - t0Width,
|
||||
dx: t0FinalSize.x,
|
||||
dw: mapSizeToFinalSize(tileSize.x - t0Width, 0).x,
|
||||
|
||||
sy: t0Source.y,
|
||||
sh: t0Height,
|
||||
dy: 0,
|
||||
dh: t0FinalSize.y,
|
||||
});
|
||||
// t[2]
|
||||
mapCoordinates.push({
|
||||
sx: t0Source.x,
|
||||
sw: t0Width,
|
||||
dx: 0,
|
||||
dw: t0FinalSize.x,
|
||||
|
||||
sy: 0,
|
||||
sh: tileSize.y - t0Height,
|
||||
dy: t0FinalSize.y,
|
||||
dh: mapSizeToFinalSize(0, tileSize.y - t0Height).y,
|
||||
});
|
||||
// t[3]
|
||||
mapCoordinates.push({
|
||||
sx: 0,
|
||||
sw: tileSize.x - t0Width,
|
||||
dx: t0FinalSize.x,
|
||||
dw: mapSizeToFinalSize(tileSize.x - t0Width, 0).x,
|
||||
|
||||
sy: 0,
|
||||
sh: tileSize.y - t0Height,
|
||||
dy: t0FinalSize.y,
|
||||
dh: mapSizeToFinalSize(0, tileSize.y - t0Height).y,
|
||||
});
|
||||
|
||||
// wait for the basemaps to arrive
|
||||
const baseMaps = (await baseMapsPromise).map((map) => map.value ?? false);
|
||||
|
||||
// build the response
|
||||
const t0Base = baseMaps[0].base;
|
||||
const t0Overlay = baseMaps[0].overlay;
|
||||
let t1Base; let t1Overlay; let t2Base; let t2Overlay; let t3Base; let t3Overlay;
|
||||
if (mapCoordinates[1].dx < radarFinalSize.width && baseMaps[1]) {
|
||||
t1Base = baseMaps[1].base;
|
||||
t1Overlay = baseMaps[1].overlay;
|
||||
}
|
||||
if (mapCoordinates[2].dy < radarFinalSize.height && baseMaps[2]) {
|
||||
t2Base = baseMaps[2].base;
|
||||
t2Overlay = baseMaps[2].overlay;
|
||||
if (mapCoordinates[1].dx < radarFinalSize.width && baseMaps[3]) {
|
||||
t3Base = baseMaps[3].base;
|
||||
t3Overlay = baseMaps[3].overlay;
|
||||
}
|
||||
}
|
||||
// baseContext.drawImage(baseMaps.fullMap, sourceXY.x, sourceXY.y, offsetX * 2, offsetY * 2, 0, 0, radarFinalSize.width, radarFinalSize.height);
|
||||
|
||||
postMessage({
|
||||
t0Base, t0Overlay, t1Base, t1Overlay, t2Base, t2Overlay, t3Base, t3Overlay,
|
||||
}, [t0Base, t0Overlay, t1Base, t1Overlay, t2Base, t2Overlay, t3Base, t3Overlay]);
|
||||
};
|
||||
@@ -1,47 +1,10 @@
|
||||
import {
|
||||
radarFinalSize, radarFullSize, pixelToFile, modTile, tileSize, removeDopplerRadarImageNoise, mapSizeToFinalSize,
|
||||
radarFinalSize, radarFullSize, removeDopplerRadarImageNoise,
|
||||
} from './radar-utils.mjs';
|
||||
|
||||
const fetchAsBlob = async (url) => {
|
||||
const response = await fetch(url);
|
||||
return response.blob();
|
||||
};
|
||||
|
||||
const baseMapImages = (tile) => new Promise((resolve) => {
|
||||
if (tile === false) resolve(false);
|
||||
fetchAsBlob(`/images/maps/radar-tiles/${tile}.webp`).then((blob) => {
|
||||
createImageBitmap(blob).then((imageBitmap) => {
|
||||
// extract the black pixels to overlay on to the final image (boundaries)
|
||||
const canvas = new OffscreenCanvas(imageBitmap.width, imageBitmap.height);
|
||||
const context = canvas.getContext('2d');
|
||||
context.drawImage(imageBitmap, 0, 0);
|
||||
const imageData = context.getImageData(0, 0, imageBitmap.width, imageBitmap.height);
|
||||
|
||||
// go through the image data and preserve the black pixels, making the rest transparent
|
||||
for (let i = 0; i < imageData.data.length; i += 4) {
|
||||
if (imageData.data[i + 0] >= 116 || imageData.data[i + 1] >= 116 || imageData.data[i + 2] >= 116) {
|
||||
// make it transparent
|
||||
imageData.data[i + 3] = 0;
|
||||
}
|
||||
}
|
||||
// write the image data back
|
||||
context.putImageData(imageData, 0, 0);
|
||||
|
||||
resolve({
|
||||
base: imageBitmap,
|
||||
overlay: canvas,
|
||||
});
|
||||
});
|
||||
});
|
||||
});
|
||||
|
||||
const drawOnBasemap = (baseContext, drawImage, positions) => {
|
||||
baseContext.drawImage(drawImage, positions.sx, positions.sy, positions.sw, positions.sh, positions.dx, positions.dy, positions.dw, positions.dh);
|
||||
};
|
||||
|
||||
onmessage = async (e) => {
|
||||
const {
|
||||
url, RADAR_HOST, OVERRIDES, radarSourceXY, sourceXY, offsetX, offsetY,
|
||||
url, RADAR_HOST, OVERRIDES, radarSourceXY,
|
||||
} = e.data;
|
||||
|
||||
// get the image
|
||||
@@ -49,7 +12,6 @@ onmessage = async (e) => {
|
||||
const radarResponsePromise = fetch(modifiedRadarUrl);
|
||||
|
||||
// calculate offsets and sizes
|
||||
|
||||
const radarSource = {
|
||||
width: 240,
|
||||
height: 163,
|
||||
@@ -57,104 +19,11 @@ onmessage = async (e) => {
|
||||
y: Math.round(radarSourceXY.y / 2),
|
||||
};
|
||||
|
||||
// create destination context
|
||||
const baseCanvas = new OffscreenCanvas(radarFinalSize.width, radarFinalSize.height);
|
||||
const baseContext = baseCanvas.getContext('2d');
|
||||
baseContext.imageSmoothingEnabled = false;
|
||||
|
||||
// create working context for manipulation
|
||||
// create radar context for manipulation
|
||||
const radarCanvas = new OffscreenCanvas(radarFullSize.width, radarFullSize.height);
|
||||
const radarContext = radarCanvas.getContext('2d');
|
||||
radarContext.imageSmoothingEnabled = false;
|
||||
|
||||
// determine the basemap images needed
|
||||
const baseMapTiles = [
|
||||
pixelToFile(sourceXY.x, sourceXY.y),
|
||||
pixelToFile(sourceXY.x + offsetX * 2, sourceXY.y),
|
||||
pixelToFile(sourceXY.x, sourceXY.y + offsetY * 2),
|
||||
pixelToFile(sourceXY.x + offsetX * 2, sourceXY.y + offsetY * 2),
|
||||
];
|
||||
|
||||
// get the base maps
|
||||
const baseMapsPromise = Promise.allSettled(baseMapTiles.map(baseMapImages));
|
||||
|
||||
// do some more calculations for assembling the tiles
|
||||
// the tiles are arranged as follows, with the horizontal axis as x, and correlating with the second set of digits in the image file number
|
||||
// T[0] T[1]
|
||||
// T[2] T[3]
|
||||
// tile 0 gets special treatment, it's placement is the basis for all downstream calculations
|
||||
const t0Source = modTile(sourceXY.x, sourceXY.y);
|
||||
const t0Width = tileSize.x - t0Source.x;
|
||||
const t0Height = tileSize.y - t0Source.y;
|
||||
const t0FinalSize = mapSizeToFinalSize(t0Width, t0Height);
|
||||
|
||||
// these will all be used again for the overlay, calculate them once here
|
||||
const mapCoordinates = [];
|
||||
// t[0]
|
||||
mapCoordinates.push({
|
||||
sx: t0Source.x,
|
||||
sw: t0Width,
|
||||
dx: 0,
|
||||
dw: t0FinalSize.x,
|
||||
|
||||
sy: t0Source.y,
|
||||
sh: t0Height,
|
||||
dy: 0,
|
||||
dh: t0FinalSize.y,
|
||||
});
|
||||
// t[1]
|
||||
mapCoordinates.push({
|
||||
sx: 0,
|
||||
sw: tileSize.x - t0Width,
|
||||
dx: t0FinalSize.x,
|
||||
dw: mapSizeToFinalSize(tileSize.x - t0Width, 0).x,
|
||||
|
||||
sy: t0Source.y,
|
||||
sh: t0Height,
|
||||
dy: 0,
|
||||
dh: t0FinalSize.y,
|
||||
});
|
||||
// t[2]
|
||||
mapCoordinates.push({
|
||||
sx: t0Source.x,
|
||||
sw: t0Width,
|
||||
dx: 0,
|
||||
dw: t0FinalSize.x,
|
||||
|
||||
sy: 0,
|
||||
sh: tileSize.y - t0Height,
|
||||
dy: t0FinalSize.y,
|
||||
dh: mapSizeToFinalSize(0, tileSize.y - t0Height).y,
|
||||
});
|
||||
// t[3]
|
||||
mapCoordinates.push({
|
||||
sx: 0,
|
||||
sw: tileSize.x - t0Width,
|
||||
dx: t0FinalSize.x,
|
||||
dw: mapSizeToFinalSize(tileSize.x - t0Width, 0).x,
|
||||
|
||||
sy: 0,
|
||||
sh: tileSize.y - t0Height,
|
||||
dy: t0FinalSize.y,
|
||||
dh: mapSizeToFinalSize(0, tileSize.y - t0Height).y,
|
||||
});
|
||||
|
||||
// wait for the basemaps to arrive
|
||||
const baseMaps = (await baseMapsPromise).map((map) => map.value ?? false);
|
||||
|
||||
// draw each tile if needed
|
||||
drawOnBasemap(baseContext, baseMaps[0].base, mapCoordinates[0]);
|
||||
if (mapCoordinates[1].dx < radarFinalSize.width && baseMaps[1]) {
|
||||
drawOnBasemap(baseContext, baseMaps[1].base, mapCoordinates[1]);
|
||||
}
|
||||
if (mapCoordinates[2].dy < radarFinalSize.height && baseMaps[2]) {
|
||||
drawOnBasemap(baseContext, baseMaps[2].base, mapCoordinates[2]);
|
||||
if (mapCoordinates[1].dx < radarFinalSize.width && baseMaps[3]) {
|
||||
drawOnBasemap(baseContext, baseMaps[3].base, mapCoordinates[3]);
|
||||
}
|
||||
}
|
||||
// baseContext.drawImage(baseMaps.fullMap, sourceXY.x, sourceXY.y, offsetX * 2, offsetY * 2, 0, 0, radarFinalSize.width, radarFinalSize.height);
|
||||
|
||||
// test response
|
||||
const radarResponse = await radarResponsePromise;
|
||||
if (!radarResponse.ok) throw new Error(`Unable to fetch radar error ${radarResponse.status} ${radarResponse.statusText} from ${radarResponse.url}`);
|
||||
@@ -183,21 +52,7 @@ onmessage = async (e) => {
|
||||
stretchContext.imageSmoothingEnabled = false;
|
||||
stretchContext.drawImage(croppedRadarCanvas, 0, 0, radarSource.width, radarSource.height, 0, 0, radarFinalSize.width, radarFinalSize.height);
|
||||
|
||||
// put the radar on the base map
|
||||
baseContext.drawImage(stretchCanvas, 0, 0);
|
||||
// put the road/boundaries overlay on the map as needed
|
||||
drawOnBasemap(baseContext, baseMaps[0].overlay, mapCoordinates[0]);
|
||||
if (mapCoordinates[1].dx < radarFinalSize.width && baseMaps[1]) {
|
||||
drawOnBasemap(baseContext, baseMaps[1].overlay, mapCoordinates[1]);
|
||||
}
|
||||
if (mapCoordinates[2].dy < radarFinalSize.height && baseMaps[2]) {
|
||||
drawOnBasemap(baseContext, baseMaps[2].overlay, mapCoordinates[2]);
|
||||
if (mapCoordinates[1].dx < radarFinalSize.width && baseMaps[3]) {
|
||||
drawOnBasemap(baseContext, baseMaps[3].overlay, mapCoordinates[3]);
|
||||
}
|
||||
}
|
||||
const stretchedRadar = stretchCanvas.transferToImageBitmap();
|
||||
|
||||
const processedRadar = baseCanvas.transferToImageBitmap();
|
||||
|
||||
postMessage(processedRadar, [processedRadar]);
|
||||
postMessage(stretchedRadar, [stretchedRadar]);
|
||||
};
|
||||
|
||||
@@ -5,6 +5,8 @@ import { text } from './utils/fetch.mjs';
|
||||
import WeatherDisplay from './weatherdisplay.mjs';
|
||||
import { registerDisplay, timeZone } from './navigation.mjs';
|
||||
import * as utils from './radar-utils.mjs';
|
||||
import { version } from './progress.mjs';
|
||||
import { elemForEach } from './utils/elem.mjs';
|
||||
|
||||
// TEMPORARY fix to disable radar on ios safari. The same engine (webkit) is
|
||||
// used for all ios browers (chrome, brave, firefox, etc) so it's safe to skip
|
||||
@@ -72,6 +74,10 @@ class Radar extends WeatherDisplay {
|
||||
// get some web workers started
|
||||
this.workers = (new Array(this.dopplerRadarImageMax)).fill(null).map(() => radarWorker());
|
||||
}
|
||||
if (!this.fixedWorker) {
|
||||
// get the fixed background, overlay worker started
|
||||
this.fixedWorker = fixedRadarWorker();
|
||||
}
|
||||
|
||||
const baseUrl = `https://${RADAR_HOST}/archive/data/`;
|
||||
const baseUrlEnd = '/GIS/uscomp/?F=0&P=n0r*.png';
|
||||
@@ -87,7 +93,7 @@ class Radar extends WeatherDisplay {
|
||||
const lists = (await Promise.all(baseUrls.map(async (url) => {
|
||||
try {
|
||||
// get a list of available radars
|
||||
return text(url, { cors: true });
|
||||
return text(url);
|
||||
} catch (error) {
|
||||
console.log('Unable to get list of radars');
|
||||
console.error(error);
|
||||
@@ -125,16 +131,19 @@ class Radar extends WeatherDisplay {
|
||||
const sourceXY = utils.getXYFromLatitudeLongitudeMap(this.weatherParameters, offsetX, offsetY);
|
||||
const radarSourceXY = utils.getXYFromLatitudeLongitudeDoppler(this.weatherParameters, offsetX, offsetY);
|
||||
|
||||
const baseAndOverlayPromise = this.fixedWorker.processAssets({
|
||||
sourceXY,
|
||||
offsetX,
|
||||
offsetY,
|
||||
});
|
||||
|
||||
// Load the most recent doppler radar images.
|
||||
const radarInfo = await Promise.all(urls.map(async (url, index) => {
|
||||
const processedRadar = await this.workers[index].processRadar({
|
||||
url,
|
||||
RADAR_HOST,
|
||||
OVERRIDES,
|
||||
sourceXY,
|
||||
radarSourceXY,
|
||||
offsetX,
|
||||
offsetY,
|
||||
});
|
||||
|
||||
// store the time
|
||||
@@ -163,6 +172,50 @@ class Radar extends WeatherDisplay {
|
||||
elem,
|
||||
};
|
||||
}));
|
||||
// wait for the base and overlay
|
||||
const baseAndOverlay = await baseAndOverlayPromise;
|
||||
|
||||
// calculate final tile size
|
||||
const finalTileSize = utils.mapSizeToFinalSize(utils.tileSize.x, utils.tileSize.y);
|
||||
// fill the tiles with the map
|
||||
elemForEach('.map-tiles img', (elem, index) => {
|
||||
// get the base image
|
||||
const base = baseAndOverlay[`t${index}Base`];
|
||||
// put it on a canvas
|
||||
const canvas = document.createElement('canvas');
|
||||
const context = canvas.getContext('bitmaprenderer');
|
||||
context.transferFromImageBitmap(base);
|
||||
// if it's not there, return (tile not needed)
|
||||
if (!base) return;
|
||||
// assign the bitmap to the image
|
||||
elem.width = finalTileSize.x;
|
||||
elem.height = finalTileSize.y;
|
||||
elem.src = canvas.toDataURL();
|
||||
});
|
||||
elemForEach('.overlay-tiles img', (elem, index) => {
|
||||
// get the base image
|
||||
const base = baseAndOverlay[`t${index}Overlay`];
|
||||
// put it on a canvas
|
||||
const canvas = document.createElement('canvas');
|
||||
const context = canvas.getContext('bitmaprenderer');
|
||||
context.transferFromImageBitmap(base);
|
||||
// if it's not there, return (tile not needed)
|
||||
if (!base) return;
|
||||
// assign the bitmap to the image
|
||||
elem.width = finalTileSize.x;
|
||||
elem.height = finalTileSize.y;
|
||||
elem.src = canvas.toDataURL();
|
||||
});
|
||||
// fill the tiles with the overlay
|
||||
// shift the map tile containers
|
||||
const tileShift = utils.modTile(sourceXY.x, sourceXY.y);
|
||||
const tileShiftStretched = utils.mapSizeToFinalSize(tileShift.x, tileShift.y);
|
||||
const mapTileContainer = this.elem.querySelector('.map-tiles');
|
||||
mapTileContainer.style.top = `${-tileShiftStretched.y}px`;
|
||||
mapTileContainer.style.left = `${-tileShiftStretched.x}px`;
|
||||
const overlayTileContainer = this.elem.querySelector('.overlay-tiles');
|
||||
overlayTileContainer.style.top = `${-tileShiftStretched.y}px`;
|
||||
overlayTileContainer.style.left = `${-tileShiftStretched.x}px`;
|
||||
|
||||
// put the elements in the container
|
||||
const scrollArea = this.elem.querySelector('.scroll-area');
|
||||
@@ -196,9 +249,9 @@ class Radar extends WeatherDisplay {
|
||||
// create a radar worker with helper functions
|
||||
const radarWorker = () => {
|
||||
// create the worker
|
||||
const worker = new Worker(new URL('./radar-worker.mjs', import.meta.url), { type: 'module' });
|
||||
const worker = new Worker(`/resources/radar-worker.mjs?_=${version()}`, { type: 'module' });
|
||||
|
||||
const processRadar = (url) => new Promise((resolve, reject) => {
|
||||
const processRadar = (data) => new Promise((resolve, reject) => {
|
||||
// prepare for done message
|
||||
worker.onmessage = (e) => {
|
||||
if (e?.data instanceof Error) {
|
||||
@@ -209,7 +262,7 @@ const radarWorker = () => {
|
||||
};
|
||||
|
||||
// start up the worker
|
||||
worker.postMessage(url);
|
||||
worker.postMessage(data);
|
||||
});
|
||||
|
||||
// return the object
|
||||
@@ -218,6 +271,31 @@ const radarWorker = () => {
|
||||
};
|
||||
};
|
||||
|
||||
// create a radar worker for the fixed background images
|
||||
const fixedRadarWorker = () => {
|
||||
// create the worker
|
||||
const worker = new Worker(`/resources/radar-worker-bg-fg.mjs?_=${version()}`, { type: 'module' });
|
||||
|
||||
const processAssets = (data) => new Promise((resolve, reject) => {
|
||||
// prepare for done message
|
||||
worker.onmessage = (e) => {
|
||||
if (e?.data instanceof Error) {
|
||||
reject(e.data);
|
||||
} else if (e?.data?.t0Base instanceof ImageBitmap) {
|
||||
resolve(e.data);
|
||||
}
|
||||
};
|
||||
|
||||
// start up the worker
|
||||
worker.postMessage(data);
|
||||
});
|
||||
|
||||
// return the object
|
||||
return {
|
||||
processAssets,
|
||||
};
|
||||
};
|
||||
|
||||
// register display
|
||||
// TEMPORARY: except on IOS and bots
|
||||
if (!isIos && !isBot) {
|
||||
|
||||
@@ -18,6 +18,8 @@ const testAllPoints = (point, data) => {
|
||||
data.forEach((day, index) => {
|
||||
// initialize the result
|
||||
result[index] = false;
|
||||
// if there's no data (file didn't load), exit early
|
||||
if (day === undefined) return;
|
||||
// loop through each category
|
||||
day.features.forEach((feature) => {
|
||||
if (!feature.geometry.coordinates) return;
|
||||
|
||||
@@ -38,6 +38,9 @@ class Setting {
|
||||
if (this.type === 'checkbox' && urlValue !== undefined) {
|
||||
urlState = urlValue === 'true';
|
||||
}
|
||||
if (this.type === 'boolean' && urlValue !== undefined) {
|
||||
urlState = urlValue === 'true';
|
||||
}
|
||||
if (this.type === 'select' && urlValue !== undefined) {
|
||||
urlState = parseFloat(urlValue);
|
||||
}
|
||||
|
||||
File diff suppressed because one or more lines are too long
File diff suppressed because one or more lines are too long
@@ -30,7 +30,7 @@
|
||||
.condition {
|
||||
text-align: center;
|
||||
height: 74px;
|
||||
margin-top: 10px;
|
||||
margin-top: 5px;
|
||||
}
|
||||
|
||||
.icon {
|
||||
@@ -44,7 +44,6 @@
|
||||
|
||||
.temperatures {
|
||||
width: 100%;
|
||||
margin-top: 5px;
|
||||
|
||||
.temperature-block {
|
||||
display: inline-block;
|
||||
|
||||
@@ -107,6 +107,15 @@
|
||||
|
||||
.container {
|
||||
|
||||
.tiles {
|
||||
position: absolute;
|
||||
width: 1400px;
|
||||
|
||||
img {
|
||||
vertical-align: middle;
|
||||
}
|
||||
}
|
||||
|
||||
.scroll-area {
|
||||
position: relative;
|
||||
}
|
||||
|
||||
@@ -32,11 +32,13 @@
|
||||
|
||||
<div class="main radar">
|
||||
<div class="container">
|
||||
<div class="map-tiles tiles"><img/><img/><img/><img/></div>
|
||||
<div class="scroll-area">
|
||||
<div class="frame template">
|
||||
<div class="map">
|
||||
</div>
|
||||
</div>
|
||||
</div>
|
||||
<div class="overlay-tiles tiles"><img/><img/><img/><img/></div>
|
||||
</div>
|
||||
</div>
|
||||
@@ -43,7 +43,8 @@
|
||||
"Malek",
|
||||
"mwood",
|
||||
"unmuted",
|
||||
"dumpio"
|
||||
"dumpio",
|
||||
"mesonet"
|
||||
],
|
||||
"cSpell.ignorePaths": [
|
||||
"**/package-lock.json",
|
||||
|
||||
Reference in New Issue
Block a user