|
|
@@ -1,45 +0,0 @@
|
|
|
-import { io } from "socket.io-client"
|
|
|
-import axios from "axios"
|
|
|
-import { setTimeout } from "timers/promises"
|
|
|
-const axiosInstance = axios.create({
|
|
|
- baseURL: "http://47.98.225.28/api",
|
|
|
- headers: {
|
|
|
- Authorization:
|
|
|
- "Bearer eyJhbGciOiJIUzI1NiIsInR5cCI6IkpXVCJ9.eyJ1c2VybmFtZSI6InpvdW1hQWRtaW4iLCJzdWIiOjEsInJvbGVzIjpbImFkbWluIl0sImlhdCI6MTcyNjU4MTk1OH0.dQiHFYaDDa1qp4OpEHaH5SCZ9dafJ8uO9fAAc8HZgAo"
|
|
|
- }
|
|
|
-})
|
|
|
-
|
|
|
-const {
|
|
|
- data: { items: devices }
|
|
|
-} = await axiosInstance.post("/device", {
|
|
|
- page: { page: 1, limit: 1000 },
|
|
|
- search: { where: { online: true }, order: { name: "ASC" } }
|
|
|
-})
|
|
|
-
|
|
|
-console.log(devices)
|
|
|
-const socket = io("http://47.98.225.28/")
|
|
|
-socket.on("connect", async () => {
|
|
|
- console.log("connected")
|
|
|
- for (let d of devices) {
|
|
|
- if (parseInt(d.version) < 136) {
|
|
|
- console.log("update " + d.name)
|
|
|
- socket.emit(
|
|
|
- "redirect",
|
|
|
- {
|
|
|
- to: d.socketId,
|
|
|
- message: {
|
|
|
- id: new Date().getTime() + "",
|
|
|
- action: "installApk",
|
|
|
- data: {
|
|
|
- apkUrl: "https://nebuai.oss-cn-hangzhou.aliyuncs.com/application/20241016/zje1ynoq.apk"
|
|
|
- }
|
|
|
- }
|
|
|
- },
|
|
|
- data => {
|
|
|
- console.log(data)
|
|
|
- }
|
|
|
- )
|
|
|
- await setTimeout(500)
|
|
|
- }
|
|
|
- }
|
|
|
-})
|