001: /*
002: * JBoss, Home of Professional Open Source
003: * Copyright 2005, JBoss Inc., and individual contributors as indicated
004: * by the @authors tag. See the copyright.txt in the distribution for a
005: * full listing of individual contributors.
006: *
007: * This is free software; you can redistribute it and/or modify it
008: * under the terms of the GNU Lesser General Public License as
009: * published by the Free Software Foundation; either version 2.1 of
010: * the License, or (at your option) any later version.
011: *
012: * This software is distributed in the hope that it will be useful,
013: * but WITHOUT ANY WARRANTY; without even the implied warranty of
014: * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU
015: * Lesser General Public License for more details.
016: *
017: * You should have received a copy of the GNU Lesser General Public
018: * License along with this software; if not, write to the Free
019: * Software Foundation, Inc., 51 Franklin St, Fifth Floor, Boston, MA
020: * 02110-1301 USA, or see the FSF site: http://www.fsf.org.
021: */
022: package org.jbpm.context.exe.variableinstance;
023:
024: import java.util.Iterator;
025:
026: import javax.jcr.Item;
027: import javax.jcr.Node;
028: import javax.jcr.Repository;
029: import javax.jcr.RepositoryException;
030: import javax.jcr.Session;
031: import javax.jcr.Workspace;
032:
033: import org.apache.commons.logging.Log;
034: import org.apache.commons.logging.LogFactory;
035: import org.jbpm.JbpmContext;
036: import org.jbpm.JbpmException;
037: import org.jbpm.context.exe.VariableInstance;
038: import org.jbpm.jcr.JcrService;
039: import org.jbpm.svc.Services;
040:
041: public class JcrNodeInstance extends VariableInstance {
042:
043: private static final long serialVersionUID = 1L;
044:
045: String repository = null;
046: String workspace = null;
047: String path = null;
048:
049: public boolean isStorable(Object value) {
050: if (value == null)
051: return true;
052: return Node.class.isAssignableFrom(value.getClass());
053: }
054:
055: protected Object getObject() {
056: if (path == null)
057: return null;
058:
059: // THE NODE REPOSITORY AND WORKSPACE NAME GOT TO CORRESPOND WITH A JBPM SERVICE NAME
060: JcrService jcrService = findService();
061: if (jcrService == null) {
062: throw new JbpmException(
063: "couldn't find jBPM service for JCR repository '"
064: + repository + "', workspace '" + workspace
065: + "'");
066: }
067: Session session = jcrService.getSession();
068: Item item;
069: try {
070: item = session.getItem(path);
071: } catch (Exception e) {
072: // NOTE that Error's are not caught because that might halt the JVM and mask the original Error.
073: throw new JbpmException("can't fetch JCR node '" + path
074: + "' from repository '" + repository
075: + "', workspace '" + workspace + "'", e);
076: }
077: return item;
078: }
079:
080: /**
081: * find the service that matches the stored repository and workspace.
082: * The matching is done as follows:
083: * - a service name that is equal to the repository name matches
084: * - a service that starts with the repository name and ends with the workspace name matches
085: * and takes preference over a service with the repository name
086: * @throws JbpmException if no matching jBPM context service is found.
087: */
088: private JcrService findService() {
089: String serviceName = null;
090: JbpmContext jbpmContext = JbpmContext.getCurrentJbpmContext();
091: Services services = jbpmContext.getServices();
092:
093: // if there is a service called jcr
094: if (services.hasService("jcr")) {
095: // use that one
096: serviceName = "jcr";
097:
098: } else { // otherwise
099: // start matching the JCR workspace name with the jbpm service names
100: Iterator serviceNames = services.getServiceFactories()
101: .keySet().iterator();
102: while (serviceNames.hasNext()) {
103: String candidate = (String) serviceNames.next();
104: if (candidate.startsWith(workspace)) {
105: if (candidate.length() == workspace.length()) {
106: if (serviceName == null) {
107: serviceName = candidate;
108: }
109: } else if (candidate.endsWith(workspace)) {
110: serviceName = candidate;
111: }
112: }
113: }
114: }
115:
116: if (serviceName == null) {
117: throw new JbpmException(
118: "couldn't find service for JCR repository '"
119: + repository + "', workspace '" + workspace
120: + "'");
121: }
122:
123: return (JcrService) services.getService(serviceName);
124: }
125:
126: protected void setObject(Object value) {
127: Node node = (Node) value;
128: if (value == null) {
129: repository = null;
130: workspace = null;
131: path = null;
132: } else {
133: try {
134: Session session = node.getSession();
135: Repository repo = session.getRepository();
136: Workspace wspace = session.getWorkspace();
137:
138: // THE NODE REPOSITORY AND WORKSPACE NAME GOT TO CORRESPOND WITH A JBPM SERVICE NAME
139: repository = repo
140: .getDescriptor(Repository.REP_NAME_DESC);
141: workspace = wspace.getName();
142: path = node.getPath();
143:
144: log.debug("stored jcr node repository(" + repository
145: + "), workspace(" + workspace + ") and path("
146: + path + ")");
147: } catch (RepositoryException e) {
148: throw new JbpmException("problem storing JCR node '"
149: + node + "' in the process variable '" + name
150: + "'", e);
151: }
152: }
153: }
154:
155: private static Log log = LogFactory.getLog(JcrNodeInstance.class);
156: }
|