-
Notifications
You must be signed in to change notification settings - Fork 1.3k
Commit
This commit does not belong to any branch on this repository, and may belong to a fork outside of the repository.
- Loading branch information
Geoff Stuart
committed
Jan 5, 2023
1 parent
41490ff
commit b686a5e
Showing
4 changed files
with
158 additions
and
67 deletions.
There are no files selected for viewing
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -0,0 +1,146 @@ | ||
| package chain | ||
|
|
||
| import ( | ||
| "database/sql" | ||
|
|
||
| "github.com/ipfs/go-cid" | ||
| _ "github.com/mattn/go-sqlite3" | ||
| "golang.org/x/xerrors" | ||
|
|
||
| "github.com/filecoin-project/lotus/chain/types/ethtypes" | ||
| ) | ||
|
|
||
| var pragmas = []string{ | ||
| "PRAGMA synchronous = normal", | ||
| "PRAGMA temp_store = memory", | ||
| "PRAGMA mmap_size = 30000000000", | ||
| "PRAGMA page_size = 32768", | ||
| "PRAGMA auto_vacuum = NONE", | ||
| "PRAGMA automatic_index = OFF", | ||
| "PRAGMA journal_mode = WAL", | ||
| "PRAGMA read_uncommitted = ON", | ||
| } | ||
|
|
||
| var ddls = []string{ | ||
| `CREATE TABLE IF NOT EXISTS tx_hash_lookup ( | ||
| hash TEXT PRIMARY KEY, | ||
| cid TEXT NOT NULL | ||
| )`, | ||
|
|
||
| // metadata containing version of schema | ||
| `CREATE TABLE IF NOT EXISTS _meta ( | ||
| version UINT64 NOT NULL UNIQUE | ||
| )`, | ||
|
|
||
| // version 1. | ||
| `INSERT OR IGNORE INTO _meta (version) VALUES (1)`, | ||
| } | ||
|
|
||
| const schemaVersion = 1 | ||
|
|
||
| const ( | ||
| insertTxHash = `INSERT OR IGNORE INTO tx_hash_lookup | ||
| (hash, cid) | ||
| VALUES(?, ?)` | ||
| ) | ||
|
|
||
| type TransactionHashLookup struct { | ||
| db *sql.DB | ||
| } | ||
|
|
||
| func (ei *TransactionHashLookup) InsertTxHash(txHash ethtypes.EthHash, c cid.Cid) error { | ||
| hashEntry, err := ei.db.Prepare(insertTxHash) | ||
| if err != nil { | ||
| return xerrors.Errorf("prepare insert event: %w", err) | ||
| } | ||
|
|
||
| _, err = hashEntry.Exec(txHash.String(), c.String()) | ||
| return err | ||
| } | ||
|
|
||
| func (ei *TransactionHashLookup) LookupCidFromTxHash(txHash ethtypes.EthHash) (cid.Cid, error) { | ||
| q, err := ei.db.Query("SELECT cid FROM tx_hash_lookup WHERE hash = :hash;", sql.Named("hash", txHash.String())) | ||
| if err != nil { | ||
| return cid.Undef, err | ||
| } | ||
|
|
||
| var c string | ||
| if !q.Next() { | ||
| return cid.Undef, xerrors.Errorf("transaction hash %s not found", txHash.String()) | ||
| } | ||
| err = q.Scan(&c) | ||
| if err != nil { | ||
| return cid.Undef, err | ||
| } | ||
| return cid.Decode(c) | ||
| } | ||
|
|
||
| func (ei *TransactionHashLookup) LookupTxHashFromCid(c cid.Cid) (ethtypes.EthHash, error) { | ||
| q, err := ei.db.Query("SELECT hash FROM tx_hash_lookup WHERE cid = :cid;", sql.Named("cid", c.String())) | ||
| if err != nil { | ||
| return ethtypes.EmptyEthHash, err | ||
| } | ||
|
|
||
| var hashString string | ||
| if !q.Next() { | ||
| return ethtypes.EmptyEthHash, xerrors.Errorf("transaction hash %s not found", c.String()) | ||
| } | ||
| err = q.Scan(&hashString) | ||
| if err != nil { | ||
| return ethtypes.EmptyEthHash, err | ||
| } | ||
| return ethtypes.EthHashFromHex(hashString) | ||
| } | ||
|
|
||
| func NewTransactionHashLookup(path string) (*TransactionHashLookup, error) { | ||
| db, err := sql.Open("sqlite3", path+"?mode=rwc") | ||
| if err != nil { | ||
| return nil, xerrors.Errorf("open sqlite3 database: %w", err) | ||
| } | ||
|
|
||
| for _, pragma := range pragmas { | ||
| if _, err := db.Exec(pragma); err != nil { | ||
| _ = db.Close() | ||
| return nil, xerrors.Errorf("exec pragma %q: %w", pragma, err) | ||
| } | ||
| } | ||
|
|
||
| q, err := db.Query("SELECT name FROM sqlite_master WHERE type='table' AND name='_meta';") | ||
| if err == sql.ErrNoRows || !q.Next() { | ||
| // empty database, create the schema | ||
| for _, ddl := range ddls { | ||
| if _, err := db.Exec(ddl); err != nil { | ||
| _ = db.Close() | ||
| return nil, xerrors.Errorf("exec ddl %q: %w", ddl, err) | ||
| } | ||
| } | ||
| } else if err != nil { | ||
| _ = db.Close() | ||
| return nil, xerrors.Errorf("looking for _meta table: %w", err) | ||
| } else { | ||
| // Ensure we don't open a database from a different schema version | ||
|
|
||
| row := db.QueryRow("SELECT max(version) FROM _meta") | ||
| var version int | ||
| err := row.Scan(&version) | ||
| if err != nil { | ||
| _ = db.Close() | ||
| return nil, xerrors.Errorf("invalid database version: no version found") | ||
| } | ||
| if version != schemaVersion { | ||
| _ = db.Close() | ||
| return nil, xerrors.Errorf("invalid database version: got %d, expected %d", version, schemaVersion) | ||
| } | ||
| } | ||
|
|
||
| return &TransactionHashLookup{ | ||
| db: db, | ||
| }, nil | ||
| } | ||
|
|
||
| func (ei *TransactionHashLookup) Close() error { | ||
| if ei.db == nil { | ||
| return nil | ||
| } | ||
| return ei.db.Close() | ||
| } |
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters