mirror of
https://github.com/dotFionn/iassure-wx.git
synced 2026-03-17 04:42:57 -05:00
Compare commits
6 Commits
v1.1.0
...
dc3a682a77
| Author | SHA1 | Date | |
|---|---|---|---|
| dc3a682a77 | |||
| 5bcd588b0f | |||
| 1f8979cee8 | |||
|
|
d093c016c9 | ||
|
|
c87e8ee70b | ||
| 1c9c485ca4 |
14
README.md
14
README.md
@@ -16,3 +16,17 @@ 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' } = process.env;
|
||||
const { PORT = 3000, BASE_PATH = '/api', TRUST_PROXY_IP = false } = process.env;
|
||||
|
||||
const app = express();
|
||||
|
||||
app.set('trust proxy', true);
|
||||
app.set('trust proxy', TRUST_PROXY_IP);
|
||||
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, () => {
|
||||
|
||||
@@ -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,6 +1,6 @@
|
||||
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 } = {};
|
||||
|
||||
@@ -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,15 +68,15 @@ 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)) {
|
||||
@@ -85,10 +85,10 @@ export async function getDataAtFix(fix: WxFix, index: number): Promise<WxFixData
|
||||
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,
|
||||
}
|
||||
};
|
||||
|
||||
Reference in New Issue
Block a user