Initializing msg index by 0

Author: AndriiDiachuk

engine/access/rest/websockets/data_providers/account_statuses_provider.go

@@ -99,7 +99,7 @@ func (p *AccountStatusesDataProvider) createSubscription(ctx context.Context, ar
 // No errors are expected during normal operations.
 func (p *AccountStatusesDataProvider) handleResponse() func(accountStatusesResponse *backend.AccountStatusesResponse) error {
 	blocksSinceLastMessage := uint64(0)
-	messageIndex := counters.NewMonotonousCounter(1)
+	messageIndex := counters.NewMonotonousCounter(0)
 
 	return func(accountStatusesResponse *backend.AccountStatusesResponse) error {
 		// check if there are any events in the response. if not, do not send a message unless the last
@@ -112,10 +112,10 @@ func (p *AccountStatusesDataProvider) handleResponse() func(accountStatusesRespo
 			blocksSinceLastMessage = 0
 		}
 
-		index := messageIndex.Value()
 		if ok := messageIndex.Set(messageIndex.Value() + 1); !ok {
 			return status.Errorf(codes.Internal, "message index already incremented to %d", messageIndex.Value())
 		}
+		index := messageIndex.Value()
 
 		p.send <- &models.AccountStatusesResponse{
 			BlockID:       accountStatusesResponse.BlockID.String(),

engine/access/rest/websockets/data_providers/events_provider.go

@@ -85,7 +85,7 @@ func (p *EventsDataProvider) Run() error {
 // No errors are expected during normal operations.
 func (p *EventsDataProvider) handleResponse() func(eventsResponse *backend.EventsResponse) error {
 	blocksSinceLastMessage := uint64(0)
-	messageIndex := counters.NewMonotonousCounter(1)
+	messageIndex := counters.NewMonotonousCounter(0)
 
 	return func(eventsResponse *backend.EventsResponse) error {
 		// check if there are any events in the response. if not, do not send a message unless the last
@@ -98,10 +98,10 @@ func (p *EventsDataProvider) handleResponse() func(eventsResponse *backend.Event
 			blocksSinceLastMessage = 0
 		}
 
-		index := messageIndex.Value()
 		if ok := messageIndex.Set(messageIndex.Value() + 1); !ok {
 			return fmt.Errorf("message index already incremented to: %d", messageIndex.Value())
 		}
+		index := messageIndex.Value()
 
 		p.send <- &models.EventResponse{
 			BlockId:        eventsResponse.BlockID.String(),