From a6513e9af388f0ef52412daaf9bb9a6b2b3108b9 Mon Sep 17 00:00:00 2001
From: Miki <mikif70@gmail.com>
Date: Thu, 21 Dec 2023 11:17:35 +0000
Subject: [PATCH] +priority base

---
 backend/db.go                             |  20 ++
 backend/heats.go                          |  65 ++++
 backend/http.go                           |   2 +-
 frontend/src/routes/priority/+page.svelte | 399 ++++++++++++++++++++++
 4 files changed, 485 insertions(+), 1 deletion(-)
 create mode 100644 backend/heats.go
 create mode 100644 frontend/src/routes/priority/+page.svelte

diff --git a/backend/db.go b/backend/db.go
index 6a70b50..f207084 100644
--- a/backend/db.go
+++ b/backend/db.go
@@ -1,6 +1,7 @@
 package main
 
 import (
+	"encoding/json"
 	"fmt"
 	"log"
 
@@ -46,3 +47,22 @@ func (db *DB) Read(table string, key string, value interface{}) error {
 	}
 	return nil
 }
+
+func (db *DB) loadHeats() []Heat {
+	records, err := db.Db.ReadAll("Heat")
+	if err != nil {
+		fmt.Printf("read error: %+v", err)
+	}
+
+	heats := make([]Heat, 0)
+	for _, record := range records {
+		var heat Heat
+		err = json.Unmarshal([]byte(record), &heat)
+		if err != nil {
+			fmt.Printf("decode error: %+v", err)
+		}
+		heats = append(heats, heat)
+	}
+
+	return heats
+}
diff --git a/backend/heats.go b/backend/heats.go
new file mode 100644
index 0000000..b62e39f
--- /dev/null
+++ b/backend/heats.go
@@ -0,0 +1,65 @@
+package main
+
+import (
+	"fmt"
+	"log"
+	"net/http"
+	"strings"
+
+	"github.com/gin-gonic/gin"
+)
+
+type Surfer struct {
+	Name     string `json:"name"`
+	Color    string `json:"color"`
+	Priority string `json:"priority"`
+	Score    string `json:"score"`
+}
+
+type Heat struct {
+	Name     string   `json:"name"`
+	Category string   `json:"category"`
+	Number   int      `json:"number"`
+	Timer    int      `json:"timer"`
+	Status   string   `json:"status"`
+	Surfers  []Surfer `json:"surfers"`
+}
+
+func heatName(heat Heat) string {
+	str := fmt.Sprintf("%s.%d.%s", heat.Name, heat.Number, heat.Category)
+	strings.ReplaceAll(str, " ", "_")
+	return str
+}
+
+func (app *App) SaveHeat(c *gin.Context) {
+	var heat Heat
+
+	err := c.ShouldBind(&heat)
+
+	if err != nil {
+		log.Printf("req error: %+v", err)
+		c.JSON(http.StatusBadRequest, gin.H{"error": err.Error()})
+		return
+	}
+
+	log.Printf("heat: %+v", heat)
+
+	heat.Status = "idle"
+
+	err = app.DB.Write("Heat", heatName(heat), heat)
+	if err != nil {
+		log.Printf("set error: %+v", err)
+		c.JSON(http.StatusInternalServerError, gin.H{"status": fmt.Sprintf("Error: %+v", err)})
+		return
+	}
+
+	c.JSON(http.StatusOK, gin.H{"status": "saved"})
+}
+
+func (app *App) LoadHeats(c *gin.Context) {
+	heats := app.DB.loadHeats()
+
+	c.JSON(http.StatusOK, heats)
+
+	log.Printf("heats: %+v", heats)
+}
diff --git a/backend/http.go b/backend/http.go
index eb9ffdc..a751878 100644
--- a/backend/http.go
+++ b/backend/http.go
@@ -86,6 +86,6 @@ func (app *App) RegisterApiRoutes() {
 	// api.GET("/stopheat", app.StopHeatTimer)
 	// api.POST("/saveheat", app.SaveHeat)
 	// api.POST("/deleteheat", app.DeleteHeat)
-	// api.GET("/loadheats", app.LoadHeats)
+	api.GET("/loadheats", app.LoadHeats)
 	// api.GET("/runningheat", app.LoadRunning)
 }
