From 4092f1bfc78977131fd023ec48a78c83dc2990fc Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?Toma=C5=BE=20Jerman?= Date: Tue, 11 May 2021 12:30:52 +0200 Subject: [PATCH] Add a call stack to prevent infinite WF invocations --- automation/service/service.go | 2 +- pkg/apigw/registry/registry.go | 4 +++- 2 files changed, 4 insertions(+), 2 deletions(-) diff --git a/automation/service/service.go b/automation/service/service.go index 59fcb3564..0d940a195 100644 --- a/automation/service/service.go +++ b/automation/service/service.go @@ -92,7 +92,7 @@ func Initialize(ctx context.Context, log *zap.Logger, s store.Storer, ws websock DefaultAccessControl = AccessControl() DefaultSession = Session(DefaultLogger.Named("session"), c.Workflow, ws) - DefaultWorkflow = Workflow(DefaultLogger.Named("workflow"), c.Corredor) + DefaultWorkflow = Workflow(DefaultLogger.Named("workflow"), c.Corredor, c.Workflow) DefaultTrigger = Trigger(DefaultLogger.Named("trigger"), c.Workflow) DefaultWorkflow.triggers = DefaultTrigger diff --git a/pkg/apigw/registry/registry.go b/pkg/apigw/registry/registry.go index fd59c3899..d712cd12b 100644 --- a/pkg/apigw/registry/registry.go +++ b/pkg/apigw/registry/registry.go @@ -73,5 +73,7 @@ func (r *Registry) Preload() { } func NewWorkflow() (wf filter.WfExecer) { - return service.Workflow(&zap.Logger{}, options.CorredorOpt{}) + // implementation assumes that Corredor & Workflow options can not be changed + // in the run-time. + return service.Workflow(&zap.Logger{}, *options.Corredor(), *options.Workflow()) }