Merge pull request #300 from SiaFoundation/bustedware/prometheus-updates

Prometheus updates
SiaFoundation · Feb 8, 2024 · 3ba5781 · 3ba5781
2 parents 3767237 + 3749f0a
commit 3ba5781
Show file tree

Hide file tree

Showing 5 changed files with 388 additions and 132 deletions.
diff --git a/api/endpoints.go b/api/endpoints.go
@@ -98,7 +98,7 @@ func (a *api) handleGETConsensusState(c jape.Context) {
 }
 
 func (a *api) handleGETSyncerAddr(c jape.Context) {
-	c.Encode(string(a.syncer.Address()))
+	a.writeResponse(c, http.StatusOK, SyncerAddrResp(a.syncer.Address()))
 }
 
 func (a *api) handleGETSyncerPeers(c jape.Context) {
@@ -110,7 +110,7 @@ func (a *api) handleGETSyncerPeers(c jape.Context) {
 			Version: peer.Version,
 		}
 	}
-	c.Encode(peers)
+	a.writeResponse(c, http.StatusOK, PeerResp(peers))
 }
 
 func (a *api) handlePUTSyncerPeer(c jape.Context) {
@@ -132,7 +132,7 @@ func (a *api) handleDeleteSyncerPeer(c jape.Context) {
 }
 
 func (a *api) handleGETAlerts(c jape.Context) {
-	c.Encode(a.alerts.Active())
+	a.writeResponse(c, http.StatusOK, AlertResp(a.alerts.Active()))
 }
 
 func (a *api) handlePOSTAlertsDismiss(c jape.Context) {
@@ -386,15 +386,16 @@ func (a *api) handleGETWalletTransactions(c jape.Context) {
 	if !a.checkServerError(c, "failed to get wallet transactions", err) {
 		return
 	}
-	c.Encode(transactions)
+
+	a.writeResponse(c, http.StatusOK, WalletTransactionsResp(transactions))
 }
 
 func (a *api) handleGETWalletPending(c jape.Context) {
 	pending, err := a.wallet.UnconfirmedTransactions()
 	if !a.checkServerError(c, "failed to get wallet pending", err) {
 		return
 	}
-	c.Encode(pending)
+	a.writeResponse(c, http.StatusOK, WalletPendingResp(pending))
 }
 
 func (a *api) handlePOSTWalletSend(c jape.Context) {
@@ -533,7 +534,7 @@ func (a *api) handlePUTSystemDir(c jape.Context) {
 }
 
 func (a *api) handleGETTPoolFee(c jape.Context) {
-	c.Encode(a.tpool.RecommendedFee())
+	a.writeResponse(c, http.StatusOK, TPoolResp(a.tpool.RecommendedFee()))
 }
 
 func (a *api) handleGETAccounts(c jape.Context) {