[jbpm-commits] JBoss JBPM SVN: r5169 - in jbpm4/trunk/modules/integration: form-plugin/src/main/java/org/jbpm/integration/console/forms and 1 other directories.

Wednesday, 1 July 2009


Author: heiko.braun(a)jboss.com
Date: 2009-07-01 04:12:26 -0400 (Wed, 01 Jul 2009)
New Revision: 5169

Added:
  
jbpm4/trunk/modules/integration/form-plugin/src/main/java/org/jbpm/integration/console/forms/AbstractFormDispatcher.java
  
jbpm4/trunk/modules/integration/form-plugin/src/main/java/org/jbpm/integration/console/forms/FormDispatcherComposite.java
  
jbpm4/trunk/modules/integration/form-plugin/src/main/java/org/jbpm/integration/console/forms/ProcessFormDispatcher.java
  
jbpm4/trunk/modules/integration/form-plugin/src/main/java/org/jbpm/integration/console/forms/TaskFormDispatcher.java
  
jbpm4/trunk/modules/integration/form-plugin/src/main/resources/META-INF/services/org.jboss.bpm.console.server.plugin.FormDispatcherPlugin
Removed:
  
jbpm4/trunk/modules/integration/form-plugin/src/main/java/org/jbpm/integration/console/forms/TaskDispatcherPluginImpl.java
  
jbpm4/trunk/modules/integration/form-plugin/src/main/resources/META-INF/services/org.jboss.bpm.console.server.plugin.TaskDispatcherPlugin
Modified:
  
jbpm4/trunk/modules/integration/console/src/main/java/org/jbpm/integration/console/ProcessManagementImpl.java
Log:
JBPM-2233: Start a process with task form

Modified:
jbpm4/trunk/modules/integration/console/src/main/java/org/jbpm/integration/console/ProcessManagementImpl.java
===================================================================
---
jbpm4/trunk/modules/integration/console/src/main/java/org/jbpm/integration/console/ProcessManagementImpl.java	2009-07-01
07:17:16 UTC (rev 5168)
+++
jbpm4/trunk/modules/integration/console/src/main/java/org/jbpm/integration/console/ProcessManagementImpl.java	2009-07-01
08:12:26 UTC (rev 5169)
@@ -65,7 +65,8 @@
      
       for(ProcessDefinition processDefinition : activePds)
       {
-        results.add( ModelAdaptor.adoptDefinition(processDefinition) );
+        ProcessDefinitionRef ref = ModelAdaptor.adoptDefinition(processDefinition);
+        results.add(ref);
       }
 
       // suspended  processes
@@ -75,9 +76,9 @@
 
       for(ProcessDefinition p : suspendedPds)
       {
-        ProcessDefinitionRef pref = ModelAdaptor.adoptDefinition(p);
-        pref.setSuspended(true);
-        results.add(pref);
+        ProcessDefinitionRef ref = ModelAdaptor.adoptDefinition(p);
+        ref.setSuspended(true);        
+        results.add(ref);
       }
 
       return results;

Added:
jbpm4/trunk/modules/integration/form-plugin/src/main/java/org/jbpm/integration/console/forms/AbstractFormDispatcher.java
===================================================================
---
jbpm4/trunk/modules/integration/form-plugin/src/main/java/org/jbpm/integration/console/forms/AbstractFormDispatcher.java	
                       (rev 0)
