@@ -7,8 +7,11 @@ import (
7
7
"github.com/qubic/go-archiver/protobuff"
8
8
"github.com/qubic/go-archiver/store"
9
9
"github.com/qubic/go-node-connector/types"
10
+ "google.golang.org/protobuf/proto"
10
11
)
11
12
13
+ var emptyTickData = & protobuff.TickData {}
14
+
12
15
func CalculateEmptyTicksForEpoch (ctx context.Context , ps * store.PebbleStore , epoch uint32 ) (uint32 , error ) {
13
16
14
17
epochs , err := ps .GetProcessedTickIntervals (ctx )
@@ -24,6 +27,7 @@ func CalculateEmptyTicksForEpoch(ctx context.Context, ps *store.PebbleStore, epo
24
27
var emptyTicks uint32
25
28
26
29
for _ , interval := range e .Intervals {
30
+ fmt .Printf ("Interval: %d -> %d\n " , interval .InitialProcessedTick , interval .LastProcessedTick )
27
31
for tickOffset := range interval .LastProcessedTick - interval .InitialProcessedTick + 1 {
28
32
tickNumber := tickOffset + interval .InitialProcessedTick
29
33
@@ -33,7 +37,7 @@ func CalculateEmptyTicksForEpoch(ctx context.Context, ps *store.PebbleStore, epo
33
37
}
34
38
35
39
if CheckIfTickIsEmptyProto (tickData ) {
36
- fmt .Printf ("Found empty tick. \n " )
40
+ fmt .Printf ("Found empty tick: %d \n " , tickNumber )
37
41
emptyTicks += 1
38
42
continue
39
43
}
@@ -45,7 +49,8 @@ func CalculateEmptyTicksForEpoch(ctx context.Context, ps *store.PebbleStore, epo
45
49
}
46
50
47
51
func CheckIfTickIsEmptyProto (tickData * protobuff.TickData ) bool {
48
- if tickData == nil {
52
+
53
+ if tickData == nil || proto .Equal (tickData , emptyTickData ) {
49
54
return true
50
55
}
51
56
0 commit comments