Introduce DBus support

[lgpl/argeo-commons.git] / swt / rcp / org.argeo.cms.swt.rcp / src / org / argeo / cms / ui / rcp / dbus / CmsRcpDBusLauncher.java

diff --git a/swt/rcp/org.argeo.cms.swt.rcp/src/org/argeo/cms/ui/rcp/dbus/CmsRcpDBusLauncher.java b/swt/rcp/org.argeo.cms.swt.rcp/src/org/argeo/cms/ui/rcp/dbus/CmsRcpDBusLauncher.java
new file mode 100644 (file)
index 0000000..ea69057
--- /dev/null
+++ b/swt/rcp/org.argeo.cms.swt.rcp/src/org/argeo/cms/ui/rcp/dbus/CmsRcpDBusLauncher.java
@@ -0,0 +1,48 @@
+package org.argeo.cms.ui.rcp.dbus;
+
+import java.io.IOException;
+import java.util.HashMap;
+import java.util.Map;
+import java.util.concurrent.CompletableFuture;
+
+import org.argeo.api.cms.CmsApp;
+import org.argeo.cms.dbus.CmsDBus;
+
+public class CmsRcpDBusLauncher {
+       private CompletableFuture<CmsDBus> cmsDBus = new CompletableFuture<>();
+
+       private Map<String, CmsRcpFreeDesktopApplication> apps = new HashMap<>();
+
+       public void start() {
+
+       }
+
+       public void stop() {
+
+       }
+
+       public void addCmsApp(CmsApp cmsApp, Map<String, String> properties) {
+               final String contextName = properties.get(CmsApp.CONTEXT_NAME_PROPERTY);
+               cmsDBus.thenAcceptAsync((cmsDBus) -> {
+                       CmsRcpFreeDesktopApplication application = new CmsRcpFreeDesktopApplication(cmsDBus, contextName, cmsApp);
+                       apps.put(contextName, application);
+               });
+       }
+
+       public void removeCmsApp(CmsApp cmsApp, Map<String, String> properties) {
+               final String contextName = properties.get(CmsApp.CONTEXT_NAME_PROPERTY);
+               CmsRcpFreeDesktopApplication application = apps.remove(contextName);
+               if (application != null) {
+                       try {
+                               application.close();
+                       } catch (IOException e) {
+                               throw new IllegalStateException("Cannot remove CMS RCP app " + contextName, e);
+                       }
+               }
+       }
+
+       public void setCmsDBus(CmsDBus cmsDBus) {
+               this.cmsDBus.complete(cmsDBus);
+       }
+
+}