From 2920451fd314426fee45cb074cef3a4ad74de83e Mon Sep 17 00:00:00 2001
From: Nikita Neznaemov <n.neznaemov@atomyze.ru>
Date: Tue, 21 Nov 2023 14:04:49 +0300
Subject: [PATCH] 1

---
 observer/block_peer_common.go | 4 +++-
 1 file changed, 3 insertions(+), 1 deletion(-)

diff --git a/observer/block_peer_common.go b/observer/block_peer_common.go
index 854d37c..1893808 100644
--- a/observer/block_peer_common.go
+++ b/observer/block_peer_common.go
@@ -193,9 +193,11 @@ func (bp *BlockPeer) initChannels(ctx context.Context) {
 func (bp *BlockPeer) getSeekFrom(channel string) SeekFromFetcher {
 	seekFrom := ChannelSeekOldest()
 	// at first check seekFrom var, if it is empty, check seekFromFetcher
+	bp.mu.Lock()
 	seekFromNum, exist := bp.seekFrom[channel]
+	bp.mu.Unlock()
 	if exist {
-		seekFrom = ChannelSeekFrom(seekFromNum)
+		seekFrom = ChannelSeekFrom(seekFromNum - 1)
 	} else {
 		// if seekFromFetcher is also empty, use ChannelSeekOldest
 		if bp.seekFromFetcher != nil {