diff --git a/frontend/src/routes/priority/+page.svelte b/frontend/src/routes/priority/+page.svelte
new file mode 100644
index 0000000..244fbe9
--- /dev/null
+++ b/frontend/src/routes/priority/+page.svelte
@@ -0,0 +1,399 @@
+<script>
+	// import { page } from '$app/stores';
+	import { onDestroy, onMount } from 'svelte';
+	import { dev } from '$app/environment';
+
+	if (dev) {
+		console.log('Dev mode');
+	} else {
+		console.log('Not dev mode');
+	}
+
+	let heat_number;
+	let heats = [];
+	$: surfers = [];
+	// 	{ name: 'Kanoa Igarashi', color: 'red', score: '4.50', priority: '3' },
+	// 	{ name: 'Griffin Colapinto', color: 'white', score: '5.60', priority: 'P' },
+	// 	{ name: 'Jack Robinson', color: 'blue', score: '6.10', priority: '5' },
+	// 	{ name: 'Gabriel Medina', color: 'green', score: '4.30', priority: '2' },
+	// 	{ name: 'Italo Ferreira', color: 'black', score: '6.50', priority: '4' }
+	// ];
+
+	let width;
+	// $: activeUrl = $page.url.pathname;
+
+	const pad2 = (number) => `00${number}`.slice(-2);
+
+	$: min = 0;
+	$: sec = 0;
+
+	let end = false;
+	let start = false;
+
+	loadHeats();
+
+	function Subscribe() {
+		const sse = new EventSource(`/api/sse`);
+		console.log('subscribe');
+		sse.onmessage = (e) => {
+			let Msg = JSON.parse(e.data);
+			console.log(`received: ${JSON.stringify(Msg)}`);
+			if (Msg.mode === 'priority') {
+				console.log(`priority: ${Msg.priority}`);
+				for (let i in surfers) {
+					surfers[i].priority = Msg.priority[i];
+				}
+			} else if (Msg.mode === 'time') {
+				// console.log(`duration: ${Msg.duration}`);
+				let min_sec = Msg.duration.split(':');
+				min = min_sec[0];
+				sec = min_sec[1];
+				// console.log(`min & sec = ${min} & ${sec}`);
+				if (!start) {
+					start = true;
+				}
+			} else if (Msg.mode === 'stop') {
+				console.log(`stop duration: ${Msg.duration}`);
+				end = true;
+				start = false;
+			}
+		};
+		return () => {
+			sse.close();
+			console.log(`sse closing ${Date.now()}`);
+		};
+	}
+
+	async function dblclick(id) {
+		console.log(`dblclick = ${surfers[id]}`);
+		if (surfers[id] === 'P') {
+			console.log('pressed P');
+		} else {
+			console.log(`pressed: [${id}] ${surfers[id].priority}`);
+		}
+		const res = await fetch(`/api/stopheat`);
+		const data = await res.json();
+		console.log(`stop: ${JSON.stringify(data)}`);
+	}
+
+	async function startHeat() {
+		const res = await fetch(`/api/startheat`, {
+			method: 'POST',
+			body: JSON.stringify({
+				duration: min + 'm',
+				mode: 'time'
+			}),
+			headers: {
+				'Content-Type': 'application/json'
+			}
+		});
+		console.log(`retval: ${JSON.stringify(res)}`);
+		start = true;
+		end = false;
+	}
+
+	async function loadHeats() {
+		const res = await fetch(`/api/loadheats`);
+		const data = await res.json();
+		for (let i in data) {
+			heats[i] = data[i];
+			console.log(`${i} retval: ${JSON.stringify(data[i])}`);
+		}
+	}
+
+	function setHeat(id) {
+		console.log(`setHeat: ${id}`);
+		if (id === '99') {
+			min = 0;
+			surfers = [];
+			return;
+		}
+		min = heats[id].timer;
+		surfers = heats[id].surfers;
+	}
+
+	async function click(id) {
+		let max = surfers.length;
+		console.log(surfers[id]);
+		if (surfers[id].priority === 'P') {
+			for (let i in surfers) {
+				if (i != id) {
+					let pos = parseInt(surfers[i].priority) - 1;
+					if (pos === 1) {
+						surfers[i].priority = 'P';
+					} else {
+						surfers[i].priority = pos.toString();
+					}
+				}
+			}
+			surfers[id].priority = max.toString();
+		} else if (surfers[id].priority === '') {
+			console.log(`priority empty; pressed: [${id}] ${surfers[id].priority}`);
+			for (let i in surfers) {
+				console.log(`looping(${id}): ${i} - ${surfers[i].priority}`);
+				if (i != id) {
+					if (surfers[i].priority === '') {
+						console.log(`empty: [${i}] ${surfers[i].priority}`);
+						continue;
+					} else {
+						console.log(`not empty: [${i}] ${surfers[i].priority}`);
+						let pos = parseInt(surfers[i].priority) - 1;
+						if (pos === 1) {
+							surfers[i].priority = 'P';
+						} else {
+							surfers[i].priority = pos.toString();
+						}
+					}
+				}
+			}
+			surfers[id].priority = max.toString();
+		} else {
+			console.log(`pressed: [${id}] ${surfers[id].priority}`);
+			let oldpos = parseInt(surfers[id].priority);
+			for (let i in surfers) {
+				if (i != id) {
+					console.log(`pos: [${i}] ${surfers[i].priority} ${surfers[i].priority > oldpos}`);
+					if (surfers[i].priority != 'P' && surfers[i].priority > oldpos) {
+						let pos = parseInt(surfers[i].priority);
+						if (pos > oldpos) {
+							surfers[i].priority = (pos - 1).toString();
+							console.log(`newpos: ${surfers[i].priority}`);
+						}
+					}
+				} else {
+					surfers[i].priority = max.toString();
+					console.log(`last: [${i}] ${surfers[i].priority}`);
+				}
+			}
+		}
+		const res = await fetch(`/api/priority`, {
+			method: 'POST',
+			body: JSON.stringify({
+				priority: surfers.map((obj) => obj.priority),
+				mode: 'priority'
+			}),
+			headers: {
+				'Content-Type': 'application/json'
+			}
+		});
+		console.log(
+			JSON.stringify({
+				priority: surfers.map((obj) => obj.priority),
+				mode: 'priority'
+			})
+		);
+		console.log(`retval: ${JSON.stringify(res)}`);
+	}
+
+	onMount(() => {
+		const unsub = Subscribe();
+		return unsub;
+	});
+
+	// onDestroy(() => {
+	// 	clearInterval(timer); // Pulisci il timer quando il componente viene distrutto
+	// });
+</script>
+
+<svelte:window bind:innerWidth={width} />
+
+<div class="header">
+	<!-- <button class="button" on:click={() => loadHeats()} disabled={start}>Load</button> -->
+	<select name="heats" id="heats" bind:value={heat_number} on:change={() => setHeat(heat_number)}>
+		<option value="99">Select Heat</option>
+		{#each heats as heat, id}
+			<option value={id}>{heat.name} {heat.number} {heat.category}</option>
+		{/each}
+	</select>
+	{#if !end}
+		<div class="timer">{pad2(min)}:{pad2(sec)}</div>
+	{:else}
+		<div class="timer" style="color: red">{pad2(min)}:{pad2(sec)}</div>
+	{/if}
+	<button class="button" on:click={() => startHeat()} disabled={start}>Start</button>
+</div>
+
+<div class="container">
+	{#each surfers as surfer, id}
+		<div class="box">
+			<div
+				class="square"
+				{id}
+				style="background-color: {surfer.color};"
+				on:click={() => click(id)}
+				on:contextmenu={(e) => {
+					e.preventDefault();
+					dblclick(id);
+				}}
+				on:keypress={console.log('keypress')}
+				role="button"
+				tabindex={id}
+			>
+				{#if surfer.priority != ''}
+					{#if surfer.priority === 'P'}
+						{#if surfer.color === 'white'}
+							<span class="priority_white">{surfer.priority}</span>
+						{:else}
+							<span class="priority">{surfer.priority}</span>
+						{/if}
+					{:else}
+						<span class="priority_small">{surfer.priority}</span>
+					{/if}
+				{/if}
+			</div>
+			<div class="score">{surfer.score}</div>
+		</div>
+	{/each}
+</div>
+
+<style>
+	:root {
+		--backColor: #334;
+		--textColor: white;
+		--maxWidth: (100% - 15px);
+	}
+
+	.header {
+		/* padding: 15px; */
+		height: 10vh;
+		background-color: var(--backColor);
+		padding-left: 10px;
+		padding-right: 10px;
+		padding-top: 6px;
+		padding-bottom: 6px;
+		margin-top: 2px;
+		margin-bottom: 2px;
+		width: calc(var(--maxWidth));
+		color: var(--textColor);
+		display: flex;
+		justify-content: space-between;
+		align-items: center;
+	}
+
+	.header .timer {
+		font-size: 13vh;
+		padding-left: 10px;
+		padding-right: 20px;
+		font-weight: bold;
+		flex: 2 2 auto;
+		align-self: center;
+		text-align: center;
+	}
+
+	.header .button {
+		height: 60%;
+		align-items: center;
+		background-color: yellow;
+		border-radius: 10%;
+	}
+
+	.container {
+		height: 85vh;
+		background-color: var(--backColor);
+		padding-left: 10px;
+		padding-right: 10px;
+		padding-top: 4px;
+		width: calc(var(--maxWidth));
+		color: var(--textColor);
+	}
+
+	.box {
+		width: 100%;
+		display: flex;
+		align-items: center;
+		padding: 1px;
+		margin-bottom: 1px;
+	}
+
+	.priority {
+		width: 15%;
+		height: 100%;
+		border-radius: 20%;
+		font-size: 8vh;
+		/* animation: blink 2s 2; */
+		margin-right: auto;
+		background-color: white;
+		color: black;
+		display: flex;
+		align-items: center;
+		justify-content: center;
+		font-weight: bold;
+	}
+
+	.priority_white {
+		width: 15%;
+		height: 100%;
+		border-radius: 20%;
+		font-size: 8vh;
+		/* animation: blink_white 2s 3; */
+		margin-right: auto;
+		background-color: black;
+		color: white;
+		display: flex;
+		align-items: center;
+		justify-content: center;
+		font-weight: bold;
+		padding-bottom: 4px;
+	}
+
+	.priority_small {
+		width: 13%;
+		height: 85%;
+		border-radius: 20%;
+		font-size: 8vh;
+		/* animation: blink 2s 3; */
+		margin-right: auto;
+		margin-left: 30px;
+		background-color: #ccc;
+		color: black;
+		display: flex;
+		align-items: center;
+		justify-content: center;
+		font-weight: bold;
+	}
+
+	.square {
+		width: 100%;
+		height: 16vh;
+		border-radius: 5px;
+		margin-right: 15px;
+		display: flex;
+		align-items: center;
+		justify-content: center;
+		padding-bottom: 2px;
+		margin-bottom: 2px;
+	}
+
+	.score {
+		padding-right: 20px;
+		width: 20%;
+		font-size: 12vh;
+		float: right;
+		text-align: center;
+		font-weight: bold;
+	}
+
+	@keyframes blink {
+		0% {
+			background-color: white;
+		}
+		50% {
+			background-color: rgba(255, 255, 255, 0.6);
+		}
+		100% {
+			background-color: white;
+		}
+	}
+
+	@keyframes blink_white {
+		0% {
+			background-color: black;
+		}
+		50% {
+			background-color: rgba(0, 0, 0, 0.6);
+		}
+		100% {
+			background-color: black;
+		}
+	}
+</style>