mirror of
https://github.com/kaspanet/kaspad.git
synced 2025-03-30 15:08:33 +00:00
7bf8bb5436
* [NOD-1017] Move peers.json to db * [NOD-1017] Fix tests * [NOD-1017] Change comments and rename variables * [NOD-1017] Separate to smaller functions * [NOD-1017] Renames * [NOD-1017] Name newAddrManagerForTest return params * [NOD-1017] Fix handling of non existing peersState * [NOD-1017] Add getPeersState rpc command * [NOD-1017] Fix comment * [NOD-1017] Split long line * [NOD-1017] Rename getPeersState->getPeerAddresses * [NOD-1017] Rename getPeerInfo->getConnectedPeerInfo
27 lines
662 B
Go
27 lines
662 B
Go
package dbaccess
|
|
|
|
import "github.com/kaspanet/kaspad/database"
|
|
|
|
var (
|
|
peersKey = database.MakeBucket().Key([]byte("peers"))
|
|
)
|
|
|
|
// StorePeersState stores the peers state in the database.
|
|
func StorePeersState(context Context, peersState []byte) error {
|
|
accessor, err := context.accessor()
|
|
if err != nil {
|
|
return err
|
|
}
|
|
return accessor.Put(peersKey, peersState)
|
|
}
|
|
|
|
// FetchPeersState retrieves the peers state from the database.
|
|
// Returns ErrNotFound if the state is missing from the database.
|
|
func FetchPeersState(context Context) ([]byte, error) {
|
|
accessor, err := context.accessor()
|
|
if err != nil {
|
|
return nil, err
|
|
}
|
|
return accessor.Get(peersKey)
|
|
}
|