package repositories import ( "database/sql" "log" "context" "errors" "github.com/8thlight/vulcanizedb/pkg/config" "github.com/8thlight/vulcanizedb/pkg/core" "github.com/jmoiron/sqlx" _ "github.com/lib/pq" ) type Postgres struct { Db *sqlx.DB } var ( ErrDBInsertFailed = errors.New("postgres: insert failed") ) func NewPostgres(databaseConfig config.Database) Postgres { connectString := config.DbConnectionString(databaseConfig) db, err := sqlx.Connect("postgres", connectString) if err != nil { log.Fatalf("Error connecting to DB: %v\n", err) } return Postgres{Db: db} } func (repository Postgres) CreateWatchedContract(contract core.WatchedContract) error { _, err := repository.Db.Exec( `INSERT INTO watched_contracts (contract_hash) VALUES ($1)`, contract.Hash) if err != nil { return ErrDBInsertFailed } return nil } func (repository Postgres) IsWatchedContract(contractHash string) bool { var exists bool err := repository.Db.QueryRow( `SELECT exists(select 1 from watched_contracts where contract_hash=$1) FROM watched_contracts`, contractHash).Scan(&exists) if err != nil && err != sql.ErrNoRows { log.Fatalf("error checking if row exists %v", err) } return exists } func (repository Postgres) MaxBlockNumber() int64 { var highestBlockNumber int64 repository.Db.Get(&highestBlockNumber, `SELECT MAX(block_number) FROM blocks`) return highestBlockNumber } func (repository Postgres) MissingBlockNumbers(startingBlockNumber int64, highestBlockNumber int64) []int64 { numbers := []int64{} repository.Db.Select(&numbers, `SELECT all_block_numbers FROM ( SELECT generate_series($1::INT, $2::INT) AS all_block_numbers) series LEFT JOIN blocks ON block_number = all_block_numbers WHERE block_number ISNULL`, startingBlockNumber, highestBlockNumber) return numbers } func (repository Postgres) FindBlockByNumber(blockNumber int64) *core.Block { blockRows, _ := repository.Db.Query( `SELECT id, block_number, block_gaslimit, block_gasused, block_time, block_difficulty, block_hash, block_nonce, block_parenthash, block_size, uncle_hash FROM blocks`) var savedBlocks []core.Block for blockRows.Next() { savedBlock := repository.loadBlock(blockRows) savedBlocks = append(savedBlocks, savedBlock) } if len(savedBlocks) > 0 { return &savedBlocks[0] } else { return nil } } func (repository Postgres) BlockCount() int { var count int repository.Db.Get(&count, "SELECT COUNT(*) FROM blocks") return count } func (repository Postgres) CreateBlock(block core.Block) error { tx, _ := repository.Db.BeginTx(context.Background(), nil) var blockId int64 err := tx.QueryRow( `INSERT INTO blocks (block_number, block_gaslimit, block_gasused, block_time, block_difficulty, block_hash, block_nonce, block_parenthash, block_size, uncle_hash) VALUES ($1, $2, $3, $4, $5, $6, $7, $8, $9, $10) RETURNING id `, block.Number, block.GasLimit, block.GasUsed, block.Time, block.Difficulty, block.Hash, block.Nonce, block.ParentHash, block.Size, block.UncleHash). Scan(&blockId) if err != nil { tx.Rollback() return ErrDBInsertFailed } err = repository.createTransactions(tx, blockId, block.Transactions) if err != nil { tx.Rollback() return ErrDBInsertFailed } tx.Commit() return nil } func (repository Postgres) createTransactions(tx *sql.Tx, blockId int64, transactions []core.Transaction) error { for _, transaction := range transactions { _, err := tx.Exec( `INSERT INTO transactions (block_id, tx_hash, tx_nonce, tx_to, tx_gaslimit, tx_gasprice, tx_value) VALUES ($1, $2, $3, $4, $5, $6, $7)`, blockId, transaction.Hash, transaction.Nonce, transaction.To, transaction.GasLimit, transaction.GasPrice, transaction.Value) if err != nil { return err } } return nil } func (repository Postgres) loadBlock(blockRows *sql.Rows) core.Block { var blockId int64 var blockHash string var blockNonce string var blockNumber int64 var blockParentHash string var blockSize int64 var blockTime float64 var difficulty int64 var gasLimit float64 var gasUsed float64 var uncleHash string blockRows.Scan(&blockId, &blockNumber, &gasLimit, &gasUsed, &blockTime, &difficulty, &blockHash, &blockNonce, &blockParentHash, &blockSize, &uncleHash) transactions := repository.loadTransactions(blockId) return core.Block{ Difficulty: difficulty, GasLimit: int64(gasLimit), GasUsed: int64(gasUsed), Hash: blockHash, Nonce: blockNonce, Number: blockNumber, ParentHash: blockParentHash, Size: blockSize, Time: int64(blockTime), Transactions: transactions, UncleHash: uncleHash, } } func (repository Postgres) loadTransactions(blockId int64) []core.Transaction { transactionRows, _ := repository.Db.Query(`SELECT tx_hash, tx_nonce, tx_to, tx_gaslimit, tx_gasprice, tx_value FROM transactions`) var transactions []core.Transaction for transactionRows.Next() { var hash string var nonce uint64 var to string var gasLimit int64 var gasPrice int64 var value int64 transactionRows.Scan(&hash, &nonce, &to, &gasLimit, &gasPrice, &value) transaction := core.Transaction{ Hash: hash, Nonce: nonce, To: to, GasLimit: gasLimit, GasPrice: gasPrice, Value: value, } transactions = append(transactions, transaction) } return transactions }