stakey/vspd
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

Rename Fees => Tickets

Browse Source
This commit is contained in:
jholdstock 2020-05-13 21:48:59 +01:00
parent f919d4d8fc
commit fcd068deb3
2 changed files with 19 additions and 14 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

19
database/database.go
View File

@ -18,7 +18,7 @@ var (
// vspBkt is the main parent bucket of the VSP. All values and other buckets // vspBkt is the main parent bucket of the VSP. All values and other buckets
// are nested within it. // are nested within it.
vspBkt = []byte("vspbkt") vspBkt = []byte("vspbkt")
feesBkt = []byte("feesbkt") ticketsBkt = []byte("ticketsbkt")
versionK = []byte("version") versionK = []byte("version")
backupFile = "backup.kv" backupFile = "backup.kv"
version = 1 version = 1
@ -41,22 +41,27 @@ func New(dbFile string) (*VspDatabase, error) {
return &VspDatabase{db: db}, nil return &VspDatabase{db: db}, nil
} }
// createBuckets creates all storage buckets of the VSP. // createBuckets creates all storage buckets of the VSP if they don't already
// exist.
func createBuckets(db *bolt.DB) error { func createBuckets(db *bolt.DB) error {
return db.Update(func(tx *bolt.Tx) error { return db.Update(func(tx *bolt.Tx) error {
pbkt := tx.Bucket(feesBkt) if tx.Bucket(vspBkt) == nil {
if pbkt == nil { parentBkt, err := tx.CreateBucket(vspBkt)
pbkt, err := tx.CreateBucket(feesBkt)
if err != nil { if err != nil {
return fmt.Errorf("failed to create %s bucket: %v", string(feesBkt), err) return fmt.Errorf("failed to create %s bucket: %v", string(vspBkt), err)
} }
vbytes := make([]byte, 4) vbytes := make([]byte, 4)
binary.LittleEndian.PutUint32(vbytes, uint32(version)) binary.LittleEndian.PutUint32(vbytes, uint32(version))
err = pbkt.Put(versionK, vbytes) err = parentBkt.Put(versionK, vbytes)
if err != nil { if err != nil {
return err return err
} }
_, err = parentBkt.CreateBucket(ticketsBkt)
if err != nil {
return fmt.Errorf("failed to create %s bucket: %v", string(ticketsBkt), err)
}
} }
return nil return nil

14
database/fees.go → database/tickets.go
View File

@ -1,7 +1,7 @@
package database package database
type Fees struct { type Ticket struct {
TicketHash string Hash string
CommitmentSignature string CommitmentSignature string
FeeAddress string FeeAddress string
Address string Address string
@ -15,7 +15,7 @@ func (db *VspDatabase) InsertFeeAddressVotingKey(address, votingKey string, vote
return nil return nil
} }
func (db *VspDatabase) InsertFeeAddress() error { func (db *VspDatabase) InsertFeeAddress(t Ticket) error {
return nil return nil
} }
@ -23,10 +23,10 @@ func (db *VspDatabase) GetInactiveFeeAddresses() ([]string, error) {
return []string{""}, nil return []string{""}, nil
} }
func (db *VspDatabase) GetFeesByFeeAddress(feeAddr string) (Fees, error) { func (db *VspDatabase) GetFeesByFeeAddress(feeAddr string) (Ticket, error) {
return Fees{}, nil return Ticket{}, nil
} }
func (db *VspDatabase) GetFeeAddressByTicketHash() (Fees, error) { func (db *VspDatabase) GetFeeAddressByTicketHash() (Ticket, error) {
return Fees{}, nil return Ticket{}, nil
} }