s412146/node-raspberry-server
1
0
Fork 0
Code Issues Pull Requests Releases Wiki Activity

waiting for change

Browse Source
This commit is contained in:
Dawid Kubicki 2019-01-19 13:26:09 +01:00
parent fe001c3292
commit a2e39ae7f5
1 changed files with 22 additions and 18 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

40
index.js
View File

@ -18,30 +18,34 @@ const port = 3000;
const save_data = async time => { const save_data = async time => {
try { try {
const devices = await deviceSchema.find({}).select("name ip"); const devices = await deviceSchema.find({});
console.log("DEVICES => " + devices); //console.log("DEVICES => " + devices);
for (const { ip, _id } of devices) { for (const { ip, _id, lastStatus } of devices) {
const value_data = await getScript(ip); const value_data = await getScript(ip);
const data = JSON.parse(value_data); const data = JSON.parse(value_data);
await statusSchema.findOneAndUpdate( //console.log(lastStatus, data.Sensors[0].Switch);
{ device: _id },
{ if (lastStatus != data.Sensors[0].Switch) {
$push: { status: { value: data.Sensors[0].Switch, time } } await statusSchema.findOneAndUpdate(
} { device: _id },
); {
await deviceSchema.findByIdAndUpdate(_id, { $push: { status: { value: data.Sensors[0].Switch, time } }
lastStatus: data.Sensors[0].Switch }
}); );
await deviceSchema.findByIdAndUpdate(_id, {
lastStatus: data.Sensors[0].Switch
});
}
} }
} catch (error) { } catch (error) {
console.log("ERROR z CATCHA => " + error); //console.log("ERROR z CATCHA => " + error);
} }
}; };
let interval = setInterval(() => { let interval = setInterval(() => {
save_data(Date.now()); save_data(Date.now());
}, 15000); }, 100);
const getScript = url => { const getScript = url => {
return new Promise((resolve, reject) => { return new Promise((resolve, reject) => {
@ -51,7 +55,7 @@ const getScript = url => {
url = "http://" + url + "/json"; url = "http://" + url + "/json";
console.log("DATA URL => " + url); //console.log("DATA URL => " + url);
client client
.get(url, resp => { .get(url, resp => {
@ -65,7 +69,7 @@ const getScript = url => {
// Cały response pobrany i print // Cały response pobrany i print
resp.on("end", () => { resp.on("end", () => {
resolve(data); resolve(data);
console.log(data); //console.log(data);
}); });
}) })
.on("error", err => { .on("error", err => {
@ -116,7 +120,7 @@ app.get("/all", async (req, res) => {
}); });
app.post("/device", async (req, res) => { app.post("/device", async (req, res) => {
console.log(req.body); //console.log(req.body);
const newDevice = await deviceSchema.create({ const newDevice = await deviceSchema.create({
name: req.body.name, name: req.body.name,
ip: req.body.ip ip: req.body.ip
@ -126,7 +130,7 @@ app.post("/device", async (req, res) => {
}); });
app.delete("/device/:ip", async (req, res) => { app.delete("/device/:ip", async (req, res) => {
console.log(req.body); //console.log(req.body);
const newDevice = await deviceSchema.findOneAndRemove({ ip: req.params.ip }); const newDevice = await deviceSchema.findOneAndRemove({ ip: req.params.ip });
await statusSchema.findOneAndRemove({ device: newDevice }); await statusSchema.findOneAndRemove({ device: newDevice });
res.json({ Sukces: "Usuwa OK" }); res.json({ Sukces: "Usuwa OK" });