X-Git-Url: https://git.argeo.org/?a=blobdiff_plain;f=org.argeo.cms%2Fsrc%2Forg%2Fargeo%2Fcms%2Finternal%2Fruntime%2FCmsContextImpl.java;h=7a0f3388c07a4f79cabdd6928de9fa210e3bc511;hb=f3ea14abccc33b1c3326417a87c91145be776c72;hp=10bda17fb79fbde5a579efbe383f8dddf0e99bab;hpb=da9d144b6b241e1526a3bd255dff905a7969a5bc;p=lgpl%2Fargeo-commons.git

diff --git a/org.argeo.cms/src/org/argeo/cms/internal/runtime/CmsContextImpl.java b/org.argeo.cms/src/org/argeo/cms/internal/runtime/CmsContextImpl.java
index 10bda17fb..7a0f3388c 100644
--- a/org.argeo.cms/src/org/argeo/cms/internal/runtime/CmsContextImpl.java
+++ b/org.argeo.cms/src/org/argeo/cms/internal/runtime/CmsContextImpl.java
@@ -1,34 +1,36 @@
 package org.argeo.cms.internal.runtime;
 
-import static java.util.Locale.ENGLISH;
-
 import java.lang.management.ManagementFactory;
+import java.util.ArrayList;
 import java.util.HashMap;
 import java.util.List;
 import java.util.Locale;
 import java.util.Map;
+import java.util.TreeMap;
 import java.util.UUID;
 import java.util.concurrent.CompletableFuture;
 import java.util.concurrent.ExecutionException;
+import java.util.concurrent.Flow;
+import java.util.concurrent.Flow.Subscription;
+import java.util.concurrent.SubmissionPublisher;
 
 import javax.security.auth.Subject;
 
-import org.argeo.api.acr.spi.ProvidedContent;
-import org.argeo.api.acr.spi.ProvidedRepository;
-import org.argeo.api.cms.CmsConstants;
 import org.argeo.api.cms.CmsContext;
 import org.argeo.api.cms.CmsDeployment;
+import org.argeo.api.cms.CmsEventSubscriber;
 import org.argeo.api.cms.CmsLog;
 import org.argeo.api.cms.CmsSession;
 import org.argeo.api.cms.CmsSessionId;
 import org.argeo.api.cms.CmsState;
 import org.argeo.api.uuid.UuidFactory;
