X-Git-Url: http://git.argeo.org/?a=blobdiff_plain;f=server%2Fruntime%2Forg.argeo.server.jcr%2Fsrc%2Fmain%2Fjava%2Forg%2Fargeo%2Fjcr%2FJcrUtils.java;h=77309feea0ad8e88c507b81f279184ac3b750373;hb=7f23c34bcf51716cfb8f3853d47680035747052f;hp=ad6ca0eddb10dd32d95eba289cd8c42bd4435c77;hpb=802beab5459c8da4970215886babb45d968e4639;p=lgpl%2Fargeo-commons.git

diff --git a/server/runtime/org.argeo.server.jcr/src/main/java/org/argeo/jcr/JcrUtils.java b/server/runtime/org.argeo.server.jcr/src/main/java/org/argeo/jcr/JcrUtils.java
index ad6ca0edd..77309feea 100644
--- a/server/runtime/org.argeo.server.jcr/src/main/java/org/argeo/jcr/JcrUtils.java
+++ b/server/runtime/org.argeo.server.jcr/src/main/java/org/argeo/jcr/JcrUtils.java
@@ -44,6 +44,11 @@ import javax.jcr.Value;
 import javax.jcr.nodetype.NodeType;
 import javax.jcr.query.Query;
 import javax.jcr.query.QueryResult;
+import javax.jcr.query.qom.Constraint;
+import javax.jcr.query.qom.DynamicOperand;
+import javax.jcr.query.qom.QueryObjectModelFactory;
+import javax.jcr.query.qom.Selector;
+import javax.jcr.query.qom.StaticOperand;
 
 import org.apache.commons.logging.Log;
 import org.apache.commons.logging.LogFactory;
@@ -53,6 +58,10 @@ import org.argeo.ArgeoException;
 public class JcrUtils implements ArgeoJcrConstants {
 	private final static Log log = LogFactory.getLog(JcrUtils.class);
 
+	/** Prevents instantiation */
+	private JcrUtils() {
+	}
+
 	/**
 	 * Queries one single node.
 	 * 
@@ -613,4 +622,123 @@ public class JcrUtils implements ArgeoJcrConstants {
 							+ uri, e);
 		}
 	}
+
+	/**
+	 * Discards the current changes in a session by calling
+	 * {@link Session#refresh(boolean)} with <code>false</code>, only logging
+	 * potential errors when doing so. To be used typically in a catch block.
+	 */
+	public static void discardQuietly(Session session) {
+		try {
+			if (session != null)
+				session.refresh(false);
+		} catch (RepositoryException e) {
+			log.warn("Cannot quietly discard session " + session + ": "
+					+ e.getMessage());
+		}
+	}
+
+	/** Logs out the session, not throwing any exception, even if it is null. */
+	public static void logoutQuietly(Session session) {
+		if (session != null)
+			session.logout();
+	}
+
+	/** Returns the home node of the session user or null if none was found. */
+	public static Node getUserHome(Session session) {
+		String userID = session.getUserID();
+		return getUserHome(session, userID);
+	}
+
+	/** Get the profile of the user attached to this session. */
+	public static Node getUserProfile(Session session) {
+		String userID = session.getUserID();
+		return getUserProfile(session, userID);
+	}
+
+	/**
+	 * Returns the home node of the session user or null if none was found.
+	 * 
+	 * @param session
+	 *            the session to use in order to perform the search, this can be
+	 *            a session with a different user ID than the one searched,
+	 *            typically when a system or admin session is used.
+	 * @param userID
+	 *            the id of the user
+	 */
+	public static Node getUserHome(Session session, String userID) {
+		try {
+			QueryObjectModelFactory qomf = session.getWorkspace()
+					.getQueryManager().getQOMFactory();
+
+			// query the user home for this user id
+			Selector userHomeSel = qomf.selector(ArgeoTypes.ARGEO_USER_HOME,
+					"userHome");
+			DynamicOperand userIdDop = qomf.propertyValue("userHome",
+					ArgeoNames.ARGEO_USER_ID);
+			StaticOperand userIdSop = qomf.literal(session.getValueFactory()
+					.createValue(userID));
+			Constraint constraint = qomf.comparison(userIdDop,
+					QueryObjectModelFactory.JCR_OPERATOR_EQUAL_TO, userIdSop);
+			Query query = qomf.createQuery(userHomeSel, constraint, null, null);
+			Node userHome = JcrUtils.querySingleNode(query);
+			return userHome;
+		} catch (RepositoryException e) {
+			throw new ArgeoException("Cannot find home for user " + userID, e);
+		}
+	}
+
+	public static Node getUserProfile(Session session, String userID) {
+		try {
+			QueryObjectModelFactory qomf = session.getWorkspace()
+					.getQueryManager().getQOMFactory();
+			Selector sel = qomf.selector(ArgeoTypes.ARGEO_USER_PROFILE,
+					"userProfile");
+			DynamicOperand userIdDop = qomf.propertyValue("userProfile",
+					ArgeoNames.ARGEO_USER_ID);
+			StaticOperand userIdSop = qomf.literal(session.getValueFactory()
+					.createValue(userID));
+			Constraint constraint = qomf.comparison(userIdDop,
+					QueryObjectModelFactory.JCR_OPERATOR_EQUAL_TO, userIdSop);
+			Query query = qomf.createQuery(sel, constraint, null, null);
+			Node userHome = JcrUtils.querySingleNode(query);
+			return userHome;
+		} catch (RepositoryException e) {
+			throw new ArgeoException("Cannot find profile for user " + userID,
+					e);
+		}
+	}
+
+	public static Node createUserHome(Session session, String homeBasePath,
+			String username) {
+		try {
+			if (session.hasPendingChanges())
+				throw new ArgeoException(
+						"Session has pending changes, save them first");
+			String homePath = homeBasePath + '/'
+					+ firstCharsToPath(username, 2) + '/' + username;
+			Node userHome = JcrUtils.mkdirs(session, homePath);
+
+			Node userProfile = userHome.addNode(ArgeoNames.ARGEO_PROFILE);
+			userProfile.addMixin(ArgeoTypes.ARGEO_USER_PROFILE);
+			userProfile.setProperty(ArgeoNames.ARGEO_USER_ID, username);
+			session.save();
+			// we need to save the profile before adding the user home type
+			PropertyIterator pit = userHome.getProperties();
+			while (pit.hasNext()) {
+				Property p = pit.nextProperty();
+				log.debug(p.getName() + "=" + p.getValue().getString());
+			}
+			userHome.addMixin(ArgeoTypes.ARGEO_USER_HOME);
+			// see
+			// http://jackrabbit.510166.n4.nabble.com/Jackrabbit-2-0-beta-6-Problem-adding-a-Mixin-type-with-mandatory-properties-after-setting-propertiesn-td1290332.html
+			userHome.setProperty(ArgeoNames.ARGEO_USER_ID, username);
+			session.save();
+			return userHome;
+		} catch (RepositoryException e) {
+			discardQuietly(session);
+			throw new ArgeoException("Cannot create home node for user "
+					+ username, e);
+		}
+	}
 }