From c05f5110e4a5f262e9f2f8cacbb4b7a24006c657 Mon Sep 17 00:00:00 2001
From: Stephan Richter <s.richter@srsoftware.de>
Date: Mon, 22 Dec 2025 14:42:41 +0100
Subject: [PATCH] working on project list update by event

---
 .../umbrella/messagebus/MessageApi.java       |  2 +-
 frontend/src/routes/project/List.svelte       | 20 ++++++++++++++-----
 .../umbrella/project/ProjectModule.java       |  3 ++-
 3 files changed, 18 insertions(+), 7 deletions(-)

diff --git a/bus/src/main/java/de/srsoftware/umbrella/messagebus/MessageApi.java b/bus/src/main/java/de/srsoftware/umbrella/messagebus/MessageApi.java
index 71685e2..4ff7291 100644
--- a/bus/src/main/java/de/srsoftware/umbrella/messagebus/MessageApi.java
+++ b/bus/src/main/java/de/srsoftware/umbrella/messagebus/MessageApi.java
@@ -29,7 +29,7 @@ public class MessageApi extends BaseHandler{
 		addCors(ex);
 		Optional<Token> token = SessionToken.from(ex).map(Token::of);
 		var user = userService().loadUser(token);
-		//if (user.isEmpty()) return unauthorized(ex); // TODO
+		if (user.isEmpty()) return unauthorized(ex); // TODO
 
 		var headers = ex.getResponseHeaders();
 		var addr = ex.getRemoteAddress();
diff --git a/frontend/src/routes/project/List.svelte b/frontend/src/routes/project/List.svelte
index 02bb3ed..fe5593b 100644
--- a/frontend/src/routes/project/List.svelte
+++ b/frontend/src/routes/project/List.svelte
@@ -1,19 +1,26 @@
 <script>
-    import { onMount }       from 'svelte';
-    import { useTinyRouter } from 'svelte-tiny-router';
+    import { onDestroy, onMount } from 'svelte';
+    import { useTinyRouter }      from 'svelte-tiny-router';
 
-    import { api }           from '../../urls.svelte.js';
-    import { error, yikes }  from '../../warn.svelte';
-    import { t }             from '../../translations.svelte.js';
+    import { api, eventStream }   from '../../urls.svelte.js';
+    import { error, yikes }       from '../../warn.svelte';
+    import { t }                  from '../../translations.svelte.js';
 
     const router   = useTinyRouter();
+    let events     = null;
     let projects   = $state(null);
     let companies  = $state(null);
     let showClosed = $state(router.query.closed == "show");
 
     let sortedProjects = $derived.by(() => Object.values(projects).sort((a, b) => a.name.localeCompare(b.name)));
 
+    function handleUpdate(evt){
+        let json = JSON.parse(evt.data);
+        if (json.project) projects[json.project.id] = json.project;
+    }
+
     async function loadProjects(){
+        events = eventStream(handleUpdate,handleUpdate,null);
         let url  = api('company/list');
         let resp = await fetch(url,{credentials:'include'});
         if (resp.ok){
@@ -66,6 +73,9 @@
     }
 
     onMount(loadProjects);
+	onDestroy(() => {
+		if (events) events.close();
+	})
 </script>
 
 <svelte:head>
diff --git a/project/src/main/java/de/srsoftware/umbrella/project/ProjectModule.java b/project/src/main/java/de/srsoftware/umbrella/project/ProjectModule.java
index afa51a0..31de459 100644
--- a/project/src/main/java/de/srsoftware/umbrella/project/ProjectModule.java
+++ b/project/src/main/java/de/srsoftware/umbrella/project/ProjectModule.java
@@ -13,6 +13,7 @@ import static de.srsoftware.umbrella.core.model.Permission.OWNER;
 import static de.srsoftware.umbrella.core.model.Status.OPEN;
 import static de.srsoftware.umbrella.core.model.Status.PREDEFINED;
 import static de.srsoftware.umbrella.messagebus.MessageBus.messageBus;
+import static de.srsoftware.umbrella.messagebus.events.Event.EventType.CREATE;
 import static de.srsoftware.umbrella.messagebus.events.Event.EventType.UPDATE;
 import static de.srsoftware.umbrella.project.Constants.CONFIG_DATABASE;
 import static java.lang.Boolean.TRUE;
@@ -256,7 +257,7 @@ public class ProjectModule extends BaseHandler implements ProjectService {
 			var tagList = arr.toList().stream().filter(elem -> elem instanceof String).map(String.class::cast).toList();
 			tagService().save(PROJECT,prj.id(),null,tagList);
 		}
-
+		messageBus().dispatch(new ProjectEvent(user,prj, CREATE));
 		return sendContent(ex,prj);
 	}