인프런 커뮤니티 질문&답변

네 디버깅하면서 logs가 안들어오는 것까지 확인을 했습니다.
그런데 어디 부터 잘못되는지 확인이 불가능합니다.

혹시 git에 소스코드 공유 부탁드려도 될까요?

package event

import (
	"context"
	"event/config"
	"fmt"
	"math/big"
	"time"

	"github.com/ethereum/go-ethereum"
	"github.com/ethereum/go-ethereum/common"
	ethType "github.com/ethereum/go-ethereum/core/types"
	"github.com/ethereum/go-ethereum/ethclient"
)

type Scan struct {
	config *config.Config

	FilterQuery ethereum.FilterQuery
	client      *ethclient.Client
}

func NewScan(config *config.Config, client *ethclient.Client, catchEventList []common.Hash) (*Scan, chan []ethType.Log, error) {
	s := &Scan{
		config: config,
		client: client,
	}

	eventLog := make(chan []ethType.Log, 100)

	scanCallection := common.HexToAddress("0x97D6Aba16E92d82A58519C452c006e4058A631D7")

	go s.lookingScan(config.Node.StartBlock, scanCallection, catchEventList, eventLog)

	return s, eventLog, nil
}

//44961870
// 배포 : 44961732

func (s *Scan) lookingScan(startBlock int64, scanCallection common.Address, catchEventList []common.Hash, eventLog chan<- []ethType.Log) {
	startReadtBlock, to := startBlock, uint64(0)

	s.FilterQuery = ethereum.FilterQuery{
		Addresses: []common.Address{scanCallection},
		Topics:    [][]common.Hash{catchEventList},
		FromBlock: big.NewInt(startReadtBlock),
	}

	for {
		time.Sleep(1e8)

		ctx := context.Background()

		if maxBlock, err := s.client.BlockNumber(ctx); err != nil {
			fmt.Println("Get BlockNumber", "err", err.Error())
		} else {
			to = maxBlock

			if to > uint64(startBlock) {
				fmt.Println("from Block", s.FilterQuery.ToBlock, "to Block", to)
				s.FilterQuery.ToBlock = big.NewInt(int64(to))
				s.FilterQuery.FromBlock = big.NewInt(startReadtBlock)

				tryCount := 1

				fmt.Println("s.FilterQuery : ", s.FilterQuery)

			Retry:
				if logs, err := s.client.FilterLogs(ctx, s.FilterQuery); err != nil {

					if tryCount == 3 {
						fmt.Println("failed to get Filter", "err", err.Error())
						break
					} else {
						newTo := big.NewInt(int64(to) - 1)
						newFrom := big.NewInt(startBlock - 1)

						s.FilterQuery.ToBlock = newTo
						s.FilterQuery.FromBlock = newFrom

						tryCount++

						goto Retry
					}

				} else if len(logs) > 0 {
					eventLog <- logs
					startReadtBlock = int64(to)
				}
			}
		}
	}
}

s.FilterQuery : {<nil> 44961732 52617540 [0x97D6Aba16E92d82A58519C452c006e4058A631D7] [[0xd99659a21de82e379975ce8df556f939a4ccb95e92144f38bb0dd35730ffcdd5]]}

from Block 52617540 to Block 52617540

s.FilterQuery : {<nil> 44961732 52617540 [0x97D6Aba16E92d82A58519C452c006e4058A631D7] [[0xd99659a21de82e379975ce8df556f939a4ccb95e92144f38bb0dd35730ffcdd5]]}

from Block 52617540 to Block 52617541

s.FilterQuery : {<nil> 44961732 52617541 [0x97D6Aba16E92d82A58519C452c006e4058A631D7] [[0xd99659a21de82e379975ce8df556f939a4ccb95e92144f38bb0dd35730ffcdd5]]}

from Block 52617541 to Block 52617541

s.FilterQuery : {<nil> 44961732 52617541 [0x97D6Aba16E92d82A58519C452c006e4058A631D7] [[0xd99659a21de82e379975ce8df556f939a4ccb95e92144f38bb0dd35730ffcdd5]]}

from Block 52617541 to Block 52617542

s.FilterQuery : {<nil> 44961732 52617542 [0x97D6Aba16E92d82A58519C452c006e4058A631D7] [[0xd99659a21de82e379975ce8df556f939a4ccb95e92144f38bb0dd35730ffcdd5]]}

from Block 52617542 to Block 52617542

