store siafund pool in metrics

SiaFoundation · Sep 11, 2024 · 5f9dcee · 5f9dcee
1 parent 70b5472
commit 5f9dcee
Show file tree

Hide file tree

Showing 5 changed files with 8 additions and 3 deletions.
diff --git a/explorer/types.go b/explorer/types.go
@@ -144,6 +144,8 @@ type Metrics struct {
 	Index types.ChainIndex `json:"index"`
 	// Current difficulty
 	Difficulty consensus.Work `json:"difficulty"`
+	// Siafund pool value
+	SiafundPool types.Currency `json:"siafundPool"`
 	// Total announced hosts
 	TotalHosts uint64 `json:"totalHosts"`
 	// Number of active contracts

diff --git a/explorer/update.go b/explorer/update.go
@@ -171,8 +171,9 @@ func applyChainUpdate(tx UpdateTx, cau chain.ApplyUpdate) error {
 	if err != nil {
 		return err
 	}
-	state.Metrics.Difficulty = cau.State.Difficulty
 	state.Metrics.Index = cau.State.Index
+	state.Metrics.Difficulty = cau.State.Difficulty
+	state.Metrics.SiafundPool = cau.State.SiafundPool
 
 	return tx.ApplyIndex(state)
 }

diff --git a/persist/sqlite/consensus.go b/persist/sqlite/consensus.go
@@ -910,10 +910,11 @@ func updateFileContractElements(tx *txn, revert bool, b types.Block, fces []expl
 }
 
 func addMetrics(tx *txn, s explorer.UpdateState) error {
-	_, err := tx.Exec(`INSERT INTO network_metrics(block_id, height, difficulty, total_hosts, active_contracts, failed_contracts, successful_contracts, storage_utilization, circulating_supply, contract_revenue) VALUES (?, ?, ?, ?, ?, ?, ?, ?, ?, ?)`,
+	_, err := tx.Exec(`INSERT INTO network_metrics(block_id, height, difficulty, siafund_pool, total_hosts, active_contracts, failed_contracts, successful_contracts, storage_utilization, circulating_supply, contract_revenue) VALUES (?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?)`,
 		encode(s.Metrics.Index.ID),
 		s.Metrics.Index.Height,
 		encode(s.Metrics.Difficulty),
+		encode(s.Metrics.SiafundPool),
 		s.Metrics.TotalHosts,
 		s.Metrics.ActiveContracts,
 		s.Metrics.FailedContracts,

diff --git a/persist/sqlite/init.sql b/persist/sqlite/init.sql
@@ -17,6 +17,7 @@ CREATE TABLE network_metrics (
 
 	height INTEGER NOT NULL,
 	difficulty BLOB NOT NULL,
+	siafund_pool BLOB NOT NULL,
 	total_hosts INTEGER NOT NULL,
 	active_contracts INTEGER NOT NULL,
 	failed_contracts INTEGER NOT NULL,

diff --git a/persist/sqlite/metrics.go b/persist/sqlite/metrics.go
@@ -11,7 +11,7 @@ import (
 // Metrics implements explorer.Store
 func (s *Store) Metrics(id types.BlockID) (result explorer.Metrics, err error) {
 	err = s.transaction(func(tx *txn) error {
-		err = tx.QueryRow(`SELECT block_id, height, difficulty, total_hosts, active_contracts, failed_contracts, successful_contracts, storage_utilization, circulating_supply, contract_revenue FROM network_metrics WHERE block_id = ?`, encode(id)).Scan(decode(&result.Index.ID), &result.Index.Height, decode(&result.Difficulty), &result.TotalHosts, &result.ActiveContracts, &result.FailedContracts, &result.SuccessfulContracts, &result.StorageUtilization, decode(&result.CirculatingSupply), decode(&result.ContractRevenue))
+		err = tx.QueryRow(`SELECT block_id, height, difficulty, siafund_pool, total_hosts, active_contracts, failed_contracts, successful_contracts, storage_utilization, circulating_supply, contract_revenue FROM network_metrics WHERE block_id = ?`, encode(id)).Scan(decode(&result.Index.ID), &result.Index.Height, decode(&result.Difficulty), decode(&result.SiafundPool), &result.TotalHosts, &result.ActiveContracts, &result.FailedContracts, &result.SuccessfulContracts, &result.StorageUtilization, decode(&result.CirculatingSupply), decode(&result.ContractRevenue))
 		if err != nil {
 			return fmt.Errorf("failed to get metrics: %w", err)
 		}