diff --git a/api/deploy.go b/api/deploy.go index 579c1348b..c8439751b 100644 --- a/api/deploy.go +++ b/api/deploy.go @@ -1,13 +1,11 @@ package api import ( - "fmt" "io" "io/ioutil" "os" "path/filepath" - "github.com/logrusorgru/aurora" "github.com/mesg-foundation/core/database/services" "github.com/mesg-foundation/core/service" "github.com/mesg-foundation/core/service/importer" @@ -55,11 +53,14 @@ type StatusType int const ( _ StatusType = iota // skip zero value. - // RUNNING indicates that status message belongs to an active state. - RUNNING + // Running indicates that status message belongs to a continuous state. + Running - // DONE indicates that status message belongs to completed state. - DONE + // DonePositive indicates that status message belongs to a positive noncontinuous state. + DonePositive + + // DoneNegative indicates that status message belongs to a negative noncontinuous state. + DoneNegative ) // DeployStatus represents the deployment status. @@ -81,7 +82,7 @@ func newServiceDeployer(api *API, options ...DeployServiceOption) *serviceDeploy // FromGitURL deploys a service hosted at a Git url. func (d *serviceDeployer) FromGitURL(url string) (*service.Service, *importer.ValidationError, error) { - d.sendStatus("Downloading service...", RUNNING) + d.sendStatus("Downloading service...", Running) path, err := d.createTempDir() if err != nil { return nil, nil, err @@ -97,7 +98,7 @@ func (d *serviceDeployer) FromGitURL(url string) (*service.Service, *importer.Va return nil, nil, err } - d.sendStatus(fmt.Sprintf("%s Service downloaded with success.", aurora.Green("✔")), DONE) + d.sendStatus("Service downloaded with success.", DonePositive) r, err := xarchive.GzippedTar(path) if err != nil { return nil, nil, err @@ -148,10 +149,12 @@ func (d *serviceDeployer) forwardDeployStatuses(statuses chan service.DeployStat for status := range statuses { var t StatusType switch status.Type { - case service.DRUNNING: - t = RUNNING - case service.DDONE: - t = DONE + case service.DRunning: + t = Running + case service.DDonePositive: + t = DonePositive + case service.DDoneNegative: + t = DoneNegative } d.sendStatus(status.Message, t) } diff --git a/api/deploy_test.go b/api/deploy_test.go index 41536de9c..79a227f12 100644 --- a/api/deploy_test.go +++ b/api/deploy_test.go @@ -1,7 +1,6 @@ package api import ( - "fmt" "io/ioutil" "os" "path/filepath" @@ -9,7 +8,6 @@ import ( "sync" "testing" - "github.com/logrusorgru/aurora" "github.com/mesg-foundation/core/service/importer" "github.com/mesg-foundation/core/x/xdocker/xarchive" "github.com/stretchr/testify/require" @@ -39,32 +37,32 @@ func TestDeployService(t *testing.T) { require.Equal(t, DeployStatus{ Message: "Receiving service context...", - Type: RUNNING, + Type: Running, }, <-statuses) require.Equal(t, DeployStatus{ - Message: fmt.Sprintf("%s Service context received with success.", aurora.Green("✔")), - Type: DONE, + Message: "Service context received with success.", + Type: DonePositive, }, <-statuses) require.Equal(t, DeployStatus{ - Message: fmt.Sprintf("%s [DEPRECATED] Please use .dockerignore instead of .mesgignore", aurora.Red("⨯")), - Type: DONE, + Message: "[DEPRECATED] Please use .dockerignore instead of .mesgignore", + Type: DoneNegative, }, <-statuses) require.Equal(t, DeployStatus{ Message: "Building Docker image...", - Type: RUNNING, + Type: Running, }, <-statuses) require.Equal(t, DeployStatus{ - Message: fmt.Sprintf("%s Image built with success.", aurora.Green("✔")), - Type: DONE, + Message: "Image built with success.", + Type: DonePositive, }, <-statuses) require.Equal(t, DeployStatus{ - Message: fmt.Sprintf("%s Service deployed.", aurora.Green("✔")), - Type: DONE, + Message: "Service deployed.", + Type: DonePositive, }, <-statuses) wg.Wait() @@ -94,12 +92,12 @@ func TestDeployInvalidService(t *testing.T) { require.Equal(t, DeployStatus{ Message: "Receiving service context...", - Type: RUNNING, + Type: Running, }, <-statuses) require.Equal(t, DeployStatus{ - Message: fmt.Sprintf("%s Service context received with success.", aurora.Green("✔")), - Type: DONE, + Message: "Service context received with success.", + Type: DonePositive, }, <-statuses) select { @@ -131,37 +129,37 @@ func TestDeployServiceFromURL(t *testing.T) { require.Equal(t, DeployStatus{ Message: "Downloading service...", - Type: RUNNING, + Type: Running, }, <-statuses) require.Equal(t, DeployStatus{ - Message: fmt.Sprintf("%s Service downloaded with success.", aurora.Green("✔")), - Type: DONE, + Message: "Service downloaded with success.", + Type: DonePositive, }, <-statuses) require.Equal(t, DeployStatus{ Message: "Receiving service context...", - Type: RUNNING, + Type: Running, }, <-statuses) require.Equal(t, DeployStatus{ - Message: fmt.Sprintf("%s Service context received with success.", aurora.Green("✔")), - Type: DONE, + Message: "Service context received with success.", + Type: DonePositive, }, <-statuses) require.Equal(t, DeployStatus{ Message: "Building Docker image...", - Type: RUNNING, + Type: Running, }, <-statuses) require.Equal(t, DeployStatus{ - Message: fmt.Sprintf("%s Image built with success.", aurora.Green("✔")), - Type: DONE, + Message: "Image built with success.", + Type: DonePositive, }, <-statuses) require.Equal(t, DeployStatus{ - Message: fmt.Sprintf("%s Service deployed.", aurora.Green("✔")), - Type: DONE, + Message: "Service deployed.", + Type: DonePositive, }, <-statuses) wg.Wait() diff --git a/commands/provider/service_deployer.go b/commands/provider/service_deployer.go index cafded21e..9d476885b 100644 --- a/commands/provider/service_deployer.go +++ b/commands/provider/service_deployer.go @@ -16,11 +16,14 @@ type StatusType int const ( _ StatusType = iota // skip zero value. - // RUNNING indicates that status message belongs to an active state. - RUNNING + // Running indicates that status message belongs to a continuous state. + Running - // DONE indicates that status message belongs to completed state. - DONE + // DonePositive indicates that status message belongs to a positive noncontinuous state. + DonePositive + + // DoneNegative indicates that status message belongs to a negative noncontinuous state. + DoneNegative ) // DeployStatus represents the deployment status. @@ -116,20 +119,21 @@ func readDeployReply(stream coreapi.Core_DeployServiceClient, deployment chan de switch { case status != nil: + s := DeployStatus{ + Message: status.Message, + } + switch status.Type { case coreapi.DeployServiceReply_Status_RUNNING: - statuses <- DeployStatus{ - Message: status.Message, - Type: RUNNING, - } - - case coreapi.DeployServiceReply_Status_DONE: - statuses <- DeployStatus{ - Message: status.Message, - Type: DONE, - } + s.Type = Running + case coreapi.DeployServiceReply_Status_DONE_POSITIVE: + s.Type = DonePositive + case coreapi.DeployServiceReply_Status_DONE_NEGATIVE: + s.Type = DoneNegative } + statuses <- s + case serviceID != "": result.serviceID = serviceID deployment <- result diff --git a/commands/service_deploy.go b/commands/service_deploy.go index 1ab821334..e43e700fe 100644 --- a/commands/service_deploy.go +++ b/commands/service_deploy.go @@ -61,11 +61,18 @@ func (c *serviceDeployCmd) runE(cmd *cobra.Command, args []string) error { func printDeployStatuses(statuses chan provider.DeployStatus) { for status := range statuses { switch status.Type { - case provider.RUNNING: + case provider.Running: pretty.UseSpinner(status.Message) - case provider.DONE: + default: + var sign string + switch status.Type { + case provider.DonePositive: + sign = pretty.SuccessSign + case provider.DoneNegative: + sign = pretty.FailSign + } pretty.DestroySpinner() - fmt.Println(status.Message) + fmt.Printf("%s %s\n", sign, status.Message) } } } diff --git a/interface/grpc/core/deploy.go b/interface/grpc/core/deploy.go index c417e22ed..0cc0a5bf8 100644 --- a/interface/grpc/core/deploy.go +++ b/interface/grpc/core/deploy.go @@ -48,10 +48,12 @@ func sendDeployStatus(statuses chan api.DeployStatus, stream coreapi.Core_Deploy for status := range statuses { var typ coreapi.DeployServiceReply_Status_Type switch status.Type { - case api.RUNNING: + case api.Running: typ = coreapi.DeployServiceReply_Status_RUNNING - case api.DONE: - typ = coreapi.DeployServiceReply_Status_DONE + case api.DonePositive: + typ = coreapi.DeployServiceReply_Status_DONE_POSITIVE + case api.DoneNegative: + typ = coreapi.DeployServiceReply_Status_DONE_NEGATIVE } stream.Send(&coreapi.DeployServiceReply{ diff --git a/interface/grpc/core/deploy_test.go b/interface/grpc/core/deploy_test.go index 813c5dde1..b749b183b 100644 --- a/interface/grpc/core/deploy_test.go +++ b/interface/grpc/core/deploy_test.go @@ -1,12 +1,10 @@ package core import ( - "fmt" "io/ioutil" "strings" "testing" - "github.com/logrusorgru/aurora" "github.com/mesg-foundation/core/api" "github.com/mesg-foundation/core/protobuf/coreapi" "github.com/stretchr/testify/require" @@ -24,8 +22,8 @@ func TestDeployService(t *testing.T) { require.Len(t, stream.serviceID, 40) require.Contains(t, stream.statuses, api.DeployStatus{ - Message: fmt.Sprintf("%s Service deployed.", aurora.Green("✔")), - Type: api.DONE, + Message: "Service deployed.", + Type: api.DonePositive, }) } @@ -50,9 +48,11 @@ func (s *testDeployStream) Send(m *coreapi.DeployServiceReply) error { var typ api.StatusType switch status.Type { case coreapi.DeployServiceReply_Status_RUNNING: - typ = api.RUNNING - case coreapi.DeployServiceReply_Status_DONE: - typ = api.DONE + typ = api.Running + case coreapi.DeployServiceReply_Status_DONE_POSITIVE: + typ = api.DonePositive + case coreapi.DeployServiceReply_Status_DONE_NEGATIVE: + typ = api.DoneNegative } s.statuses = append(s.statuses, api.DeployStatus{ Message: status.Message, diff --git a/protobuf/coreapi/api.pb.go b/protobuf/coreapi/api.pb.go index 701645cd2..7696486ea 100644 --- a/protobuf/coreapi/api.pb.go +++ b/protobuf/coreapi/api.pb.go @@ -26,28 +26,30 @@ const _ = proto.ProtoPackageIsVersion2 // please upgrade the proto package type DeployServiceReply_Status_Type int32 const ( - // RUNNING indicates that status message belongs to an active state. + // RUNNING indicates that status message belongs to a continuous state. DeployServiceReply_Status_RUNNING DeployServiceReply_Status_Type = 0 - // DONE indicates that status message belongs to completed state. - DeployServiceReply_Status_DONE DeployServiceReply_Status_Type = 1 + // DONE_POSITIVE indicates that status message belongs to a positive noncontinuous state. + DeployServiceReply_Status_DONE_POSITIVE DeployServiceReply_Status_Type = 1 + // DONE_NEGATIVE indicates that status message belongs to a negative noncontinuous state. + DeployServiceReply_Status_DONE_NEGATIVE DeployServiceReply_Status_Type = 2 ) var DeployServiceReply_Status_Type_name = map[int32]string{ 0: "RUNNING", - 1: "DONE", + 1: "DONE_POSITIVE", + 2: "DONE_NEGATIVE", } - var DeployServiceReply_Status_Type_value = map[string]int32{ - "RUNNING": 0, - "DONE": 1, + "RUNNING": 0, + "DONE_POSITIVE": 1, + "DONE_NEGATIVE": 2, } func (x DeployServiceReply_Status_Type) String() string { return proto.EnumName(DeployServiceReply_Status_Type_name, int32(x)) } - func (DeployServiceReply_Status_Type) EnumDescriptor() ([]byte, []int) { - return fileDescriptor_67a9cc666e46cd17, []int{11, 0, 0} + return fileDescriptor_api_3bcfee19e3d98590, []int{11, 0, 0} } type LogData_Type int32 @@ -63,7 +65,6 @@ var LogData_Type_name = map[int32]string{ 0: "Standard", 1: "Error", } - var LogData_Type_value = map[string]int32{ "Standard": 0, "Error": 1, @@ -72,9 +73,8 @@ var LogData_Type_value = map[string]int32{ func (x LogData_Type) String() string { return proto.EnumName(LogData_Type_name, int32(x)) } - func (LogData_Type) EnumDescriptor() ([]byte, []int) { - return fileDescriptor_67a9cc666e46cd17, []int{19, 0} + return fileDescriptor_api_3bcfee19e3d98590, []int{19, 0} } // The request's data for the `ListenEvent` stream's API. @@ -98,7 +98,7 @@ func (m *ListenEventRequest) Reset() { *m = ListenEventRequest{} } func (m *ListenEventRequest) String() string { return proto.CompactTextString(m) } func (*ListenEventRequest) ProtoMessage() {} func (*ListenEventRequest) Descriptor() ([]byte, []int) { - return fileDescriptor_67a9cc666e46cd17, []int{0} + return fileDescriptor_api_3bcfee19e3d98590, []int{0} } func (m *ListenEventRequest) XXX_Unmarshal(b []byte) error { return xxx_messageInfo_ListenEventRequest.Unmarshal(m, b) @@ -106,8 +106,8 @@ func (m *ListenEventRequest) XXX_Unmarshal(b []byte) error { func (m *ListenEventRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { return xxx_messageInfo_ListenEventRequest.Marshal(b, m, deterministic) } -func (m *ListenEventRequest) XXX_Merge(src proto.Message) { - xxx_messageInfo_ListenEventRequest.Merge(m, src) +func (dst *ListenEventRequest) XXX_Merge(src proto.Message) { + xxx_messageInfo_ListenEventRequest.Merge(dst, src) } func (m *ListenEventRequest) XXX_Size() int { return xxx_messageInfo_ListenEventRequest.Size(m) @@ -154,7 +154,7 @@ func (m *EventData) Reset() { *m = EventData{} } func (m *EventData) String() string { return proto.CompactTextString(m) } func (*EventData) ProtoMessage() {} func (*EventData) Descriptor() ([]byte, []int) { - return fileDescriptor_67a9cc666e46cd17, []int{1} + return fileDescriptor_api_3bcfee19e3d98590, []int{1} } func (m *EventData) XXX_Unmarshal(b []byte) error { return xxx_messageInfo_EventData.Unmarshal(m, b) @@ -162,8 +162,8 @@ func (m *EventData) XXX_Unmarshal(b []byte) error { func (m *EventData) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { return xxx_messageInfo_EventData.Marshal(b, m, deterministic) } -func (m *EventData) XXX_Merge(src proto.Message) { - xxx_messageInfo_EventData.Merge(m, src) +func (dst *EventData) XXX_Merge(src proto.Message) { + xxx_messageInfo_EventData.Merge(dst, src) } func (m *EventData) XXX_Size() int { return xxx_messageInfo_EventData.Size(m) @@ -213,7 +213,7 @@ func (m *ListenResultRequest) Reset() { *m = ListenResultRequest{} } func (m *ListenResultRequest) String() string { return proto.CompactTextString(m) } func (*ListenResultRequest) ProtoMessage() {} func (*ListenResultRequest) Descriptor() ([]byte, []int) { - return fileDescriptor_67a9cc666e46cd17, []int{2} + return fileDescriptor_api_3bcfee19e3d98590, []int{2} } func (m *ListenResultRequest) XXX_Unmarshal(b []byte) error { return xxx_messageInfo_ListenResultRequest.Unmarshal(m, b) @@ -221,8 +221,8 @@ func (m *ListenResultRequest) XXX_Unmarshal(b []byte) error { func (m *ListenResultRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { return xxx_messageInfo_ListenResultRequest.Marshal(b, m, deterministic) } -func (m *ListenResultRequest) XXX_Merge(src proto.Message) { - xxx_messageInfo_ListenResultRequest.Merge(m, src) +func (dst *ListenResultRequest) XXX_Merge(src proto.Message) { + xxx_messageInfo_ListenResultRequest.Merge(dst, src) } func (m *ListenResultRequest) XXX_Size() int { return xxx_messageInfo_ListenResultRequest.Size(m) @@ -289,7 +289,7 @@ func (m *ResultData) Reset() { *m = ResultData{} } func (m *ResultData) String() string { return proto.CompactTextString(m) } func (*ResultData) ProtoMessage() {} func (*ResultData) Descriptor() ([]byte, []int) { - return fileDescriptor_67a9cc666e46cd17, []int{3} + return fileDescriptor_api_3bcfee19e3d98590, []int{3} } func (m *ResultData) XXX_Unmarshal(b []byte) error { return xxx_messageInfo_ResultData.Unmarshal(m, b) @@ -297,8 +297,8 @@ func (m *ResultData) XXX_Unmarshal(b []byte) error { func (m *ResultData) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { return xxx_messageInfo_ResultData.Marshal(b, m, deterministic) } -func (m *ResultData) XXX_Merge(src proto.Message) { - xxx_messageInfo_ResultData.Merge(m, src) +func (dst *ResultData) XXX_Merge(src proto.Message) { + xxx_messageInfo_ResultData.Merge(dst, src) } func (m *ResultData) XXX_Size() int { return xxx_messageInfo_ResultData.Size(m) @@ -369,7 +369,7 @@ func (m *ExecuteTaskRequest) Reset() { *m = ExecuteTaskRequest{} } func (m *ExecuteTaskRequest) String() string { return proto.CompactTextString(m) } func (*ExecuteTaskRequest) ProtoMessage() {} func (*ExecuteTaskRequest) Descriptor() ([]byte, []int) { - return fileDescriptor_67a9cc666e46cd17, []int{4} + return fileDescriptor_api_3bcfee19e3d98590, []int{4} } func (m *ExecuteTaskRequest) XXX_Unmarshal(b []byte) error { return xxx_messageInfo_ExecuteTaskRequest.Unmarshal(m, b) @@ -377,8 +377,8 @@ func (m *ExecuteTaskRequest) XXX_Unmarshal(b []byte) error { func (m *ExecuteTaskRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { return xxx_messageInfo_ExecuteTaskRequest.Marshal(b, m, deterministic) } -func (m *ExecuteTaskRequest) XXX_Merge(src proto.Message) { - xxx_messageInfo_ExecuteTaskRequest.Merge(m, src) +func (dst *ExecuteTaskRequest) XXX_Merge(src proto.Message) { + xxx_messageInfo_ExecuteTaskRequest.Merge(dst, src) } func (m *ExecuteTaskRequest) XXX_Size() int { return xxx_messageInfo_ExecuteTaskRequest.Size(m) @@ -436,7 +436,7 @@ func (m *ExecuteTaskReply) Reset() { *m = ExecuteTaskReply{} } func (m *ExecuteTaskReply) String() string { return proto.CompactTextString(m) } func (*ExecuteTaskReply) ProtoMessage() {} func (*ExecuteTaskReply) Descriptor() ([]byte, []int) { - return fileDescriptor_67a9cc666e46cd17, []int{5} + return fileDescriptor_api_3bcfee19e3d98590, []int{5} } func (m *ExecuteTaskReply) XXX_Unmarshal(b []byte) error { return xxx_messageInfo_ExecuteTaskReply.Unmarshal(m, b) @@ -444,8 +444,8 @@ func (m *ExecuteTaskReply) XXX_Unmarshal(b []byte) error { func (m *ExecuteTaskReply) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { return xxx_messageInfo_ExecuteTaskReply.Marshal(b, m, deterministic) } -func (m *ExecuteTaskReply) XXX_Merge(src proto.Message) { - xxx_messageInfo_ExecuteTaskReply.Merge(m, src) +func (dst *ExecuteTaskReply) XXX_Merge(src proto.Message) { + xxx_messageInfo_ExecuteTaskReply.Merge(dst, src) } func (m *ExecuteTaskReply) XXX_Size() int { return xxx_messageInfo_ExecuteTaskReply.Size(m) @@ -482,7 +482,7 @@ func (m *StartServiceRequest) Reset() { *m = StartServiceRequest{} } func (m *StartServiceRequest) String() string { return proto.CompactTextString(m) } func (*StartServiceRequest) ProtoMessage() {} func (*StartServiceRequest) Descriptor() ([]byte, []int) { - return fileDescriptor_67a9cc666e46cd17, []int{6} + return fileDescriptor_api_3bcfee19e3d98590, []int{6} } func (m *StartServiceRequest) XXX_Unmarshal(b []byte) error { return xxx_messageInfo_StartServiceRequest.Unmarshal(m, b) @@ -490,8 +490,8 @@ func (m *StartServiceRequest) XXX_Unmarshal(b []byte) error { func (m *StartServiceRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { return xxx_messageInfo_StartServiceRequest.Marshal(b, m, deterministic) } -func (m *StartServiceRequest) XXX_Merge(src proto.Message) { - xxx_messageInfo_StartServiceRequest.Merge(m, src) +func (dst *StartServiceRequest) XXX_Merge(src proto.Message) { + xxx_messageInfo_StartServiceRequest.Merge(dst, src) } func (m *StartServiceRequest) XXX_Size() int { return xxx_messageInfo_StartServiceRequest.Size(m) @@ -520,7 +520,7 @@ func (m *StartServiceReply) Reset() { *m = StartServiceReply{} } func (m *StartServiceReply) String() string { return proto.CompactTextString(m) } func (*StartServiceReply) ProtoMessage() {} func (*StartServiceReply) Descriptor() ([]byte, []int) { - return fileDescriptor_67a9cc666e46cd17, []int{7} + return fileDescriptor_api_3bcfee19e3d98590, []int{7} } func (m *StartServiceReply) XXX_Unmarshal(b []byte) error { return xxx_messageInfo_StartServiceReply.Unmarshal(m, b) @@ -528,8 +528,8 @@ func (m *StartServiceReply) XXX_Unmarshal(b []byte) error { func (m *StartServiceReply) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { return xxx_messageInfo_StartServiceReply.Marshal(b, m, deterministic) } -func (m *StartServiceReply) XXX_Merge(src proto.Message) { - xxx_messageInfo_StartServiceReply.Merge(m, src) +func (dst *StartServiceReply) XXX_Merge(src proto.Message) { + xxx_messageInfo_StartServiceReply.Merge(dst, src) } func (m *StartServiceReply) XXX_Size() int { return xxx_messageInfo_StartServiceReply.Size(m) @@ -559,7 +559,7 @@ func (m *StopServiceRequest) Reset() { *m = StopServiceRequest{} } func (m *StopServiceRequest) String() string { return proto.CompactTextString(m) } func (*StopServiceRequest) ProtoMessage() {} func (*StopServiceRequest) Descriptor() ([]byte, []int) { - return fileDescriptor_67a9cc666e46cd17, []int{8} + return fileDescriptor_api_3bcfee19e3d98590, []int{8} } func (m *StopServiceRequest) XXX_Unmarshal(b []byte) error { return xxx_messageInfo_StopServiceRequest.Unmarshal(m, b) @@ -567,8 +567,8 @@ func (m *StopServiceRequest) XXX_Unmarshal(b []byte) error { func (m *StopServiceRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { return xxx_messageInfo_StopServiceRequest.Marshal(b, m, deterministic) } -func (m *StopServiceRequest) XXX_Merge(src proto.Message) { - xxx_messageInfo_StopServiceRequest.Merge(m, src) +func (dst *StopServiceRequest) XXX_Merge(src proto.Message) { + xxx_messageInfo_StopServiceRequest.Merge(dst, src) } func (m *StopServiceRequest) XXX_Size() int { return xxx_messageInfo_StopServiceRequest.Size(m) @@ -597,7 +597,7 @@ func (m *StopServiceReply) Reset() { *m = StopServiceReply{} } func (m *StopServiceReply) String() string { return proto.CompactTextString(m) } func (*StopServiceReply) ProtoMessage() {} func (*StopServiceReply) Descriptor() ([]byte, []int) { - return fileDescriptor_67a9cc666e46cd17, []int{9} + return fileDescriptor_api_3bcfee19e3d98590, []int{9} } func (m *StopServiceReply) XXX_Unmarshal(b []byte) error { return xxx_messageInfo_StopServiceReply.Unmarshal(m, b) @@ -605,8 +605,8 @@ func (m *StopServiceReply) XXX_Unmarshal(b []byte) error { func (m *StopServiceReply) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { return xxx_messageInfo_StopServiceReply.Marshal(b, m, deterministic) } -func (m *StopServiceReply) XXX_Merge(src proto.Message) { - xxx_messageInfo_StopServiceReply.Merge(m, src) +func (dst *StopServiceReply) XXX_Merge(src proto.Message) { + xxx_messageInfo_StopServiceReply.Merge(dst, src) } func (m *StopServiceReply) XXX_Size() int { return xxx_messageInfo_StopServiceReply.Size(m) @@ -662,7 +662,7 @@ func (m *DeployServiceRequest) Reset() { *m = DeployServiceRequest{} } func (m *DeployServiceRequest) String() string { return proto.CompactTextString(m) } func (*DeployServiceRequest) ProtoMessage() {} func (*DeployServiceRequest) Descriptor() ([]byte, []int) { - return fileDescriptor_67a9cc666e46cd17, []int{10} + return fileDescriptor_api_3bcfee19e3d98590, []int{10} } func (m *DeployServiceRequest) XXX_Unmarshal(b []byte) error { return xxx_messageInfo_DeployServiceRequest.Unmarshal(m, b) @@ -670,8 +670,8 @@ func (m *DeployServiceRequest) XXX_Unmarshal(b []byte) error { func (m *DeployServiceRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { return xxx_messageInfo_DeployServiceRequest.Marshal(b, m, deterministic) } -func (m *DeployServiceRequest) XXX_Merge(src proto.Message) { - xxx_messageInfo_DeployServiceRequest.Merge(m, src) +func (dst *DeployServiceRequest) XXX_Merge(src proto.Message) { + xxx_messageInfo_DeployServiceRequest.Merge(dst, src) } func (m *DeployServiceRequest) XXX_Size() int { return xxx_messageInfo_DeployServiceRequest.Size(m) @@ -808,7 +808,7 @@ func (m *DeployServiceReply) Reset() { *m = DeployServiceReply{} } func (m *DeployServiceReply) String() string { return proto.CompactTextString(m) } func (*DeployServiceReply) ProtoMessage() {} func (*DeployServiceReply) Descriptor() ([]byte, []int) { - return fileDescriptor_67a9cc666e46cd17, []int{11} + return fileDescriptor_api_3bcfee19e3d98590, []int{11} } func (m *DeployServiceReply) XXX_Unmarshal(b []byte) error { return xxx_messageInfo_DeployServiceReply.Unmarshal(m, b) @@ -816,8 +816,8 @@ func (m *DeployServiceReply) XXX_Unmarshal(b []byte) error { func (m *DeployServiceReply) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { return xxx_messageInfo_DeployServiceReply.Marshal(b, m, deterministic) } -func (m *DeployServiceReply) XXX_Merge(src proto.Message) { - xxx_messageInfo_DeployServiceReply.Merge(m, src) +func (dst *DeployServiceReply) XXX_Merge(src proto.Message) { + xxx_messageInfo_DeployServiceReply.Merge(dst, src) } func (m *DeployServiceReply) XXX_Size() int { return xxx_messageInfo_DeployServiceReply.Size(m) @@ -977,7 +977,7 @@ func (m *DeployServiceReply_Status) Reset() { *m = DeployServiceReply_St func (m *DeployServiceReply_Status) String() string { return proto.CompactTextString(m) } func (*DeployServiceReply_Status) ProtoMessage() {} func (*DeployServiceReply_Status) Descriptor() ([]byte, []int) { - return fileDescriptor_67a9cc666e46cd17, []int{11, 0} + return fileDescriptor_api_3bcfee19e3d98590, []int{11, 0} } func (m *DeployServiceReply_Status) XXX_Unmarshal(b []byte) error { return xxx_messageInfo_DeployServiceReply_Status.Unmarshal(m, b) @@ -985,8 +985,8 @@ func (m *DeployServiceReply_Status) XXX_Unmarshal(b []byte) error { func (m *DeployServiceReply_Status) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { return xxx_messageInfo_DeployServiceReply_Status.Marshal(b, m, deterministic) } -func (m *DeployServiceReply_Status) XXX_Merge(src proto.Message) { - xxx_messageInfo_DeployServiceReply_Status.Merge(m, src) +func (dst *DeployServiceReply_Status) XXX_Merge(src proto.Message) { + xxx_messageInfo_DeployServiceReply_Status.Merge(dst, src) } func (m *DeployServiceReply_Status) XXX_Size() int { return xxx_messageInfo_DeployServiceReply_Status.Size(m) @@ -1030,7 +1030,7 @@ func (m *DeleteServiceRequest) Reset() { *m = DeleteServiceRequest{} } func (m *DeleteServiceRequest) String() string { return proto.CompactTextString(m) } func (*DeleteServiceRequest) ProtoMessage() {} func (*DeleteServiceRequest) Descriptor() ([]byte, []int) { - return fileDescriptor_67a9cc666e46cd17, []int{12} + return fileDescriptor_api_3bcfee19e3d98590, []int{12} } func (m *DeleteServiceRequest) XXX_Unmarshal(b []byte) error { return xxx_messageInfo_DeleteServiceRequest.Unmarshal(m, b) @@ -1038,8 +1038,8 @@ func (m *DeleteServiceRequest) XXX_Unmarshal(b []byte) error { func (m *DeleteServiceRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { return xxx_messageInfo_DeleteServiceRequest.Marshal(b, m, deterministic) } -func (m *DeleteServiceRequest) XXX_Merge(src proto.Message) { - xxx_messageInfo_DeleteServiceRequest.Merge(m, src) +func (dst *DeleteServiceRequest) XXX_Merge(src proto.Message) { + xxx_messageInfo_DeleteServiceRequest.Merge(dst, src) } func (m *DeleteServiceRequest) XXX_Size() int { return xxx_messageInfo_DeleteServiceRequest.Size(m) @@ -1068,7 +1068,7 @@ func (m *DeleteServiceReply) Reset() { *m = DeleteServiceReply{} } func (m *DeleteServiceReply) String() string { return proto.CompactTextString(m) } func (*DeleteServiceReply) ProtoMessage() {} func (*DeleteServiceReply) Descriptor() ([]byte, []int) { - return fileDescriptor_67a9cc666e46cd17, []int{13} + return fileDescriptor_api_3bcfee19e3d98590, []int{13} } func (m *DeleteServiceReply) XXX_Unmarshal(b []byte) error { return xxx_messageInfo_DeleteServiceReply.Unmarshal(m, b) @@ -1076,8 +1076,8 @@ func (m *DeleteServiceReply) XXX_Unmarshal(b []byte) error { func (m *DeleteServiceReply) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { return xxx_messageInfo_DeleteServiceReply.Marshal(b, m, deterministic) } -func (m *DeleteServiceReply) XXX_Merge(src proto.Message) { - xxx_messageInfo_DeleteServiceReply.Merge(m, src) +func (dst *DeleteServiceReply) XXX_Merge(src proto.Message) { + xxx_messageInfo_DeleteServiceReply.Merge(dst, src) } func (m *DeleteServiceReply) XXX_Size() int { return xxx_messageInfo_DeleteServiceReply.Size(m) @@ -1099,7 +1099,7 @@ func (m *ListServicesRequest) Reset() { *m = ListServicesRequest{} } func (m *ListServicesRequest) String() string { return proto.CompactTextString(m) } func (*ListServicesRequest) ProtoMessage() {} func (*ListServicesRequest) Descriptor() ([]byte, []int) { - return fileDescriptor_67a9cc666e46cd17, []int{14} + return fileDescriptor_api_3bcfee19e3d98590, []int{14} } func (m *ListServicesRequest) XXX_Unmarshal(b []byte) error { return xxx_messageInfo_ListServicesRequest.Unmarshal(m, b) @@ -1107,8 +1107,8 @@ func (m *ListServicesRequest) XXX_Unmarshal(b []byte) error { func (m *ListServicesRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { return xxx_messageInfo_ListServicesRequest.Marshal(b, m, deterministic) } -func (m *ListServicesRequest) XXX_Merge(src proto.Message) { - xxx_messageInfo_ListServicesRequest.Merge(m, src) +func (dst *ListServicesRequest) XXX_Merge(src proto.Message) { + xxx_messageInfo_ListServicesRequest.Merge(dst, src) } func (m *ListServicesRequest) XXX_Size() int { return xxx_messageInfo_ListServicesRequest.Size(m) @@ -1161,7 +1161,7 @@ func (m *ListServicesReply) Reset() { *m = ListServicesReply{} } func (m *ListServicesReply) String() string { return proto.CompactTextString(m) } func (*ListServicesReply) ProtoMessage() {} func (*ListServicesReply) Descriptor() ([]byte, []int) { - return fileDescriptor_67a9cc666e46cd17, []int{15} + return fileDescriptor_api_3bcfee19e3d98590, []int{15} } func (m *ListServicesReply) XXX_Unmarshal(b []byte) error { return xxx_messageInfo_ListServicesReply.Unmarshal(m, b) @@ -1169,8 +1169,8 @@ func (m *ListServicesReply) XXX_Unmarshal(b []byte) error { func (m *ListServicesReply) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { return xxx_messageInfo_ListServicesReply.Marshal(b, m, deterministic) } -func (m *ListServicesReply) XXX_Merge(src proto.Message) { - xxx_messageInfo_ListServicesReply.Merge(m, src) +func (dst *ListServicesReply) XXX_Merge(src proto.Message) { + xxx_messageInfo_ListServicesReply.Merge(dst, src) } func (m *ListServicesReply) XXX_Size() int { return xxx_messageInfo_ListServicesReply.Size(m) @@ -1207,7 +1207,7 @@ func (m *GetServiceRequest) Reset() { *m = GetServiceRequest{} } func (m *GetServiceRequest) String() string { return proto.CompactTextString(m) } func (*GetServiceRequest) ProtoMessage() {} func (*GetServiceRequest) Descriptor() ([]byte, []int) { - return fileDescriptor_67a9cc666e46cd17, []int{16} + return fileDescriptor_api_3bcfee19e3d98590, []int{16} } func (m *GetServiceRequest) XXX_Unmarshal(b []byte) error { return xxx_messageInfo_GetServiceRequest.Unmarshal(m, b) @@ -1215,8 +1215,8 @@ func (m *GetServiceRequest) XXX_Unmarshal(b []byte) error { func (m *GetServiceRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { return xxx_messageInfo_GetServiceRequest.Marshal(b, m, deterministic) } -func (m *GetServiceRequest) XXX_Merge(src proto.Message) { - xxx_messageInfo_GetServiceRequest.Merge(m, src) +func (dst *GetServiceRequest) XXX_Merge(src proto.Message) { + xxx_messageInfo_GetServiceRequest.Merge(dst, src) } func (m *GetServiceRequest) XXX_Size() int { return xxx_messageInfo_GetServiceRequest.Size(m) @@ -1276,7 +1276,7 @@ func (m *GetServiceReply) Reset() { *m = GetServiceReply{} } func (m *GetServiceReply) String() string { return proto.CompactTextString(m) } func (*GetServiceReply) ProtoMessage() {} func (*GetServiceReply) Descriptor() ([]byte, []int) { - return fileDescriptor_67a9cc666e46cd17, []int{17} + return fileDescriptor_api_3bcfee19e3d98590, []int{17} } func (m *GetServiceReply) XXX_Unmarshal(b []byte) error { return xxx_messageInfo_GetServiceReply.Unmarshal(m, b) @@ -1284,8 +1284,8 @@ func (m *GetServiceReply) XXX_Unmarshal(b []byte) error { func (m *GetServiceReply) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { return xxx_messageInfo_GetServiceReply.Marshal(b, m, deterministic) } -func (m *GetServiceReply) XXX_Merge(src proto.Message) { - xxx_messageInfo_GetServiceReply.Merge(m, src) +func (dst *GetServiceReply) XXX_Merge(src proto.Message) { + xxx_messageInfo_GetServiceReply.Merge(dst, src) } func (m *GetServiceReply) XXX_Size() int { return xxx_messageInfo_GetServiceReply.Size(m) @@ -1316,7 +1316,7 @@ func (m *ServiceLogsRequest) Reset() { *m = ServiceLogsRequest{} } func (m *ServiceLogsRequest) String() string { return proto.CompactTextString(m) } func (*ServiceLogsRequest) ProtoMessage() {} func (*ServiceLogsRequest) Descriptor() ([]byte, []int) { - return fileDescriptor_67a9cc666e46cd17, []int{18} + return fileDescriptor_api_3bcfee19e3d98590, []int{18} } func (m *ServiceLogsRequest) XXX_Unmarshal(b []byte) error { return xxx_messageInfo_ServiceLogsRequest.Unmarshal(m, b) @@ -1324,8 +1324,8 @@ func (m *ServiceLogsRequest) XXX_Unmarshal(b []byte) error { func (m *ServiceLogsRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { return xxx_messageInfo_ServiceLogsRequest.Marshal(b, m, deterministic) } -func (m *ServiceLogsRequest) XXX_Merge(src proto.Message) { - xxx_messageInfo_ServiceLogsRequest.Merge(m, src) +func (dst *ServiceLogsRequest) XXX_Merge(src proto.Message) { + xxx_messageInfo_ServiceLogsRequest.Merge(dst, src) } func (m *ServiceLogsRequest) XXX_Size() int { return xxx_messageInfo_ServiceLogsRequest.Size(m) @@ -1367,7 +1367,7 @@ func (m *LogData) Reset() { *m = LogData{} } func (m *LogData) String() string { return proto.CompactTextString(m) } func (*LogData) ProtoMessage() {} func (*LogData) Descriptor() ([]byte, []int) { - return fileDescriptor_67a9cc666e46cd17, []int{19} + return fileDescriptor_api_3bcfee19e3d98590, []int{19} } func (m *LogData) XXX_Unmarshal(b []byte) error { return xxx_messageInfo_LogData.Unmarshal(m, b) @@ -1375,8 +1375,8 @@ func (m *LogData) XXX_Unmarshal(b []byte) error { func (m *LogData) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { return xxx_messageInfo_LogData.Marshal(b, m, deterministic) } -func (m *LogData) XXX_Merge(src proto.Message) { - xxx_messageInfo_LogData.Merge(m, src) +func (dst *LogData) XXX_Merge(src proto.Message) { + xxx_messageInfo_LogData.Merge(dst, src) } func (m *LogData) XXX_Size() int { return xxx_messageInfo_LogData.Size(m) @@ -1427,7 +1427,7 @@ func (m *Service) Reset() { *m = Service{} } func (m *Service) String() string { return proto.CompactTextString(m) } func (*Service) ProtoMessage() {} func (*Service) Descriptor() ([]byte, []int) { - return fileDescriptor_67a9cc666e46cd17, []int{20} + return fileDescriptor_api_3bcfee19e3d98590, []int{20} } func (m *Service) XXX_Unmarshal(b []byte) error { return xxx_messageInfo_Service.Unmarshal(m, b) @@ -1435,8 +1435,8 @@ func (m *Service) XXX_Unmarshal(b []byte) error { func (m *Service) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { return xxx_messageInfo_Service.Marshal(b, m, deterministic) } -func (m *Service) XXX_Merge(src proto.Message) { - xxx_messageInfo_Service.Merge(m, src) +func (dst *Service) XXX_Merge(src proto.Message) { + xxx_messageInfo_Service.Merge(dst, src) } func (m *Service) XXX_Size() int { return xxx_messageInfo_Service.Size(m) @@ -1518,7 +1518,7 @@ func (m *Event) Reset() { *m = Event{} } func (m *Event) String() string { return proto.CompactTextString(m) } func (*Event) ProtoMessage() {} func (*Event) Descriptor() ([]byte, []int) { - return fileDescriptor_67a9cc666e46cd17, []int{21} + return fileDescriptor_api_3bcfee19e3d98590, []int{21} } func (m *Event) XXX_Unmarshal(b []byte) error { return xxx_messageInfo_Event.Unmarshal(m, b) @@ -1526,8 +1526,8 @@ func (m *Event) XXX_Unmarshal(b []byte) error { func (m *Event) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { return xxx_messageInfo_Event.Marshal(b, m, deterministic) } -func (m *Event) XXX_Merge(src proto.Message) { - xxx_messageInfo_Event.Merge(m, src) +func (dst *Event) XXX_Merge(src proto.Message) { + xxx_messageInfo_Event.Merge(dst, src) } func (m *Event) XXX_Size() int { return xxx_messageInfo_Event.Size(m) @@ -1582,7 +1582,7 @@ func (m *Task) Reset() { *m = Task{} } func (m *Task) String() string { return proto.CompactTextString(m) } func (*Task) ProtoMessage() {} func (*Task) Descriptor() ([]byte, []int) { - return fileDescriptor_67a9cc666e46cd17, []int{22} + return fileDescriptor_api_3bcfee19e3d98590, []int{22} } func (m *Task) XXX_Unmarshal(b []byte) error { return xxx_messageInfo_Task.Unmarshal(m, b) @@ -1590,8 +1590,8 @@ func (m *Task) XXX_Unmarshal(b []byte) error { func (m *Task) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { return xxx_messageInfo_Task.Marshal(b, m, deterministic) } -func (m *Task) XXX_Merge(src proto.Message) { - xxx_messageInfo_Task.Merge(m, src) +func (dst *Task) XXX_Merge(src proto.Message) { + xxx_messageInfo_Task.Merge(dst, src) } func (m *Task) XXX_Size() int { return xxx_messageInfo_Task.Size(m) @@ -1652,7 +1652,7 @@ func (m *Output) Reset() { *m = Output{} } func (m *Output) String() string { return proto.CompactTextString(m) } func (*Output) ProtoMessage() {} func (*Output) Descriptor() ([]byte, []int) { - return fileDescriptor_67a9cc666e46cd17, []int{23} + return fileDescriptor_api_3bcfee19e3d98590, []int{23} } func (m *Output) XXX_Unmarshal(b []byte) error { return xxx_messageInfo_Output.Unmarshal(m, b) @@ -1660,8 +1660,8 @@ func (m *Output) XXX_Unmarshal(b []byte) error { func (m *Output) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { return xxx_messageInfo_Output.Marshal(b, m, deterministic) } -func (m *Output) XXX_Merge(src proto.Message) { - xxx_messageInfo_Output.Merge(m, src) +func (dst *Output) XXX_Merge(src proto.Message) { + xxx_messageInfo_Output.Merge(dst, src) } func (m *Output) XXX_Size() int { return xxx_messageInfo_Output.Size(m) @@ -1716,7 +1716,7 @@ func (m *Parameter) Reset() { *m = Parameter{} } func (m *Parameter) String() string { return proto.CompactTextString(m) } func (*Parameter) ProtoMessage() {} func (*Parameter) Descriptor() ([]byte, []int) { - return fileDescriptor_67a9cc666e46cd17, []int{24} + return fileDescriptor_api_3bcfee19e3d98590, []int{24} } func (m *Parameter) XXX_Unmarshal(b []byte) error { return xxx_messageInfo_Parameter.Unmarshal(m, b) @@ -1724,8 +1724,8 @@ func (m *Parameter) XXX_Unmarshal(b []byte) error { func (m *Parameter) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { return xxx_messageInfo_Parameter.Marshal(b, m, deterministic) } -func (m *Parameter) XXX_Merge(src proto.Message) { - xxx_messageInfo_Parameter.Merge(m, src) +func (dst *Parameter) XXX_Merge(src proto.Message) { + xxx_messageInfo_Parameter.Merge(dst, src) } func (m *Parameter) XXX_Size() int { return xxx_messageInfo_Parameter.Size(m) @@ -1788,7 +1788,7 @@ func (m *Dependency) Reset() { *m = Dependency{} } func (m *Dependency) String() string { return proto.CompactTextString(m) } func (*Dependency) ProtoMessage() {} func (*Dependency) Descriptor() ([]byte, []int) { - return fileDescriptor_67a9cc666e46cd17, []int{25} + return fileDescriptor_api_3bcfee19e3d98590, []int{25} } func (m *Dependency) XXX_Unmarshal(b []byte) error { return xxx_messageInfo_Dependency.Unmarshal(m, b) @@ -1796,8 +1796,8 @@ func (m *Dependency) XXX_Unmarshal(b []byte) error { func (m *Dependency) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { return xxx_messageInfo_Dependency.Marshal(b, m, deterministic) } -func (m *Dependency) XXX_Merge(src proto.Message) { - xxx_messageInfo_Dependency.Merge(m, src) +func (dst *Dependency) XXX_Merge(src proto.Message) { + xxx_messageInfo_Dependency.Merge(dst, src) } func (m *Dependency) XXX_Size() int { return xxx_messageInfo_Dependency.Size(m) @@ -2386,83 +2386,85 @@ var _Core_serviceDesc = grpc.ServiceDesc{ } func init() { - proto.RegisterFile("github.com/mesg-foundation/core/protobuf/coreapi/api.proto", fileDescriptor_67a9cc666e46cd17) -} - -var fileDescriptor_67a9cc666e46cd17 = []byte{ - // 1183 bytes of a gzipped FileDescriptorProto - 0x1f, 0x8b, 0x08, 0x00, 0x00, 0x00, 0x00, 0x00, 0x02, 0xff, 0xbc, 0x57, 0xdf, 0x6f, 0xdc, 0x44, - 0x10, 0xb6, 0x73, 0xbf, 0xe7, 0xae, 0xe9, 0x65, 0x93, 0xb6, 0xe6, 0x04, 0x69, 0xb4, 0xd0, 0x2a, - 0x42, 0x22, 0x29, 0x97, 0x22, 0x4a, 0x45, 0x55, 0x29, 0xdc, 0xd1, 0x44, 0x8d, 0x52, 0xe4, 0x04, - 0x1e, 0x78, 0x73, 0xee, 0x36, 0x57, 0x2b, 0x3e, 0xaf, 0xb1, 0xd7, 0x11, 0xc7, 0x2b, 0xe2, 0x9d, - 0x17, 0xc4, 0x13, 0xa2, 0x7f, 0x00, 0x7f, 0x24, 0xda, 0xd9, 0xb5, 0xbd, 0x3e, 0x87, 0x92, 0x00, - 0xe2, 0xcd, 0xf3, 0xcd, 0xec, 0xec, 0xb7, 0xdf, 0xfe, 0x98, 0x31, 0x3c, 0x9d, 0xf9, 0xe2, 0x75, - 0x7a, 0xb6, 0x33, 0xe1, 0xf3, 0xdd, 0x39, 0x4b, 0x66, 0x1f, 0x9d, 0xf3, 0x34, 0x9c, 0x7a, 0xc2, - 0xe7, 0xe1, 0xee, 0x84, 0xc7, 0x6c, 0x37, 0x8a, 0xb9, 0xe0, 0x67, 0xe9, 0x39, 0x5a, 0x5e, 0xe4, - 0xef, 0x7a, 0x91, 0xbf, 0x83, 0x20, 0xa9, 0x79, 0x91, 0x4f, 0x4f, 0x81, 0x1c, 0xf9, 0x89, 0x60, - 0xe1, 0xf8, 0x92, 0x85, 0xc2, 0x65, 0xdf, 0xa5, 0x2c, 0x11, 0xe4, 0x5d, 0xe8, 0x24, 0x2c, 0xbe, - 0xf4, 0x27, 0xec, 0x70, 0xe4, 0xd8, 0x5b, 0xf6, 0x76, 0xc7, 0x2d, 0x00, 0xb2, 0x05, 0x5d, 0x26, - 0xa3, 0xbf, 0xf4, 0x03, 0xc1, 0x62, 0x67, 0x05, 0xfd, 0x26, 0x44, 0xc7, 0xd0, 0xc1, 0x7c, 0x23, - 0x4f, 0x78, 0x64, 0x00, 0x6d, 0xf4, 0xbd, 0x64, 0x0b, 0x9d, 0x2b, 0xb7, 0xe5, 0x44, 0x2c, 0x0b, - 0xd4, 0x89, 0x0a, 0x80, 0xfe, 0x6a, 0xc3, 0xba, 0x62, 0xe7, 0xb2, 0x24, 0x0d, 0xae, 0x49, 0x6f, - 0x13, 0x40, 0x78, 0xc9, 0x45, 0x89, 0x9d, 0x81, 0x10, 0x0a, 0x3d, 0x9e, 0x8a, 0x28, 0xcd, 0xf8, - 0xd7, 0x30, 0xa2, 0x84, 0xa9, 0x1c, 0x33, 0x65, 0x24, 0x4e, 0x7d, 0xab, 0xa6, 0x72, 0x64, 0x08, - 0xfd, 0xc3, 0x06, 0x50, 0x9c, 0x70, 0x89, 0x52, 0x91, 0xef, 0xd9, 0x24, 0x95, 0xba, 0xe7, 0x94, - 0x4c, 0x88, 0x38, 0xd0, 0x92, 0x14, 0xa4, 0x06, 0x8a, 0x51, 0x66, 0xca, 0xc5, 0xa8, 0xa9, 0xa5, - 0x4f, 0x71, 0x29, 0x00, 0x49, 0x44, 0x19, 0xa8, 0x50, 0x5d, 0x2d, 0xa6, 0x40, 0xc8, 0x07, 0x70, - 0x2b, 0x9f, 0xe6, 0xd4, 0x9b, 0x25, 0x4e, 0x03, 0xb9, 0x96, 0x41, 0xfa, 0xb3, 0x0d, 0x64, 0x8c, - 0x08, 0x3b, 0xf5, 0x92, 0x8b, 0xeb, 0xe9, 0xf8, 0x56, 0xca, 0x7e, 0x98, 0x71, 0xd2, 0x94, 0x73, - 0xa0, 0x4a, 0xa9, 0x7e, 0x15, 0xa5, 0xc7, 0xd0, 0x2f, 0x31, 0x8a, 0x82, 0xc5, 0xdf, 0xcb, 0x48, - 0xf7, 0x60, 0xfd, 0x44, 0x78, 0xb1, 0x38, 0x51, 0x2c, 0xaf, 0xb5, 0x10, 0xba, 0x0e, 0x6b, 0xe5, - 0x41, 0x51, 0xb0, 0xa0, 0x43, 0x20, 0x27, 0x82, 0x47, 0x37, 0x4a, 0x44, 0xa0, 0x5f, 0x1a, 0x23, - 0xf3, 0xbc, 0x84, 0x8d, 0x11, 0x8b, 0x02, 0xbe, 0x58, 0xca, 0x44, 0xa0, 0x96, 0xc6, 0x81, 0x52, - 0xee, 0xc0, 0x72, 0xa5, 0x41, 0xee, 0x42, 0x63, 0xf2, 0x3a, 0x0d, 0x2f, 0x50, 0xb3, 0xde, 0x81, - 0xe5, 0x2a, 0x73, 0xbf, 0x05, 0x8d, 0x4b, 0x2f, 0x48, 0x19, 0xfd, 0x7d, 0x05, 0xc8, 0x52, 0x36, - 0xa9, 0xcb, 0x13, 0x68, 0x26, 0xc2, 0x13, 0x69, 0x82, 0xe9, 0xba, 0xc3, 0xcd, 0x1d, 0x79, 0x8b, - 0xab, 0x81, 0x3b, 0x27, 0x18, 0x75, 0x60, 0xb9, 0x3a, 0x9e, 0x6c, 0x9a, 0xeb, 0xa9, 0x69, 0x2e, - 0xc6, 0x1e, 0x7f, 0x08, 0xb7, 0x2f, 0xbd, 0xc0, 0x57, 0x2f, 0xc6, 0x38, 0x8e, 0x79, 0xac, 0xce, - 0xd8, 0x81, 0xe5, 0x2e, 0x3b, 0x06, 0x3f, 0x40, 0x53, 0xe5, 0x97, 0x27, 0x63, 0xce, 0x92, 0xc4, - 0x9b, 0x31, 0xad, 0x51, 0x66, 0x92, 0x4f, 0xa1, 0x2e, 0x16, 0x11, 0x43, 0x9e, 0xab, 0xc3, 0xf7, - 0xdf, 0xce, 0x73, 0xe7, 0x74, 0x11, 0x31, 0x17, 0x07, 0xd0, 0xf7, 0xa0, 0x2e, 0x2d, 0xd2, 0x85, - 0x96, 0xfb, 0xf5, 0xf1, 0xf1, 0xe1, 0xf1, 0x8b, 0xbe, 0x45, 0xda, 0x50, 0x1f, 0xbd, 0x3a, 0x1e, - 0xf7, 0xed, 0x42, 0xa1, 0xc7, 0x52, 0xee, 0x80, 0x09, 0x76, 0xa3, 0x8d, 0xdb, 0x90, 0xb2, 0x96, - 0x46, 0xc9, 0xad, 0xbb, 0xa3, 0x5e, 0x17, 0x8d, 0x25, 0x3a, 0x15, 0x7d, 0x06, 0x6b, 0x65, 0x58, - 0x6e, 0xc1, 0x36, 0xb4, 0x75, 0xba, 0xc4, 0xb1, 0xb7, 0x6a, 0xdb, 0xdd, 0x61, 0x0f, 0x17, 0x97, - 0x25, 0xcc, 0xbd, 0xf4, 0x63, 0x58, 0x7b, 0xc1, 0x6e, 0x76, 0x40, 0x3f, 0x83, 0xdb, 0xe6, 0x10, - 0x39, 0xdf, 0x43, 0x68, 0x69, 0x3f, 0x86, 0x2f, 0x4f, 0x97, 0x39, 0xe9, 0x37, 0x40, 0x34, 0x76, - 0xc4, 0x67, 0xc9, 0xf5, 0x2e, 0x36, 0x85, 0xde, 0x94, 0x45, 0x2c, 0x9c, 0xb2, 0x70, 0xe2, 0x33, - 0x79, 0xa8, 0xe4, 0xfd, 0x2c, 0x61, 0xf4, 0x27, 0x1b, 0x5a, 0x47, 0x7c, 0x86, 0x17, 0x7a, 0x13, - 0x20, 0xf7, 0x65, 0x4f, 0xb8, 0x81, 0x90, 0x07, 0xa5, 0x4d, 0x5f, 0x43, 0xa2, 0x7a, 0xac, 0xb1, - 0xc5, 0x84, 0x40, 0x7d, 0x9a, 0x3d, 0x18, 0x3d, 0x17, 0xbf, 0xe9, 0x7d, 0xbd, 0xed, 0x3d, 0x68, - 0x9f, 0x08, 0x2f, 0x9c, 0x7a, 0xf1, 0xb4, 0x6f, 0x91, 0x0e, 0x34, 0xf0, 0xc8, 0xf5, 0x6d, 0xfa, - 0x66, 0x05, 0x5a, 0x7a, 0x81, 0x64, 0x15, 0x56, 0x0e, 0x47, 0x0e, 0xe0, 0xfc, 0x2b, 0x87, 0x23, - 0x99, 0x30, 0xf4, 0xe6, 0xd9, 0x19, 0xc4, 0x6f, 0xf9, 0x84, 0x4c, 0x59, 0x32, 0x89, 0xfd, 0x48, - 0x1e, 0xdc, 0xac, 0x36, 0x19, 0x10, 0xb9, 0x0f, 0x0d, 0xf9, 0x8e, 0xa9, 0x97, 0xb2, 0x3b, 0xec, - 0x20, 0x5d, 0x7c, 0x83, 0x14, 0x4e, 0x28, 0x34, 0xb1, 0x04, 0x25, 0x4e, 0x13, 0x23, 0x00, 0x23, - 0x54, 0x7d, 0xd4, 0x1e, 0xb2, 0xb7, 0x24, 0x61, 0x0b, 0x23, 0x6f, 0x67, 0xe7, 0x5d, 0x2b, 0x53, - 0xd6, 0x94, 0x7c, 0x02, 0xb7, 0x26, 0x3c, 0x3c, 0xf7, 0x67, 0x69, 0x8c, 0xd7, 0xca, 0x69, 0xe3, - 0xce, 0x56, 0x46, 0x95, 0xa3, 0xa4, 0xfc, 0x31, 0x8b, 0x78, 0xe2, 0x0b, 0x1e, 0x2f, 0x9c, 0x8e, - 0x92, 0xbf, 0x40, 0x68, 0x02, 0x0d, 0x24, 0x47, 0xfa, 0x50, 0xbb, 0x60, 0x0b, 0x5d, 0x24, 0xe4, - 0xe7, 0x3f, 0x54, 0x88, 0xe6, 0x1b, 0x25, 0x17, 0xb5, 0x8a, 0xf4, 0xbe, 0xf2, 0x62, 0x6f, 0xce, - 0x04, 0x8b, 0xf5, 0xc6, 0xfd, 0x66, 0x43, 0x5d, 0x8a, 0x96, 0x4d, 0xda, 0xfe, 0xb7, 0x93, 0x3e, - 0x84, 0x26, 0x96, 0x90, 0x4c, 0xf5, 0xe5, 0x69, 0xb5, 0x97, 0x3c, 0x80, 0x96, 0x2a, 0x7f, 0x99, - 0xe8, 0x5d, 0x0c, 0x7c, 0x85, 0x98, 0x9b, 0xf9, 0xa8, 0x80, 0xa6, 0x82, 0xfe, 0x57, 0x55, 0x7e, - 0xb4, 0xa1, 0x93, 0x63, 0xff, 0x99, 0x34, 0x44, 0xdf, 0x2f, 0x55, 0x69, 0xd5, 0x65, 0x1a, 0x40, - 0x9b, 0xa3, 0xd7, 0x0b, 0x70, 0x69, 0x6d, 0x37, 0xb7, 0xe9, 0x1b, 0x1b, 0xa0, 0x38, 0x4e, 0x57, - 0xd0, 0xd8, 0x80, 0x86, 0x3f, 0x2f, 0x5e, 0x6f, 0x65, 0xc8, 0x57, 0xfd, 0x92, 0x07, 0xe9, 0x3c, - 0x7f, 0x11, 0x32, 0x53, 0x52, 0xd4, 0x9f, 0xe7, 0x31, 0x9f, 0xa3, 0x02, 0x1d, 0xd7, 0x84, 0x64, - 0xc6, 0x88, 0xc7, 0x22, 0xab, 0xf5, 0xca, 0x90, 0x19, 0x27, 0x7c, 0x3e, 0xf7, 0xc2, 0xa9, 0xd3, - 0x50, 0x75, 0x42, 0x9b, 0xc3, 0x5f, 0x1a, 0x50, 0xff, 0x82, 0xc7, 0x8c, 0x3c, 0x85, 0xae, 0xd1, - 0x7f, 0x92, 0x7b, 0xea, 0xf1, 0xa8, 0x74, 0xa4, 0x83, 0xd5, 0xe2, 0x12, 0x62, 0x6b, 0x68, 0x3d, - 0xb2, 0xc9, 0x33, 0xe8, 0x99, 0xdd, 0x21, 0x71, 0x8c, 0xc1, 0xa5, 0x86, 0x71, 0xa0, 0xae, 0x58, - 0xd1, 0xb0, 0xe1, 0xf0, 0xe7, 0xd0, 0x35, 0x3a, 0x10, 0x3d, 0x75, 0xb5, 0x4b, 0x1a, 0xdc, 0xa9, - 0x3a, 0x64, 0xf5, 0xb0, 0xc8, 0x3e, 0xf4, 0xcc, 0xbe, 0x42, 0xcf, 0x7f, 0x45, 0x7f, 0x32, 0xb8, - 0x7b, 0x85, 0x47, 0xe5, 0x78, 0x0e, 0x5d, 0xa3, 0xa5, 0xd0, 0x24, 0xaa, 0x8d, 0x89, 0x26, 0x51, - 0xe9, 0x3e, 0x2c, 0x72, 0x08, 0xb7, 0x4a, 0x05, 0x96, 0xbc, 0x73, 0x55, 0xd1, 0x55, 0x49, 0xee, - 0xfd, 0x45, 0x3d, 0xa6, 0xd6, 0xb6, 0xfd, 0xc8, 0x26, 0x63, 0x99, 0xca, 0xa8, 0x92, 0x79, 0xaa, - 0x6a, 0xbd, 0xcd, 0x53, 0x55, 0x8a, 0x2a, 0xca, 0x62, 0xd6, 0x4f, 0x63, 0x5b, 0x96, 0x2a, 0xad, - 0x96, 0xa5, 0x52, 0x6c, 0xa9, 0x45, 0x3e, 0x07, 0x28, 0x2a, 0x22, 0x51, 0x71, 0x95, 0xaa, 0x3a, - 0xd8, 0xa8, 0xe0, 0x6a, 0xf4, 0x13, 0xe8, 0x1a, 0x45, 0x31, 0x13, 0xb5, 0x52, 0x26, 0x07, 0x3d, - 0xb3, 0x54, 0xc9, 0x33, 0xb1, 0xdf, 0xf9, 0xb6, 0xa5, 0x7f, 0x94, 0xce, 0x9a, 0xf8, 0x97, 0xb4, - 0xf7, 0x67, 0x00, 0x00, 0x00, 0xff, 0xff, 0x26, 0x86, 0x8d, 0x14, 0x63, 0x0d, 0x00, 0x00, + proto.RegisterFile("github.com/mesg-foundation/core/protobuf/coreapi/api.proto", fileDescriptor_api_3bcfee19e3d98590) +} + +var fileDescriptor_api_3bcfee19e3d98590 = []byte{ + // 1205 bytes of a gzipped FileDescriptorProto + 0x1f, 0x8b, 0x08, 0x00, 0x00, 0x00, 0x00, 0x00, 0x02, 0xff, 0xbc, 0x57, 0x5f, 0x6f, 0xdc, 0x44, + 0x10, 0x3f, 0xdf, 0xff, 0x9b, 0xbb, 0x24, 0x97, 0x4d, 0xda, 0x9a, 0x13, 0x4a, 0xa3, 0x85, 0x56, + 0x11, 0x12, 0x49, 0xb9, 0x14, 0xd1, 0x56, 0x54, 0x15, 0xe1, 0x8e, 0xe4, 0xd4, 0x28, 0xa9, 0x7c, + 0xa1, 0x0f, 0xbc, 0x20, 0xe7, 0x6e, 0x73, 0xb5, 0xe2, 0xb3, 0x8d, 0xbd, 0x8e, 0xb8, 0x67, 0xc4, + 0x3b, 0x2f, 0xc0, 0x13, 0x52, 0x3f, 0x00, 0x1f, 0x81, 0x0f, 0x87, 0x76, 0x76, 0x6d, 0xaf, 0xcf, + 0xa1, 0x24, 0x80, 0x78, 0xf3, 0xfc, 0x66, 0x76, 0xf6, 0xb7, 0xbf, 0xfd, 0x33, 0x63, 0x78, 0x36, + 0x73, 0xf8, 0x9b, 0xf8, 0x7c, 0x77, 0xe2, 0xcf, 0xf7, 0xe6, 0x2c, 0x9a, 0x7d, 0x7c, 0xe1, 0xc7, + 0xde, 0xd4, 0xe6, 0x8e, 0xef, 0xed, 0x4d, 0xfc, 0x90, 0xed, 0x05, 0xa1, 0xcf, 0xfd, 0xf3, 0xf8, + 0x02, 0x2d, 0x3b, 0x70, 0xf6, 0xec, 0xc0, 0xd9, 0x45, 0x90, 0x54, 0xec, 0xc0, 0xa1, 0x67, 0x40, + 0x8e, 0x9d, 0x88, 0x33, 0x6f, 0x78, 0xc5, 0x3c, 0x6e, 0xb1, 0xef, 0x62, 0x16, 0x71, 0xf2, 0x3e, + 0xb4, 0x22, 0x16, 0x5e, 0x39, 0x13, 0x36, 0x1a, 0x98, 0xc6, 0xb6, 0xb1, 0xd3, 0xb2, 0x32, 0x80, + 0x6c, 0x43, 0x9b, 0x89, 0xe8, 0xaf, 0x1c, 0x97, 0xb3, 0xd0, 0x2c, 0xa3, 0x5f, 0x87, 0xe8, 0x10, + 0x5a, 0x98, 0x6f, 0x60, 0x73, 0x9b, 0xf4, 0xa0, 0x89, 0xbe, 0x97, 0x6c, 0xa1, 0x72, 0xa5, 0xb6, + 0x98, 0x88, 0x25, 0x81, 0x2a, 0x51, 0x06, 0xd0, 0x5f, 0x0d, 0xd8, 0x90, 0xec, 0x2c, 0x16, 0xc5, + 0xee, 0x0d, 0xe9, 0x6d, 0x01, 0x70, 0x3b, 0xba, 0xcc, 0xb1, 0xd3, 0x10, 0x42, 0xa1, 0xe3, 0xc7, + 0x3c, 0x88, 0x13, 0xfe, 0x15, 0x8c, 0xc8, 0x61, 0x32, 0xc7, 0x4c, 0x1a, 0x91, 0x59, 0xdd, 0xae, + 0xc8, 0x1c, 0x09, 0x42, 0x7f, 0x37, 0x00, 0x24, 0x27, 0x5c, 0xa2, 0x50, 0xe4, 0x7b, 0x36, 0x89, + 0x85, 0xee, 0x29, 0x25, 0x1d, 0x22, 0x26, 0x34, 0x04, 0x05, 0xa1, 0x81, 0x64, 0x94, 0x98, 0x62, + 0x31, 0x72, 0x6a, 0xe1, 0x93, 0x5c, 0x32, 0x40, 0x10, 0x91, 0x06, 0x2a, 0x54, 0x95, 0x8b, 0xc9, + 0x10, 0xf2, 0x21, 0xac, 0xa4, 0xd3, 0x9c, 0xd9, 0xb3, 0xc8, 0xac, 0x21, 0xd7, 0x3c, 0x48, 0x7f, + 0x32, 0x80, 0x0c, 0x11, 0x61, 0x67, 0x76, 0x74, 0x79, 0x33, 0x1d, 0xdf, 0x49, 0xd9, 0xf1, 0x12, + 0x4e, 0x8a, 0x72, 0x0a, 0x14, 0x29, 0x55, 0xaf, 0xa3, 0xf4, 0x18, 0xba, 0x39, 0x46, 0x81, 0xbb, + 0xf8, 0x7b, 0x19, 0xe9, 0x3e, 0x6c, 0x8c, 0xb9, 0x1d, 0xf2, 0xb1, 0x64, 0x79, 0xa3, 0x85, 0xd0, + 0x0d, 0x58, 0xcf, 0x0f, 0x0a, 0xdc, 0x05, 0xed, 0x03, 0x19, 0x73, 0x3f, 0xb8, 0x55, 0x22, 0x02, + 0xdd, 0xdc, 0x18, 0x91, 0xe7, 0x25, 0x6c, 0x0e, 0x58, 0xe0, 0xfa, 0x8b, 0xa5, 0x4c, 0x04, 0x2a, + 0x71, 0xe8, 0x4a, 0xe5, 0x8e, 0x4a, 0x96, 0x30, 0xc8, 0x5d, 0xa8, 0x4d, 0xde, 0xc4, 0xde, 0x25, + 0x6a, 0xd6, 0x39, 0x2a, 0x59, 0xd2, 0x3c, 0x68, 0x40, 0xed, 0xca, 0x76, 0x63, 0x46, 0xff, 0x28, + 0x03, 0x59, 0xca, 0x26, 0x74, 0x79, 0x02, 0xf5, 0x88, 0xdb, 0x3c, 0x8e, 0x30, 0x5d, 0xbb, 0xbf, + 0xb5, 0x2b, 0x6e, 0x71, 0x31, 0x70, 0x77, 0x8c, 0x51, 0x47, 0x25, 0x4b, 0xc5, 0x93, 0x2d, 0x7d, + 0x3d, 0x15, 0xc5, 0x45, 0xdb, 0xe3, 0x8f, 0x60, 0xed, 0xca, 0x76, 0x1d, 0xf9, 0x62, 0x0c, 0xc3, + 0xd0, 0x0f, 0xe5, 0x19, 0x3b, 0x2a, 0x59, 0xcb, 0x8e, 0xde, 0x2f, 0x06, 0xd4, 0xe5, 0x04, 0xe2, + 0x68, 0xcc, 0x59, 0x14, 0xd9, 0x33, 0xa6, 0x44, 0x4a, 0x4c, 0xf2, 0x19, 0x54, 0xf9, 0x22, 0x60, + 0x48, 0x74, 0xb5, 0xff, 0xc1, 0xbb, 0x89, 0xee, 0x9e, 0x2d, 0x02, 0x66, 0xe1, 0x00, 0xfa, 0x14, + 0xaa, 0xc2, 0x22, 0x6d, 0x68, 0x58, 0x5f, 0x9f, 0x9c, 0x8c, 0x4e, 0x0e, 0xbb, 0x25, 0xb2, 0x0e, + 0x2b, 0x83, 0xd3, 0x93, 0xe1, 0xb7, 0xaf, 0x4e, 0xc7, 0xa3, 0xb3, 0xd1, 0xeb, 0x61, 0xd7, 0x48, + 0xa1, 0x93, 0xe1, 0xe1, 0x17, 0x08, 0x95, 0x33, 0xf9, 0x1e, 0x8b, 0xbd, 0x70, 0x19, 0x67, 0xb7, + 0xda, 0xd5, 0x4d, 0xa1, 0x79, 0x6e, 0x94, 0xd8, 0xd7, 0x3b, 0xf2, 0xe9, 0x51, 0x58, 0xa4, 0x52, + 0xd1, 0xe7, 0xb0, 0x9e, 0x87, 0xc5, 0xfe, 0xec, 0x40, 0x53, 0xa5, 0x8b, 0x4c, 0x63, 0xbb, 0xb2, + 0xd3, 0xee, 0x77, 0x70, 0xe1, 0x49, 0xc2, 0xd4, 0x4b, 0x3f, 0x81, 0xf5, 0x43, 0x76, 0xbb, 0xd3, + 0xfb, 0x14, 0xd6, 0xf4, 0x21, 0x62, 0xbe, 0x87, 0xd0, 0x50, 0x7e, 0x0c, 0x5f, 0x9e, 0x2e, 0x71, + 0xd2, 0xd7, 0x40, 0x14, 0x76, 0xec, 0xcf, 0xa2, 0x9b, 0xdd, 0x7a, 0x0a, 0x9d, 0x29, 0x0b, 0x98, + 0x37, 0x65, 0xde, 0xc4, 0x61, 0xe2, 0xc4, 0x89, 0xcb, 0x9b, 0xc3, 0xe8, 0x8f, 0x06, 0x34, 0x8e, + 0xfd, 0x19, 0xde, 0xf6, 0x2d, 0x80, 0xd4, 0x97, 0xbc, 0xef, 0x1a, 0x42, 0x1e, 0xe4, 0x0e, 0xc4, + 0x3a, 0x12, 0x55, 0x63, 0xb5, 0xed, 0x27, 0x04, 0xaa, 0xd3, 0xe4, 0x35, 0xe9, 0x58, 0xf8, 0x4d, + 0xef, 0xab, 0x23, 0xd1, 0x81, 0xe6, 0x98, 0xdb, 0xde, 0xd4, 0x0e, 0xa7, 0xdd, 0x12, 0x69, 0x41, + 0x0d, 0xcf, 0x63, 0xd7, 0xa0, 0x6f, 0xcb, 0xd0, 0x50, 0x0b, 0x24, 0xab, 0x50, 0x1e, 0x0d, 0x4c, + 0xc0, 0xf9, 0xcb, 0xa3, 0x81, 0x48, 0xe8, 0xd9, 0xf3, 0xe4, 0x7c, 0xe2, 0xb7, 0x78, 0x5f, 0xa6, + 0x2c, 0x9a, 0x84, 0x4e, 0x20, 0x4e, 0x75, 0x52, 0xb8, 0x34, 0x88, 0xdc, 0x87, 0x9a, 0x78, 0xe4, + 0xe4, 0x33, 0xda, 0xee, 0xb7, 0x90, 0x2e, 0x3e, 0x50, 0x12, 0x27, 0x14, 0xea, 0x58, 0x9f, 0x22, + 0xb3, 0x8e, 0x11, 0x80, 0x11, 0xb2, 0x78, 0x2a, 0x0f, 0xd9, 0x5f, 0x92, 0xb0, 0x81, 0x91, 0x6b, + 0xc9, 0x5d, 0x50, 0xca, 0xe4, 0x35, 0x25, 0x9f, 0xc2, 0xca, 0xc4, 0xf7, 0x2e, 0x9c, 0x59, 0x1c, + 0xe2, 0x9d, 0x33, 0x9b, 0xb8, 0xb3, 0x85, 0x51, 0xf9, 0x28, 0x21, 0x7f, 0xc8, 0x02, 0x3f, 0x72, + 0xb8, 0x1f, 0x2e, 0xcc, 0x96, 0x94, 0x3f, 0x43, 0x68, 0x04, 0x35, 0x24, 0x47, 0xba, 0x50, 0xb9, + 0x64, 0x0b, 0x55, 0x41, 0xc4, 0xe7, 0x3f, 0x54, 0x88, 0xa6, 0x1b, 0x25, 0x16, 0xb5, 0x8a, 0xf4, + 0x5e, 0xd9, 0xa1, 0x3d, 0x67, 0x9c, 0x85, 0x6a, 0xe3, 0x7e, 0x33, 0xa0, 0x2a, 0x44, 0x4b, 0x26, + 0x6d, 0xfe, 0xdb, 0x49, 0x1f, 0x42, 0x1d, 0xeb, 0x4b, 0xa2, 0xfa, 0xf2, 0xb4, 0xca, 0x4b, 0x1e, + 0x40, 0x43, 0xd6, 0xc6, 0x44, 0xf4, 0x36, 0x06, 0x9e, 0x22, 0x66, 0x25, 0x3e, 0xca, 0xa1, 0x2e, + 0xa1, 0xff, 0x55, 0x95, 0x1f, 0x0c, 0x68, 0xa5, 0xd8, 0x7f, 0x26, 0x0d, 0x51, 0xf7, 0x4b, 0x96, + 0x61, 0x79, 0x99, 0x7a, 0xd0, 0xf4, 0xd1, 0x6b, 0xbb, 0xb8, 0xb4, 0xa6, 0x95, 0xda, 0xf4, 0xad, + 0x01, 0x90, 0x1d, 0xa7, 0x6b, 0x68, 0x6c, 0x42, 0xcd, 0x99, 0x67, 0x2f, 0xbb, 0x34, 0xc4, 0x8b, + 0x7f, 0xe5, 0xbb, 0xf1, 0x3c, 0x7d, 0x11, 0x12, 0x53, 0x50, 0x54, 0x9f, 0x17, 0xa1, 0x3f, 0x47, + 0x05, 0x5a, 0x96, 0x0e, 0x89, 0x8c, 0x81, 0x1f, 0xf2, 0xa4, 0x11, 0x90, 0x86, 0xc8, 0x38, 0xf1, + 0xe7, 0x73, 0xdb, 0x9b, 0x9a, 0x35, 0x59, 0x43, 0x94, 0xd9, 0xff, 0xb9, 0x06, 0xd5, 0x2f, 0xfd, + 0x90, 0x91, 0x67, 0xd0, 0xd6, 0x9a, 0x53, 0x72, 0x4f, 0x3e, 0x1e, 0x85, 0x76, 0xb5, 0xb7, 0x9a, + 0x5d, 0x42, 0xec, 0x1b, 0x4b, 0x8f, 0x0c, 0xf2, 0x1c, 0x3a, 0x7a, 0xeb, 0x48, 0x4c, 0x6d, 0x70, + 0xae, 0x9b, 0xec, 0xc9, 0x2b, 0x96, 0x75, 0x73, 0x38, 0xfc, 0x05, 0xb4, 0xb5, 0xf6, 0x44, 0x4d, + 0x5d, 0x6c, 0xa1, 0x7a, 0x77, 0x8a, 0x0e, 0x51, 0x3d, 0x4a, 0xe4, 0x00, 0x3a, 0x7a, 0xd3, 0xa1, + 0xe6, 0xbf, 0xa6, 0x79, 0xe9, 0xdd, 0xbd, 0xc6, 0x23, 0x73, 0xbc, 0x80, 0xb6, 0xd6, 0x6f, 0x28, + 0x12, 0xc5, 0xae, 0x45, 0x91, 0x28, 0xb4, 0x26, 0x25, 0x32, 0x82, 0x95, 0x5c, 0xf1, 0x25, 0xef, + 0x5d, 0x57, 0x90, 0x65, 0x92, 0x7b, 0x7f, 0x51, 0xab, 0x69, 0x69, 0xc7, 0x78, 0x64, 0x90, 0xa1, + 0x48, 0xa5, 0x55, 0xc9, 0x34, 0x55, 0xb1, 0xde, 0xa6, 0xa9, 0x0a, 0x45, 0x15, 0x65, 0xd1, 0xeb, + 0xa7, 0xb6, 0x2d, 0x4b, 0x95, 0x56, 0xc9, 0x52, 0x28, 0xb6, 0xb4, 0x44, 0x3e, 0x07, 0xc8, 0x2a, + 0x22, 0x91, 0x71, 0x85, 0xaa, 0xda, 0xdb, 0x2c, 0xe0, 0x72, 0xf4, 0x13, 0x68, 0x6b, 0x45, 0x31, + 0x11, 0xb5, 0x50, 0x26, 0x7b, 0x1d, 0xbd, 0x54, 0x89, 0x33, 0x71, 0xd0, 0xfa, 0xa6, 0xa1, 0xfe, + 0xa2, 0xce, 0xeb, 0xf8, 0x0b, 0xb5, 0xff, 0x67, 0x00, 0x00, 0x00, 0xff, 0xff, 0xc9, 0x06, 0x2b, + 0xee, 0x80, 0x0d, 0x00, 0x00, } diff --git a/protobuf/coreapi/api.proto b/protobuf/coreapi/api.proto index c1d11f375..dbff31f5f 100644 --- a/protobuf/coreapi/api.proto +++ b/protobuf/coreapi/api.proto @@ -226,11 +226,14 @@ message DeployServiceRequest { message DeployServiceReply { message Status { enum Type { - // RUNNING indicates that status message belongs to an active state. + // RUNNING indicates that status message belongs to a continuous state. RUNNING = 0; - // DONE indicates that status message belongs to completed state. - DONE = 1; + // DONE_POSITIVE indicates that status message belongs to a positive noncontinuous state. + DONE_POSITIVE = 1; + + // DONE_NEGATIVE indicates that status message belongs to a negative noncontinuous state. + DONE_NEGATIVE = 2; } // message is status message. diff --git a/protobuf/serviceapi/api.pb.go b/protobuf/serviceapi/api.pb.go index 8bc68638f..abc37f0ea 100644 --- a/protobuf/serviceapi/api.pb.go +++ b/protobuf/serviceapi/api.pb.go @@ -46,7 +46,7 @@ func (m *EmitEventRequest) Reset() { *m = EmitEventRequest{} } func (m *EmitEventRequest) String() string { return proto.CompactTextString(m) } func (*EmitEventRequest) ProtoMessage() {} func (*EmitEventRequest) Descriptor() ([]byte, []int) { - return fileDescriptor_2e0fe40fa06c912d, []int{0} + return fileDescriptor_api_7368b4573047168d, []int{0} } func (m *EmitEventRequest) XXX_Unmarshal(b []byte) error { return xxx_messageInfo_EmitEventRequest.Unmarshal(m, b) @@ -54,8 +54,8 @@ func (m *EmitEventRequest) XXX_Unmarshal(b []byte) error { func (m *EmitEventRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { return xxx_messageInfo_EmitEventRequest.Marshal(b, m, deterministic) } -func (m *EmitEventRequest) XXX_Merge(src proto.Message) { - xxx_messageInfo_EmitEventRequest.Merge(m, src) +func (dst *EmitEventRequest) XXX_Merge(src proto.Message) { + xxx_messageInfo_EmitEventRequest.Merge(dst, src) } func (m *EmitEventRequest) XXX_Size() int { return xxx_messageInfo_EmitEventRequest.Size(m) @@ -98,7 +98,7 @@ func (m *EmitEventReply) Reset() { *m = EmitEventReply{} } func (m *EmitEventReply) String() string { return proto.CompactTextString(m) } func (*EmitEventReply) ProtoMessage() {} func (*EmitEventReply) Descriptor() ([]byte, []int) { - return fileDescriptor_2e0fe40fa06c912d, []int{1} + return fileDescriptor_api_7368b4573047168d, []int{1} } func (m *EmitEventReply) XXX_Unmarshal(b []byte) error { return xxx_messageInfo_EmitEventReply.Unmarshal(m, b) @@ -106,8 +106,8 @@ func (m *EmitEventReply) XXX_Unmarshal(b []byte) error { func (m *EmitEventReply) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { return xxx_messageInfo_EmitEventReply.Marshal(b, m, deterministic) } -func (m *EmitEventReply) XXX_Merge(src proto.Message) { - xxx_messageInfo_EmitEventReply.Merge(m, src) +func (dst *EmitEventReply) XXX_Merge(src proto.Message) { + xxx_messageInfo_EmitEventReply.Merge(dst, src) } func (m *EmitEventReply) XXX_Size() int { return xxx_messageInfo_EmitEventReply.Size(m) @@ -137,7 +137,7 @@ func (m *ListenTaskRequest) Reset() { *m = ListenTaskRequest{} } func (m *ListenTaskRequest) String() string { return proto.CompactTextString(m) } func (*ListenTaskRequest) ProtoMessage() {} func (*ListenTaskRequest) Descriptor() ([]byte, []int) { - return fileDescriptor_2e0fe40fa06c912d, []int{2} + return fileDescriptor_api_7368b4573047168d, []int{2} } func (m *ListenTaskRequest) XXX_Unmarshal(b []byte) error { return xxx_messageInfo_ListenTaskRequest.Unmarshal(m, b) @@ -145,8 +145,8 @@ func (m *ListenTaskRequest) XXX_Unmarshal(b []byte) error { func (m *ListenTaskRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { return xxx_messageInfo_ListenTaskRequest.Marshal(b, m, deterministic) } -func (m *ListenTaskRequest) XXX_Merge(src proto.Message) { - xxx_messageInfo_ListenTaskRequest.Merge(m, src) +func (dst *ListenTaskRequest) XXX_Merge(src proto.Message) { + xxx_messageInfo_ListenTaskRequest.Merge(dst, src) } func (m *ListenTaskRequest) XXX_Size() int { return xxx_messageInfo_ListenTaskRequest.Size(m) @@ -189,7 +189,7 @@ func (m *TaskData) Reset() { *m = TaskData{} } func (m *TaskData) String() string { return proto.CompactTextString(m) } func (*TaskData) ProtoMessage() {} func (*TaskData) Descriptor() ([]byte, []int) { - return fileDescriptor_2e0fe40fa06c912d, []int{3} + return fileDescriptor_api_7368b4573047168d, []int{3} } func (m *TaskData) XXX_Unmarshal(b []byte) error { return xxx_messageInfo_TaskData.Unmarshal(m, b) @@ -197,8 +197,8 @@ func (m *TaskData) XXX_Unmarshal(b []byte) error { func (m *TaskData) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { return xxx_messageInfo_TaskData.Marshal(b, m, deterministic) } -func (m *TaskData) XXX_Merge(src proto.Message) { - xxx_messageInfo_TaskData.Merge(m, src) +func (dst *TaskData) XXX_Merge(src proto.Message) { + xxx_messageInfo_TaskData.Merge(dst, src) } func (m *TaskData) XXX_Size() int { return xxx_messageInfo_TaskData.Size(m) @@ -254,7 +254,7 @@ func (m *SubmitResultRequest) Reset() { *m = SubmitResultRequest{} } func (m *SubmitResultRequest) String() string { return proto.CompactTextString(m) } func (*SubmitResultRequest) ProtoMessage() {} func (*SubmitResultRequest) Descriptor() ([]byte, []int) { - return fileDescriptor_2e0fe40fa06c912d, []int{4} + return fileDescriptor_api_7368b4573047168d, []int{4} } func (m *SubmitResultRequest) XXX_Unmarshal(b []byte) error { return xxx_messageInfo_SubmitResultRequest.Unmarshal(m, b) @@ -262,8 +262,8 @@ func (m *SubmitResultRequest) XXX_Unmarshal(b []byte) error { func (m *SubmitResultRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { return xxx_messageInfo_SubmitResultRequest.Marshal(b, m, deterministic) } -func (m *SubmitResultRequest) XXX_Merge(src proto.Message) { - xxx_messageInfo_SubmitResultRequest.Merge(m, src) +func (dst *SubmitResultRequest) XXX_Merge(src proto.Message) { + xxx_messageInfo_SubmitResultRequest.Merge(dst, src) } func (m *SubmitResultRequest) XXX_Size() int { return xxx_messageInfo_SubmitResultRequest.Size(m) @@ -306,7 +306,7 @@ func (m *SubmitResultReply) Reset() { *m = SubmitResultReply{} } func (m *SubmitResultReply) String() string { return proto.CompactTextString(m) } func (*SubmitResultReply) ProtoMessage() {} func (*SubmitResultReply) Descriptor() ([]byte, []int) { - return fileDescriptor_2e0fe40fa06c912d, []int{5} + return fileDescriptor_api_7368b4573047168d, []int{5} } func (m *SubmitResultReply) XXX_Unmarshal(b []byte) error { return xxx_messageInfo_SubmitResultReply.Unmarshal(m, b) @@ -314,8 +314,8 @@ func (m *SubmitResultReply) XXX_Unmarshal(b []byte) error { func (m *SubmitResultReply) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { return xxx_messageInfo_SubmitResultReply.Marshal(b, m, deterministic) } -func (m *SubmitResultReply) XXX_Merge(src proto.Message) { - xxx_messageInfo_SubmitResultReply.Merge(m, src) +func (dst *SubmitResultReply) XXX_Merge(src proto.Message) { + xxx_messageInfo_SubmitResultReply.Merge(dst, src) } func (m *SubmitResultReply) XXX_Size() int { return xxx_messageInfo_SubmitResultReply.Size(m) @@ -514,10 +514,10 @@ var _Service_serviceDesc = grpc.ServiceDesc{ } func init() { - proto.RegisterFile("github.com/mesg-foundation/core/protobuf/serviceapi/api.proto", fileDescriptor_2e0fe40fa06c912d) + proto.RegisterFile("github.com/mesg-foundation/core/protobuf/serviceapi/api.proto", fileDescriptor_api_7368b4573047168d) } -var fileDescriptor_2e0fe40fa06c912d = []byte{ +var fileDescriptor_api_7368b4573047168d = []byte{ // 346 bytes of a gzipped FileDescriptorProto 0x1f, 0x8b, 0x08, 0x00, 0x00, 0x00, 0x00, 0x00, 0x02, 0xff, 0x84, 0x92, 0x41, 0x4f, 0xc2, 0x40, 0x10, 0x85, 0xa9, 0x44, 0xa1, 0x23, 0x1a, 0x58, 0x94, 0x34, 0x0d, 0x31, 0xa4, 0x27, 0x3d, 0x48, diff --git a/service/service.go b/service/service.go index 047d39ed3..b5a395911 100644 --- a/service/service.go +++ b/service/service.go @@ -11,7 +11,6 @@ import ( "github.com/cnf/structhash" "github.com/docker/docker/pkg/archive" - "github.com/logrusorgru/aurora" "github.com/mesg-foundation/core/container" "github.com/mesg-foundation/core/service/importer" uuid "github.com/satori/go.uuid" @@ -71,11 +70,14 @@ type DStatusType int const ( _ DStatusType = iota // skip zero value. - // DRUNNING indicates that status message belongs to an active state. - DRUNNING + // DRunning indicates that status message belongs to a continuous state. + DRunning - // DDONE indicates that status message belongs to completed state. - DDONE + // DDonePositive indicates that status message belongs to a positive noncontinuous state. + DDonePositive + + // DDoneNegative indicates that status message belongs to a negative noncontinuous state. + DDoneNegative ) // DeployStatus represents the deployment status. @@ -181,8 +183,8 @@ func (s *Service) saveContext(r io.Reader) error { return err } - s.sendStatus("Receiving service context...", DRUNNING) - defer s.sendStatus(fmt.Sprintf("%s Service context received with success.", aurora.Green("✔")), DDONE) + s.sendStatus("Receiving service context...", DRunning) + defer s.sendStatus("Service context received with success.", DDonePositive) return archive.Untar(r, s.tempPath, &archive.TarOptions{ Compression: archive.Gzip, @@ -203,15 +205,15 @@ func (s *Service) deploy() error { defer s.removeTempDir() defer s.closeStatusSend() - s.sendStatus("Building Docker image...", DRUNNING) + s.sendStatus("Building Docker image...", DRunning) imageHash, err := s.docker.Build(s.tempPath) if err != nil { return err } - s.sendStatus(fmt.Sprintf("%s Image built with success.", aurora.Green("✔")), DDONE) - s.sendStatus(fmt.Sprintf("%s Service deployed.", aurora.Green("✔")), DDONE) + s.sendStatus("Image built with success.", DDonePositive) + s.sendStatus("Service deployed.", DDonePositive) s.configuration.Key = "service" s.configuration.Image = imageHash @@ -223,8 +225,7 @@ func (s *Service) deploy() error { func (s *Service) checkDeprecations() error { if _, err := os.Stat(filepath.Join(s.tempPath, ".mesgignore")); err == nil { // TODO: remove for a future release - s.sendStatus(fmt.Sprintf("%s [DEPRECATED] Please use .dockerignore instead of .mesgignore", - aurora.Red("⨯")), DDONE) + s.sendStatus("[DEPRECATED] Please use .dockerignore instead of .mesgignore", DDoneNegative) } return nil }