-
Notifications
You must be signed in to change notification settings - Fork 1
/
Copy pathindex.js
95 lines (80 loc) · 2.48 KB
/
index.js
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
import http from "http";
import https from "https";
import express from "express";
import compression from "compression";
import cors from "cors";
const serverPort = process.env.PORT || 3000;
const fieldsToReturnFromApi = new Set([
"Copper",
"Gold",
"Palladium",
"Platinum",
"Rhodium",
"Silver",
]);
const app = express();
const httpServer = http.createServer(app);
app.use(compression());
app.use(cors());
app.options('*', cors());
const metalCostsMiddleware = (request, clientResponse) => {
console.log('metalCostsMiddleware was called');
https
.get("https://www.moneymetals.com/ajax/spot-prices", (pricesResponse) => {
let data = "";
// A chunk of data has been received.
pricesResponse.on("data", (chunk) => {
data += chunk;
});
// The whole response has been received. Print out the result.
pricesResponse.on("end", () => {
clientResponse.header("Access-Control-Allow-Origin", "*");
try {
const costsDataWithUselessFields = JSON.parse(data);
const costsWithUselessEntries = Object.entries(costsDataWithUselessFields);
const costsWithoutUselessEntries = costsWithUselessEntries.filter(
([ key ]) => fieldsToReturnFromApi.has(key)
);
const usefulCosts = Object.fromEntries(costsWithoutUselessEntries);
clientResponse.json({
isOk: true,
payload: usefulCosts
});
} catch (error) {
console.error("Error: " + error.message);
clientResponse.status(500).json({
isOk: false,
message: 'Metals API unavailable',
})
}
});
})
.on("error", (err) => {
console.error("Error: " + err.message);
clientResponse.status(500).json({
isOk: false,
message: 'Metals API unavailable',
})
});
};
app.get("/api/metalCosts", metalCostsMiddleware);
app.get("/", (request, response) => {
response.send("<html><body></body></html>").status(200);
});
httpServer.listen(serverPort, function () {
console.log("http server is listening");
});
["SIGHUP", "SIGINT", "SIGQUIT", "SIGTERM"].forEach((sig) =>
process.on(sig, () => {
console.log("Exiting...");
if (!httpServer.listening) {
console.error("Http Server is not listening.\n\n");
return process.exit(1);
}
httpServer.close((err) => {
if (err) console.error(err);
console.log("Http server closed.");
process.exit(~~!!err);
});
})
);