Updated protocol
This commit is contained in:
@@ -1,18 +1,15 @@
|
|||||||
import Server, { ServerAPI } from "@/types/server";
|
import Server, { ServerAPI } from "@/types/server";
|
||||||
import Data from "../data";
|
import Data from "../data";
|
||||||
|
import axios from "axios";
|
||||||
|
|
||||||
export const useServer = (server: ServerAPI, index: number) => {
|
export const useServer = (server: ServerAPI, index: number) => {
|
||||||
const ws = new WebSocket(`ws://${server.ip}:5273`);
|
const interval = setInterval(() => {
|
||||||
ws.onmessage = (msg) => {
|
|
||||||
try {
|
|
||||||
if (deletes.has(index) || !currentServers[index]) {
|
if (deletes.has(index) || !currentServers[index]) {
|
||||||
deletes.delete(index);
|
deletes.delete(index);
|
||||||
ws.close();
|
interval.close();
|
||||||
return;
|
return;
|
||||||
}
|
}
|
||||||
if (msg.data === "Success") {return}
|
axios.get(`http://${server.ip}:8080/`, {params: {auth: 'my-key'}}).then(({data}) => {
|
||||||
const data = JSON.parse(msg.data);
|
|
||||||
|
|
||||||
if (data.status) {
|
if (data.status) {
|
||||||
currentServers[index].status = data.status;
|
currentServers[index].status = data.status;
|
||||||
}
|
}
|
||||||
@@ -28,11 +25,10 @@ export const useServer = (server: ServerAPI, index: number) => {
|
|||||||
if (data.network) {
|
if (data.network) {
|
||||||
currentServers[index].network = data.network;
|
currentServers[index].network = data.network;
|
||||||
}
|
}
|
||||||
} catch (e) {
|
}).catch((e) => {
|
||||||
console.error("Error parsing WebSocket message:", e);
|
console.error(e.data);
|
||||||
}
|
})
|
||||||
};
|
}, 2000);
|
||||||
ws.onopen = () => ws.send("my-key");
|
|
||||||
};
|
};
|
||||||
|
|
||||||
export const deletes = new Set<number>();
|
export const deletes = new Set<number>();
|
||||||
|
|||||||
Reference in New Issue
Block a user