-import org.argeo.cms.LocaleUtils;
+import org.argeo.cms.CmsDeployProperty;
 import org.argeo.cms.internal.auth.CmsSessionImpl;
 import org.ietf.jgss.GSSCredential;
 import org.osgi.service.useradmin.UserAdmin;
 
 public class CmsContextImpl implements CmsContext {
+
 	private final CmsLog log = CmsLog.getLog(getClass());
 //	private final BundleContext bc = FrameworkUtil.getBundle(getClass()).getBundleContext();
 
@@ -39,7 +41,7 @@ public class CmsContextImpl implements CmsContext {
 	private CmsDeployment cmsDeployment;
 	private UserAdmin userAdmin;
 	private UuidFactory uuidFactory;
-	private ProvidedRepository contentRepository;
+//	private ProvidedRepository contentRepository;
 
 	// i18n
 	private Locale defaultLocale;
@@ -51,15 +53,23 @@ public class CmsContextImpl implements CmsContext {
 	private Map<UUID, CmsSessionImpl> cmsSessionsByUuid = new HashMap<>();
 	private Map<String, CmsSessionImpl> cmsSessionsByLocalId = new HashMap<>();
 
+	// CMS events
+	private Map<String, SubmissionPublisher<Map<String, Object>>> topics = new TreeMap<>();
+//	private IdentityHashMap<CmsEventSubscriber, List<CmsEventFlowSubscriber>> subscriptions = new IdentityHashMap<>();
+
 //	public CmsContextImpl() {
 //		initTrackers();
 //	}
 
 	public void start() {
-		Object defaultLocaleValue = KernelUtils.getFrameworkProp(CmsConstants.I18N_DEFAULT_LOCALE);
-		defaultLocale = defaultLocaleValue != null ? new Locale(defaultLocaleValue.toString())
-				: new Locale(ENGLISH.getLanguage());
-		locales = LocaleUtils.asLocaleList(KernelUtils.getFrameworkProp(CmsConstants.I18N_LOCALES));
+		List<String> codes = CmsStateImpl.getDeployProperties(cmsState, CmsDeployProperty.LOCALE);
+		locales = getLocaleList(codes);
+		if (locales.size() == 0)
+			throw new IllegalStateException("At least one locale must be set");
+		defaultLocale = locales.get(0);
+//		Object defaultLocaleValue = KernelUtils.getFrameworkProp(CmsConstants.I18N_DEFAULT_LOCALE);
+//		defaultLocale = defaultLocaleValue != null ? new Locale(defaultLocaleValue.toString())
+//				: new Locale(ENGLISH.getLanguage());
 		// node repository
 //		new ServiceTracker<Repository, Repository>(bc, Repository.class, null) {
 //			@Override
@@ -145,6 +155,29 @@ public class CmsContextImpl implements CmsContext {
 		throw new UnsupportedOperationException();
 	}
 
+	/** Returns null if argument is null. */
+	private static List<Locale> getLocaleList(List<String> codes) {
+		if (codes == null)
+			return null;
+		ArrayList<Locale> availableLocales = new ArrayList<Locale>();
+		for (String code : codes) {
+			if (code == null)
+				continue;
+			// variant not supported
+			int indexUnd = code.indexOf("_");
+			Locale locale;
+			if (indexUnd > 0) {
+				String language = code.substring(0, indexUnd);
+				String country = code.substring(indexUnd + 1);
+				locale = new Locale(language, country);
+			} else {
+				locale = new Locale(code);
+			}
+			availableLocales.add(locale);
+		}
+		return availableLocales;
+	}
+
 	public void setCmsDeployment(CmsDeployment cmsDeployment) {
 		this.cmsDeployment = cmsDeployment;
 	}
@@ -165,13 +198,13 @@ public class CmsContextImpl implements CmsContext {
 		this.uuidFactory = uuidFactory;
 	}
 
-	public ProvidedRepository getContentRepository() {
-		return contentRepository;
-	}
-
-	public void setContentRepository(ProvidedRepository contentRepository) {
-		this.contentRepository = contentRepository;
-	}
+//	public ProvidedRepository getContentRepository() {
+//		return contentRepository;
+//	}
+//
+//	public void setContentRepository(ProvidedRepository contentRepository) {
+//		this.contentRepository = contentRepository;
+//	}
 
 	@Override
 	public Locale getDefaultLocale() {
@@ -284,4 +317,86 @@ public class CmsContextImpl implements CmsContext {
 		return cmsSessionsByLocalId.get(localId);
 	}
 
+	/*
+	 * CMS Events
+	 */
+	public void sendEvent(String topic, Map<String, Object> event) {
+		SubmissionPublisher<Map<String, Object>> publisher = topics.get(topic);
+		if (publisher == null)
+			return; // no one is interested
+		publisher.submit(event);
+	}
+
+	public void addEventSubscriber(String topic, CmsEventSubscriber subscriber) {
+		synchronized (topics) {
+			if (!topics.containsKey(topic))
+				topics.put(topic, new SubmissionPublisher<>());
+		}
+		SubmissionPublisher<Map<String, Object>> publisher = topics.get(topic);
+		CmsEventFlowSubscriber flowSubscriber = new CmsEventFlowSubscriber(topic, subscriber);
+		publisher.subscribe(flowSubscriber);
+	}
+
+	public void removeEventSubscriber(String topic, CmsEventSubscriber subscriber) {
+		SubmissionPublisher<Map<String, Object>> publisher = topics.get(topic);
+		if (publisher == null) {
+			log.error("There should be an event topic " + topic);
+			return;
+		}
+		for (Flow.Subscriber<? super Map<String, Object>> flowSubscriber : publisher.getSubscribers()) {
+			if (flowSubscriber instanceof CmsEventFlowSubscriber)
+				((CmsEventFlowSubscriber) flowSubscriber).unsubscribe();
+		}
+		synchronized (topics) {
+			if (!publisher.hasSubscribers()) {
+				publisher.close();
+				topics.remove(topic);
+			}
+		}
+	}
+
+	static class CmsEventFlowSubscriber implements Flow.Subscriber<Map<String, Object>> {
+		private String topic;
+		private CmsEventSubscriber eventSubscriber;
+
+		private Subscription subscription;
+
+		public CmsEventFlowSubscriber(String topic, CmsEventSubscriber eventSubscriber) {
+			this.topic = topic;
+			this.eventSubscriber = eventSubscriber;
+		}
+
+		@Override
+		public void onSubscribe(Subscription subscription) {
+			this.subscription = subscription;
+			subscription.request(Long.MAX_VALUE);
+		}
+
+		@Override
+		public void onNext(Map<String, Object> item) {
+			eventSubscriber.onEvent(topic, item);
+
+		}
+
+		@Override
+		public void onError(Throwable throwable) {
+			// TODO Auto-generated method stub
+
+		}
+
+		@Override
+		public void onComplete() {
+			// TODO Auto-generated method stub
+
+		}
+
+		void unsubscribe() {
+			if (subscription != null)
+				subscription.cancel();
+			else
+				throw new IllegalStateException("No subscription to cancel");
+		}
+
+	}
+
 }