diff --git a/backend/ssestream.go b/backend/ssestream.go index 102718c..7f45a28 100644 --- a/backend/ssestream.go +++ b/backend/ssestream.go @@ -56,6 +56,8 @@ func (sse *SseStream) Stream(c *gin.Context) { Events: c.QueryArray("events"), } + log.Printf("events: %+v", client.Events) + client.Id = generateClientId(client.Ip, client.Events, 8) sse.AddClient(*client) diff --git a/frontend/src/routes/priority/+page.svelte b/frontend/src/routes/priority/+page.svelte index de103b4..fdda911 100644 --- a/frontend/src/routes/priority/+page.svelte +++ b/frontend/src/routes/priority/+page.svelte @@ -4,7 +4,7 @@ import { dev } from '$app/environment'; import { priority } from '$lib/stores/priority.js'; import Select from '$lib/select.svelte'; - import Button from '../../lib/button.svelte'; + import Button from '$lib/button.svelte'; if (dev) { console.log('Dev mode'); @@ -12,6 +12,8 @@ console.log('Not dev mode'); } + const events = 'priority,time'; + let saved = false; $: if (saved && $priority) { @@ -69,7 +71,7 @@ } function Subscribe() { - const sse = new EventSource(`/api/sse`); + const sse = new EventSource(`/api/sse?events=${events}`); console.log('subscribe'); sse.onmessage = (e) => { let Msg = JSON.parse(e.data);