Merge pull request #93 from neutron-org/fix/change-update-period-behaviour

pr0n00gler · web-flow · commit adff2c9db3f8 · 2024-09-19T22:58:52.000+03:00
fix: change behaviour for update period #NTRN-396
diff --git a/internal/subscriber/subscriber.go b/internal/subscriber/subscriber.go
@@ -177,7 +177,7 @@ func (s *Subscriber) processBlockEvent(ctx context.Context, tasks chan neutronty
 
 	for _, activeQuery := range s.activeQueries {
 		// Skip the ActiveQuery if we didn't reach the update time.
-		if currentHeight < (activeQuery.LastSubmittedResultLocalHeight + activeQuery.UpdatePeriod) {
+		if activeQuery.LastSubmittedResultLocalHeight != 0 && currentHeight < (activeQuery.LastSubmittedResultLocalHeight+activeQuery.UpdatePeriod) {
 			continue
 		}
 

Original file line number	Diff line number	Diff line change
`@@ -177,7 +177,7 @@ func (s *Subscriber) processBlockEvent(ctx context.Context, tasks chan neutronty`
`177`	`177`
`178`	`178`	`for _, activeQuery := range s.activeQueries {`
`179`	`179`	`// Skip the ActiveQuery if we didn't reach the update time.`
`180`		`- if currentHeight < (activeQuery.LastSubmittedResultLocalHeight + activeQuery.UpdatePeriod) {`
	`180`	`+ if activeQuery.LastSubmittedResultLocalHeight != 0 && currentHeight < (activeQuery.LastSubmittedResultLocalHeight+activeQuery.UpdatePeriod) {`
`181`	`181`	`continue`
`182`	`182`	`}`
`183`	`183`