+++
jbpm4/trunk/modules/integration/form-plugin/src/main/java/org/jbpm/integration/console/forms/AbstractFormDispatcher.java	2009-07-01
08:12:26 UTC (rev 5169)
@@ -0,0 +1,143 @@
+/*
+ * JBoss, Home of Professional Open Source.
+ * Copyright 2006, Red Hat Middleware LLC, and individual contributors
+ * as indicated by the @author tags. See the copyright.txt file in the
+ * distribution for a full listing of individual contributors.
+ *
+ * This is free software; you can redistribute it and/or modify it
+ * under the terms of the GNU Lesser General Public License as
+ * published by the Free Software Foundation; either version 2.1 of
+ * the License, or (at your option) any later version.
+ *
+ * This software is distributed in the hope that it will be useful,
+ * but WITHOUT ANY WARRANTY; without even the implied warranty of
+ * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU
+ * Lesser General Public License for more details.
+ *
+ * You should have received a copy of the GNU Lesser General Public
+ * License along with this software; if not, write to the Free
+ * Software Foundation, Inc., 51 Franklin St, Fifth Floor, Boston, MA
+ * 02110-1301 USA, or see the FSF site: http://www.fsf.org.
+ */
+package org.jbpm.integration.console.forms;
+
+import org.jbpm.api.ProcessEngine;
+import org.jbpm.integration.spi.mgmt.ServerConfig;
+import org.jbpm.integration.spi.mgmt.ServerConfigFactory;
+
+import javax.naming.InitialContext;
+import javax.activation.DataHandler;
+import javax.activation.DataSource;
+import java.io.*;
+import java.util.Map;
+
+import freemarker.template.DefaultObjectWrapper;
+import freemarker.template.Template;
+
+/**
+ * @author Heiko.Braun <heiko.braun(a)jboss.com&gt;
+ */
+public class AbstractFormDispatcher
+{
+  protected final static String WEB_CONTEXT = "/gwt-console-server/rs";
+  
+  protected ProcessEngine processEngine;
+  protected ServerConfig serverConfig = null;
+  protected static final String FORM_DIRECTIVE_KEY = "form";
+  protected static final String OUTCOME_DIRECTIVE_NAME = "outcome";
+
+
+  public AbstractFormDispatcher()
+  {
+    initializeProcessEngine();
+  }
+
+  protected void initializeProcessEngine()
+  {
+    try
+    {
+      InitialContext ctx = new InitialContext();
+      this.processEngine = (ProcessEngine)ctx.lookup("java:/ProcessEngine");
+    }
+    catch (Exception e)
+    {
+      throw new RuntimeException("Failed to lookup process engine", e);
+    }
+  }
+
+  protected ServerConfig getServerConfig()
+  {
+    if(null==serverConfig)
+    {
+      serverConfig = ServerConfigFactory.getServerConfig();
+    }
+    return serverConfig;
+  }
+
+  protected StringBuilder getBaseUrl()
+  {
+    StringBuilder spec = new StringBuilder();
+    spec.append("http://");
+    spec.append(getServerConfig().getWebServiceHost());
+    spec.append(":").append(getServerConfig().getWebServicePort());
+    spec.append(WEB_CONTEXT);
+    return spec;    
+  }
+
+  protected DataHandler processTemplate(
+      final String name, InputStream src,
+      Map<String, Object> renderContext
+  )
+  {
+    DataHandler merged = null;
+
+    try
+    {
+      freemarker.template.Configuration cfg = new freemarker.template.Configuration();
+      cfg.setObjectWrapper(new DefaultObjectWrapper());
+      cfg.setTemplateUpdateDelay(0);
+
+      Template temp = new Template(name, new InputStreamReader(src), cfg);
+      temp.dump(System.out);
+
+      final ByteArrayOutputStream bout = new ByteArrayOutputStream();
+      Writer out = new OutputStreamWriter(bout);
+      temp.process(renderContext, out);
+      out.flush();
+
+      merged = new DataHandler(
+
+          new DataSource()
+          {
+
+            public InputStream getInputStream() throws IOException
+            {
+              return new ByteArrayInputStream(bout.toByteArray());
+            }
+
+            public OutputStream getOutputStream() throws IOException
+            {
+              return bout;
+            }
+
+            public String getContentType()
+            {
+              return "application/octet-stream";
+            }
+
+            public String getName()
+            {
+              return name + "_DataSource";
+            }
+          }
+      );
+
+    }
+    catch (Exception e)
+    {
+      throw new RuntimeException("Failed to process task template", e);
+    }
+
+    return merged;
+  }
+}

Added:
jbpm4/trunk/modules/integration/form-plugin/src/main/java/org/jbpm/integration/console/forms/FormDispatcherComposite.java
===================================================================
---
jbpm4/trunk/modules/integration/form-plugin/src/main/java/org/jbpm/integration/console/forms/FormDispatcherComposite.java	
                       (rev 0)
