131 lines
2.6 KiB
JavaScript
131 lines
2.6 KiB
JavaScript
const express = require("express");
|
|
const http = require("http");
|
|
const { Server } = require("socket.io");
|
|
const cors = require("cors");
|
|
|
|
const app = express();
|
|
app.use(cors());
|
|
|
|
const server = http.createServer(app);
|
|
|
|
const io = new Server(server, {
|
|
cors: {
|
|
origin: "*",
|
|
},
|
|
});
|
|
|
|
const PORT = 7532;
|
|
|
|
let currentSlide = 0;
|
|
const slideSeconds = 7;
|
|
|
|
const { XMLParser } = require("fast-xml-parser");
|
|
|
|
let slides = [];
|
|
|
|
async function loadSlides() {
|
|
try {
|
|
const response = await fetch(
|
|
"http://10.40.0.2:9000/announcements?list-type=2"
|
|
);
|
|
|
|
const xml = await response.text();
|
|
|
|
const parser = new XMLParser();
|
|
const data = parser.parse(xml);
|
|
|
|
const contents = data.ListBucketResult?.Contents || [];
|
|
|
|
const files = Array.isArray(contents)
|
|
? contents
|
|
: [contents];
|
|
|
|
slides = files
|
|
.map((file) => file.Key)
|
|
.filter((name) =>
|
|
/\.(png|jpg|jpeg|webp)$/i.test(name)
|
|
)
|
|
.map((name) => {
|
|
const encodedName = name
|
|
.split("/")
|
|
.map((part) => encodeURIComponent(part))
|
|
.join("/");
|
|
|
|
return `http://10.40.0.2:9000/announcements/${encodedName}`;
|
|
});
|
|
|
|
console.log("Slides loaded:", slides.length);
|
|
|
|
if (currentSlide >= slides.length) {
|
|
currentSlide = 0;
|
|
}
|
|
|
|
broadcastState();
|
|
} catch (err) {
|
|
console.error("Failed to load slides:", err);
|
|
}
|
|
}
|
|
|
|
const mqtt = require("mqtt");
|
|
|
|
let mode = "on";
|
|
|
|
const mqttClient = mqtt.connect("mqtt://10.40.0.2");
|
|
|
|
mqttClient.on("connect", () => {
|
|
console.log("MQTT connected");
|
|
mqttClient.subscribe("announcements/mode");
|
|
});
|
|
|
|
mqttClient.on("message", (topic, message) => {
|
|
if (topic === "announcements/mode") {
|
|
const value = message.toString().trim().toLowerCase();
|
|
|
|
if (value === "on" || value === "off") {
|
|
mode = value;
|
|
broadcastState();
|
|
console.log("Announcement mode:", mode);
|
|
}
|
|
}
|
|
});
|
|
|
|
function broadcastState() {
|
|
io.emit("slideshow:state", {
|
|
currentSlide,
|
|
slides,
|
|
slideSeconds,
|
|
mode,
|
|
});
|
|
}
|
|
|
|
io.on("connection", (socket) => {
|
|
console.log("Client connected:", socket.id);
|
|
|
|
socket.emit("slideshow:state", {
|
|
currentSlide,
|
|
slides,
|
|
slideSeconds,
|
|
mode,
|
|
});
|
|
});
|
|
|
|
setInterval(() => {
|
|
if (slides.length === 0) return;
|
|
|
|
currentSlide = (currentSlide + 1) % slides.length;
|
|
broadcastState();
|
|
}, slideSeconds * 1000);
|
|
|
|
app.get("/", (req, res) => {
|
|
res.send("Announcement server is running");
|
|
});
|
|
|
|
loadSlides();
|
|
|
|
setInterval(() => {
|
|
loadSlides();
|
|
}, 30000);
|
|
|
|
server.listen(PORT, () => {
|
|
console.log(`Announcement server running on http://10.40.0.2:${PORT}`);
|
|
}); |