fix: fixed bug where the unhealthy da event didn't stop block product…

…ion (#431)
dymensionxyz · Jul 31, 2023 · 9e359f6 · 9e359f6
1 parent 6a045ea
commit 9e359f6
Show file tree

Hide file tree

Showing 2 changed files with 2 additions and 2 deletions.
diff --git a/da/celestia/celestia_test.go b/da/celestia/celestia_test.go
@@ -132,7 +132,7 @@ func TestSubmitBatch(t *testing.T) {
 		go func() {
 			select {
 			case event := <-HealthSubscription.Out():
-				healthStatusEvent := event.Data().(da.EventDataDAHealthStatus)
+				healthStatusEvent := event.Data().(*da.EventDataDAHealthStatus)
 				assert.Equal(tc.expectedHealthEvent.Healthy, healthStatusEvent.Healthy)
 				done <- true
 				break

diff --git a/da/utils.go b/da/utils.go
@@ -7,7 +7,7 @@ import (
 )
 
 func SubmitBatchHealthEventHelper(pubsubServer *pubsub.Server, ctx context.Context, healthy bool, err error) (ResultSubmitBatch, error) {
-	err = pubsubServer.PublishWithEvents(ctx, EventDataDAHealthStatus{Healthy: healthy, Error: err},
+	err = pubsubServer.PublishWithEvents(ctx, &EventDataDAHealthStatus{Healthy: healthy, Error: err},
 		map[string][]string{EventTypeKey: {EventDAHealthStatus}})
 	if err != nil {
 		return ResultSubmitBatch{