Compare commits

..

No commits in common. 'develop' and 'main' have entirely different histories.

@ -16,17 +16,3 @@ Tags:
## Configuration
IASsure-WX can be configured using the `wx-config.json`-file. For now it contains test data but will include production data for at least the Langen FIR. It necessary, another file can be mounted on top of it (`/opt/wx-config.json`). You may also choose to make the necessary changes to the file in this repository. The file is documented in the schema definition file (`wx-config.schema.json`).
## Environment Variables
Some options can be defined using environment variables:
```bash
# defines the port, the application will listen on
PORT=3000
# defines the base path used for the api
BASE_PATH=/api
# defines ips that are allowed as proxy ips
# See http://expressjs.com/en/guide/behind-proxies.html
TRUST_PROXY_ID=
```

@ -4,11 +4,11 @@ import morgan from 'morgan';
import router from './router';
import wxService from './services/wx.service';
const { PORT = 3000, BASE_PATH = '/api', TRUST_PROXY_IP = false } = process.env;
const { PORT = 3000, BASE_PATH = '/api' } = process.env;
const app = express();
app.set('trust proxy', TRUST_PROXY_IP);
app.set('trust proxy', true);
app.use(morgan('combined'));
app.use(BASE_PATH, router.router);
@ -25,7 +25,7 @@ app.use((err, req: Request, res: Response, next: NextFunction) => {
res.status(500).json({ msg: 'an error occurred' });
});
nodesched.scheduleJob('regenerate data', '*/30 * * * * *', wxService.wrappedGenerateData);
nodesched.scheduleJob('regenerate data', '*/30 * * * * *', wxService.wrappedGenerateData)
wxService.wrappedGenerateData();
const server = app.listen(PORT, () => {

@ -15,7 +15,7 @@ export async function getRegion(req: express.Request, res: express.Response, nex
const regionData = regionsService.getRegion(region);
if (!regionData) {
if(!regionData) {
return next();
}

@ -23,4 +23,4 @@ export function getConfig(): WxConfig {
export default {
getConfig,
};
}

@ -1,6 +1,6 @@
import configService, { WxConfig, WxRegion } from './config.service';
import configService, { WxConfig, WxRegion } from "./config.service";
export function getRegions(): WxConfig['regions'] {
export function getRegions(): WxConfig["regions"] {
return configService.getConfig().regions;
}

@ -1,8 +1,8 @@
import axios from 'axios';
import { WxFix } from './config.service';
import regionsService from './regions.service';
import axios from "axios";
import { WxFix } from "./config.service";
import regionsService from "./regions.service";
const cachedData: { [key: string]: WxData } = {};
const cachedData: {[key: string]: WxData} = {};
const qnhLevelMapping = {
200: 390,
@ -12,7 +12,7 @@ const qnhLevelMapping = {
500: 180,
600: 140,
700: 100,
850: 50,
850: 50
};
const necessaryDatapoints = [
@ -34,10 +34,10 @@ for (const qnh of Object.keys(qnhLevelMapping)) {
}
interface WxLevelData {
'T(K)': string;
"T(K)": string;
windspeed: string;
windhdg: string;
}
};
export interface WxFixData {
coords: {
@ -68,27 +68,27 @@ export async function getDataAtFix(fix: WxFix, index: number): Promise<WxFixData
const data: WxFixData = {
coords: {
lat: String(fix.lat),
long: String(fix.lon),
long: String(fix.lon)
},
levels: {},
};
levels: {}
}
data.levels['0'] = {
'T(K)': String(Number(hourlyData?.temperature_2m?.[index]) + 273.15),
'windspeed': String(hourlyData?.windspeed_10m?.[index]),
'windhdg': String(hourlyData?.winddirection_10m?.[index]),
data.levels["0"] = {
"T(K)": String(Number(hourlyData?.[`temperature_2m`]?.[index]) + 273.15),
"windspeed": String(hourlyData?.[`windspeed_10m`]?.[index]),
"windhdg": String(hourlyData?.[`winddirection_10m`]?.[index]),
};
for (const [qnh, fl] of Object.entries(qnhLevelMapping)) {
for(const [qnh, fl] of Object.entries(qnhLevelMapping)) {
const temp = Number(hourlyData?.[`temperature_${qnh}hPa`]?.[index]) + 273.15;
const dir = hourlyData?.[`winddirection_${qnh}hPa`]?.[index];
const speed = hourlyData?.[`windspeed_${qnh}hPa`]?.[index];
data.levels[String(fl)] = {
'T(K)': String(temp),
'windspeed': String(speed),
'windhdg': String(dir),
};
"T(K)": String(temp),
"windspeed": String(speed),
"windhdg": String(dir),
}
}
return data;
@ -104,10 +104,10 @@ export async function generateData() {
info: {
date: now.toISOString(),
datestring: `${now.getUTCDate()}${now.getUTCHours()}`,
legal: 'Weather data by Open-Meteo.com (https://open-meteo.com)',
legal: "Weather data by Open-Meteo.com (https://open-meteo.com)"
},
data: {},
};
data: {}
}
for (const fix of region.fixes) {
regionData.data[fix.name] = await getDataAtFix(fix, now.getUTCHours());
@ -133,4 +133,4 @@ export default {
getWx,
generateData,
wrappedGenerateData,
};
}
Loading…
Cancel
Save