重命名

server.js

@@ -0,0 +1,131 @@
+require('dotenv').config()
+const port = process.env.PORT || 3000
+const express = require('express')
+const socketio = require('socket.io')
+const CronJob = require('cron').CronJob
+const request = require('request')
+const sense = require('sense-hat-led').sync
+const app = express()
+const server = app.listen(port, '0.0.0.0', () => console.log(`server is running on port ${port}`))
+const io = socketio(server)
+app.use(express.static('public'))
+sense.clear()
+sense.setRotation(180)
+sense.lowLight = true
+
+const color_red = [255, 0, 0]
+const color_blue = [0, 0, 255]
+const leds = [
+    [0, 0, 0, 0, 0, 0, 0, 0],
+    [0, 0, 0, 0, 0, 0, 0, 0],
+    [0, 0, 0, 0, 0, 0, 0, 0],
+    [0, 0, 0, 0, 0, 0, 0, 0],
+    [0, 0, 0, 0, 0, 0, 0, 0],
+    [0, 0, 0, 0, 0, 0, 0, 0],
+    [0, 0, 0, 0, 0, 0, 0, 0],
+    [0, 0, 0, 0, 0, 0, 0, 0],
+]
+io.emit('leds', leds)
+
+let zhao_server_errors = 0
+
+const job = new CronJob(
+    '*/3 * * * * *',
+    async () => {
+        // 测试 http://zhao 的连通性
+        request('http://zhao', (err, res, body) => {
+            if (res.statusCode != 200) {
+                zhao_server_errors++
+            }
+            if (zhao_server_errors > 0) {
+                for (let i = 0; i < zhao_server_errors; i++) {
+                    const x = i % 8
+                    const y = Math.floor(i / 8)
+                    sense.setPixel(x, y, color_red)
+                }
+            } else {
+                let color = sense.getPixel(0, 0)
+                let [r, g, b] = color
+                sense.setPixel(0, 0, [r, g > 0 ? 0 : 255, b])
+            }
+        })
+    },
+    null,
+    true
+)
+
+// const rpistatus = new CronJob(
+//     '*/5 * * * * *',
+//     async () => {
+//         request('http://zhao:4000', (err, res, body) => {
+//             if (res.statusCode == 200) {
+//                 io.emit('data', body)
+//             }
+//         })
+//         request('http://pi:4000', (err, res, body) => {
+//             if (res.statusCode == 200) {
+//                 io.emit('data', body)
+//             }
+//         })
+//     },
+//     null,
+//     true
+// )
+
+io.on('connection', (client) => {
+    client.emit('leds', leds)
+    client.on('action', ({ action, x, y }) => {
+        console.log({ action, x, y })
+        switch (action) {
+            case 'on':
+                sense.setPixel(Number(x), Number(y), color_blue)
+                leds[y][x] = 1
+                break
+            case 'off':
+                sense.setPixel(Number(x), Number(y), [0, 0, 0])
+                leds[y][x] = 0
+                break
+            case 'hello':
+                sense.flashMessage('HELLO', 1, color_blue)
+                sense.clear()
+                read_all_leds(0)
+                break
+            case 'flash':
+                sense.clear([255, 255, 255])
+                setTimeout(sense.clear, 100)
+                read_all_leds(0)
+                break
+            case 'clear':
+                sense.clear()
+                read_all_leds(0)
+                break
+            case 'temp':
+                read_all_leds()
+                get_rpis_info()
+                break
+            default:
+                break
+        }
+        io.emit('leds', leds)
+    })
+})
+
+function read_all_leds(value = null) {
+    const pixels = sense.getPixels()
+    for (let y = 0; y < 8; y++) {
+        for (let x = 0; x < 8; x++) {
+            leds[y][x] = value !== null ? value : sense.getPixel(x, y)[2] == 0 ? 0 : 1
+        }
+    }
+}
+
+async function get_rpis_info() {
+    const rpis = []
+    request('http://zhao:4000', (err, res, body) => {
+        if (res.statusCode == 200) rpis.push(JSON.parse(body))
+        request('http://pi:4000', (err, res, body) => {
+            if (res.statusCode == 200) rpis.push(JSON.parse(body))
+            io.emit('data', rpis)
+        })
+    })
+}