X-Git-Url: http://git.argeo.org/?a=blobdiff_plain;f=server%2Fruntime%2Forg.argeo.server.jackrabbit%2Fsrc%2Fmain%2Fjava%2Forg%2Fargeo%2Fjackrabbit%2Fremote%2FSimpleSessionProvider.java;h=11edfe94735cc938c7c7584473984e260bfa4c3c;hb=a430449adf43f6cc6103d9fb90e8f15225f0a96b;hp=74b96e9edd45436c0a7cb4869d8fe36884319619;hpb=484dcb1507e4e35cc282e50522ea7eac7e99a7f9;p=lgpl%2Fargeo-commons.git diff --git a/server/runtime/org.argeo.server.jackrabbit/src/main/java/org/argeo/jackrabbit/remote/SimpleSessionProvider.java b/server/runtime/org.argeo.server.jackrabbit/src/main/java/org/argeo/jackrabbit/remote/SimpleSessionProvider.java index 74b96e9ed..11edfe947 100644 --- a/server/runtime/org.argeo.server.jackrabbit/src/main/java/org/argeo/jackrabbit/remote/SimpleSessionProvider.java +++ b/server/runtime/org.argeo.server.jackrabbit/src/main/java/org/argeo/jackrabbit/remote/SimpleSessionProvider.java @@ -1,3 +1,18 @@ +/* + * Copyright (C) 2007-2012 Mathieu Baudier + * + * Licensed under the Apache License, Version 2.0 (the "License"); + * you may not use this file except in compliance with the License. + * You may obtain a copy of the License at + * + * http://www.apache.org/licenses/LICENSE-2.0 + * + * Unless required by applicable law or agreed to in writing, software + * distributed under the License is distributed on an "AS IS" BASIS, + * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. + * See the License for the specific language governing permissions and + * limitations under the License. + */ package org.argeo.jackrabbit.remote; import java.io.Serializable; @@ -27,10 +42,11 @@ import org.apache.jackrabbit.server.SessionProvider; import org.argeo.ArgeoException; import org.argeo.jcr.ArgeoNames; import org.argeo.jcr.JcrUtils; +import org.argeo.jcr.UserJcrUtils; /** - * To be injected, typically of scope="session". Implements an open session in - * view patter: a new JCR session is created for each request + * Implements an open session in view patter: a new JCR session is created for + * each request */ public class SimpleSessionProvider implements SessionProvider, Serializable { private static final long serialVersionUID = 2270957712453841368L; @@ -42,7 +58,7 @@ public class SimpleSessionProvider implements SessionProvider, Serializable { private Boolean openSessionInView = true; - private String securityWorkspace = "security"; + private String defaultWorkspace = "default"; public Session getSession(HttpServletRequest request, Repository rep, String workspace) throws LoginException, ServletException, @@ -51,7 +67,8 @@ public class SimpleSessionProvider implements SessionProvider, Serializable { if (openSessionInView) { JackrabbitSession session = (JackrabbitSession) rep .login(workspace); - writeRemoteRoles(session); + if (session.getWorkspace().getName().equals(defaultWorkspace)) + writeRemoteRoles(session); return session; } else { // since sessions is transient it can't be restored from the session @@ -63,7 +80,9 @@ public class SimpleSessionProvider implements SessionProvider, Serializable { try { JackrabbitSession session = (JackrabbitSession) rep.login( null, workspace); - writeRemoteRoles(session); + if (session.getWorkspace().getName() + .equals(defaultWorkspace)) + writeRemoteRoles(session); if (log.isTraceEnabled()) log.trace("User " + session.getUserID() + " logged into " + request.getServletPath()); @@ -86,8 +105,7 @@ public class SimpleSessionProvider implements SessionProvider, Serializable { protected void writeRemoteRoles(JackrabbitSession session) throws RepositoryException { - if (!session.getWorkspace().getName().equals(securityWorkspace)) - return; + // FIXME better deal w/ non node repo // retrieve roles String userId = session.getUserID(); @@ -103,12 +121,11 @@ public class SimpleSessionProvider implements SessionProvider, Serializable { userGroupIds.add(it.next().getID()); // write roles if needed - Node userProfile = JcrUtils.getUserHome(session).getNode( - ArgeoNames.ARGEO_PROFILE); + Node userHome = UserJcrUtils.getUserHome(session); boolean writeRoles = false; - if (userProfile.hasProperty(ArgeoNames.ARGEO_REMOTE_ROLES)) { - Value[] roles = userProfile.getProperty( - ArgeoNames.ARGEO_REMOTE_ROLES).getValues(); + if (userHome.hasProperty(ArgeoNames.ARGEO_REMOTE_ROLES)) { + Value[] roles = userHome.getProperty(ArgeoNames.ARGEO_REMOTE_ROLES) + .getValues(); if (roles.length != userGroupIds.size()) writeRoles = true; else @@ -120,14 +137,14 @@ public class SimpleSessionProvider implements SessionProvider, Serializable { if (writeRoles) { session.getWorkspace().getVersionManager() - .checkout(userProfile.getPath()); + .checkout(userHome.getPath()); String[] roleIds = userGroupIds.toArray(new String[userGroupIds .size()]); - userProfile.setProperty(ArgeoNames.ARGEO_REMOTE_ROLES, roleIds); - JcrUtils.updateLastModified(userProfile); + userHome.setProperty(ArgeoNames.ARGEO_REMOTE_ROLES, roleIds); + JcrUtils.updateLastModified(userHome); session.save(); session.getWorkspace().getVersionManager() - .checkin(userProfile.getPath()); + .checkin(userHome.getPath()); } } @@ -147,7 +164,7 @@ public class SimpleSessionProvider implements SessionProvider, Serializable { public void init() { } - public void dispose() { + public void destroy() { if (sessions != null) for (String workspace : sessions.keySet()) { Session session = sessions.get(workspace); @@ -158,4 +175,18 @@ public class SimpleSessionProvider implements SessionProvider, Serializable { } } } + + /** + * If set to true a new session will be created each time (the default), + * otherwise a single session is cached by workspace and the object should + * be of scope session (not supported) + */ + public void setOpenSessionInView(Boolean openSessionInView) { + this.openSessionInView = openSessionInView; + } + + public void setSecurityWorkspace(String securityWorkspace) { + this.defaultWorkspace = securityWorkspace; + } + }