Skip to content

Commit

Permalink
Adding proto changes compatible to gauge 0.8.0
Browse files Browse the repository at this point in the history
  • Loading branch information
apoorvam committed Feb 17, 2017
1 parent 734c832 commit 7e46971
Show file tree
Hide file tree
Showing 27 changed files with 1,476 additions and 1,440 deletions.
2 changes: 1 addition & 1 deletion gauge-proto
Submodule gauge-proto updated 4 files
+88 −79 api.proto
+45 −19 api_v2.proto
+67 −66 messages.proto
+128 −91 spec.proto
32 changes: 16 additions & 16 deletions gauge/runner.go
Original file line number Diff line number Diff line change
Expand Up @@ -29,20 +29,20 @@ func init() {
}

processors = mp.ProcessorDictionary{}
processors[*m.Message_StepNamesRequest.Enum()] = &mp.StepNamesRequestProcessor{}
processors[*m.Message_StepValidateRequest.Enum()] = &mp.StepValidateRequestProcessor{}
processors[*m.Message_SuiteDataStoreInit.Enum()] = &mp.SuiteDataStoreInitRequestProcessor{}
processors[*m.Message_ExecutionStarting.Enum()] = &mp.ExecutionStartingRequestProcessor{}
processors[*m.Message_SpecExecutionStarting.Enum()] = &mp.SpecExecutionStartingRequestProcessor{}
processors[*m.Message_ScenarioExecutionStarting.Enum()] = &mp.ScenarioExecutionStartingRequestProcessor{}
processors[*m.Message_StepExecutionStarting.Enum()] = &mp.StepExecutionStartingRequestProcessor{}
processors[*m.Message_ExecuteStep.Enum()] = &mp.ExecuteStepProcessor{}
processors[*m.Message_ExecutionEnding.Enum()] = &mp.ExecutionEndingProcessor{}
processors[*m.Message_StepExecutionEnding.Enum()] = &mp.StepExecutionEndingProcessor{}
processors[*m.Message_ScenarioExecutionEnding.Enum()] = &mp.ScenarioExecutionEndingProcessor{}
processors[*m.Message_SpecExecutionEnding.Enum()] = &mp.SpecExecutionEndingProcessor{}
processors[*m.Message_SpecDataStoreInit.Enum()] = &mp.SpecDataStoreInitProcessor{}
processors[*m.Message_ScenarioDataStoreInit.Enum()] = &mp.ScenarioDataStoreInitProcessor{}
processors[m.Message_StepNamesRequest] = &mp.StepNamesRequestProcessor{}
processors[m.Message_StepValidateRequest] = &mp.StepValidateRequestProcessor{}
processors[m.Message_SuiteDataStoreInit] = &mp.SuiteDataStoreInitRequestProcessor{}
processors[m.Message_ExecutionStarting] = &mp.ExecutionStartingRequestProcessor{}
processors[m.Message_SpecExecutionStarting] = &mp.SpecExecutionStartingRequestProcessor{}
processors[m.Message_ScenarioExecutionStarting] = &mp.ScenarioExecutionStartingRequestProcessor{}
processors[m.Message_StepExecutionStarting] = &mp.StepExecutionStartingRequestProcessor{}
processors[m.Message_ExecuteStep] = &mp.ExecuteStepProcessor{}
processors[m.Message_ExecutionEnding] = &mp.ExecutionEndingProcessor{}
processors[m.Message_StepExecutionEnding] = &mp.StepExecutionEndingProcessor{}
processors[m.Message_ScenarioExecutionEnding] = &mp.ScenarioExecutionEndingProcessor{}
processors[m.Message_SpecExecutionEnding] = &mp.SpecExecutionEndingProcessor{}
processors[m.Message_SpecDataStoreInit] = &mp.SpecDataStoreInitProcessor{}
processors[m.Message_ScenarioDataStoreInit] = &mp.ScenarioDataStoreInitProcessor{}

t.CustomScreenShot = &CustomScreenshotFn
}
Expand Down Expand Up @@ -206,11 +206,11 @@ func Run() {
fmt.Println("Error reading message : ", err)
return
}
if *msg.MessageType.Enum() == *m.Message_KillProcessRequest.Enum() {
if msg.MessageType == m.Message_KillProcessRequest {
return
}

processor := processors[*msg.MessageType.Enum()]
processor := processors[msg.MessageType]

if processor == nil {
fmt.Println("Unable to find processor for message type : ", msg.MessageType)
Expand Down
Loading

0 comments on commit 7e46971

Please sign in to comment.