Apply automatic changes

Author: actions-user

README.md

@@ -166,18 +166,24 @@ import (
 func initBpmnEngine() {
 	bpmnEngine = bpmn_engine.New("Ordering-Microservice")
 	process, _ = bpmnEngine.LoadFromBytes(OrderingItemsWorkflowBpmn)
-	bpmnEngine.AddTaskHandler("validate-order", businessActionHandler)
-	bpmnEngine.AddTaskHandler("send-bill", businessActionHandler)
-	bpmnEngine.AddTaskHandler("send-friendly-reminder", businessActionHandler)
-	bpmnEngine.AddTaskHandler("update-accounting", businessActionHandler)
-	bpmnEngine.AddTaskHandler("package-and-deliver", businessActionHandler)
-	bpmnEngine.AddTaskHandler("send-cancellation", businessActionHandler)
+	bpmnEngine.AddTaskHandler("validate-order", printHandler)
+	bpmnEngine.AddTaskHandler("send-bill", printHandler)
+	bpmnEngine.AddTaskHandler("send-friendly-reminder", printHandler)
+	bpmnEngine.AddTaskHandler("update-accounting", updateAccountingHandler)
+	bpmnEngine.AddTaskHandler("package-and-deliver", printHandler)
+	bpmnEngine.AddTaskHandler("send-cancellation", printHandler)
 }
 
-func businessActionHandler(job bpmn_engine.ActivatedJob) {
+func printHandler(job bpmn_engine.ActivatedJob) {
 	// do important stuff here
-	msg := fmt.Sprintf("%s >>> Executing job '%s", time.Now(), job.ElementId)
-	println(msg)
+	println(fmt.Sprintf("%s >>> Executing job '%s", time.Now(), job.ElementId))
+	job.Complete()
+}
+
+func updateAccountingHandler(job bpmn_engine.ActivatedJob) {
+	println(fmt.Sprintf("%s >>> Executing job '%s", time.Now(), job.ElementId))
+	println(fmt.Sprintf("%s >>> update ledger revenue account with amount=%s", time.Now(), job.GetVariable("amount")))
+	job.Complete()
 }
 ```
 <!-- MARKDOWN-AUTO-DOCS:END -->
@@ -215,6 +221,8 @@ func showOrderStatus(writer http.ResponseWriter, request *http.Request) {
 	orderId, _ := strconv.ParseInt(orderIdStr, 10, 64)
 	instance := bpmnEngine.FindProcessInstanceById(orderId)
 	if instance != nil {
+		// we re-use this GET request to ensure we catch up the timers - ideally the service uses internal timers instead
+		bpmnEngine.RunOrContinueInstance(instance.GetInstanceKey())
 		bytes, _ := prepareJsonResponse(orderIdStr, instance.GetState(), instance.GetCreatedAt())
 		writer.Header().Set("Content-Type", "application/json")
 		writer.Write(bytes)
@@ -235,10 +243,25 @@ package main
 import (
 	_ "embed"
 	"net/http"
+	"strconv"
 )
 
 func handleReceivePayment(writer http.ResponseWriter, request *http.Request) {
-	writer.Header().Set("Content-Type", "application/json")
+	orderIdStr := request.FormValue("orderId")
+	amount := request.FormValue("amount")
+	if len(orderIdStr) > 0 && len(amount) > 0 {
+		orderId, _ := strconv.ParseInt(orderIdStr, 10, 64)
+		processInstance := bpmnEngine.FindProcessInstanceById(orderId)
+		if processInstance != nil {
+			processInstance.SetVariable("amount", amount)
+			bpmnEngine.PublishEventForInstance(processInstance.GetInstanceKey(), "payment-received")
+			bpmnEngine.RunOrContinueInstance(processInstance.GetInstanceKey())
+			http.Redirect(writer, request, "/", http.StatusFound)
+			return
+		}
+	}
+	writer.WriteHeader(400)
+	writer.Write([]byte("Bad request: the request must contain form data with 'orderId' and 'amount', and the order must exist"))
 }
 ```
 <!-- MARKDOWN-AUTO-DOCS:END -->