lib-bpmn-engine-js/main_js.go at main · nitram509/lib-bpmn-engine-js · GitHub

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
package main

import (
	"fmt"
	"github.com/nitram509/lib-bpmn-engine/pkg/bpmn_engine"
	"github.com/norunners/vert"
	"syscall/js"
)

type jsBinding struct {
	Name string `js:"name"`
}

type EngineWrapper struct {
	engine *bpmn_engine.BpmnEngineState
}

type ActivatedJobHandler struct {
	handler js.Value
}

var engineCounter = 0

func main() {
	done := make(chan struct{}, 0)
	js.Global().Set("NewBpmnEngine", js.FuncOf(newBpmnEngine))
	<-done
}

func newBpmnEngine(this js.Value, args []js.Value) interface{} {
	engine := bpmn_engine.New(fmt.Sprintf("engine-%d", engineCounter))
	engineCounter++
	ew := EngineWrapper{
		engine: &engine,
	}
	obj := vert.ValueOf(jsBinding{Name: engine.GetName()})
	obj.Set("GetName", js.FuncOf(func(this js.Value, args []js.Value) any {
		return engine.GetName()
	}))
	obj.Set("CreateAndRunInstance", js.FuncOf(ew.CreateAndRunInstance))
	obj.Set("LoadFromString", js.FuncOf(ew.JsLoadFromString))
	obj.Set("NewTaskHandlerForId", js.FuncOf(ew.JsNewTaskHandlerForId))
	return obj.JSValue()
}

func (ew EngineWrapper) JsLoadFromString(this js.Value, args []js.Value) any {
	xmlString := args[0].String()
	process, err := ew.engine.LoadFromBytes([]byte(xmlString))
	if err != nil {
		return js.ValueOf(false)
	}
	return js.ValueOf(process.ProcessKey)
}

func (ew EngineWrapper) JsNewTaskHandlerForId(this js.Value, args []js.Value) any {
	id := args[0].String()
	jsHandler := args[1]
	ajh := ActivatedJobHandler{
		handler: jsHandler,
	}
	ew.engine.NewTaskHandler().Id(id).Handler(ajh.JsActivatedJobHandler)
	return js.Undefined()
}

func (ew EngineWrapper) CreateAndRunInstance(this js.Value, args []js.Value) any {
	processKey := int64(args[0].Float())
	ew.engine.CreateAndRunInstance(processKey, nil)
	return js.Undefined()
}

func (ajh ActivatedJobHandler) JsActivatedJobHandler(job bpmn_engine.ActivatedJob) {
	type retObj struct{}
	obj := vert.ValueOf(retObj{})
	obj.Set("GetKey", js.FuncOf(func(this js.Value, args []js.Value) any {
		return job.GetKey()
	}))
	obj.Set("GetProcessInstanceKey", js.FuncOf(func(this js.Value, args []js.Value) any {
		return job.GetProcessInstanceKey()
	}))
	obj.Set("GetBpmnProcessId", js.FuncOf(func(this js.Value, args []js.Value) any {
		return job.GetBpmnProcessId()
	}))
	obj.Set("GetProcessDefinitionVersion", js.FuncOf(func(this js.Value, args []js.Value) any {
		return job.GetProcessDefinitionVersion()
	}))
	obj.Set("GetProcessDefinitionKey", js.FuncOf(func(this js.Value, args []js.Value) any {
		return job.GetProcessDefinitionKey()
	}))
	obj.Set("GetElementId", js.FuncOf(func(this js.Value, args []js.Value) any {
		return job.GetElementId()
	}))
	obj.Set("GetCreatedAt", js.FuncOf(func(this js.Value, args []js.Value) any {
		return vert.ValueOf(job.GetCreatedAt()).JSValue()
	}))
	obj.Set("Fail", js.FuncOf(func(this js.Value, args []js.Value) any {
		reason := args[0].String()
		job.Fail(reason)
		return js.Undefined()
	}))
	obj.Set("Complete", js.FuncOf(func(this js.Value, args []js.Value) any {
		job.Complete()
		return js.Undefined()
	}))
	ajh.handler.Invoke(obj.JSValue())
}