-
Notifications
You must be signed in to change notification settings - Fork 22
/
activity_example.go
64 lines (54 loc) · 1.9 KB
/
activity_example.go
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
package examples
import (
"github.com/project-flogo/contrib/activity/rest"
trigger "github.com/project-flogo/contrib/trigger/rest"
"github.com/project-flogo/core/api"
"github.com/project-flogo/core/engine"
"github.com/project-flogo/microgateway"
"github.com/project-flogo/microgateway/activity/anomaly"
microapi "github.com/project-flogo/microgateway/api"
)
// Example returns an API example
func Example() (engine.Engine, error) {
app := api.NewApp()
gateway := microapi.New("Test")
serviceAnomaly := gateway.NewService("Anomaly", &anomaly.Activity{})
serviceAnomaly.SetDescription("Look for anomalies")
serviceAnomaly.AddSetting("depth", 3)
serviceUpdate := gateway.NewService("Update", &rest.Activity{})
serviceUpdate.SetDescription("Make calls to test")
serviceUpdate.AddSetting("uri", "http://localhost:1234/test")
serviceUpdate.AddSetting("method", "PUT")
step := gateway.NewStep(serviceAnomaly)
step.AddInput("payload", "=$.payload.content")
step = gateway.NewStep(serviceUpdate)
step.SetIf("($.Anomaly.outputs.count < 100) || ($.Anomaly.outputs.complexity < 3)")
step.AddInput("content", "=$.payload.content")
response := gateway.NewResponse(false)
response.SetIf("($.Anomaly.outputs.count < 100) || ($.Anomaly.outputs.complexity < 3)")
response.SetCode(200)
response.SetData("=$.Update.outputs.data")
response = gateway.NewResponse(true)
response.SetCode(403)
response.SetData(map[string]interface{}{
"error": "anomaly!",
"complexity": "=$.Anomaly.outputs.complexity",
})
settings, err := gateway.AddResource(app)
if err != nil {
return nil, err
}
trg := app.NewTrigger(&trigger.Trigger{}, &trigger.Settings{Port: 9096})
handler, err := trg.NewHandler(&trigger.HandlerSettings{
Method: "PUT",
Path: "/test",
})
if err != nil {
return nil, err
}
_, err = handler.NewAction(µgateway.Action{}, settings)
if err != nil {
return nil, err
}
return api.NewEngine(app)
}