@@ -1396,25 +1396,6 @@ func (c *ClickHouseConnector) getTableName(chainId *big.Int, defaultTable string
13961396 return defaultTable
13971397}
13981398
1399- /*
1400- type TokenTransfer struct {
1401- TokenType string `json:"token_type"`
1402- ChainID *big.Int `json:"chain_id"`
1403- TokenAddress string `json:"token_address"`
1404- FromAddress string `json:"from_address"`
1405- ToAddress string `json:"to_address"`
1406- BlockNumber *big.Int `json:"block_number"`
1407- BlockTimestamp time.Time `json:"block_timestamp"`
1408- TransactionHash string `json:"transaction_hash"`
1409- TokenID *big.Int `json:"token_id"`
1410- Amount *big.Int `json:"amount"`
1411- LogIndex uint64 `json:"log_index"`
1412- Sign int8 `json:"sign"`
1413- InsertTimestamp time.Time `json:"insert_timestamp"`
1414- }
1415-
1416- */
1417-
14181399func (c * ClickHouseConnector ) GetTokenTransfers (qf TransfersQueryFilter , fields ... string ) (QueryResult [common.TokenTransfer ], error ) {
14191400 columns := "token_type, chain_id, token_address, from_address, to_address, block_number, block_timestamp, transaction_hash, token_id, amount, log_index, sign, insert_timestamp"
14201401 if len (fields ) > 0 {
@@ -1475,8 +1456,6 @@ func (c *ClickHouseConnector) GetTokenTransfers(qf TransfersQueryFilter, fields
14751456 } else if qf .Limit > 0 {
14761457 query += fmt .Sprintf (" LIMIT %d" , qf .Limit )
14771458 }
1478- fmt .Println ("QUERRRYRYYRY" , query )
1479- fmt .Println ("qf" , qf .ChainId )
14801459 rows , err := c .conn .Query (context .Background (), query , qf .ChainId )
14811460 if err != nil {
14821461 return QueryResult [common.TokenTransfer ]{}, err
0 commit comments