Raising missing events #1741

execution/parallelGrpcExecution.go

@@ -57,15 +57,16 @@ func (e *parallelExecution) notifyBeforeSuite() {
 			CurrentExecutionInfo: &gauge_messages.ExecutionInfo{},
 			Stream:               1},
 	}
-	res := e.runners[0].ExecuteAndGetStatus(m)
 	e.pluginHandler.NotifyPlugins(m)
+	res := e.runners[0].ExecuteAndGetStatus(m)
 	e.suiteResult.PreHookMessages = res.Message
 	e.suiteResult.PreHookScreenshotFiles = res.ScreenshotFiles
 	e.suiteResult.PreHookScreenshots = res.Screenshots
 	if res.GetFailed() {
 		result.AddPreHook(e.suiteResult, res)
 	}
 	m.ExecutionStartingRequest.SuiteResult = gauge.ConvertToProtoSuiteResult(e.suiteResult)
+	e.pluginHandler.NotifyPlugins(m)
 }
 
 func (e *parallelExecution) notifyAfterSuite() {
@@ -75,13 +76,14 @@ func (e *parallelExecution) notifyAfterSuite() {
 			Stream:               1,
 		},
 	}
-	res := e.runners[0].ExecuteAndGetStatus(m)
 	e.pluginHandler.NotifyPlugins(m)
+	res := e.runners[0].ExecuteAndGetStatus(m)
 	e.suiteResult.PostHookMessages = res.Message
 	e.suiteResult.PostHookScreenshotFiles = res.ScreenshotFiles
 	e.suiteResult.PostHookScreenshots = res.Screenshots
 	if res.GetFailed() {
 		result.AddPostHook(e.suiteResult, res)
 	}
 	m.ExecutionEndingRequest.SuiteResult = gauge.ConvertToProtoSuiteResult(e.suiteResult)
+	e.pluginHandler.NotifyPlugins(m)
 }

execution/parallelGrpcExecution_test.go

@@ -19,16 +19,20 @@ import (
 
 func TestSuiteHooksAreExecutedOncePerRun(t *testing.T) {
 	specs := createSpecsList(6)
+	var recievedMesseges []*gauge_messages.Message
 	runner1 := &fakeGrpcRunner{messageCount: make(map[gauge_messages.Message_MessageType]int)}
 	runner2 := &fakeGrpcRunner{messageCount: make(map[gauge_messages.Message_MessageType]int)}
 	e := parallelExecution{
 		numberOfExecutionStreams: 5,
 		specCollection:           gauge.NewSpecCollection(specs, false),
 		runners:                  []runner.Runner{runner1, runner2},
-		pluginHandler:            &mockPluginHandler{NotifyPluginsfunc: func(m *gauge_messages.Message) {}},
+		pluginHandler: &mockPluginHandler{NotifyPluginsfunc: func(m *gauge_messages.Message) {
+			recievedMesseges = append(recievedMesseges, m)
+		}},
 	}
 
 	t.Run("BeforeSuite", func(t *testing.T) {
+		recievedMesseges = []*gauge_messages.Message{}
 		e.suiteResult = result.NewSuiteResult("", time.Now())
 		runner1.mockResult = &gauge_messages.ProtoExecutionResult{}
 		e.notifyBeforeSuite()
@@ -40,9 +44,13 @@ func TestSuiteHooksAreExecutedOncePerRun(t *testing.T) {
 		if r2count != 0 {
 			t.Errorf("Expected runner2 to have received 0 ExecutionStarting request, got %d", r2count)
 		}
+		if len(recievedMesseges) != 2 {
+			t.Errorf("Expected plugins to have received 2 ExecutionStarting notifications, got %d", len(recievedMesseges))
+		}
 	})
 
 	t.Run("AfterSuite", func(t *testing.T) {
+		recievedMesseges = []*gauge_messages.Message{}
 		e.notifyAfterSuite()
 		e.suiteResult = result.NewSuiteResult("", time.Now())
 		runner1.mockResult = &gauge_messages.ProtoExecutionResult{}
@@ -54,6 +62,9 @@ func TestSuiteHooksAreExecutedOncePerRun(t *testing.T) {
 		if r2count != 0 {
 			t.Errorf("Expected runner2 to have received 0 ExecutionEnding request, got %d", r2count)
 		}
+		if len(recievedMesseges) != 2 {
+			t.Errorf("Expected plugins to have received 2 ExecutionStarting notifications, got %d", len(recievedMesseges))
+		}
 	})
 }
 

version/version.go

@@ -14,7 +14,7 @@ import (
 )
 
 // CurrentGaugeVersion represents the current version of Gauge
-var CurrentGaugeVersion = &Version{1, 1, 3}
+var CurrentGaugeVersion = &Version{1, 1, 4}
 
 // BuildMetadata represents build information of current release (e.g, nightly build information)
 var BuildMetadata = ""