From 9d27f7ff4e5cac8210e52bc98e54d1d6d39572c9 Mon Sep 17 00:00:00 2001
From: David Kaufmann <david.kaufmann@student.tuwien.ac.at>
Date: Sun, 20 Jan 2019 16:55:56 +0100
Subject: [PATCH] catch more stuff and send to offline_analysis

---
 camunda-overlay/sentiment-analysis.bpmn | 156 +++++++++++++++---------
 1 file changed, 100 insertions(+), 56 deletions(-)

diff --git a/camunda-overlay/sentiment-analysis.bpmn b/camunda-overlay/sentiment-analysis.bpmn
index 8b6b94c..0bed5ff 100644
--- a/camunda-overlay/sentiment-analysis.bpmn
+++ b/camunda-overlay/sentiment-analysis.bpmn
@@ -9,31 +9,7 @@
     <bpmn:sequenceFlow id="SequenceFlow_0jebdb9" sourceRef="Task_1e7059p" targetRef="EndEvent_0bmuv13" />
     <bpmn:sequenceFlow id="SequenceFlow_15dip2q" sourceRef="StartEvent_1t6nxib" targetRef="IntermediateThrowEvent_193oik9" />
     <bpmn:sequenceFlow id="SequenceFlow_1j2y6tv" sourceRef="terms_loop" targetRef="service-report" />
-    <bpmn:startEvent id="StartEvent_1t6nxib" camunda:formKey="embedded:deployment:input-terms.html">
-      <bpmn:extensionElements>
-        <camunda:executionListener event="start">
-          <camunda:script scriptFormat="javascript">// make variable global
-execution.setVariable("results", S('[]'))</camunda:script>
-        </camunda:executionListener>
-      </bpmn:extensionElements>
-      <bpmn:outgoing>SequenceFlow_15dip2q</bpmn:outgoing>
-    </bpmn:startEvent>
-    <bpmn:endEvent id="EndEvent_0bmuv13">
-      <bpmn:incoming>SequenceFlow_0jebdb9</bpmn:incoming>
-    </bpmn:endEvent>
     <bpmn:sequenceFlow id="SequenceFlow_0o77usd" sourceRef="IntermediateThrowEvent_193oik9" targetRef="terms_loop" />
-    <bpmn:userTask id="Task_1e7059p" name="download pdf" camunda:formKey="embedded:deployment:download-pdf.html">
-      <bpmn:incoming>SequenceFlow_1mnqqvo</bpmn:incoming>
-      <bpmn:outgoing>SequenceFlow_0jebdb9</bpmn:outgoing>
-    </bpmn:userTask>
-    <bpmn:intermediateCatchEvent id="IntermediateThrowEvent_193oik9">
-      <bpmn:incoming>SequenceFlow_15dip2q</bpmn:incoming>
-      <bpmn:incoming>SequenceFlow_1mphutj</bpmn:incoming>
-      <bpmn:outgoing>SequenceFlow_0o77usd</bpmn:outgoing>
-      <bpmn:timerEventDefinition>
-        <bpmn:timeDuration xsi:type="bpmn:tFormalExpression">PT0S</bpmn:timeDuration>
-      </bpmn:timerEventDefinition>
-    </bpmn:intermediateCatchEvent>
     <bpmn:subProcess id="terms_loop">
       <bpmn:extensionElements>
         <camunda:executionListener event="start">
@@ -115,8 +91,59 @@ S(response);</camunda:script>
       <bpmn:sequenceFlow id="SequenceFlow_1bz7zx2" sourceRef="service-analysis" targetRef="EndEvent_parsing_term" />
       <bpmn:endEvent id="EndEvent_parsing_term">
         <bpmn:incoming>SequenceFlow_1bz7zx2</bpmn:incoming>
+        <bpmn:incoming>SequenceFlow_0d4q1qg</bpmn:incoming>
       </bpmn:endEvent>
