-
Notifications
You must be signed in to change notification settings - Fork 817
uplift database package from evm repositories
#4331
New issue
Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.
By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.
Already on GitHub? Sign in to your account
Merged
Merged
Changes from 4 commits
Commits
Show all changes
28 commits
Select commit
Hold shift + click to select a range
1c9f2b5
Add wrapped_database.go
JonathanOppenheimer 1082510
lint
JonathanOppenheimer b4cf02f
Apply suggestions from code review
JonathanOppenheimer 04075c3
Rodrigo suggestions
JonathanOppenheimer 76d4295
cleanup comments
JonathanOppenheimer 7af3440
Merge branch 'master' into JonathanOppenheimer/uplift-database
JonathanOppenheimer 13955ae
Merge branch 'master' into JonathanOppenheimer/uplift-database
JonathanOppenheimer 5258cd6
Josh review
JonathanOppenheimer 1c8cf95
dedouble implementation
JonathanOppenheimer c005a86
Merge branch 'master' into JonathanOppenheimer/uplift-database
JonathanOppenheimer 1bda77f
rename type
JonathanOppenheimer 99e6e6f
remove embed
JonathanOppenheimer 2ba7b0e
Merge branch 'master' into JonathanOppenheimer/uplift-database
JonathanOppenheimer c47e2b7
remove unneeded functions
JonathanOppenheimer d9237b4
add basic test suite
JonathanOppenheimer 0152bc1
rename to database
JonathanOppenheimer 6fe651f
add test to ensure prod returns errors
JonathanOppenheimer daad661
use correct testdb
JonathanOppenheimer 3ae6c29
lint
JonathanOppenheimer 42e8b9a
Josh nits
JonathanOppenheimer dd3f00f
Update vms/evm/database/database_test.go
JonathanOppenheimer 18038b5
nits
JonathanOppenheimer cb00b75
Merge branch 'master' into JonathanOppenheimer/uplift-database
JonathanOppenheimer dfd33c7
remove copy command
JonathanOppenheimer 46fc003
Apply suggestions from code review
JonathanOppenheimer 903aa1f
remove comment
JonathanOppenheimer 7cde922
Update vms/evm/database/database_test.go
JonathanOppenheimer 072975b
remove comment
JonathanOppenheimer File filter
Filter by extension
Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
There are no files selected for viewing
This file contains hidden or 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,71 @@ | ||
| // Copyright (C) 2019-2025, Ava Labs, Inc. All rights reserved. | ||
| // See the file LICENSE for licensing terms. | ||
|
|
||
| package database | ||
|
|
||
| import ( | ||
| "errors" | ||
|
|
||
| "github.com/ava-labs/libevm/ethdb" | ||
|
|
||
| "github.com/ava-labs/avalanchego/database" | ||
| ) | ||
|
|
||
| var ( | ||
| _ ethdb.Batch = (*ethBatchWrapper)(nil) | ||
| _ ethdb.KeyValueStore = (*ethDBWrapper)(nil) | ||
JonathanOppenheimer marked this conversation as resolved.
Outdated
Show resolved
Hide resolved
|
||
|
|
||
| ErrSnapshotNotSupported = errors.New("snapshot is not supported") | ||
| ErrStatNotSupported = errors.New("stat is not supported") | ||
JonathanOppenheimer marked this conversation as resolved.
Outdated
Show resolved
Hide resolved
|
||
| ) | ||
|
|
||
| func WrapDatabase(db database.Database) ethdb.KeyValueStore { return ethDBWrapper{db} } | ||
JonathanOppenheimer marked this conversation as resolved.
Outdated
Show resolved
Hide resolved
|
||
|
|
||
| // ethDbWrapper implements ethdb.Database | ||
JonathanOppenheimer marked this conversation as resolved.
Outdated
Show resolved
Hide resolved
|
||
| type ethDBWrapper struct{ database.Database } | ||
JonathanOppenheimer marked this conversation as resolved.
Outdated
Show resolved
Hide resolved
|
||
|
|
||
| // Stat implements ethdb.Database | ||
| func (ethDBWrapper) Stat(string) (string, error) { return "", ErrStatNotSupported } | ||
|
|
||
| // NewBatch implements ethdb.Database | ||
| func (db ethDBWrapper) NewBatch() ethdb.Batch { return ethBatchWrapper{db.Database.NewBatch()} } | ||
|
|
||
| // NewBatchWithSize implements ethdb.Database | ||
| // TODO: propagate size through avalanchego Database interface | ||
JonathanOppenheimer marked this conversation as resolved.
Outdated
Show resolved
Hide resolved
|
||
| func (db ethDBWrapper) NewBatchWithSize(int) ethdb.Batch { | ||
| return ethBatchWrapper{db.Database.NewBatch()} | ||
JonathanOppenheimer marked this conversation as resolved.
Outdated
Show resolved
Hide resolved
|
||
| } | ||
|
|
||
| func (ethDBWrapper) NewSnapshot() (ethdb.Snapshot, error) { | ||
| return nil, ErrSnapshotNotSupported | ||
| } | ||
|
|
||
| // NewIterator implements ethdb.Database | ||
| // | ||
| // Note: This method assumes that the prefix is NOT part of the start, so there's | ||
| // no need for the caller to prepend the prefix to the start. | ||
| func (db ethDBWrapper) NewIterator(prefix []byte, start []byte) ethdb.Iterator { | ||
| // avalanchego's database implementation assumes that the prefix is part of the | ||
| // start, so it is added here (if it is provided). | ||
JonathanOppenheimer marked this conversation as resolved.
Outdated
Show resolved
Hide resolved
|
||
| if len(prefix) != 0 { | ||
JonathanOppenheimer marked this conversation as resolved.
Outdated
Show resolved
Hide resolved
|
||
| newStart := make([]byte, len(prefix)+len(start)) | ||
| copy(newStart, prefix) | ||
| copy(newStart[len(prefix):], start) | ||
| start = newStart | ||
| } | ||
| return db.Database.NewIteratorWithStartAndPrefix(start, prefix) | ||
JonathanOppenheimer marked this conversation as resolved.
Outdated
Show resolved
Hide resolved
|
||
| } | ||
|
|
||
| // NewIteratorWithStart implements ethdb.Database | ||
| func (db ethDBWrapper) NewIteratorWithStart(start []byte) ethdb.Iterator { | ||
| return db.Database.NewIteratorWithStart(start) | ||
| } | ||
|
|
||
| // ethBatchWrapper implements ethdb.Batch | ||
| type ethBatchWrapper struct{ database.Batch } | ||
JonathanOppenheimer marked this conversation as resolved.
Outdated
Show resolved
Hide resolved
|
||
|
|
||
| // ValueSize implements ethdb.Batch | ||
| func (batch ethBatchWrapper) ValueSize() int { return batch.Batch.Size() } | ||
JonathanOppenheimer marked this conversation as resolved.
Outdated
Show resolved
Hide resolved
|
||
|
|
||
| // Replay implements ethdb.Batch | ||
| func (batch ethBatchWrapper) Replay(w ethdb.KeyValueWriter) error { return batch.Batch.Replay(w) } | ||
Oops, something went wrong.
Add this suggestion to a batch that can be applied as a single commit.
This suggestion is invalid because no changes were made to the code.
Suggestions cannot be applied while the pull request is closed.
Suggestions cannot be applied while viewing a subset of changes.
Only one suggestion per line can be applied in a batch.
Add this suggestion to a batch that can be applied as a single commit.
Applying suggestions on deleted lines is not supported.
You must change the existing code in this line in order to create a valid suggestion.
Outdated suggestions cannot be applied.
This suggestion has been applied or marked resolved.
Suggestions cannot be applied from pending reviews.
Suggestions cannot be applied on multi-line comments.
Suggestions cannot be applied while the pull request is queued to merge.
Suggestion cannot be applied right now. Please check back later.
Uh oh!
There was an error while loading. Please reload this page.