Periodically update slot for accounts in memory

jeffyanta · jeffyanta · commit 202406d01a35 · 2024-10-17T13:12:28.000-04:00
diff --git a/geyser/handler_memory.go b/geyser/handler_memory.go
@@ -263,7 +263,8 @@ func (h *MemoryAccountWithDataUpdateHandler) onStateObserved(ctx context.Context
 		if isInitialized {
 			if cachedVirtualAccountState.IsInitialized &&
 				cachedVirtualAccountState.Address == base58VirtualAccountAddress &&
-				bytes.Equal(cachedVirtualAccountState.State, newVirtualAccountState) {
+				bytes.Equal(cachedVirtualAccountState.State, newVirtualAccountState) &&
+				observedAtSlot-cachedVirtualAccountState.Slot < 100 { // todo: configurable?
 				continue
 			}
 

Original file line number	Diff line number	Diff line change
`@@ -263,7 +263,8 @@ func (h *MemoryAccountWithDataUpdateHandler) onStateObserved(ctx context.Context`
`263`	`263`	`if isInitialized {`
`264`	`264`	`if cachedVirtualAccountState.IsInitialized &&`
`265`	`265`	`cachedVirtualAccountState.Address == base58VirtualAccountAddress &&`
`266`		`- bytes.Equal(cachedVirtualAccountState.State, newVirtualAccountState) {`
	`266`	`+ bytes.Equal(cachedVirtualAccountState.State, newVirtualAccountState) &&`
	`267`	`+ observedAtSlot-cachedVirtualAccountState.Slot < 100 { // todo: configurable?`
`267`	`268`	`continue`
`268`	`269`	`}`
`269`	`270`