+      <bpmn:boundaryEvent id="BoundaryEvent_0qgiers" attachedToRef="service-analysis">
+        <bpmn:outgoing>SequenceFlow_0a608kq</bpmn:outgoing>
+        <bpmn:errorEventDefinition />
+      </bpmn:boundaryEvent>
+      <bpmn:serviceTask id="ServiceTask_0y5nlkj" name="Analysis Service">
+        <bpmn:extensionElements>
+          <camunda:connector>
+            <camunda:inputOutput>
+              <camunda:inputParameter name="url">http://analysis:8081/offline_analysis/</camunda:inputParameter>
+              <camunda:inputParameter name="method">POST</camunda:inputParameter>
+              <camunda:inputParameter name="headers">
+                <camunda:map>
+                  <camunda:entry key="Accept">application/json</camunda:entry>
+                  <camunda:entry key="Content-Type">application/json</camunda:entry>
+                </camunda:map>
+              </camunda:inputParameter>
+              <camunda:inputParameter name="payload">${tweets.toString()}</camunda:inputParameter>
+              <camunda:outputParameter name="analysis">${response.trim()}</camunda:outputParameter>
+            </camunda:inputOutput>
+            <camunda:connectorId>http-connector</camunda:connectorId>
+          </camunda:connector>
+        </bpmn:extensionElements>
+        <bpmn:incoming>SequenceFlow_0a608kq</bpmn:incoming>
+        <bpmn:outgoing>SequenceFlow_0d4q1qg</bpmn:outgoing>
+      </bpmn:serviceTask>
+      <bpmn:sequenceFlow id="SequenceFlow_0a608kq" sourceRef="BoundaryEvent_0qgiers" targetRef="ServiceTask_0y5nlkj" />
+      <bpmn:sequenceFlow id="SequenceFlow_0d4q1qg" sourceRef="ServiceTask_0y5nlkj" targetRef="EndEvent_parsing_term" />
     </bpmn:subProcess>
+    <bpmn:sequenceFlow id="SequenceFlow_1mnqqvo" sourceRef="IntermediateThrowEvent_0sns4tf" targetRef="Task_1e7059p" />
+    <bpmn:sequenceFlow id="SequenceFlow_0pjn3f9" sourceRef="BoundaryEvent_0vcqy0m" targetRef="IntermediateThrowEvent_193oik9" />
+    <bpmn:boundaryEvent id="BoundaryEvent_0vcqy0m" attachedToRef="terms_loop">
+      <bpmn:outgoing>SequenceFlow_0pjn3f9</bpmn:outgoing>
+      <bpmn:errorEventDefinition />
+    </bpmn:boundaryEvent>
+    <bpmn:intermediateCatchEvent id="IntermediateThrowEvent_193oik9">
+      <bpmn:incoming>SequenceFlow_15dip2q</bpmn:incoming>
+      <bpmn:incoming>SequenceFlow_0pjn3f9</bpmn:incoming>
+      <bpmn:outgoing>SequenceFlow_0o77usd</bpmn:outgoing>
+      <bpmn:timerEventDefinition>
+        <bpmn:timeDuration xsi:type="bpmn:tFormalExpression">PT0S</bpmn:timeDuration>
+      </bpmn:timerEventDefinition>
+    </bpmn:intermediateCatchEvent>
+    <bpmn:startEvent id="StartEvent_1t6nxib" camunda:formKey="embedded:deployment:input-terms.html">
+      <bpmn:extensionElements>
+        <camunda:executionListener event="start">
+          <camunda:script scriptFormat="javascript">// make variable global
+execution.setVariable("results", S('[]'))</camunda:script>
+        </camunda:executionListener>
+      </bpmn:extensionElements>
+      <bpmn:outgoing>SequenceFlow_15dip2q</bpmn:outgoing>
+    </bpmn:startEvent>
     <bpmn:serviceTask id="service-report" name="Report Service">
       <bpmn:extensionElements>
         <camunda:connector>
@@ -229,7 +256,6 @@ file</camunda:script>
       <bpmn:incoming>SequenceFlow_1j2y6tv</bpmn:incoming>
       <bpmn:outgoing>SequenceFlow_14nqu0e</bpmn:outgoing>
     </bpmn:serviceTask>
-    <bpmn:sequenceFlow id="SequenceFlow_1mnqqvo" sourceRef="IntermediateThrowEvent_0sns4tf" targetRef="Task_1e7059p" />
     <bpmn:intermediateCatchEvent id="IntermediateThrowEvent_0sns4tf">
       <bpmn:incoming>SequenceFlow_14nqu0e</bpmn:incoming>
       <bpmn:outgoing>SequenceFlow_1mnqqvo</bpmn:outgoing>
@@ -237,19 +263,21 @@ file</camunda:script>
         <bpmn:timeDuration xsi:type="bpmn:tFormalExpression">PT0S</bpmn:timeDuration>
       </bpmn:timerEventDefinition>
     </bpmn:intermediateCatchEvent>
