Adopt new protobuf structure, automation code cleanup

Gopkg.lock

@@ -716,6 +716,7 @@
     "google.golang.org/grpc",
     "google.golang.org/grpc/codes",
     "google.golang.org/grpc/grpclog",
+    "google.golang.org/grpc/metadata",
     "google.golang.org/grpc/status",
     "gopkg.in/Masterminds/squirrel.v1",
     "gopkg.in/mail.v2",

codegen.sh

@@ -160,16 +160,29 @@ function specs {
 
 function proto {
 	yellow "> proto"
+
+
 	CORTEZA_PROTOBUF_PATH=${CORTEZA_PROTOBUF_PATH:-"vendor/github.com/cortezaproject/corteza-protobuf"}
 
+	# Compose Proto Path
+	CPC="github.com/cortezaproject/corteza-server/compose/proto"
+
 	yellow "  ${CORTEZA_PROTOBUF_PATH} >> compose/proto"
 	PATH=$PATH:$GOPATH/bin protoc \
 		--proto_path ${CORTEZA_PROTOBUF_PATH}/compose \
-		--go_out=plugins=grpc:compose/proto \
-		namespace.proto \
-		module.proto \
-		record.proto \
-		script_runner.proto
+		--go_out=./compose/proto \
+		record.proto namespace.proto module.proto
+
+
+  assoc="${assoc},Mcompose/record.proto=${CPC}"
+  assoc="${assoc},Mcompose/module.proto=${CPC}"
+  assoc="${assoc},Mcompose/namespace.proto=${CPC}"
+
+	yellow "  ${CORTEZA_PROTOBUF_PATH} >> pkg/automation/corredor"
+	PATH=$PATH:$GOPATH/bin protoc \
+		--proto_path ${CORTEZA_PROTOBUF_PATH} \
+		--go_out="plugins=grpc${assoc}:./pkg/automation/corredor" \
+		service-corredor.proto
 
 	yellow "  ${CORTEZA_PROTOBUF_PATH} >> system/proto"
 	PATH=$PATH:$GOPATH/bin protoc \

compose/internal/service/automation_runner.go

@@ -14,6 +14,7 @@ import (
 	"github.com/cortezaproject/corteza-server/compose/types"
 	"github.com/cortezaproject/corteza-server/internal/auth"
 	"github.com/cortezaproject/corteza-server/pkg/automation"
+	"github.com/cortezaproject/corteza-server/pkg/automation/corredor"
 	"github.com/cortezaproject/corteza-server/pkg/sentry"
 )
 
@@ -22,7 +23,7 @@ type (
 		opt          AutomationRunnerOpt
 		ac           automationRunnerAccessControler
 		logger       *zap.Logger
-		runner       proto.ScriptRunnerClient
+		runner       corredor.ScriptRunnerClient
 		scriptFinder automationScriptsFinder
 		jwtEncoder   auth.TokenEncoder
 	}
@@ -47,7 +48,7 @@ const (
 	AutomationResourceRecord = "compose:record"
 )
 
-func AutomationRunner(opt AutomationRunnerOpt, f automationScriptsFinder, r proto.ScriptRunnerClient) automationRunner {
+func AutomationRunner(opt AutomationRunnerOpt, f automationScriptsFinder, r corredor.ScriptRunnerClient) automationRunner {
 	var svc = automationRunner{
 		opt: opt,
 
@@ -219,7 +220,7 @@ func (svc automationRunner) RecordScriptTester(ctx context.Context, source strin
 //
 func (svc automationRunner) makeRecordScriptRunner(ctx context.Context, ns *types.Namespace, m *types.Module, r *types.Record, discard bool) func(script *automation.Script) error {
 	// Static request params (record gets updated
-	var req = &proto.RunRecordRequest{
+	var req = &corredor.RunRecordRequest{
 		Namespace: proto.FromNamespace(ns),
 		Module:    proto.FromModule(m),
 		Record:    proto.FromRecord(r),
@@ -250,7 +251,7 @@ func (svc automationRunner) makeRecordScriptRunner(ctx context.Context, ns *type
 		}
 
 		// Add script info
-		req.Script = proto.FromAutomationScript(script)
+		req.Script = corredor.FromScript(script)
 
 		rsp, err := svc.runner.Record(ctx, req, grpc.WaitForReady(script.Critical))
 

compose/internal/service/service.go

@@ -7,13 +7,13 @@ import (
 	"go.uber.org/zap"
 
 	"github.com/cortezaproject/corteza-server/compose/internal/repository"
-	"github.com/cortezaproject/corteza-server/compose/proto"
 	"github.com/cortezaproject/corteza-server/internal/auth"
 	"github.com/cortezaproject/corteza-server/internal/permissions"
 	"github.com/cortezaproject/corteza-server/internal/store"
 	"github.com/cortezaproject/corteza-server/pkg/automation"
+	"github.com/cortezaproject/corteza-server/pkg/automation/corredor"
 	"github.com/cortezaproject/corteza-server/pkg/cli/options"
-	proto2 "github.com/cortezaproject/corteza-server/system/proto"
+	systemProto "github.com/cortezaproject/corteza-server/system/proto"
 )
 
 type (
@@ -84,7 +84,7 @@ func Init(ctx context.Context, log *zap.Logger, c Config) (err error) {
 			return err
 		}
 
-		DefaultSystemUser = SystemUser(proto2.NewUsersClient(systemClientConn))
+		DefaultSystemUser = SystemUser(systemProto.NewUsersClient(systemClientConn))
 	}
 
 	// ias: Internal Automatinon Service
@@ -104,17 +104,17 @@ func Init(ctx context.Context, log *zap.Logger, c Config) (err error) {
 	DefaultAutomationTriggerManager = AutomationTrigger(ias)
 
 	{
-		var scriptRunnerClient proto.ScriptRunnerClient
+		var scriptRunnerClient corredor.ScriptRunnerClient
 
 		if c.Corredor.Enabled {
-			corredor, err := automation.Corredor(ctx, c.Corredor, DefaultLogger)
+			conn, err := corredor.NewConnection(ctx, c.Corredor, DefaultLogger)
 
 			log.Info("initializing corredor connection", zap.String("addr", c.Corredor.Addr), zap.Error(err))
 			if err != nil {
 				return err
 			}
 
-			scriptRunnerClient = proto.NewScriptRunnerClient(corredor)
+			scriptRunnerClient = corredor.NewScriptRunnerClient(conn)
 		}
 
 		DefaultAutomationRunner = AutomationRunner(

compose/proto/module.go

@@ -0,0 +1,31 @@
+package proto
+
+import (
+	"github.com/cortezaproject/corteza-server/compose/types"
+)
+
+func FromModule(i *types.Module) *Module {
+	if i == nil {
+		return nil
+	}
+
+	var p = &Module{
+		ModuleID:    i.ID,
+		NamespaceID: i.NamespaceID,
+		Name:        i.Name,
+		CreatedAt:   fromTime(i.CreatedAt),
+		UpdatedAt:   fromTime(i.UpdatedAt),
+		DeletedAt:   fromTime(i.DeletedAt),
+		Fields:      make([]*ModuleField, len(i.Fields)),
+	}
+
+	for f := range i.Fields {
+		p.Fields[f] = &ModuleField{
+			FieldID: i.Fields[f].ID,
+			Name:    i.Fields[f].Name,
+			Kind:    i.Fields[f].Kind,
+		}
+	}
+
+	return p
+}

compose/proto/namespace.go

@@ -0,0 +1,23 @@
+package proto
+
+import (
+	"github.com/cortezaproject/corteza-server/compose/types"
+)
+
+func FromNamespace(i *types.Namespace) *Namespace {
+	if i == nil {
+		return nil
+	}
+
+	var p = &Namespace{
+		NamespaceID: i.ID,
+		Name:        i.Name,
+		Slug:        i.Slug,
+		Enabled:     i.Enabled,
+		CreatedAt:   fromTime(i.CreatedAt),
+		UpdatedAt:   fromTime(i.UpdatedAt),
+		DeletedAt:   fromTime(i.DeletedAt),
+	}
+
+	return p
+}

compose/proto/record.go

@@ -49,3 +49,32 @@ func toTimePtr(ts *timestamp.Timestamp) *time.Time {
 	var t = toTime(ts)
 	return &t
 }
+
+func FromRecord(i *types.Record) *Record {
+	if i == nil {
+		return nil
+	}
+
+	var p = &Record{
+		RecordID:    i.ID,
+		ModuleID:    i.ModuleID,
+		NamespaceID: i.NamespaceID,
+		OwnedBy:     i.OwnedBy,
+		CreatedBy:   i.CreatedBy,
+		UpdatedBy:   i.UpdatedBy,
+		DeletedBy:   i.DeletedBy,
+		CreatedAt:   fromTime(i.CreatedAt),
+		UpdatedAt:   fromTime(i.UpdatedAt),
+		DeletedAt:   fromTime(i.DeletedAt),
+		Values:      make([]*RecordValue, len(i.Values)),
+	}
+
+	for v := range i.Values {
+		p.Values[v] = &RecordValue{
+			Value: i.Values[v].Value,
+			Name:  i.Values[v].Name,
+		}
+	}
+
+	return p
+}

compose/proto/time.go

@@ -0,0 +1,24 @@
+package proto
+
+import (
+	"time"
+
+	"github.com/golang/protobuf/ptypes/timestamp"
+)
+
+// Converts time.Time (ptr AND value) to *timestamp.Timestamp
+//
+// Intentionally ignoring
+func fromTime(i interface{}) *timestamp.Timestamp {
+	switch t := i.(type) {
+	case *time.Time:
+		if t == nil {
+			return nil
+		}
+		return &timestamp.Timestamp{Seconds: t.Unix(), Nanos: int32(t.Nanosecond())}
+	case time.Time:
+		return &timestamp.Timestamp{Seconds: t.Unix(), Nanos: int32(t.Nanosecond())}
+	default:
+		return nil
+	}
+}

compose/proto/to_proto.go

@@ -1,118 +0,0 @@
-package proto
-
-import (
-	"time"
-
-	"github.com/golang/protobuf/ptypes/timestamp"
-
-	"github.com/cortezaproject/corteza-server/compose/types"
-	"github.com/cortezaproject/corteza-server/pkg/automation"
-)
-
-type (
-	Runnable interface {
-		IsAsync() bool
-		GetName() string
-		GetSource() string
-		GetTimeout() uint32
-	}
-)
-
-func FromRecord(i *types.Record) *Record {
-	if i == nil {
-		return nil
-	}
-
-	var p = &Record{
-		RecordID:    i.ID,
-		ModuleID:    i.ModuleID,
-		NamespaceID: i.NamespaceID,
-		OwnedBy:     i.OwnedBy,
-		CreatedBy:   i.CreatedBy,
-		UpdatedBy:   i.UpdatedBy,
-		DeletedBy:   i.DeletedBy,
-		CreatedAt:   fromTime(i.CreatedAt),
-		UpdatedAt:   fromTime(i.UpdatedAt),
-		DeletedAt:   fromTime(i.DeletedAt),
-		Values:      make([]*RecordValue, len(i.Values)),
-	}
-
-	for v := range i.Values {
-		p.Values[v] = &RecordValue{
-			Value: i.Values[v].Value,
-			Name:  i.Values[v].Name,
-		}
-	}
-
-	return p
-}
-
-func FromModule(i *types.Module) *Module {
-	if i == nil {
-		return nil
-	}
-
-	var p = &Module{
-		ModuleID:    i.ID,
-		NamespaceID: i.NamespaceID,
-		Name:        i.Name,
-		CreatedAt:   fromTime(i.CreatedAt),
-		UpdatedAt:   fromTime(i.UpdatedAt),
-		DeletedAt:   fromTime(i.DeletedAt),
-		Fields:      make([]*ModuleField, len(i.Fields)),
-	}
-
-	for f := range i.Fields {
-		p.Fields[f] = &ModuleField{
-			FieldID: i.Fields[f].ID,
-			Name:    i.Fields[f].Name,
-			Kind:    i.Fields[f].Kind,
-		}
-	}
-
-	return p
-}
-
-func FromNamespace(i *types.Namespace) *Namespace {
-	if i == nil {
-		return nil
-	}
-
-	var p = &Namespace{
-		NamespaceID: i.ID,
-		Name:        i.Name,
-		Slug:        i.Slug,
-		Enabled:     i.Enabled,
-		CreatedAt:   fromTime(i.CreatedAt),
-		UpdatedAt:   fromTime(i.UpdatedAt),
-		DeletedAt:   fromTime(i.DeletedAt),
-	}
-
-	return p
-}
-
-func FromAutomationScript(s *automation.Script) *Script {
-	return &Script{
-		Source:  s.Source,
-		Name:    s.Name,
-		Timeout: uint32(s.Timeout),
-		Async:   s.Async,
-	}
-}
-
-// Converts time.Time (ptr AND value) to *timestamp.Timestamp
-//
-// Intentionally ignoring
-func fromTime(i interface{}) *timestamp.Timestamp {
-	switch t := i.(type) {
-	case *time.Time:
-		if t == nil {
-			return nil
-		}
-		return &timestamp.Timestamp{Seconds: t.Unix(), Nanos: int32(t.Nanosecond())}
-	case time.Time:
-		return &timestamp.Timestamp{Seconds: t.Unix(), Nanos: int32(t.Nanosecond())}
-	default:
-		return nil
-	}
-}

pkg/automation/corredor/conn.go

@@ -1,4 +1,4 @@
-package automation
+package corredor
 
 import (
 	"context"
@@ -12,7 +12,7 @@ import (
 )
 
 // Corredor standard connector to Corredor service via gRPC
-func Corredor(ctx context.Context, opt options.CorredorOpt, logger *zap.Logger) (c *grpc.ClientConn, err error) {
+func NewConnection(ctx context.Context, opt options.CorredorOpt, logger *zap.Logger) (c *grpc.ClientConn, err error) {
 	if !opt.Enabled {
 		// Do not connect when script runner is not enabled
 		return

pkg/automation/corredor/script.go

@@ -0,0 +1,23 @@
+package corredor
+
+import (
+	"github.com/cortezaproject/corteza-server/pkg/automation"
+)
+
+type (
+	Runnable interface {
+		IsAsync() bool
+		GetName() string
+		GetSource() string
+		GetTimeout() uint32
+	}
+)
+
+func FromScript(s *automation.Script) *Script {
+	return &Script{
+		Source:  s.Source,
+		Name:    s.Name,
+		Timeout: uint32(s.Timeout),
+		Async:   s.Async,
+	}
+}

pkg/automation/corredor/service-corredor.pb.go

@@ -1,11 +1,12 @@
 // Code generated by protoc-gen-go. DO NOT EDIT.
-// source: script_runner.proto
+// source: service-corredor.proto
 
-package proto
+package corredor
 
 import (
 	context "context"
 	fmt "fmt"
+	proto1 "github.com/cortezaproject/corteza-server/compose/proto"
 	proto "github.com/golang/protobuf/proto"
 	grpc "google.golang.org/grpc"
 	codes "google.golang.org/grpc/codes"
@@ -36,7 +37,7 @@ func (m *RunTestRequest) Reset()         { *m = RunTestRequest{} }
 func (m *RunTestRequest) String() string { return proto.CompactTextString(m) }
 func (*RunTestRequest) ProtoMessage()    {}
 func (*RunTestRequest) Descriptor() ([]byte, []int) {
-	return fileDescriptor_62210b9e3e4a7a06, []int{0}
+	return fileDescriptor_c06bb92bf45e37e2, []int{0}
 }
 
 func (m *RunTestRequest) XXX_Unmarshal(b []byte) error {
@@ -74,7 +75,7 @@ func (m *RunTestRequest) GetName() string {
 type RunNamespaceRequest struct {
 	Config               map[string]string `protobuf:"bytes,1,rep,name=config,proto3" json:"config,omitempty" protobuf_key:"bytes,1,opt,name=key,proto3" protobuf_val:"bytes,2,opt,name=value,proto3"`
 	Script               *Script           `protobuf:"bytes,2,opt,name=script,proto3" json:"script,omitempty"`
-	Namespace            *Namespace        `protobuf:"bytes,3,opt,name=namespace,proto3" json:"namespace,omitempty"`
+	Namespace            *proto1.Namespace `protobuf:"bytes,3,opt,name=namespace,proto3" json:"namespace,omitempty"`
 	XXX_NoUnkeyedLiteral struct{}          `json:"-"`
 	XXX_unrecognized     []byte            `json:"-"`
 	XXX_sizecache        int32             `json:"-"`
@@ -84,7 +85,7 @@ func (m *RunNamespaceRequest) Reset()         { *m = RunNamespaceRequest{} }
 func (m *RunNamespaceRequest) String() string { return proto.CompactTextString(m) }
 func (*RunNamespaceRequest) ProtoMessage()    {}
 func (*RunNamespaceRequest) Descriptor() ([]byte, []int) {
-	return fileDescriptor_62210b9e3e4a7a06, []int{1}
+	return fileDescriptor_c06bb92bf45e37e2, []int{1}
 }
 
 func (m *RunNamespaceRequest) XXX_Unmarshal(b []byte) error {
@@ -119,7 +120,7 @@ func (m *RunNamespaceRequest) GetScript() *Script {
 	return nil
 }
 
-func (m *RunNamespaceRequest) GetNamespace() *Namespace {
+func (m *RunNamespaceRequest) GetNamespace() *proto1.Namespace {
 	if m != nil {
 		return m.Namespace
 	}
@@ -129,8 +130,8 @@ func (m *RunNamespaceRequest) GetNamespace() *Namespace {
 type RunModuleRequest struct {
 	Config               map[string]string `protobuf:"bytes,1,rep,name=config,proto3" json:"config,omitempty" protobuf_key:"bytes,1,opt,name=key,proto3" protobuf_val:"bytes,2,opt,name=value,proto3"`
 	Script               *Script           `protobuf:"bytes,2,opt,name=script,proto3" json:"script,omitempty"`
-	Namespace            *Namespace        `protobuf:"bytes,3,opt,name=namespace,proto3" json:"namespace,omitempty"`
-	Module               *Module           `protobuf:"bytes,4,opt,name=module,proto3" json:"module,omitempty"`
+	Namespace            *proto1.Namespace `protobuf:"bytes,3,opt,name=namespace,proto3" json:"namespace,omitempty"`
+	Module               *proto1.Module    `protobuf:"bytes,4,opt,name=module,proto3" json:"module,omitempty"`
 	XXX_NoUnkeyedLiteral struct{}          `json:"-"`
 	XXX_unrecognized     []byte            `json:"-"`
 	XXX_sizecache        int32             `json:"-"`
@@ -140,7 +141,7 @@ func (m *RunModuleRequest) Reset()         { *m = RunModuleRequest{} }
 func (m *RunModuleRequest) String() string { return proto.CompactTextString(m) }
 func (*RunModuleRequest) ProtoMessage()    {}
 func (*RunModuleRequest) Descriptor() ([]byte, []int) {
-	return fileDescriptor_62210b9e3e4a7a06, []int{2}
+	return fileDescriptor_c06bb92bf45e37e2, []int{2}
 }
 
 func (m *RunModuleRequest) XXX_Unmarshal(b []byte) error {
@@ -175,14 +176,14 @@ func (m *RunModuleRequest) GetScript() *Script {
 	return nil
 }
 
-func (m *RunModuleRequest) GetNamespace() *Namespace {
+func (m *RunModuleRequest) GetNamespace() *proto1.Namespace {
 	if m != nil {
 		return m.Namespace
 	}
 	return nil
 }
 
-func (m *RunModuleRequest) GetModule() *Module {
+func (m *RunModuleRequest) GetModule() *proto1.Module {
 	if m != nil {
 		return m.Module
 	}
@@ -192,9 +193,9 @@ func (m *RunModuleRequest) GetModule() *Module {
 type RunRecordRequest struct {
 	Config               map[string]string `protobuf:"bytes,1,rep,name=config,proto3" json:"config,omitempty" protobuf_key:"bytes,1,opt,name=key,proto3" protobuf_val:"bytes,2,opt,name=value,proto3"`
 	Script               *Script           `protobuf:"bytes,2,opt,name=script,proto3" json:"script,omitempty"`
-	Namespace            *Namespace        `protobuf:"bytes,3,opt,name=namespace,proto3" json:"namespace,omitempty"`
-	Module               *Module           `protobuf:"bytes,4,opt,name=module,proto3" json:"module,omitempty"`
-	Record               *Record           `protobuf:"bytes,5,opt,name=record,proto3" json:"record,omitempty"`
+	Namespace            *proto1.Namespace `protobuf:"bytes,3,opt,name=namespace,proto3" json:"namespace,omitempty"`
+	Module               *proto1.Module    `protobuf:"bytes,4,opt,name=module,proto3" json:"module,omitempty"`
+	Record               *proto1.Record    `protobuf:"bytes,5,opt,name=record,proto3" json:"record,omitempty"`
 	XXX_NoUnkeyedLiteral struct{}          `json:"-"`
 	XXX_unrecognized     []byte            `json:"-"`
 	XXX_sizecache        int32             `json:"-"`
@@ -204,7 +205,7 @@ func (m *RunRecordRequest) Reset()         { *m = RunRecordRequest{} }
 func (m *RunRecordRequest) String() string { return proto.CompactTextString(m) }
 func (*RunRecordRequest) ProtoMessage()    {}
 func (*RunRecordRequest) Descriptor() ([]byte, []int) {
-	return fileDescriptor_62210b9e3e4a7a06, []int{3}
+	return fileDescriptor_c06bb92bf45e37e2, []int{3}
 }
 
 func (m *RunRecordRequest) XXX_Unmarshal(b []byte) error {
@@ -239,21 +240,21 @@ func (m *RunRecordRequest) GetScript() *Script {
 	return nil
 }
 
-func (m *RunRecordRequest) GetNamespace() *Namespace {
+func (m *RunRecordRequest) GetNamespace() *proto1.Namespace {
 	if m != nil {
 		return m.Namespace
 	}
 	return nil
 }
 
-func (m *RunRecordRequest) GetModule() *Module {
+func (m *RunRecordRequest) GetModule() *proto1.Module {
 	if m != nil {
 		return m.Module
 	}
 	return nil
 }
 
-func (m *RunRecordRequest) GetRecord() *Record {
+func (m *RunRecordRequest) GetRecord() *proto1.Record {
 	if m != nil {
 		return m.Record
 	}
@@ -270,7 +271,7 @@ func (m *RunTestResponse) Reset()         { *m = RunTestResponse{} }
 func (m *RunTestResponse) String() string { return proto.CompactTextString(m) }
 func (*RunTestResponse) ProtoMessage()    {}
 func (*RunTestResponse) Descriptor() ([]byte, []int) {
-	return fileDescriptor_62210b9e3e4a7a06, []int{4}
+	return fileDescriptor_c06bb92bf45e37e2, []int{4}
 }
 
 func (m *RunTestResponse) XXX_Unmarshal(b []byte) error {
@@ -292,17 +293,17 @@ func (m *RunTestResponse) XXX_DiscardUnknown() {
 var xxx_messageInfo_RunTestResponse proto.InternalMessageInfo
 
 type RunNamespaceResponse struct {
-	Namespace            *Namespace `protobuf:"bytes,1,opt,name=namespace,proto3" json:"namespace,omitempty"`
-	XXX_NoUnkeyedLiteral struct{}   `json:"-"`
-	XXX_unrecognized     []byte     `json:"-"`
-	XXX_sizecache        int32      `json:"-"`
+	Namespace            *proto1.Namespace `protobuf:"bytes,1,opt,name=namespace,proto3" json:"namespace,omitempty"`
+	XXX_NoUnkeyedLiteral struct{}          `json:"-"`
+	XXX_unrecognized     []byte            `json:"-"`
+	XXX_sizecache        int32             `json:"-"`
 }
 
 func (m *RunNamespaceResponse) Reset()         { *m = RunNamespaceResponse{} }
 func (m *RunNamespaceResponse) String() string { return proto.CompactTextString(m) }
 func (*RunNamespaceResponse) ProtoMessage()    {}
 func (*RunNamespaceResponse) Descriptor() ([]byte, []int) {
-	return fileDescriptor_62210b9e3e4a7a06, []int{5}
+	return fileDescriptor_c06bb92bf45e37e2, []int{5}
 }
 
 func (m *RunNamespaceResponse) XXX_Unmarshal(b []byte) error {
@@ -323,7 +324,7 @@ func (m *RunNamespaceResponse) XXX_DiscardUnknown() {
 
 var xxx_messageInfo_RunNamespaceResponse proto.InternalMessageInfo
 
-func (m *RunNamespaceResponse) GetNamespace() *Namespace {
+func (m *RunNamespaceResponse) GetNamespace() *proto1.Namespace {
 	if m != nil {
 		return m.Namespace
 	}
@@ -331,17 +332,17 @@ func (m *RunNamespaceResponse) GetNamespace() *Namespace {
 }
 
 type RunModuleResponse struct {
-	Module               *Module  `protobuf:"bytes,1,opt,name=module,proto3" json:"module,omitempty"`
-	XXX_NoUnkeyedLiteral struct{} `json:"-"`
-	XXX_unrecognized     []byte   `json:"-"`
-	XXX_sizecache        int32    `json:"-"`
+	Module               *proto1.Module `protobuf:"bytes,1,opt,name=module,proto3" json:"module,omitempty"`
+	XXX_NoUnkeyedLiteral struct{}       `json:"-"`
+	XXX_unrecognized     []byte         `json:"-"`
+	XXX_sizecache        int32          `json:"-"`
 }
 
 func (m *RunModuleResponse) Reset()         { *m = RunModuleResponse{} }
 func (m *RunModuleResponse) String() string { return proto.CompactTextString(m) }
 func (*RunModuleResponse) ProtoMessage()    {}
 func (*RunModuleResponse) Descriptor() ([]byte, []int) {
-	return fileDescriptor_62210b9e3e4a7a06, []int{6}
+	return fileDescriptor_c06bb92bf45e37e2, []int{6}
 }
 
 func (m *RunModuleResponse) XXX_Unmarshal(b []byte) error {
@@ -362,7 +363,7 @@ func (m *RunModuleResponse) XXX_DiscardUnknown() {
 
 var xxx_messageInfo_RunModuleResponse proto.InternalMessageInfo
 
-func (m *RunModuleResponse) GetModule() *Module {
+func (m *RunModuleResponse) GetModule() *proto1.Module {
 	if m != nil {
 		return m.Module
 	}
@@ -370,17 +371,17 @@ func (m *RunModuleResponse) GetModule() *Module {
 }
 
 type RunRecordResponse struct {
-	Record               *Record  `protobuf:"bytes,1,opt,name=record,proto3" json:"record,omitempty"`
-	XXX_NoUnkeyedLiteral struct{} `json:"-"`
-	XXX_unrecognized     []byte   `json:"-"`
-	XXX_sizecache        int32    `json:"-"`
+	Record               *proto1.Record `protobuf:"bytes,1,opt,name=record,proto3" json:"record,omitempty"`
+	XXX_NoUnkeyedLiteral struct{}       `json:"-"`
+	XXX_unrecognized     []byte         `json:"-"`
+	XXX_sizecache        int32          `json:"-"`
 }
 
 func (m *RunRecordResponse) Reset()         { *m = RunRecordResponse{} }
 func (m *RunRecordResponse) String() string { return proto.CompactTextString(m) }
 func (*RunRecordResponse) ProtoMessage()    {}
 func (*RunRecordResponse) Descriptor() ([]byte, []int) {
-	return fileDescriptor_62210b9e3e4a7a06, []int{7}
+	return fileDescriptor_c06bb92bf45e37e2, []int{7}
 }
 
 func (m *RunRecordResponse) XXX_Unmarshal(b []byte) error {
@@ -401,7 +402,7 @@ func (m *RunRecordResponse) XXX_DiscardUnknown() {
 
 var xxx_messageInfo_RunRecordResponse proto.InternalMessageInfo
 
-func (m *RunRecordResponse) GetRecord() *Record {
+func (m *RunRecordResponse) GetRecord() *proto1.Record {
 	if m != nil {
 		return m.Record
 	}
@@ -422,7 +423,7 @@ func (m *Script) Reset()         { *m = Script{} }
 func (m *Script) String() string { return proto.CompactTextString(m) }
 func (*Script) ProtoMessage()    {}
 func (*Script) Descriptor() ([]byte, []int) {
-	return fileDescriptor_62210b9e3e4a7a06, []int{8}
+	return fileDescriptor_c06bb92bf45e37e2, []int{8}
 }
 
 func (m *Script) XXX_Unmarshal(b []byte) error {
@@ -472,55 +473,55 @@ func (m *Script) GetAsync() bool {
 }
 
 func init() {
-	proto.RegisterType((*RunTestRequest)(nil), "compose.RunTestRequest")
-	proto.RegisterType((*RunNamespaceRequest)(nil), "compose.RunNamespaceRequest")
-	proto.RegisterMapType((map[string]string)(nil), "compose.RunNamespaceRequest.ConfigEntry")
-	proto.RegisterType((*RunModuleRequest)(nil), "compose.RunModuleRequest")
-	proto.RegisterMapType((map[string]string)(nil), "compose.RunModuleRequest.ConfigEntry")
-	proto.RegisterType((*RunRecordRequest)(nil), "compose.RunRecordRequest")
-	proto.RegisterMapType((map[string]string)(nil), "compose.RunRecordRequest.ConfigEntry")
-	proto.RegisterType((*RunTestResponse)(nil), "compose.RunTestResponse")
-	proto.RegisterType((*RunNamespaceResponse)(nil), "compose.RunNamespaceResponse")
-	proto.RegisterType((*RunModuleResponse)(nil), "compose.RunModuleResponse")
-	proto.RegisterType((*RunRecordResponse)(nil), "compose.RunRecordResponse")
-	proto.RegisterType((*Script)(nil), "compose.Script")
+	proto.RegisterType((*RunTestRequest)(nil), "corredor.RunTestRequest")
+	proto.RegisterType((*RunNamespaceRequest)(nil), "corredor.RunNamespaceRequest")
+	proto.RegisterMapType((map[string]string)(nil), "corredor.RunNamespaceRequest.ConfigEntry")
+	proto.RegisterType((*RunModuleRequest)(nil), "corredor.RunModuleRequest")
+	proto.RegisterMapType((map[string]string)(nil), "corredor.RunModuleRequest.ConfigEntry")
+	proto.RegisterType((*RunRecordRequest)(nil), "corredor.RunRecordRequest")
+	proto.RegisterMapType((map[string]string)(nil), "corredor.RunRecordRequest.ConfigEntry")
+	proto.RegisterType((*RunTestResponse)(nil), "corredor.RunTestResponse")
+	proto.RegisterType((*RunNamespaceResponse)(nil), "corredor.RunNamespaceResponse")
+	proto.RegisterType((*RunModuleResponse)(nil), "corredor.RunModuleResponse")
+	proto.RegisterType((*RunRecordResponse)(nil), "corredor.RunRecordResponse")
+	proto.RegisterType((*Script)(nil), "corredor.Script")
 }
 
-func init() { proto.RegisterFile("script_runner.proto", fileDescriptor_62210b9e3e4a7a06) }
+func init() { proto.RegisterFile("service-corredor.proto", fileDescriptor_c06bb92bf45e37e2) }
 
-var fileDescriptor_62210b9e3e4a7a06 = []byte{
-	// 483 bytes of a gzipped FileDescriptorProto
+var fileDescriptor_c06bb92bf45e37e2 = []byte{
+	// 492 bytes of a gzipped FileDescriptorProto
 	0x1f, 0x8b, 0x08, 0x00, 0x00, 0x00, 0x00, 0x00, 0x02, 0xff, 0xcc, 0x54, 0xdd, 0x8a, 0x13, 0x31,
-	0x14, 0x26, 0xd3, 0x76, 0x6a, 0x4f, 0x57, 0xbb, 0x9b, 0x5d, 0x34, 0x0e, 0x0a, 0xcb, 0x80, 0xd8,
-	0xab, 0x41, 0xea, 0x8d, 0x2b, 0x2b, 0x8a, 0x22, 0xec, 0x8d, 0x5e, 0x44, 0xaf, 0xbc, 0x91, 0x71,
-	0x1a, 0xa5, 0xd8, 0x49, 0xc6, 0x64, 0x22, 0xf4, 0x2d, 0xbc, 0xf1, 0x61, 0x7c, 0x28, 0xdf, 0x41,
-	0x26, 0xc9, 0xfc, 0xa4, 0xb6, 0xa5, 0x52, 0x90, 0xbd, 0x9a, 0x39, 0x39, 0x5f, 0xbe, 0xe4, 0xfb,
-	0x4e, 0xce, 0x81, 0x53, 0x95, 0xc9, 0x45, 0x51, 0x7e, 0x94, 0x9a, 0x73, 0x26, 0x93, 0x42, 0x8a,
-	0x52, 0xe0, 0x61, 0x26, 0xf2, 0x42, 0x28, 0x16, 0x4d, 0x78, 0x9a, 0x33, 0x55, 0xa4, 0x19, 0xb3,
-	0x99, 0xe8, 0x28, 0x17, 0x73, 0xbd, 0x6c, 0x22, 0xc9, 0x32, 0x21, 0xe7, 0x36, 0x8a, 0x2f, 0xe1,
-	0x16, 0xd5, 0xfc, 0x3d, 0x53, 0x25, 0x65, 0xdf, 0x34, 0x53, 0x25, 0xbe, 0x0d, 0xa1, 0x12, 0x5a,
-	0x66, 0x8c, 0xa0, 0x73, 0x34, 0x1d, 0x51, 0x17, 0x61, 0x0c, 0xfd, 0x8a, 0x98, 0x04, 0x66, 0xd5,
-	0xfc, 0xc7, 0xbf, 0x11, 0x9c, 0x52, 0xcd, 0xdf, 0xd6, 0x07, 0xd6, 0x1c, 0x2f, 0x20, 0xcc, 0x04,
-	0xff, 0xbc, 0xf8, 0x42, 0xd0, 0x79, 0x6f, 0x3a, 0x9e, 0x4d, 0x13, 0x77, 0xb9, 0x64, 0x03, 0x3a,
-	0x79, 0x65, 0xa0, 0xaf, 0x79, 0x29, 0x57, 0xd4, 0xed, 0xc3, 0x0f, 0x21, 0xb4, 0x22, 0xcd, 0x79,
-	0xe3, 0xd9, 0xa4, 0x61, 0x78, 0x67, 0x96, 0xa9, 0x4b, 0xe3, 0x47, 0x30, 0x6a, 0xf4, 0x92, 0x9e,
-	0xc1, 0xe2, 0x06, 0xdb, 0x1e, 0xd5, 0x82, 0xa2, 0x0b, 0x18, 0x77, 0x4e, 0xc4, 0xc7, 0xd0, 0xfb,
-	0xca, 0x56, 0x4e, 0x6c, 0xf5, 0x8b, 0xcf, 0x60, 0xf0, 0x3d, 0x5d, 0xea, 0x5a, 0xaa, 0x0d, 0x9e,
-	0x06, 0x4f, 0x50, 0xfc, 0x23, 0x80, 0x63, 0xaa, 0xf9, 0x1b, 0xe3, 0x67, 0x2d, 0xf6, 0xd9, 0x9a,
-	0xd8, 0x07, 0x5d, 0xb1, 0x1e, 0xf4, 0x3f, 0x2b, 0xad, 0xa8, 0x6d, 0xe9, 0x49, 0x7f, 0x8d, 0xda,
-	0x5d, 0xcb, 0xa5, 0x0f, 0xb1, 0xe4, 0x97, 0xb5, 0x84, 0x9a, 0x47, 0xb5, 0x97, 0x25, 0x1e, 0xf4,
-	0xba, 0x5a, 0x52, 0x01, 0x6d, 0xa3, 0x90, 0xc1, 0x1a, 0xd0, 0xdd, 0xdf, 0xa5, 0x0f, 0xf1, 0xee,
-	0x04, 0x26, 0x4d, 0xf3, 0xa9, 0x42, 0x70, 0xc5, 0xe2, 0x2b, 0x38, 0xf3, 0x5b, 0xc4, 0xae, 0xfb,
-	0x4a, 0xd1, 0x1e, 0x4a, 0xe3, 0x4b, 0x38, 0xe9, 0xbc, 0x3f, 0x47, 0xd3, 0xca, 0x47, 0x3b, 0xe5,
-	0xbb, 0xdd, 0x75, 0xa9, 0xda, 0xdd, 0xce, 0x13, 0xb4, 0xd3, 0x93, 0x78, 0x0e, 0xa1, 0xad, 0xd4,
-	0xbf, 0x4c, 0x13, 0x4c, 0x60, 0x58, 0x2e, 0x72, 0x26, 0x74, 0x69, 0x6a, 0x79, 0x93, 0xd6, 0x61,
-	0x65, 0x61, 0xaa, 0x56, 0x3c, 0x33, 0x45, 0xbb, 0x41, 0x6d, 0x30, 0xfb, 0x19, 0xc0, 0x91, 0x7b,
-	0x10, 0x66, 0x10, 0xe2, 0x0b, 0xe8, 0x57, 0x66, 0xe2, 0x3b, 0xdd, 0xe7, 0xd6, 0x99, 0x6d, 0x11,
-	0xf9, 0x3b, 0xe1, 0xa4, 0x5d, 0xc1, 0xa8, 0x71, 0x11, 0xdf, 0xdb, 0x35, 0xae, 0xa2, 0xfb, 0x5b,
-	0xb2, 0x8e, 0xe9, 0x39, 0x84, 0xd6, 0x4b, 0x7c, 0x77, 0xeb, 0x20, 0x88, 0xa2, 0x4d, 0xa9, 0x96,
-	0xc0, 0xda, 0xe9, 0x13, 0x78, 0x6d, 0xe3, 0x13, 0xf8, 0x65, 0x7a, 0x39, 0xfc, 0x30, 0x30, 0xc3,
-	0xfd, 0x53, 0x68, 0x3e, 0x8f, 0xff, 0x04, 0x00, 0x00, 0xff, 0xff, 0x1b, 0x6d, 0xe8, 0xeb, 0x30,
-	0x06, 0x00, 0x00,
+	0x14, 0x26, 0x6d, 0x77, 0xdc, 0x9e, 0xaa, 0xdb, 0x8d, 0x65, 0x8d, 0x23, 0xca, 0x32, 0x17, 0x5a,
+	0x2f, 0x1c, 0xa5, 0xde, 0xf8, 0xb3, 0x08, 0x8b, 0x08, 0x22, 0xe8, 0x45, 0xf4, 0x05, 0x6a, 0x1a,
+	0xa5, 0xb8, 0x93, 0x8c, 0xc9, 0x64, 0xa1, 0xaf, 0xe1, 0xbd, 0x4f, 0xe2, 0x43, 0xf9, 0x0a, 0x32,
+	0xf9, 0x99, 0x69, 0xc6, 0x6e, 0x59, 0x29, 0x88, 0x77, 0x73, 0xce, 0xf9, 0x72, 0xce, 0x7c, 0xdf,
+	0xf9, 0x81, 0x23, 0xcd, 0xd5, 0xf9, 0x92, 0xf1, 0x87, 0x4c, 0x2a, 0xc5, 0x17, 0x52, 0xe5, 0xa5,
+	0x92, 0x95, 0xc4, 0xfb, 0xc1, 0x4e, 0x6f, 0x32, 0x59, 0x94, 0x52, 0xf3, 0x47, 0x62, 0x5e, 0x70,
+	0x5d, 0xce, 0x19, 0x77, 0x90, 0x74, 0x12, 0x02, 0x85, 0x5c, 0x98, 0xb3, 0x3f, 0xbc, 0x8a, 0x33,
+	0xa9, 0x16, 0xce, 0x9b, 0x9d, 0xc0, 0x75, 0x6a, 0xc4, 0x47, 0xae, 0x2b, 0xca, 0xbf, 0x19, 0xae,
+	0x2b, 0x7c, 0x04, 0x89, 0x96, 0x46, 0x31, 0x4e, 0xd0, 0x31, 0x9a, 0x0e, 0xa9, 0xb7, 0x30, 0x86,
+	0x41, 0x5d, 0x88, 0xf4, 0xac, 0xd7, 0x7e, 0x67, 0xbf, 0x10, 0xdc, 0xa0, 0x46, 0xbc, 0x0f, 0x3f,
+	0x10, 0x72, 0x9c, 0x42, 0xc2, 0xa4, 0xf8, 0xbc, 0xfc, 0x42, 0xd0, 0x71, 0x7f, 0x3a, 0x9a, 0x3d,
+	0xc8, 0x1b, 0x16, 0x1b, 0xe0, 0xf9, 0x2b, 0x8b, 0x7d, 0x2d, 0x2a, 0xb5, 0xa2, 0xfe, 0x21, 0x9e,
+	0x42, 0xa2, 0x99, 0x5a, 0x96, 0x95, 0x2d, 0x38, 0x9a, 0x8d, 0xdb, 0x14, 0x1f, 0xac, 0x9f, 0xfa,
+	0x38, 0x7e, 0x0c, 0xc3, 0x46, 0x01, 0xd2, 0xb7, 0x60, 0x9c, 0x7b, 0xb2, 0x79, 0x5b, 0xab, 0x05,
+	0xa5, 0xcf, 0x60, 0xb4, 0x56, 0x12, 0x8f, 0xa1, 0xff, 0x95, 0xaf, 0x3c, 0xdd, 0xfa, 0x13, 0x4f,
+	0x60, 0xef, 0x7c, 0x7e, 0x66, 0x02, 0x59, 0x67, 0x3c, 0xef, 0x3d, 0x45, 0xd9, 0xf7, 0x1e, 0x8c,
+	0xa9, 0x11, 0xef, 0xac, 0xb2, 0x81, 0xee, 0xcb, 0x0e, 0xdd, 0x7b, 0x11, 0xdd, 0x08, 0xfb, 0xaf,
+	0xb9, 0xe2, 0xfb, 0x90, 0xb8, 0x31, 0x20, 0x03, 0x0b, 0x3f, 0x68, 0xe0, 0xfe, 0xbf, 0x7c, 0x78,
+	0x17, 0x51, 0x7e, 0x3a, 0x51, 0xa8, 0x1d, 0xac, 0xcb, 0x89, 0x12, 0x61, 0xff, 0x5b, 0x51, 0x6a,
+	0xa0, 0x5b, 0x17, 0xb2, 0xd7, 0x01, 0x7a, 0x02, 0x3e, 0xbc, 0x8b, 0x7a, 0x87, 0x70, 0xd0, 0xac,
+	0xa0, 0x2e, 0xa5, 0xd0, 0x3c, 0x7b, 0x03, 0x93, 0x78, 0x4f, 0x9c, 0x3f, 0x66, 0x8a, 0x2e, 0xc1,
+	0x34, 0x3b, 0x81, 0xc3, 0xb5, 0x11, 0xf4, 0x69, 0x5a, 0xfa, 0x68, 0x2b, 0x7d, 0xff, 0x3a, 0xf4,
+	0xaa, 0x7d, 0xed, 0x35, 0x41, 0x5b, 0x35, 0xc9, 0x16, 0x90, 0xb8, 0x4e, 0xfd, 0xcd, 0x4d, 0xc1,
+	0x04, 0xae, 0x54, 0xcb, 0x82, 0x4b, 0x53, 0xd9, 0x5e, 0x5e, 0xa3, 0xc1, 0xac, 0x25, 0x9c, 0xeb,
+	0x95, 0x60, 0xb6, 0x69, 0xfb, 0xd4, 0x19, 0xb3, 0x1f, 0x3d, 0xb8, 0xea, 0x07, 0xc2, 0x08, 0xc1,
+	0x15, 0x7e, 0x01, 0x83, 0x5a, 0x4c, 0x4c, 0xa2, 0x81, 0x5b, 0x3b, 0x71, 0xe9, 0xad, 0x0d, 0x11,
+	0x4f, 0xee, 0x2d, 0x0c, 0x1b, 0x1d, 0xf1, 0x9d, 0xad, 0x67, 0x2b, 0xbd, 0x7b, 0x51, 0xd8, 0xe7,
+	0x3a, 0x85, 0xc4, 0xe9, 0x89, 0xd3, 0x8b, 0x0f, 0x42, 0x7a, 0x7b, 0x63, 0xac, 0x4d, 0xe1, 0x44,
+	0xed, 0xa4, 0x88, 0xd6, 0xa7, 0x93, 0x22, 0x6e, 0xd7, 0xa7, 0xc4, 0x1e, 0xfa, 0x27, 0xbf, 0x03,
+	0x00, 0x00, 0xff, 0xff, 0x72, 0x3d, 0x15, 0x27, 0x51, 0x06, 0x00, 0x00,
 }
 
 // Reference imports to suppress errors if they are not otherwise used.
@@ -551,7 +552,7 @@ func NewScriptRunnerClient(cc *grpc.ClientConn) ScriptRunnerClient {
 
 func (c *scriptRunnerClient) Test(ctx context.Context, in *RunTestRequest, opts ...grpc.CallOption) (*RunTestResponse, error) {
 	out := new(RunTestResponse)
-	err := c.cc.Invoke(ctx, "/compose.ScriptRunner/Test", in, out, opts...)
+	err := c.cc.Invoke(ctx, "/corredor.ScriptRunner/Test", in, out, opts...)
 	if err != nil {
 		return nil, err
 	}
@@ -560,7 +561,7 @@ func (c *scriptRunnerClient) Test(ctx context.Context, in *RunTestRequest, opts
 
 func (c *scriptRunnerClient) Namespace(ctx context.Context, in *RunNamespaceRequest, opts ...grpc.CallOption) (*RunNamespaceResponse, error) {
 	out := new(RunNamespaceResponse)
-	err := c.cc.Invoke(ctx, "/compose.ScriptRunner/Namespace", in, out, opts...)
+	err := c.cc.Invoke(ctx, "/corredor.ScriptRunner/Namespace", in, out, opts...)
 	if err != nil {
 		return nil, err
 	}
@@ -569,7 +570,7 @@ func (c *scriptRunnerClient) Namespace(ctx context.Context, in *RunNamespaceRequ
 
 func (c *scriptRunnerClient) Module(ctx context.Context, in *RunModuleRequest, opts ...grpc.CallOption) (*RunModuleResponse, error) {
 	out := new(RunModuleResponse)
-	err := c.cc.Invoke(ctx, "/compose.ScriptRunner/Module", in, out, opts...)
+	err := c.cc.Invoke(ctx, "/corredor.ScriptRunner/Module", in, out, opts...)
 	if err != nil {
 		return nil, err
 	}
@@ -578,7 +579,7 @@ func (c *scriptRunnerClient) Module(ctx context.Context, in *RunModuleRequest, o
 
 func (c *scriptRunnerClient) Record(ctx context.Context, in *RunRecordRequest, opts ...grpc.CallOption) (*RunRecordResponse, error) {
 	out := new(RunRecordResponse)
-	err := c.cc.Invoke(ctx, "/compose.ScriptRunner/Record", in, out, opts...)
+	err := c.cc.Invoke(ctx, "/corredor.ScriptRunner/Record", in, out, opts...)
 	if err != nil {
 		return nil, err
 	}
@@ -624,7 +625,7 @@ func _ScriptRunner_Test_Handler(srv interface{}, ctx context.Context, dec func(i
 	}
 	info := &grpc.UnaryServerInfo{
 		Server:     srv,
-		FullMethod: "/compose.ScriptRunner/Test",
+		FullMethod: "/corredor.ScriptRunner/Test",
 	}
 	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
 		return srv.(ScriptRunnerServer).Test(ctx, req.(*RunTestRequest))
@@ -642,7 +643,7 @@ func _ScriptRunner_Namespace_Handler(srv interface{}, ctx context.Context, dec f
 	}
 	info := &grpc.UnaryServerInfo{
 		Server:     srv,
-		FullMethod: "/compose.ScriptRunner/Namespace",
+		FullMethod: "/corredor.ScriptRunner/Namespace",
 	}
 	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
 		return srv.(ScriptRunnerServer).Namespace(ctx, req.(*RunNamespaceRequest))
@@ -660,7 +661,7 @@ func _ScriptRunner_Module_Handler(srv interface{}, ctx context.Context, dec func
 	}
 	info := &grpc.UnaryServerInfo{
 		Server:     srv,
-		FullMethod: "/compose.ScriptRunner/Module",
+		FullMethod: "/corredor.ScriptRunner/Module",
 	}
 	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
 		return srv.(ScriptRunnerServer).Module(ctx, req.(*RunModuleRequest))
@@ -678,7 +679,7 @@ func _ScriptRunner_Record_Handler(srv interface{}, ctx context.Context, dec func
 	}
 	info := &grpc.UnaryServerInfo{
 		Server:     srv,
-		FullMethod: "/compose.ScriptRunner/Record",
+		FullMethod: "/corredor.ScriptRunner/Record",
 	}
 	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
 		return srv.(ScriptRunnerServer).Record(ctx, req.(*RunRecordRequest))
@@ -687,7 +688,7 @@ func _ScriptRunner_Record_Handler(srv interface{}, ctx context.Context, dec func
 }
 
 var _ScriptRunner_serviceDesc = grpc.ServiceDesc{
-	ServiceName: "compose.ScriptRunner",
+	ServiceName: "corredor.ScriptRunner",
 	HandlerType: (*ScriptRunnerServer)(nil),
 	Methods: []grpc.MethodDesc{
 		{
@@ -708,5 +709,5 @@ var _ScriptRunner_serviceDesc = grpc.ServiceDesc{
 		},
 	},
 	Streams:  []grpc.StreamDesc{},
-	Metadata: "script_runner.proto",
+	Metadata: "service-corredor.proto",
 }

system/system.go

@@ -79,6 +79,7 @@ func Configure() *cli.Config {
 					)
 
 					// Temporary gRPC server initialization location
+					// @todo move out of system Configure
 					grpcServer := grpc.NewServer()
 
 					ln, err := net.Listen(c.GRPCServerSystem.Network, c.GRPCServerSystem.Addr)