51 lines
1.4 KiB
JavaScript
51 lines
1.4 KiB
JavaScript
/* eslint-disable no-console */
|
|
const got = require("got");
|
|
|
|
const { CloudEvent } = require("cloudevents-sdk");
|
|
const WebSocket = require("ws");
|
|
const wss = new WebSocket.Server({ port: 8080 });
|
|
|
|
const api = "https://api.openweathermap.org/data/2.5/weather";
|
|
const key = "REPLACE WITH API KEY";
|
|
|
|
console.log("WebSocket server started. Waiting for events.");
|
|
|
|
wss.on("connection", function connection(ws) {
|
|
console.log("Connection received");
|
|
ws.on("message", function incoming(message) {
|
|
console.log(`Message received: ${message}`);
|
|
const event = new CloudEvent(JSON.parse(message));
|
|
fetch(event.data.zip)
|
|
.then((weather) => {
|
|
const response = new CloudEvent({
|
|
dataContentType: "application/json",
|
|
type: "current.weather",
|
|
source: "/weather.server",
|
|
data: weather,
|
|
});
|
|
ws.send(JSON.stringify(response));
|
|
})
|
|
.catch((err) => {
|
|
console.error(err);
|
|
ws.send(
|
|
JSON.stringify(
|
|
new CloudEvent({
|
|
type: "weather.error",
|
|
source: "/weather.server",
|
|
data: err.toString(),
|
|
}),
|
|
),
|
|
);
|
|
});
|
|
});
|
|
});
|
|
|
|
function fetch(zip) {
|
|
const query = `${api}?zip=${zip}&appid=${key}&units=imperial`;
|
|
return new Promise((resolve, reject) => {
|
|
got(query)
|
|
.then((response) => resolve(JSON.parse(response.body)))
|
|
.catch((err) => reject(err.message));
|
|
});
|
|
}
|