-    <bpmn:boundaryEvent id="BoundaryEvent_0vcqy0m" attachedToRef="terms_loop">
-      <bpmn:outgoing>SequenceFlow_1mphutj</bpmn:outgoing>
-      <bpmn:errorEventDefinition />
-    </bpmn:boundaryEvent>
-    <bpmn:sequenceFlow id="SequenceFlow_1mphutj" sourceRef="BoundaryEvent_0vcqy0m" targetRef="IntermediateThrowEvent_193oik9" />
+    <bpmn:userTask id="Task_1e7059p" name="download pdf" camunda:formKey="embedded:deployment:download-pdf.html">
+      <bpmn:incoming>SequenceFlow_1mnqqvo</bpmn:incoming>
+      <bpmn:outgoing>SequenceFlow_0jebdb9</bpmn:outgoing>
+    </bpmn:userTask>
+    <bpmn:endEvent id="EndEvent_0bmuv13">
+      <bpmn:incoming>SequenceFlow_0jebdb9</bpmn:incoming>
+    </bpmn:endEvent>
   </bpmn:process>
   <bpmndi:BPMNDiagram id="BPMNDiagram_1">
     <bpmndi:BPMNPlane id="BPMNPlane_1" bpmnElement="Collaboration">
       <bpmndi:BPMNShape id="Participant_0gzc3m9_di" bpmnElement="Sentiment_Analysis">
-        <dc:Bounds x="0" y="0" width="1084" height="245" />
+        <dc:Bounds x="0" y="0" width="1087" height="369" />
       </bpmndi:BPMNShape>
       <bpmndi:BPMNShape id="SubProcess_1skl2rb_di" bpmnElement="terms_loop" isExpanded="true">
-        <dc:Bounds x="188" y="19" width="443" height="163" />
+        <dc:Bounds x="188" y="19" width="440" height="297" />
       </bpmndi:BPMNShape>
       <bpmndi:BPMNShape id="ServiceTask_01bq7a6_di" bpmnElement="service-analysis">
         <dc:Bounds x="434" y="60" width="100" height="80" />
@@ -273,58 +301,74 @@ file</camunda:script>
         <di:waypoint x="569" y="100" />
       </bpmndi:BPMNEdge>
       <bpmndi:BPMNShape id="StartEvent_1t6nxib_di" bpmnElement="StartEvent_1t6nxib">
-        <dc:Bounds x="56" y="83" width="36" height="36" />
+        <dc:Bounds x="54" y="151" width="36" height="36" />
       </bpmndi:BPMNShape>
       <bpmndi:BPMNShape id="ServiceTask_1gaqtzh_di" bpmnElement="service-report">
-        <dc:Bounds x="664" y="61" width="100" height="80" />
+        <dc:Bounds x="664" y="129" width="100" height="80" />
       </bpmndi:BPMNShape>
       <bpmndi:BPMNShape id="UserTask_0iooc2g_di" bpmnElement="Task_1e7059p">
-        <dc:Bounds x="889" y="61" width="100" height="80" />
+        <dc:Bounds x="882" y="129" width="100" height="80" />
       </bpmndi:BPMNShape>
       <bpmndi:BPMNShape id="EndEvent_0bmuv13_di" bpmnElement="EndEvent_0bmuv13">
-        <dc:Bounds x="1024" y="83" width="36" height="36" />
+        <dc:Bounds x="1021" y="151" width="36" height="36" />
       </bpmndi:BPMNShape>
       <bpmndi:BPMNEdge id="SequenceFlow_14nqu0e_di" bpmnElement="SequenceFlow_14nqu0e">
-        <di:waypoint x="764" y="101" />
-        <di:waypoint x="803" y="101" />
+        <di:waypoint x="764" y="169" />
+        <di:waypoint x="804" y="169" />
       </bpmndi:BPMNEdge>
       <bpmndi:BPMNEdge id="SequenceFlow_0jebdb9_di" bpmnElement="SequenceFlow_0jebdb9">
-        <di:waypoint x="989" y="101" />
-        <di:waypoint x="1024" y="101" />
+        <di:waypoint x="982" y="169" />
+        <di:waypoint x="1021" y="169" />
       </bpmndi:BPMNEdge>
       <bpmndi:BPMNEdge id="SequenceFlow_15dip2q_di" bpmnElement="SequenceFlow_15dip2q">
