adipu/blinds_express
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

websocket update on wand pos update

Browse Source
This commit is contained in:
pulipakaa24
2026-03-18 01:07:21 -05:00
parent a51e498928
commit f59726be8d
1 changed files with 8 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

10
index.js
View File

@@ -1479,14 +1479,20 @@ app.post('/position', authenticateToken, async (req, res) => {
console.log("devicepos"); console.log("devicepos");
try { try {
const {port, pos} = req.body; const {port, pos} = req.body;
const {rows} = await pool.query("update peripherals set last_pos=$1 where device_id=$2 and peripheral_number=$3 returning await_calib", const {rows} = await pool.query("update peripherals set last_pos=$1 where device_id=$2 and peripheral_number=$3 returning await_calib, id, user_id",
[pos, req.peripheral, port]); [pos, req.peripheral, port]);
if (rows.length != 1) { if (rows.length != 1) {
return res.sendStatus(404); return res.sendStatus(404);
} }
res.status(201).json(rows[0]); res.status(201).json({await_calib: rows[0].await_calib});
// Notify user app of device-reported position
const {rows: userRows} = await pool.query("select socket from user_tokens where user_id=$1 and connected=TRUE", [rows[0].user_id]);
if (userRows.length === 1 && userRows[0]) {
io.to(userRows[0].socket).emit("device_pos_report", {periphID: rows[0].id, pos});
}
} catch { } catch {
res.status(500).json({error: "server error"}); res.status(500).json({error: "server error"});
} }