+++
jbpm4/trunk/modules/integration/form-plugin/src/main/java/org/jbpm/integration/console/forms/FormDispatcherComposite.java	2009-07-01
08:12:26 UTC (rev 5169)
@@ -0,0 +1,87 @@
+/*
+ * JBoss, Home of Professional Open Source.
+ * Copyright 2006, Red Hat Middleware LLC, and individual contributors
+ * as indicated by the @author tags. See the copyright.txt file in the
+ * distribution for a full listing of individual contributors.
+ *
+ * This is free software; you can redistribute it and/or modify it
+ * under the terms of the GNU Lesser General Public License as
+ * published by the Free Software Foundation; either version 2.1 of
+ * the License, or (at your option) any later version.
+ *
+ * This software is distributed in the hope that it will be useful,
+ * but WITHOUT ANY WARRANTY; without even the implied warranty of
+ * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU
+ * Lesser General Public License for more details.
+ *
+ * You should have received a copy of the GNU Lesser General Public
+ * License along with this software; if not, write to the Free
+ * Software Foundation, Inc., 51 Franklin St, Fifth Floor, Boston, MA
+ * 02110-1301 USA, or see the FSF site: http://www.fsf.org.
+ */
+package org.jbpm.integration.console.forms;
+
+import org.jboss.bpm.console.server.plugin.FormDispatcherPlugin;
+import org.jboss.bpm.console.server.plugin.FormAuthorityRef;
+
+import javax.activation.DataHandler;
+import java.net.URL;
+import java.util.Map;
+
+/**
+ * @author Heiko.Braun <heiko.braun(a)jboss.com&gt;
+ */
+public class FormDispatcherComposite implements FormDispatcherPlugin
+{
+
+  private FormDispatcherPlugin taskDispatcher;
+  private FormDispatcherPlugin processDispatcher;
+
+
+  public FormDispatcherComposite()
+  {
+    this.taskDispatcher = new TaskFormDispatcher();
+    this.processDispatcher = new ProcessFormDispatcher();
+  }
+
+  public URL getDispatchUrl(FormAuthorityRef ref)
+  {
+    switch(ref.getType())
+    {
+      case TASK:
+        return taskDispatcher.getDispatchUrl(ref);
+      case PROCESS:
+        return processDispatcher.getDispatchUrl(ref);
+      default:
+        throw new IllegalArgumentException("Unknown authority
type:"+ref.getType());
+    }
+  }
+
+  public DataHandler provideForm(FormAuthorityRef ref)
+  {
+    switch(ref.getType())
+    {
+      case TASK:
+        return taskDispatcher.provideForm(ref);
+      case PROCESS:
+        return processDispatcher.provideForm(ref);
+      default:
+        throw new IllegalArgumentException("Unknown authority
type:"+ref.getType());
+    }
+  }
+
+  public void processCompletion(FormAuthorityRef ref, Map<String, Object> payload,
String performingUser, String outcome)
+  {
+    switch(ref.getType())
+    {
+      case TASK:
+        taskDispatcher.processCompletion(ref, payload, performingUser, outcome);
+        break;
+      case PROCESS:
+        processDispatcher.processCompletion(ref, payload, performingUser, outcome);
+        break;
+      default:
+        throw new IllegalArgumentException("Unknown authority
type:"+ref.getType());
+    }
+  }
+}

Added:
jbpm4/trunk/modules/integration/form-plugin/src/main/java/org/jbpm/integration/console/forms/ProcessFormDispatcher.java
===================================================================
---
jbpm4/trunk/modules/integration/form-plugin/src/main/java/org/jbpm/integration/console/forms/ProcessFormDispatcher.java	
                       (rev 0)
+++
jbpm4/trunk/modules/integration/form-plugin/src/main/java/org/jbpm/integration/console/forms/ProcessFormDispatcher.java	2009-07-01
08:12:26 UTC (rev 5169)
@@ -0,0 +1,180 @@
+/*
+ * JBoss, Home of Professional Open Source.
+ * Copyright 2006, Red Hat Middleware LLC, and individual contributors
+ * as indicated by the @author tags. See the copyright.txt file in the
+ * distribution for a full listing of individual contributors.
+ *
+ * This is free software; you can redistribute it and/or modify it
+ * under the terms of the GNU Lesser General Public License as
+ * published by the Free Software Foundation; either version 2.1 of
+ * the License, or (at your option) any later version.
+ *
+ * This software is distributed in the hope that it will be useful,
+ * but WITHOUT ANY WARRANTY; without even the implied warranty of
+ * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU
+ * Lesser General Public License for more details.
+ *
+ * You should have received a copy of the GNU Lesser General Public
+ * License along with this software; if not, write to the Free
+ * Software Foundation, Inc., 51 Franklin St, Fifth Floor, Boston, MA
+ * 02110-1301 USA, or see the FSF site: http://www.fsf.org.
+ */
+package org.jbpm.integration.console.forms;
+
+import org.jboss.bpm.console.server.plugin.FormAuthorityRef;
+import org.jboss.bpm.console.server.plugin.FormDispatcherPlugin;
+import org.jbpm.api.ExecutionService;
+import org.jbpm.api.ProcessDefinition;
+import org.jbpm.api.RepositoryService;
+import org.jbpm.pvm.internal.env.Environment;
+import org.jbpm.pvm.internal.env.EnvironmentFactory;
+
+import javax.activation.DataHandler;
+import java.io.InputStream;
+import java.net.MalformedURLException;
+import java.net.URL;
+import java.util.HashMap;
+import java.util.Map;
+import java.util.List;
+
+/**
+ * Processes form data to start processes.
+ * 
+ * @author Heiko.Braun <heiko.braun(a)jboss.com&gt;
+ */
+public class ProcessFormDispatcher extends AbstractFormDispatcher
+    implements FormDispatcherPlugin
+{
+
+  public URL getDispatchUrl(FormAuthorityRef ref)
+  {
+    if(!processHasForm(ref.getReferenceId()))
+      return null;
+    
+    StringBuilder baseUrl = getBaseUrl();
+    baseUrl.append("/form/process/");
+    baseUrl.append( ref.getReferenceId());
+    baseUrl.append("/render");
+
+    try
+    {
+      return new URL(baseUrl.toString());
+    }
+    catch (MalformedURLException e)
+    {
+      throw new RuntimeException("Failed to resolve task dispatch url", e);
+    }
+  }
+
+  private boolean processHasForm(String id)
+  {
+    return getStartFormName(id)!=null;
+  }
+
+  private String getStartFormName(String id)
+  {
+    String name = null;
+
+    Environment env = ((EnvironmentFactory)processEngine).openEnvironment();
+    try
+    {
+      RepositoryService repoService = processEngine.getRepositoryService();
+      List<String> startActivityNames = repoService.getStartActivityNames(id);
+
+      if(null==startActivityNames) // who knows? I'd expect anything from jbpm
+        throw new RuntimeException("Unable to resolve start activity names for
process: "+id);
+
+      String defaultActitvity = startActivityNames.get(0);
+      if(startActivityNames.size()>1)
+      {
+        System.out.println("WARN: More then 1 start activity found. Default to
" + defaultActitvity + " to resolve the form name.");
+      }
+
+      name = repoService.getStartFormResourceName(id, defaultActitvity);       
+    }
+    finally{
+      env.close();
+    }
+
+    return name;
+  }
+
+  public DataHandler provideForm(FormAuthorityRef ref)
+  {
+    Environment env = ((EnvironmentFactory)processEngine).openEnvironment();
+
+    DataHandler result = null;
+
+    try
+    {
+
+      RepositoryService repoService = processEngine.getRepositoryService();
+
+      // check if a template exists
+      String startFormResourceName = getStartFormName(ref.getReferenceId());
+      if(null==startFormResourceName)
+        throw new IllegalArgumentException("Process " +ref.getReferenceId() +
" doesn't provide a start form");
+
+      ProcessDefinition procDef =
+          repoService
+              .createProcessDefinitionQuery()
+              .processDefinitionId(ref.getReferenceId())
+              .uniqueResult();
+
+      InputStream template = repoService.getResourceAsStream(
+          procDef.getDeploymentId(), startFormResourceName
+      );
+
+      // merge template with process variables
+      if(template!=null)
+      {
+        // plugin context
+        StringBuilder action = getBaseUrl();
+        action.append("/form/process/");
+        action.append( ref.getReferenceId() );
+        action.append("/complete");
+
+        Map<String, Object> renderContext = new HashMap<String,Object>();
+
+        // form directive
+        FormDirective formDirective = new FormDirective();
+        formDirective.setAction( action.toString() );
+        renderContext.put(FORM_DIRECTIVE_KEY, formDirective);
+
+        // outcome directive
+        renderContext.put(OUTCOME_DIRECTIVE_NAME, new OutcomeDirective());
+
+        result = processTemplate(startFormResourceName, template, renderContext);
+      }
+
+      return result;
+    }
+    finally{
+      env.close();
+    }
+  }
+
+  public void processCompletion(FormAuthorityRef ref, Map<String, Object> payload,
String performingUser, String outcome)
+  {
+    Environment env = ((EnvironmentFactory)processEngine).openEnvironment();
+
+    try
+    {
+      ExecutionService execService = processEngine.getExecutionService();
+      if(payload!=null)
+      {
+        execService.startProcessInstanceById(
+            ref.getReferenceId(), payload
+        );
+      }
+      else
+      {
+        execService.startProcessInstanceById(ref.getReferenceId());
+      }      
+    }
+    finally
+    {
+      env.close();
+    }
+  }
+}

Deleted:
jbpm4/trunk/modules/integration/form-plugin/src/main/java/org/jbpm/integration/console/forms/TaskDispatcherPluginImpl.java
===================================================================
---
jbpm4/trunk/modules/integration/form-plugin/src/main/java/org/jbpm/integration/console/forms/TaskDispatcherPluginImpl.java	2009-07-01
07:17:16 UTC (rev 5168)
+++
jbpm4/trunk/modules/integration/form-plugin/src/main/java/org/jbpm/integration/console/forms/TaskDispatcherPluginImpl.java	2009-07-01
08:12:26 UTC (rev 5169)
@@ -1,263 +0,0 @@
-/*
- * JBoss, Home of Professional Open Source.
- * Copyright 2006, Red Hat Middleware LLC, and individual contributors
- * as indicated by the @author tags. See the copyright.txt file in the
- * distribution for a full listing of individual contributors.
- *
- * This is free software; you can redistribute it and/or modify it
- * under the terms of the GNU Lesser General Public License as
- * published by the Free Software Foundation; either version 2.1 of
- * the License, or (at your option) any later version.
- *
- * This software is distributed in the hope that it will be useful,
- * but WITHOUT ANY WARRANTY; without even the implied warranty of
- * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU
- * Lesser General Public License for more details.
- *
- * You should have received a copy of the GNU Lesser General Public
- * License along with this software; if not, write to the Free
- * Software Foundation, Inc., 51 Franklin St, Fifth Floor, Boston, MA
- * 02110-1301 USA, or see the FSF site: http://www.fsf.org.
- */
-package org.jbpm.integration.console.forms;
-
-import java.io.ByteArrayInputStream;
-import java.io.ByteArrayOutputStream;
-import java.io.IOException;
-import java.io.InputStream;
-import java.io.InputStreamReader;
-import java.io.OutputStream;
-import java.io.OutputStreamWriter;
-import java.io.Writer;
-import java.net.MalformedURLException;
-import java.net.URL;
-import java.util.HashMap;
-import java.util.List;
-import java.util.Map;
-import java.util.Set;
-
-import javax.activation.DataHandler;
-import javax.activation.DataSource;
-import javax.naming.InitialContext;
-
-import org.jboss.bpm.console.server.plugin.TaskDispatcherPlugin;
-import org.jbpm.api.ExecutionService;
-import org.jbpm.api.ProcessDefinition;
-import org.jbpm.api.ProcessDefinitionQuery;
-import org.jbpm.api.ProcessEngine;
-import org.jbpm.api.RepositoryService;
-import org.jbpm.api.TaskService;
-import org.jbpm.api.task.Task;
-import org.jbpm.integration.spi.mgmt.ServerConfig;
-import org.jbpm.integration.spi.mgmt.ServerConfigFactory;
-import org.jbpm.pvm.internal.env.Environment;
-import org.jbpm.pvm.internal.env.EnvironmentFactory;
-import org.jbpm.pvm.internal.model.ExecutionImpl;
-import org.jbpm.pvm.internal.model.Transition;
-import org.jbpm.pvm.internal.task.TaskImpl;
-
-import freemarker.template.DefaultObjectWrapper;
-import freemarker.template.Template;
-
-/**
- * @author Heiko.Braun <heiko.braun(a)jboss.com&gt;
- */
-public class TaskDispatcherPluginImpl implements TaskDispatcherPlugin
-{
-  private ProcessEngine processEngine;
-
-  private ServerConfig serverConfig = null;
-
-  public TaskDispatcherPluginImpl()
-  {
-    initializeProcessEngine();
-  }
-
-  public URL getDispatchUrl(long taskId)
-  {
-    StringBuilder spec = new StringBuilder();
-    spec.append("http://");
-    spec.append(getServerConfig().getWebServiceHost());
-    spec.append(":").append(getServerConfig().getWebServicePort());
-    spec.append("/gwt-console-server/rs/task/");
-    spec.append( taskId );
-    spec.append("/render");
-
-    try
-    {
-      return new URL(spec.toString());
-    }
-    catch (MalformedURLException e)
-    {
-      throw new RuntimeException("Failed to resolve task dispatch url", e);
-    }
-  }
-
-
-  private ServerConfig getServerConfig()
-  {
-    if(null==serverConfig)
-    {
-      serverConfig = ServerConfigFactory.getServerConfig();
-    }
-    return serverConfig;
-  }
-
-  public DataHandler provideTaskUI(long taskId)
-  {
-    Environment env = ((EnvironmentFactory)processEngine).openEnvironment();
-
-    DataHandler result = null;
-
-    try
-    {
-      TaskService taskService = processEngine.getTaskService();
-      Task task = taskService.getTask(Long.toString(taskId));
-
-      // access the processdefition
-      TaskImpl cast = ((TaskImpl) task);
-      ExecutionImpl processInstance = cast.getProcessInstance();
-      String processInstanceId =  processInstance.getId();
-      String processId =  processInstance.getProcessDefinition().getId();
-
-      RepositoryService repoService = processEngine.getRepositoryService();
-      ProcessDefinitionQuery query = repoService.createProcessDefinitionQuery();
-      query.processDefinitionId(processId);
-      ProcessDefinition procDef = query.uniqueResult();
-
-      // check if a template exists
-      String name = task.getName() + ".ftl";
-      InputStream template = repoService.getResourceAsStream(
-          procDef.getDeploymentId(), name
-      );
-
-      // merge template with process variables
-      if(template!=null)
-      {
-        ExecutionService execService = processEngine.getExecutionService();
-
-        Set<String> varNames = execService.getVariableNames(processInstanceId);
-        if(varNames!=null)
-        {
-          Map<String, Object> processContext =
execService.getVariables(processInstanceId, varNames);
-
-          // plugin context
-
-          StringBuilder action = new StringBuilder();
-          action.append("http://");
-          action.append(getServerConfig().getWebServiceHost());
-          action.append(":").append(getServerConfig().getWebServicePort());
-          action.append("/gwt-console-server/rs/task/");
-          action.append( taskId );
-          action.append("/process");
-
-          Map<String, Object> renderContext = new HashMap<String,Object>();
-
-          // formResourceName directive
-          FormDirective formDirective = new FormDirective();
-          formDirective.setAction( action.toString() );
-          renderContext.put("formResourceName", formDirective);
-
-          // outcome directive
-          // TODO: Fix when https://jira.jboss.org/jira/browse/JBPM-2220 is done
-          OutcomeDirective outcomeDirective = new OutcomeDirective();
-          List<Transition> transitions =
-              ((ExecutionImpl) processInstance).getActivity().getOutgoingTransitions();
-          for(Transition t : transitions)
-          {
-            String outcomeName = t.getName()!=null ? t.getName() :
"to_"+t.getDestination().getName();
-            outcomeDirective.getValues().add(outcomeName);
-          }
-          renderContext.put("outcome",outcomeDirective);          
-
-          // process variables
-          renderContext.putAll(processContext);
-
-
-          result = processTemplate(name, template, renderContext);
-        }
-      }
-
-      return result;
-    }
-    finally{
-      env.close();
-    }
-  }
-
-  private DataHandler processTemplate(
-      final String name, InputStream src,
-      Map<String, Object> renderContext
-      )
-  {
-    DataHandler merged = null;
-
-    try
-    {
-      freemarker.template.Configuration cfg = new freemarker.template.Configuration();   
  
-      cfg.setObjectWrapper(new DefaultObjectWrapper());
-      cfg.setTemplateUpdateDelay(0);
-
-      Template temp = new Template(name, new InputStreamReader(src), cfg);
-      temp.dump(System.out);
-
-      final ByteArrayOutputStream bout = new ByteArrayOutputStream();
-      Writer out = new OutputStreamWriter(bout);
-      temp.process(renderContext, out);
-      out.flush();
-       
-      merged = new DataHandler(
-
-          new DataSource()
-          {
-
-            public InputStream getInputStream() throws IOException
-            {
-              return new ByteArrayInputStream(bout.toByteArray());
-            }
-
-            public OutputStream getOutputStream() throws IOException
-            {
-              return bout;
-            }
-
-            public String getContentType()
-            {
-              return "application/octet-stream";
-            }
-
-            public String getName()
-            {
-              return name + "_DataSource";
-            }
-          }
-      );
-
-    }
-    catch (Exception e)
-    {
-      throw new RuntimeException("Failed to process task template", e);
-    }
-
-    return merged;
-  }
-
-  public void processCompletion(long taskId, String outcome, InputStream payload)
-  {
-
-  }
-
-  protected void initializeProcessEngine()
-  {
-    try
-    {
-      InitialContext ctx = new InitialContext();
-      this.processEngine = (ProcessEngine)ctx.lookup("java:/ProcessEngine");
-    }
-    catch (Exception e)
-    {
-      throw new RuntimeException("Failed to lookup process engine", e);
-    }
-  }
-
-}

Copied:
jbpm4/trunk/modules/integration/form-plugin/src/main/java/org/jbpm/integration/console/forms/TaskFormDispatcher.java
(from rev 5155,
jbpm4/trunk/modules/integration/form-plugin/src/main/java/org/jbpm/integration/console/forms/TaskDispatcherPluginImpl.java)
===================================================================
---
jbpm4/trunk/modules/integration/form-plugin/src/main/java/org/jbpm/integration/console/forms/TaskFormDispatcher.java	
                       (rev 0)
+++
jbpm4/trunk/modules/integration/form-plugin/src/main/java/org/jbpm/integration/console/forms/TaskFormDispatcher.java	2009-07-01
08:12:26 UTC (rev 5169)
@@ -0,0 +1,199 @@
+/*
+ * JBoss, Home of Professional Open Source.
+ * Copyright 2006, Red Hat Middleware LLC, and individual contributors
+ * as indicated by the @author tags. See the copyright.txt file in the
+ * distribution for a full listing of individual contributors.
+ *
+ * This is free software; you can redistribute it and/or modify it
+ * under the terms of the GNU Lesser General Public License as
+ * published by the Free Software Foundation; either version 2.1 of
+ * the License, or (at your option) any later version.
+ *
+ * This software is distributed in the hope that it will be useful,
+ * but WITHOUT ANY WARRANTY; without even the implied warranty of
+ * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU
+ * Lesser General Public License for more details.
+ *
+ * You should have received a copy of the GNU Lesser General Public
+ * License along with this software; if not, write to the Free
+ * Software Foundation, Inc., 51 Franklin St, Fifth Floor, Boston, MA
+ * 02110-1301 USA, or see the FSF site: http://www.fsf.org.
+ */
+package org.jbpm.integration.console.forms;
+
+import org.jboss.bpm.console.server.plugin.FormAuthorityRef;
+import org.jboss.bpm.console.server.plugin.FormDispatcherPlugin;
+import org.jbpm.api.*;
+import org.jbpm.api.task.Task;
+import org.jbpm.pvm.internal.env.Environment;
+import org.jbpm.pvm.internal.env.EnvironmentFactory;
+import org.jbpm.pvm.internal.model.ExecutionImpl;
+import org.jbpm.pvm.internal.model.Transition;
+import org.jbpm.pvm.internal.task.TaskImpl;
+
+import javax.activation.DataHandler;
+import java.io.InputStream;
+import java.net.MalformedURLException;
+import java.net.URL;
+import java.util.HashMap;
+import java.util.List;
+import java.util.Map;
+import java.util.Set;
+
+/**
+ * Processes form data to complete tasks.
+ *
+ * @author Heiko.Braun <heiko.braun(a)jboss.com&gt;
+ */
+public class TaskFormDispatcher extends AbstractFormDispatcher
+    implements FormDispatcherPlugin
+{
+
+  public TaskFormDispatcher()
+  {
+    super();
+  }
+
+  public URL getDispatchUrl(FormAuthorityRef ref)
+  {
+    if(!taskHasForm(ref.getReferenceId()))
+      return null;
+
+    StringBuilder baseUrl = getBaseUrl();
+    baseUrl.append("/form/task/");
+    baseUrl.append( ref.getReferenceId());
+    baseUrl.append("/render");
+
+    try
+    {
+      return new URL(baseUrl.toString());
+    }
+    catch (MalformedURLException e)
+    {
+      throw new RuntimeException("Failed to resolve task dispatch url", e);
+    }
+  }
+
+  private boolean taskHasForm(String id)
+  {
+    boolean result = false;
+
+    Environment env = ((EnvironmentFactory)processEngine).openEnvironment();
+    try
+    {
+      TaskService taskService = processEngine.getTaskService();
+      Task task = taskService.getTask(id);
+      result = (task.getFormResourceName()!=null);
+    }
+    finally
+    {
+      env.close();
+    }
+
+    return result;
+  }
+
+  public DataHandler provideForm(FormAuthorityRef ref)
+  {
+    Environment env = ((EnvironmentFactory)processEngine).openEnvironment();
+   
+    try
+    {
+      TaskService taskService = processEngine.getTaskService();
+      Task task = taskService.getTask(ref.getReferenceId());
+
+      // access the processdefition
+      TaskImpl cast = ((TaskImpl) task);
+      ExecutionImpl processInstance = cast.getProcessInstance();
+      String processInstanceId =  processInstance.getId();
+      String processId =  processInstance.getProcessDefinition().getId();
+
+      RepositoryService repoService = processEngine.getRepositoryService();
+      ProcessDefinitionQuery query = repoService.createProcessDefinitionQuery();
+      query.processDefinitionId(processId);
+      ProcessDefinition procDef = query.uniqueResult();
+
+      // check if a template exists
+      String name = task.getFormResourceName();
+      InputStream template = repoService.getResourceAsStream(
+          procDef.getDeploymentId(), name
+      );
+
+      // merge template with process variables
+      if(template==null)
+        throw new IllegalArgumentException("Task form resource
'"+name+"' doesn't exist.");
+
+      Map<String, Object> processContext = new HashMap<String, Object>(); //
empty default
+      ExecutionService execService = processEngine.getExecutionService();
+      Set<String> varNames = execService.getVariableNames(processInstanceId);
+
+      if(varNames!=null)
+        processContext = execService.getVariables(processInstanceId, varNames);
+
+      // plugin context
+      StringBuilder action = getBaseUrl();
+      action.append("/form/task/");
+      action.append( ref.getReferenceId() );
+      action.append("/complete");
+
+      Map<String, Object> renderContext = new HashMap<String,Object>();
+
+      // form directive
+      FormDirective formDirective = new FormDirective();
+      formDirective.setAction( action.toString() );
+      renderContext.put(FORM_DIRECTIVE_KEY, formDirective);
+
+      // outcome directive
+      // TODO: Fix when https://jira.jboss.org/jira/browse/JBPM-2220 is done
+      OutcomeDirective outcomeDirective = new OutcomeDirective();
+      List<Transition> transitions =
+          ((ExecutionImpl) processInstance).getActivity().getOutgoingTransitions();
+      for(Transition t : transitions)
+      {
+        String outcomeName = t.getName()!=null ? t.getName() :
"to_"+t.getDestination().getName();
+        outcomeDirective.getValues().add(outcomeName);
+      }
+      renderContext.put(OUTCOME_DIRECTIVE_NAME, outcomeDirective);
+
+      // process variables
+      renderContext.putAll(processContext);
+
+      DataHandler result = processTemplate(name, template, renderContext);
+      return result;
+    }
+    finally
+    {
+      env.close();
+    }
+  }
+
+  public void processCompletion(
+      FormAuthorityRef ref,
+      Map<String,Object> payload,
+      String performingUser,
+      String outcome)
+  {
+    Environment env = ((EnvironmentFactory)processEngine).openEnvironment();
+
+    String taskId = ref.getReferenceId();
+
+    try
+    {
+      TaskService taskService = processEngine.getTaskService();
+
+      if(payload!=null)
+        taskService.setVariables(taskId, payload);
+
+      if(null==outcome)
+        taskService.completeTask(taskId);
+      else
+        taskService.completeTask(taskId, outcome);
+
+    }
+    finally
+    {
+      env.close();
+    }
+  }
+
+}

Copied:
jbpm4/trunk/modules/integration/form-plugin/src/main/resources/META-INF/services/org.jboss.bpm.console.server.plugin.FormDispatcherPlugin
(from rev 5146,
jbpm4/trunk/modules/integration/form-plugin/src/main/resources/META-INF/services/org.jboss.bpm.console.server.plugin.TaskDispatcherPlugin)
===================================================================
---
jbpm4/trunk/modules/integration/form-plugin/src/main/resources/META-INF/services/org.jboss.bpm.console.server.plugin.FormDispatcherPlugin	
                       (rev 0)
+++
jbpm4/trunk/modules/integration/form-plugin/src/main/resources/META-INF/services/org.jboss.bpm.console.server.plugin.FormDispatcherPlugin	2009-07-01
08:12:26 UTC (rev 5169)
@@ -0,0 +1 @@
+org.jbpm.integration.console.forms.FormDispatcherComposite
\ No newline at end of file

Deleted:
jbpm4/trunk/modules/integration/form-plugin/src/main/resources/META-INF/services/org.jboss.bpm.console.server.plugin.TaskDispatcherPlugin
===================================================================
---
jbpm4/trunk/modules/integration/form-plugin/src/main/resources/META-INF/services/org.jboss.bpm.console.server.plugin.TaskDispatcherPlugin	2009-07-01
07:17:16 UTC (rev 5168)
+++
jbpm4/trunk/modules/integration/form-plugin/src/main/resources/META-INF/services/org.jboss.bpm.console.server.plugin.TaskDispatcherPlugin	2009-07-01
08:12:26 UTC (rev 5169)
@@ -1 +0,0 @@
-org.jbpm.integration.console.forms.TaskDispatcherPluginImpl
\ No newline at end of file


    

2024

2023

2022

2021

2020

2019

2018

2017

2016

2015

2014

2013

2012

2011

2010

2009

2008

[jbpm-commits] JBoss JBPM SVN: r5169 - in jbpm4/trunk/modules/integration: form-plugin/src/main/java/org/jbpm/integration/console/forms and 1 other directories.