mirror of
https://github.com/lightningnetwork/lnd.git
synced 2025-11-10 14:17:56 +01:00
Merge pull request #9281 from ziggie1984/export-towerclientdb-version
wtdb: export versions of wtclient.db
This commit is contained in:
@@ -78,6 +78,12 @@ func getLatestDBVersion(versions []version) uint32 {
|
|||||||
return uint32(len(versions))
|
return uint32(len(versions))
|
||||||
}
|
}
|
||||||
|
|
||||||
|
// LatestDBMigrationVersion returns the number of the latest existing database
|
||||||
|
// migration version available.
|
||||||
|
func LatestDBMigrationVersion() uint32 {
|
||||||
|
return getLatestDBVersion(clientDBVersions)
|
||||||
|
}
|
||||||
|
|
||||||
// getMigrations returns a slice of all updates with a greater number that
|
// getMigrations returns a slice of all updates with a greater number that
|
||||||
// curVersion that need to be applied to sync up with the latest version.
|
// curVersion that need to be applied to sync up with the latest version.
|
||||||
func getMigrations(versions []version, curVersion uint32) []version {
|
func getMigrations(versions []version, curVersion uint32) []version {
|
||||||
@@ -91,6 +97,27 @@ func getMigrations(versions []version, curVersion uint32) []version {
|
|||||||
return updates
|
return updates
|
||||||
}
|
}
|
||||||
|
|
||||||
|
// CurrentDatabaseVersion reads the current database version from the database
|
||||||
|
// and returns it.
|
||||||
|
func CurrentDatabaseVersion(db kvdb.Backend) (uint32, error) {
|
||||||
|
var (
|
||||||
|
version uint32
|
||||||
|
err error
|
||||||
|
)
|
||||||
|
|
||||||
|
err = kvdb.View(db, func(tx kvdb.RTx) error {
|
||||||
|
version, err = getDBVersion(tx)
|
||||||
|
return err
|
||||||
|
}, func() {
|
||||||
|
version = 0
|
||||||
|
})
|
||||||
|
if err != nil {
|
||||||
|
return 0, err
|
||||||
|
}
|
||||||
|
|
||||||
|
return version, nil
|
||||||
|
}
|
||||||
|
|
||||||
// getDBVersion retrieves the current database version from the metadata bucket
|
// getDBVersion retrieves the current database version from the metadata bucket
|
||||||
// using the dbVersionKey.
|
// using the dbVersionKey.
|
||||||
func getDBVersion(tx kvdb.RTx) (uint32, error) {
|
func getDBVersion(tx kvdb.RTx) (uint32, error) {
|
||||||
|
|||||||
Reference in New Issue
Block a user