X-Git-Url: https://git.argeo.org/?a=blobdiff_plain;f=security%2Fruntime%2Forg.argeo.security.core%2Fsrc%2Fmain%2Fjava%2Forg%2Fargeo%2Fsecurity%2Fcore%2FKeyBasedSystemExecutionService.java;fp=security%2Fruntime%2Forg.argeo.security.core%2Fsrc%2Fmain%2Fjava%2Forg%2Fargeo%2Fsecurity%2Fcore%2FKeyBasedSystemExecutionService.java;h=d586d1178268af09ed507bea46390eac1c41ef33;hb=977a7a352131b082a98739f15e421f2bff747567;hp=0000000000000000000000000000000000000000;hpb=1481c0531c6f902cff32b3b7e0fd0e7fba304871;p=lgpl%2Fargeo-commons.git

diff --git a/security/runtime/org.argeo.security.core/src/main/java/org/argeo/security/core/KeyBasedSystemExecutionService.java b/security/runtime/org.argeo.security.core/src/main/java/org/argeo/security/core/KeyBasedSystemExecutionService.java
new file mode 100644
index 000000000..d586d1178
--- /dev/null
+++ b/security/runtime/org.argeo.security.core/src/main/java/org/argeo/security/core/KeyBasedSystemExecutionService.java
@@ -0,0 +1,57 @@
+package org.argeo.security.core;
+
+import org.argeo.security.SystemExecutionService;
+import org.springframework.core.task.SimpleAsyncTaskExecutor;
+import org.springframework.core.task.TaskExecutor;
+import org.springframework.security.Authentication;
+import org.springframework.security.AuthenticationManager;
+import org.springframework.security.context.SecurityContext;
+import org.springframework.security.context.SecurityContextHolder;
+
+public class KeyBasedSystemExecutionService implements SystemExecutionService {
+	private AuthenticationManager authenticationManager;
+	private String systemAuthenticationKey;
+
+	public void executeAsSystem(Runnable runnable) {
+		wrapWithSystemAuthentication(runnable).run();
+	}
+
+	public TaskExecutor createSystemAuthenticatedTaskExecutor() {
+		return new SimpleAsyncTaskExecutor() {
+			private static final long serialVersionUID = -8126773862193265020L;
+
+			@Override
+			public Thread createThread(Runnable runnable) {
+				return super
+						.createThread(wrapWithSystemAuthentication(runnable));
+			}
+
+		};
+	}
+
+	protected Runnable wrapWithSystemAuthentication(final Runnable runnable) {
+		return new Runnable() {
+
+			public void run() {
+				SecurityContext securityContext = SecurityContextHolder
+						.getContext();
+				Authentication auth = authenticationManager
+						.authenticate(new InternalAuthentication(
+								systemAuthenticationKey));
+				securityContext.setAuthentication(auth);
+
+				runnable.run();
+			}
+		};
+	}
+
+	public void setAuthenticationManager(
+			AuthenticationManager authenticationManager) {
+		this.authenticationManager = authenticationManager;
+	}
+
+	public void setSystemAuthenticationKey(String systemAuthenticationKey) {
+		this.systemAuthenticationKey = systemAuthenticationKey;
+	}
+
+}