-        <di:waypoint x="92" y="101" />
-        <di:waypoint x="122" y="101" />
+        <di:waypoint x="90" y="169" />
+        <di:waypoint x="122" y="169" />
       </bpmndi:BPMNEdge>
       <bpmndi:BPMNEdge id="SequenceFlow_1j2y6tv_di" bpmnElement="SequenceFlow_1j2y6tv">
-        <di:waypoint x="631" y="101" />
-        <di:waypoint x="664" y="101" />
+        <di:waypoint x="628" y="169" />
+        <di:waypoint x="664" y="169" />
       </bpmndi:BPMNEdge>
       <bpmndi:BPMNShape id="EndEvent_07g109m_di" bpmnElement="EndEvent_parsing_term">
         <dc:Bounds x="569" y="82" width="36" height="36" />
       </bpmndi:BPMNShape>
       <bpmndi:BPMNEdge id="SequenceFlow_0o77usd_di" bpmnElement="SequenceFlow_0o77usd">
-        <di:waypoint x="158" y="101" />
-        <di:waypoint x="188" y="101" />
+        <di:waypoint x="158" y="169" />
+        <di:waypoint x="188" y="169" />
       </bpmndi:BPMNEdge>
       <bpmndi:BPMNShape id="IntermediateCatchEvent_1248i6u_di" bpmnElement="IntermediateThrowEvent_193oik9">
-        <dc:Bounds x="122" y="83" width="36" height="36" />
+        <dc:Bounds x="122" y="151" width="36" height="36" />
       </bpmndi:BPMNShape>
       <bpmndi:BPMNEdge id="SequenceFlow_1mnqqvo_di" bpmnElement="SequenceFlow_1mnqqvo">
-        <di:waypoint x="839" y="101" />
-        <di:waypoint x="889" y="101" />
+        <di:waypoint x="840" y="169" />
+        <di:waypoint x="882" y="169" />
       </bpmndi:BPMNEdge>
       <bpmndi:BPMNShape id="IntermediateCatchEvent_065fcij_di" bpmnElement="IntermediateThrowEvent_0sns4tf">
-        <dc:Bounds x="803" y="83" width="36" height="36" />
+        <dc:Bounds x="804" y="151" width="36" height="36" />
       </bpmndi:BPMNShape>
       <bpmndi:BPMNShape id="BoundaryEvent_1yw4jbm_di" bpmnElement="BoundaryEvent_0vcqy0m">
-        <dc:Bounds x="569" y="164" width="36" height="36" />
+        <dc:Bounds x="566" y="298" width="36" height="36" />
       </bpmndi:BPMNShape>
-      <bpmndi:BPMNEdge id="SequenceFlow_1mphutj_di" bpmnElement="SequenceFlow_1mphutj">
-        <di:waypoint x="587" y="200" />
-        <di:waypoint x="587" y="220" />
-        <di:waypoint x="140" y="220" />
-        <di:waypoint x="140" y="119" />
+      <bpmndi:BPMNEdge id="SequenceFlow_0pjn3f9_di" bpmnElement="SequenceFlow_0pjn3f9">
+        <di:waypoint x="584" y="334" />
+        <di:waypoint x="584" y="354" />
+        <di:waypoint x="140" y="354" />
+        <di:waypoint x="140" y="187" />
+      </bpmndi:BPMNEdge>
+      <bpmndi:BPMNShape id="BoundaryEvent_1gxbbqe_di" bpmnElement="BoundaryEvent_0qgiers">
+        <dc:Bounds x="466" y="122" width="36" height="36" />
+      </bpmndi:BPMNShape>
+      <bpmndi:BPMNShape id="ServiceTask_0y5nlkj_di" bpmnElement="ServiceTask_0y5nlkj">
+        <dc:Bounds x="434" y="202" width="100" height="80" />
+      </bpmndi:BPMNShape>
+      <bpmndi:BPMNEdge id="SequenceFlow_0a608kq_di" bpmnElement="SequenceFlow_0a608kq">
+        <di:waypoint x="484" y="158" />
+        <di:waypoint x="484" y="202" />
+      </bpmndi:BPMNEdge>
+      <bpmndi:BPMNEdge id="SequenceFlow_0d4q1qg_di" bpmnElement="SequenceFlow_0d4q1qg">
+        <di:waypoint x="534" y="242" />
+        <di:waypoint x="552" y="242" />
+        <di:waypoint x="552" y="100" />
+        <di:waypoint x="569" y="100" />
       </bpmndi:BPMNEdge>
     </bpmndi:BPMNPlane>
   </bpmndi:BPMNDiagram>
-- 
2.43.0