Merge pull request #1317 from mesg-foundation/test/orchestrator

Add tests for orchestrator
mesg-foundation · Sep 20, 2019 · 06af76a · 06af76a
2 parents 6f489c9 + c27ca89
commit 06af76a
Show file tree

Hide file tree

Showing 7 changed files with 462 additions and 16 deletions.
diff --git a/orchestrator/mocks/EventSDK.go b/orchestrator/mocks/EventSDK.go
diff --git a/orchestrator/mocks/ExecutionSDK.go b/orchestrator/mocks/ExecutionSDK.go
diff --git a/orchestrator/mocks/ProcessSDK.go b/orchestrator/mocks/ProcessSDK.go
diff --git a/orchestrator/orchestrator.go b/orchestrator/orchestrator.go
@@ -8,27 +8,12 @@ import (
 	"github.com/mesg-foundation/engine/hash"
 	"github.com/mesg-foundation/engine/process"
 	"github.com/mesg-foundation/engine/protobuf/types"
-	eventsdk "github.com/mesg-foundation/engine/sdk/event"
 	executionsdk "github.com/mesg-foundation/engine/sdk/execution"
-	processesdk "github.com/mesg-foundation/engine/sdk/process"
 	"github.com/sirupsen/logrus"
 )
 
-// Orchestrator manages the executions based on the definition of the processes
-type Orchestrator struct {
-	event       *eventsdk.Event
-	eventStream *eventsdk.Listener
-
-	execution       *executionsdk.Execution
-	executionStream *executionsdk.Listener
-
-	process *processesdk.Process
-
-	ErrC chan error
-}
-
 // New creates a new Process instance
-func New(event *eventsdk.Event, execution *executionsdk.Execution, process *processesdk.Process) *Orchestrator {
+func New(event EventSDK, execution ExecutionSDK, process ProcessSDK) *Orchestrator {
 	return &Orchestrator{
 		event:     event,
 		execution: execution,