s.FilterQuery : {<nil> 44961732 52617542 [0x97D6Aba16E92d82A58519C452c006e4058A631D7] [[0xd99659a21de82e379975ce8df556f939a4ccb95e92144f38bb0dd35730ffcdd5]]}

exit status 0xc000013a

s.FilterQuery는 잘 들어오고 있는것 같은데 nil은 정상적인거죠?

package event

import (
	"context"
	"event/config"
	"event/types"
	"fmt"

	"github.com/ethereum/go-ethereum/common"
	ethType "github.com/ethereum/go-ethereum/core/types"
	"github.com/ethereum/go-ethereum/crypto"
	"github.com/ethereum/go-ethereum/ethclient"
)

type Catch struct {
	config           *config.Config
	client           *ethclient.Client
	needToCatchEvent map[common.Hash]types.NeedToCatchEvent
}

func NewCatch(config *config.Config, client *ethclient.Client) (*Catch, error) {
	c := &Catch{
		config: config,
		client: client,
	}

	c.needToCatchEvent = map[common.Hash]types.NeedToCatchEvent{
		common.BytesToHash(crypto.Keccak256([]byte("Transfer(address,address,uint256"))): {
			NeedToCatchEventFunc: c.Transfer,
		},
	}

	return c, nil
}

func (c *Catch) Transfer(e *ethType.Log, tx *ethType.Transaction) {
	fmt.Println("들어 왔습니다.")
}

// start To Catch Event
func (c *Catch) StartToCatch(events <-chan []ethType.Log) {
	fmt.Println("Event가 들어 왔습니다.")

	for event := range events {
		ctx := context.Background()
		txList := make(map[common.Hash]*ethType.Transaction)

		for _, e := range event {
			Hash := e.TxHash

			if _, ok := txList[Hash]; !ok {
				if tx, pending, err := c.client.TransactionByHash(ctx, Hash); err == nil {
					if !pending {
						txList[Hash] = tx
					}
				}
			}

			if e.Removed {
				continue
			} else if et, ok := c.needToCatchEvent[e.Topics[0]]; !ok {

			} else {
				et.NeedToCatchEventFunc(&e, txList[Hash])
			}

			//e.Topics[0]

		}
	}
}

func (c *Catch) GetEventsToCatch() []common.Hash {
	eventsToCatch := make([]common.Hash, 0)

	for e := range c.needToCatchEvent {
		eventsToCatch = append(eventsToCatch, e)
	}

	return eventsToCatch
}

package app

import (
	"event/config"
	"event/event"
	repostory "event/repository"

	ethType "github.com/ethereum/go-ethereum/core/types"
	"github.com/ethereum/go-ethereum/ethclient"
)

type App struct {
	config *config.Config

	client *ethclient.Client

	repostory *repostory.Repostory
	scan      *event.Scan
	catch     *event.Catch
}

func NewApp(config *config.Config) {
	a := App{
		config: config,
	}

	var err error

	if a.client, err = ethclient.Dial(config.Node.Uri); err != nil {
		panic(err)
	} else {
		if a.repostory, err = repostory.NewRepostory(config); err != nil {
			panic(err)
		}

		if a.catch, err = event.NewCatch(config, a.client); err != nil {
			panic(err)
		}

		var eventChan chan []ethType.Log

		if a.scan, eventChan, err = event.NewScan(config, a.client, a.catch.GetEventsToCatch()); err != nil {
			panic(err)
		}

		go a.catch.StartToCatch(eventChan)

		for {

		}
	}
}

에러 코드는 없었습니다.
트랜잭션을 전송하셨는지 질문을 드렸는데?
mumbai에 트랜잭션을 말씀하신건가요? => 테스트넷에서
0x9f878a0a73a53dd676d4f9ec58b823ab9130df335c8b38b4df8ac2d15f49adee 검색할 수 있는 트랜잭션 해쉬 코드 입니다.

실행 했을때의 로그입니다,

Event가 들어 왔습니다.

from Block <nil> to Block 52533290

from Block 52533290 to Block 52533290

from Block 52533290 to Block 52533291

exit status 0xc000013a

음 혹시 추가적인 정보를 얻을 수 있을까요?

에러코드라든지 트랜잭션을 전송하셨는지

추가적인 정보가 필요합니다.

블럭 넘버에 대한 값을 보내주신걸보니 트랜재션은 성공한걸로 보입니다.

아마도 채널값에서 초기화하기 전에 이벤트를 잡으려고 하셔서 그런걸로 보입니다.

컨트랙트 또는 app.go에 있는 코드 보내주시면 답변해드리는데에 있어서 도움을 드릴 수 있을거 같아요!!!