mirror of
https://github.com/hanzoai/bootnode.git
synced 2026-10-25 02:31:30 +00:00
zeekayandHanzo Dev
734997e46c
The lux.cloud dashboard was blank because the collector could not reach a
single validator. Two independent breaks, either one fatal:
1. It called /ext. luxd 1.36 serves /v1 only — /ext/info is 404 — and the
collector's _rpc() maps any non-200 to None, so every field came back
null with no error anywhere.
2. It dialled 15 hardcoded public LoadBalancer IPs. There are now zero
LoadBalancer Services in lux-mainnet/testnet/devnet; those IPs do not
answer at all (connect timeout, not 404).
Both are the same root defect: the observer was outside the thing it observes
and had to be told where to look. So the observer moves in. Running in lux-k8s,
a validator's address is its pod IP, read from the pod list on every
collection — there is nothing left to configure and nothing left to go stale.
Chain facts come from the node itself over /v1: info.getNodeVersion,
getNodeID, getNodeIP, peers, isBootstrapped per chain, eth_blockNumber at
/v1/bc/C/rpc (the bc/ segment is load-bearing; /v1/C/rpc is not a route) and
platform.getHeight at /v1/bc/P, which quotes its integer.
That also collapses the MODE A / MODE B split: there is one path, not two.
Two corrections to what the old collector reported:
version is now what the fleet RUNS, not what the CR declares. The mainnet
LuxNetwork CR asks for ghcr.io/luxfi/node:v1.34.0, a tag that does not
exist; the nodes are on luxd/1.36.2. The dashboard must show the running
truth, so observation wins and image keeps the declared value.
external_ip becomes ip, matching console/lib/fleet.ts, and carries the
address the node advertises for itself (info.getNodeIP) rather than an
address someone wrote down.
Degraded is reported as degraded. A node that does not answer keeps every
field null and counts against nodes_rpc_ok; it is never smoothed over.
Placement: this stays in hanzoai/bootnode rather than folding into
hanzoai/cloud. cloud is not deployed on lux-k8s, and standing the whole
monolith up inside the chain cluster to run a read-only collector is a far
larger change than the collector itself. The surface is registered with zip's
Group; the route set is unchanged.
Deploy: Deployment/Service/RBAC in lux-k8s (lux-fleet.yaml, read-only —
list/get on pods and luxnetworks, no pods/proxy, no exec). The public URL
resolves to bootnode-k8s, so that cluster forwards just /v1/fleets/lux across
(lux-fleet-bridge.yaml); no other path on the host is touched.
Tests: a luxd stub that 404s anything outside /v1 and quotes platform height;
assertions that every probe path is under /v1, that no wire key is ever
omitted (an absent key reads as undefined and blanks a cell), that a down node
stays null, and that /v1/fleets/lux/zzzz is 404 next to a 200 on /overview.
Co-authored-by: Hanzo Dev <[email protected]>
62 lines
1.7 KiB
Go
62 lines
1.7 KiB
Go
package fleet
|
|
|
|
import (
|
|
"bytes"
|
|
"context"
|
|
"encoding/json"
|
|
"net/http"
|
|
"time"
|
|
)
|
|
|
|
// Markets counts the venues listed on a network's native DEX graph.
|
|
type Markets interface {
|
|
Count(ctx context.Context, network string) (int, bool)
|
|
}
|
|
|
|
// graphHost is the explorer that serves each network's DEX graph.
|
|
var graphHost = map[string]string{
|
|
"mainnet": "explorer.lux.network",
|
|
"testnet": "explorer.testnet.lux.network",
|
|
"devnet": "explorer.devnet.lux.network",
|
|
}
|
|
|
|
// Graph reads the market count from the explorer's DEX GraphQL endpoint.
|
|
// A network whose graph is not up simply reports no count.
|
|
type Graph struct{ http *http.Client }
|
|
|
|
// NewGraph returns a market counter with a short budget — the count is a
|
|
// garnish on the overview, never a reason to hold it up.
|
|
func NewGraph() *Graph { return &Graph{http: &http.Client{Timeout: 4 * time.Second}} }
|
|
|
|
// Count returns the number of markets, and whether the graph answered.
|
|
func (g *Graph) Count(ctx context.Context, network string) (int, bool) {
|
|
host, ok := graphHost[network]
|
|
if !ok {
|
|
return 0, false
|
|
}
|
|
body := []byte(`{"query":"{ markets { id } }"}`)
|
|
req, err := http.NewRequestWithContext(ctx, http.MethodPost,
|
|
"https://"+host+"/v1/graph/lux/dex/graphql", bytes.NewReader(body))
|
|
if err != nil {
|
|
return 0, false
|
|
}
|
|
req.Header.Set("Content-Type", "application/json")
|
|
resp, err := g.http.Do(req)
|
|
if err != nil {
|
|
return 0, false
|
|
}
|
|
defer resp.Body.Close()
|
|
if resp.StatusCode != http.StatusOK {
|
|
return 0, false
|
|
}
|
|
var out struct {
|
|
Data struct {
|
|
Markets []json.RawMessage `json:"markets"`
|
|
} `json:"data"`
|
|
}
|
|
if json.NewDecoder(resp.Body).Decode(&out) != nil || out.Data.Markets == nil {
|
|
return 0, false
|
|
}
|
|
return len(out.Data.Markets), true
|
|
}
|