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
85
86
87
88
89
90
91
92
|
// The explorer module provides a glimpse into what the Sia network
// currently looks like.
package explorer
import (
"errors"
"github.com/NebulousLabs/Sia/modules"
"github.com/NebulousLabs/Sia/persist"
"github.com/NebulousLabs/Sia/types"
)
const (
// hashrateEstimationBlocks is the number of blocks that are used to
// estimate the current hashrate.
hashrateEstimationBlocks = 200 // 33 hours
)
var (
errNilCS = errors.New("explorer cannot use a nil consensus set")
)
type (
// fileContractHistory stores the original file contract and the chain of
// revisions that have affected a file contract through the life of the
// blockchain.
fileContractHistory struct {
Contract types.FileContract
Revisions []types.FileContractRevision
StorageProof types.StorageProof
}
// blockFacts contains a set of facts about the consensus set related to a
// certain block. The explorer needs some additional information in the
// history so that it can calculate certain values, which is one of the
// reasons that the explorer uses a separate struct instead of
// modules.BlockFacts.
blockFacts struct {
modules.BlockFacts
Timestamp types.Timestamp
}
// An Explorer contains a more comprehensive view of the blockchain,
// including various statistics and metrics.
Explorer struct {
cs modules.ConsensusSet
db *persist.BoltDatabase
persistDir string
}
)
// New creates the internal data structures, and subscribes to
// consensus for changes to the blockchain
func New(cs modules.ConsensusSet, persistDir string) (*Explorer, error) {
// Check that input modules are non-nil
if cs == nil {
return nil, errNilCS
}
// Initialize the explorer.
e := &Explorer{
cs: cs,
persistDir: persistDir,
}
// Initialize the persistent structures, including the database.
err := e.initPersist()
if err != nil {
return nil, err
}
// retrieve the current ConsensusChangeID
var recentChange modules.ConsensusChangeID
err = e.db.View(dbGetInternal(internalRecentChange, &recentChange))
if err != nil {
return nil, err
}
err = cs.ConsensusSetSubscribe(e, recentChange)
if err != nil {
// TODO: restart from 0
return nil, errors.New("explorer subscription failed: " + err.Error())
}
return e, nil
}
// Close closes the explorer.
func (e *Explorer) Close() error {
return e.db.Close()
}
|
