diff --git a/src/routes/+page.svelte b/src/routes/+page.svelte index a02c88c..1a98c5c 100644 --- a/src/routes/+page.svelte +++ b/src/routes/+page.svelte @@ -3,11 +3,15 @@ import mqtt from "mqtt"; let arena_id; /** @type {string} */ -let arena_topic; +let arena_metadata_topic; /** @type {string} */ let arena_state_topic; /** @type {string} */ let arena_score_topic; +/** @type {string} */ +let display_state_topic; +/** @type {string} */ +let display_class_topic; let event_name = "Mecha Mayhem 2024"; let match_name = "No Match"; @@ -24,15 +28,37 @@ let timer_end = undefined; let timer_next_tick = undefined; let timer = "Scheduled"; +/** @type {string} */ +let display_state = "init"; + +/** @type {string} */ +let display_class = "side-display"; + const client = mqtt.connect("ws://127.0.0.1:8883"); client.on("connect", () => { console.log("connected to mqtt"); - client.subscribe(arena_topic, (err) => { + client.subscribe(display_state_topic, (err) => { + if (err) { + console.log(err); + } else { + console.log(`subscribed to ${display_state_topic}`); + } + }); + + client.subscribe(display_class_topic, (err) => { + if (err) { + console.log(err); + } else { + console.log(`subscribed to ${display_class_topic}`); + } + }); + + client.subscribe(arena_metadata_topic, (err) => { if (err) { console.log(err); } else { - console.log(`subscribed to ${arena_topic}`); + console.log(`subscribed to ${arena_metadata_topic}`); } }); @@ -87,7 +113,7 @@ client.on("message", (topic, message) => { console.log(`${topic_str} - ${message_str}`); switch(topic_str){ - case arena_topic: + case arena_metadata_topic: const arena_obj = JSON.parse(message_str); teams_red = [arena_obj.red1, arena_obj.red2]; teams_blue = [arena_obj.blue1, arena_obj.blue2]; @@ -132,6 +158,20 @@ client.on("message", (topic, message) => { score_red = score_obj.red.total; score_blue = score_obj.blue.total; break; + case display_state_topic: + display_state = message_str; + break; + case display_class_topic: + switch(message_str){ + case "side": + display_class = "side-display"; + break; + case "center": + display_class = "center-display"; + break; + default: + console.log(`invalid display class ${message_str}`) + } default: console.log(`Unhandled topic ${topic_str}`) } @@ -144,14 +184,17 @@ onMount(() => { if (arena_id === null) { arena_id = "default"; } - arena_topic = `arena/${arena_id}`; - arena_state_topic = `arena/${arena_id}/state`; - arena_score_topic = `arena/${arena_id}/score`; + arena_metadata_topic = `arena/${arena_id}`; + arena_state_topic = `arena/${arena_id}/state`; + arena_score_topic = `arena/${arena_id}/score`; + display_state_topic = `display/${arena_id}/state`; + display_class_topic = `display/${arena_id}/class`; }); -
{event_name}
{timer}
@@ -171,6 +214,11 @@ onMount(() => { {/each}