forked from NebulousLabs/Sia
-
Notifications
You must be signed in to change notification settings - Fork 7
/
persist.go
84 lines (74 loc) · 1.71 KB
/
persist.go
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
package explorer
import (
"os"
"path/filepath"
"github.com/NebulousLabs/Sia/encoding"
"github.com/NebulousLabs/Sia/modules"
"github.com/NebulousLabs/Sia/persist"
"github.com/NebulousLabs/Sia/types"
"github.com/coreos/bbolt"
)
var explorerMetadata = persist.Metadata{
Header: "Sia Explorer",
Version: "0.5.2",
}
// initPersist initializes the persistent structures of the explorer module.
func (e *Explorer) initPersist() error {
// Make the persist directory
err := os.MkdirAll(e.persistDir, 0700)
if err != nil {
return err
}
// Open the database
db, err := persist.OpenDatabase(explorerMetadata, filepath.Join(e.persistDir, "explorer.db"))
if err != nil {
return err
}
e.db = db
// Initialize the database
err = e.db.Update(func(tx *bolt.Tx) error {
buckets := [][]byte{
bucketBlockFacts,
bucketBlockIDs,
bucketBlocksDifficulty,
bucketBlockTargets,
bucketFileContractHistories,
bucketFileContractIDs,
bucketInternal,
bucketSiacoinOutputIDs,
bucketSiacoinOutputs,
bucketSiafundOutputIDs,
bucketSiafundOutputs,
bucketTransactionIDs,
bucketUnlockHashes,
}
for _, b := range buckets {
_, err := tx.CreateBucketIfNotExists(b)
if err != nil {
return err
}
}
// set default values for the bucketInternal
internalDefaults := []struct {
key, val []byte
}{
{internalBlockHeight, encoding.Marshal(types.BlockHeight(0))},
{internalRecentChange, encoding.Marshal(modules.ConsensusChangeID{})},
}
b := tx.Bucket(bucketInternal)
for _, d := range internalDefaults {
if b.Get(d.key) != nil {
continue
}
err := b.Put(d.key, d.val)
if err != nil {
return err
}
}
return nil
})
if err != nil {
return err
}
return nil
}