amend table in last nft trades block getter.

diadata-org · May 18, 2022 · be30eac · be30eac
1 parent 856c9ed
commit be30eac
Show file tree

Hide file tree

Showing 2 changed files with 2 additions and 2 deletions.
diff --git a/cmd/nftTradescrapers/go.mod b/cmd/nftTradescrapers/go.mod
@@ -3,7 +3,7 @@ module github.com/diadata-org/diadata/cmd/nftTradescrapers
 go 1.17
 
 require (
-	github.com/diadata-org/diadata v1.4.1-rc-173
+	github.com/diadata-org/diadata v1.4.1-rc-174
 	github.com/jackc/pgconn v1.10.0
 	github.com/sirupsen/logrus v1.8.1
 )
diff --git a/pkg/model/nfts.go b/pkg/model/nfts.go
@@ -244,7 +244,7 @@ func (rdb *RelDB) SetNFTTradeToTable(trade dia.NFTTrade, table string) error {
 
 // GetLastBlockNFTTtrade returns the last blocknumber that was scraped for trades in @nftclass.
 func (rdb *RelDB) GetLastBlockNFTTrade(nftclass dia.NFTClass) (blocknumber uint64, err error) {
-	query := fmt.Sprintf("SELECT block_number FROM %s WHERE nftclass_id=(SELECT nftclass_id FROM %s WHERE address='%s' AND blockchain='%s') ORDER BY block_number DESC LIMIT 1;", nfttradeTable, nftclassTable, nftclass.Address, nftclass.Blockchain)
+	query := fmt.Sprintf("SELECT block_number FROM %s WHERE nftclass_id=(SELECT nftclass_id FROM %s WHERE address='%s' AND blockchain='%s') ORDER BY block_number DESC LIMIT 1;", NfttradeCurrTable, nftclassTable, nftclass.Address, nftclass.Blockchain)
 	err = rdb.postgresClient.QueryRow(context.Background(), query).Scan(&blocknumber)
 	if err != nil {
 		return