Skip to content

Commit

Permalink
Misc fixes
Browse files Browse the repository at this point in the history
  • Loading branch information
pointlander committed Feb 27, 2019
1 parent b60eccf commit ce61f44
Showing 1 changed file with 30 additions and 2 deletions.
32 changes: 30 additions & 2 deletions examples/examples.go
Original file line number Diff line number Diff line change
Expand Up @@ -10,6 +10,7 @@ import (
"github.com/project-flogo/core/engine/channels"
"github.com/project-flogo/microgateway"
microapi "github.com/project-flogo/microgateway/api"
"github.com/project-flogo/microgateway/internal/pattern"
)

// BasicGatewayExample returns a Basic Gateway API example
Expand Down Expand Up @@ -228,6 +229,33 @@ func DefaultChannelPattern() (engine.Engine, error) {
return api.NewEngine(app)
}

// CustomPattern returns an engine configured for given pattern name
func CustomPattern(patternName string, custompattern string) (engine.Engine, error) {
err := pattern.Register(patternName, custompattern)
if err != nil {
panic(err)
}
app := api.NewApp()

trg := app.NewTrigger(&trigger.Trigger{}, &trigger.Settings{Port: 9096})
handler, err := trg.NewHandler(&trigger.HandlerSettings{
Method: "GET",
Path: "/endpoint",
})
if err != nil {
panic(err)
}

_, err = handler.NewAction(&microgateway.Action{}, map[string]interface{}{
"pattern": patternName,
})
if err != nil {
panic(err)
}

return api.NewEngine(app)
}

func AsyncGatewayExample() (engine.Engine, error) {
app := api.NewApp()
gateway := microapi.New("Log")
Expand All @@ -241,7 +269,7 @@ func AsyncGatewayExample() (engine.Engine, error) {
settings, err := gateway.AddResource(app)
settings["async"] = true
if err != nil {
panic(err)
return nil, err
}

trg := app.NewTrigger(&trigger.Trigger{}, &trigger.Settings{Port: 9096})
Expand All @@ -259,4 +287,4 @@ func AsyncGatewayExample() (engine.Engine, error) {
}

return api.NewEngine(app)
}
}

0 comments on commit ce61f44

Please sign in to comment.