feat: direct token transfers

Author: harsh-98

go.mod

@@ -3,7 +3,7 @@ module github.com/Gearbox-protocol/third-eye
 go 1.20
 
 require (
-	github.com/Gearbox-protocol/sdk-go v0.0.0-20250202041008-5cd987002fd9
+	github.com/Gearbox-protocol/sdk-go v0.0.0-20250206105656-76adcae4b482
 	github.com/ethereum/go-ethereum v1.13.14
 	github.com/go-playground/validator/v10 v10.4.1
 	github.com/google/go-cmp v0.5.9
@@ -82,6 +82,6 @@ require (
 
 replace github.com/btcsuite/btcd => github.com/btcsuite/btcd v0.22.1
 
-replace github.com/Gearbox-protocol/sdk-go v0.0.0-20241126153159-4d2505d49944 => ../sdk-go
+replace github.com/Gearbox-protocol/sdk-go v0.0.0-20250202041008-5cd987002fd9 => ../sdk-go
 
 replace github.com/ethereum/go-ethereum v1.13.14 => github.com/OffchainLabs/go-ethereum v1.13.4-0.20240313010929-e5d8587e7227

go.sum

@@ -5,8 +5,8 @@ contrib.go.opencensus.io/exporter/ocagent v0.6.0/go.mod h1:zmKjrJcdo0aYcVS7bmEeS
 github.com/BurntSushi/toml v0.3.1 h1:WXkYYl6Yr3qBf1K79EBnL4mak0OimBfB0XUf9Vl28OQ=
 github.com/BurntSushi/toml v0.3.1/go.mod h1:xHWCNGjB5oqiDr8zfno3MHue2Ht5sIBksp03qcyfWMU=
 github.com/DataDog/zstd v1.4.5 h1:EndNeuB0l9syBZhut0wns3gV1hL8zX8LIu6ZiVHWLIQ=
-github.com/Gearbox-protocol/sdk-go v0.0.0-20250202041008-5cd987002fd9 h1:nPRo/oxbzDsrzDUeq0XGETd+a0WepVGGmvq5o1ne0cc=
-github.com/Gearbox-protocol/sdk-go v0.0.0-20250202041008-5cd987002fd9/go.mod h1:jRBSOG94bpGc5ci8EWIPUVXZdaGEaekMNmhajbmWFVU=
+github.com/Gearbox-protocol/sdk-go v0.0.0-20250206105656-76adcae4b482 h1:24uVEuVEK1dzOcLhz8onUSg4csvGQpcQ8sEmqdhPRHY=
+github.com/Gearbox-protocol/sdk-go v0.0.0-20250206105656-76adcae4b482/go.mod h1:jRBSOG94bpGc5ci8EWIPUVXZdaGEaekMNmhajbmWFVU=
 github.com/Microsoft/go-winio v0.6.1 h1:9/kr64B9VUZrLm5YYwbGtUJnMgqWVOdUAXu6Migciow=
 github.com/Microsoft/go-winio v0.6.1/go.mod h1:LRdKpFKfdobln8UmuiYcKPot9D2v6svN5+sAH+4kjUM=
 github.com/OffchainLabs/go-ethereum v1.13.4-0.20240313010929-e5d8587e7227 h1:+/3TrD+q+BP36jGj2Bycdmrc/joKLNbc5ImePQzKRLM=

models/wrappers/cm_wrapper/index.go

@@ -28,7 +28,7 @@ func NewCMWrapper(client core.ClientI) *CMWrapper {
 
 func (s CMWrapper) OnLogs(txLogs []types.Log) {
 	ind := 0
-	var lastBlockNum int64 = 0
+	var lastBlockNum int64 = s.GetLastSync()
 	for ind < len(txLogs) {
 		txLog := txLogs[ind]
 		// check block change
@@ -86,7 +86,7 @@ func (s CMWrapper) onBlockChange(lastBlockNum, newBlockNum int64) {
 	}
 	// update for direct token transfer
 	for _, adapter := range adapters {
-		if adapter.GetLastSync() >= lastBlockNum {
+		if adapter.GetLastSync() >= newBlockNum {
 			continue
 		}
 		cm := credit_manager.GetCMForWrapper(adapter)