wibu/hipmi
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

auto push

Browse Source
This commit is contained in:
Bagasbanuna02
2024-04-19 10:18:59 +08:00
parent dab7b8748b
commit c8666e65d1
84 changed files with 410 additions and 287 deletions
Download Patch File Download Diff File Expand all files Collapse all files

12
src/util/mqtt_client.ts
View File

@@ -1,10 +1,10 @@
import mqtt from "mqtt";
declare global {
var mqtt_client: mqtt.MqttClient;
}
// declare global {
// var mqtt_client: mqtt.MqttClient;
// }
const mqtt_client =
globalThis.mqtt_client || mqtt.connect("wss://io.wibudev.com");
// const mqtt_client =
// globalThis.mqtt_client || mqtt.connect("wss://io.wibudev.com");
export default mqtt_client;
// export default mqtt_client;

34
src/util/mqtt_loader.tsx
View File

@@ -1,22 +1,22 @@
"use client";
import { useEffect } from "react";
import mqtt_client from "./mqtt_client";
import { useAtom } from "jotai";
import { gs_coba_chat } from "@/app/makuro/gs_coba";
// import mqtt_client from "./mqtt_client";
// import { useAtom } from "jotai";
// import { gs_coba_chat } from "@/app/makuro/gs_coba";
export default function MqttLoader() {
const [msg, setMsg] = useAtom(gs_coba_chat);
useEffect(() => {
mqtt_client.on("connect", () => {
console.log("connected");
mqtt_client.subscribe("example_hipmi");
});
// export default function MqttLoader() {
// const [msg, setMsg] = useAtom(gs_coba_chat);
// useEffect(() => {
// mqtt_client.on("connect", () => {
// console.log("connected");
// mqtt_client.subscribe("example_hipmi");
// });
mqtt_client.on("message", (apa, message) => {
console.log(message.toLocaleString());
setMsg(message.toLocaleString() as any);
});
}, [setMsg]);
return null;
}
// mqtt_client.on("message", (apa, message) => {
// console.log(message.toLocaleString());
// setMsg(message.toLocaleString() as any);
// });
// }, [setMsg]);
// return null;
// }