# v2 git bundle 43084ab84df098eaab86aa5f1bf5ced0942cb806 refs/heads/bundle 43084ab84df098eaab86aa5f1bf5ced0942cb806 HEAD PACKxKN0 =%6xN!Ă{ 'v 4 Fhz35S%?RrD>L#{?ll,ydZĄW_8+Αc 9CxvxMuxu5K=u~b .Ȉiڻ;0m cޠ.j3UΟuMrގy4R@4U x_N0 s K<"Ft͌bLtiR%)+'۟gf"@]{$JuZP. c%[tX þfI:eF:8a\뵞Sw?[.JչLqS4P N!JxsֺT+- :/0EG[Cvv.S)`)L{%G )|c5ax )BM $w㍸L@Rnӑtrn!Ptt̙l 5k[ˎׅb2x/tree 68a63bc88e9feb5fbd10abd209fe87bf4f419ded parent c2ab1ea2d487ac345c4e1d73397892b8e5bc2746 author Darkhorse7stars 1779620243 -0700 committer Darkhorse7stars 1779620243 -0700 deps: bump indexer to 0.20260524105612-65220f1104cd Pulls luxfi/indexer#9 — formatAddress + addrCounters now read both the legacy `transactions_count` / `contract_code` and the SQLite-backed `tx_count` / `code` column names, and coerce nil counters to int64(0) so the Blockscout-derived SPA can call .toLocaleString() without crashing. Repros against rpc.dev.redacted.com: GET /v1/indexer/evm/addresses/0x58a86aafb6cdd0989c799353c891e420fb530e0a returned transactions_count: null + is_contract: false for a real deployed AMM pool → now returns the actual tx count + is_contract: true. I/x tree b32d9907be943012c2b933d9f5964669730e2a6f parent 1645c44a7976588af7767463ec7abe978c40a372 author Darkhorse7stars <92065535+Darkhorse7stars@users.noreply.github.com> 1779617218 -0700 committer GitHub 1779617218 -0700 ci: drop arm64 QEMU build (2h -> ~5 min) (#11) The previous matrix did linux/amd64,linux/arm64 with arm64 via docker/setup-qemu-action. QEMU-emulated builds of this image (Next.js SPA + Go cgo-sqlite) ran for ~2 hours per tag — fast enough to bottleneck every hotfix tag. Drop arm64. Cluster runners are amd64; Mac devs already run native arm64 under OrbStack with its own arm64 base story. If we ever need an arm64 multi-arch index, the right path is a second matrix entry on a native arm64 runner — not QEMU.]x)tree 2d465242887e048e5300993fd4cb9bdebd7d736f parent f72759aa0c8cd5b9190f71ee77f84ebf378820d5 author Darkhorse7stars <92065535+Darkhorse7stars@users.noreply.github.com> 1779608652 -0700 committer GitHub 1779608652 -0700 indexer: wire chains[].indexer.start_block + default devnet chainId (#10) Two related fixes for running the explorer against a mainnet-fork devnet: 1. Honor the per-chain `indexer.start_block` field from chains.yaml when the indexer DB is fresh. Without this the indexer always backfills from block 0, which on a mainnet fork is 25M+ blocks of irrelevant pre-fork history. Now an operator can set: chains: - slug: evm rpc: http://anvil:8545 indexer: start_block: 25162000 and the indexer skips to that block on first run. Once any rows exist in evm_blocks, start_block is ignored and indexing resumes from MAX(number)+1 as before — backward-compatible for fresh-genesis chains. 2. Default the bundled SPA's NETWORK_ID to 8675312 (the Liquid devnet chain ID). The Dockerfile previously inherited luxfi/explore's default of 8675311 — a stale leftover from before the devnet chainId migration. Adds NETWORK_ID / NETWORK_NAME / CURRENCY_SYMBOL as build-args so the same Dockerfile produces correct images for devnet/testnet/mainnet. Requires luxfi/indexer #8 (StartBlock field on evm.Config) — bumped via `go mod edit` to the post-merge commit d5e65d4b50c1.]W.Gx|tree abfe5dc2b9cd0a7a48fa5dd67a21a5394276ab87 parent 3429fab105dded2a6751647272d7034d5658064f author Darkhorse7stars <92065535+Darkhorse7stars@users.noreply.github.com> 1779420692 -0700 committer GitHub 1779420692 -0700 fix(sse): minimal HEAD response to avoid GCP/Traefik 502 on streaming content-type (#9) GCP HTTP/2 load balancers (and Traefik in some configs) return 502 to clients when a HEAD response carries `Connection: keep-alive` plus a streaming content-type — because they expect HEAD to be a closed-body response, not an opened SSE stream. Symptom: external `curl -I https://.../v1/base/realtime` → 502 even though in-cluster `curl -I http://localhost:8090/v1/base/realtime` → 200 OK with full SSE headers. SPA's `fetch(..., {method:'HEAD'}).then(r => r.ok)` gets false → live channel `disabled=true` → no live updates ever fire. Fix: HEAD pre-flight returns ONLY `Content-Type: text/event-stream` + 200, without the streaming-only headers. The full SSE header set still ships on the actual GET stream. Applies to both the per-channel HandleSSE() and the multiplexed HandleMultiplexedSSE() handlers."fxatree de3bf981ef4194c6bd1abf733996872270b27eef parent b3af1c074fabe026a0381ab883a3f029962944b5 author Darkhorse7stars <92065535+Darkhorse7stars@users.noreply.github.com> 1779420479 -0700 committer GitHub 1779420479 -0700 feat(realtime): add /v1/base/realtime multiplexed SSE channel (#8) The bundled SPA opens a single EventSource at /v1/base/realtime and routes incoming frames via msg.event off a handler map — see realtime_sse.go for the wire shape. Per-channel /blocks /transactions etc. stay for external consumers; the SPA only uses this one path. client.es.onmessage = o => { const c = JSON.parse(o.data); const d = this.handlers.get(c.event); if (d) for (const m of d) m(c.data); }; Wire: - HandleMultiplexedSSE() attaches a wildcard sseClient (channel=`*`) - Broadcast() now builds two SSE payloads per event: perChannel: existing `event:\ndata:\n\n` framing for /blocks /transactions /etc. wildcard: `data:{"event":,"chain":,"data":<...>}\n\n` for /v1/base/realtime — no `event:` line so SPA's onmessage gets the JSON envelope and dispatches. - sseRegistry.fanout dispatches both payloads to matching clients based on channel ("*" → wildcard, "blocks" → perChannel) - main.go mounts GET + HEAD /v1/base/realtime (HEAD is the SPA's pre-flight to decide whether to disable the live channel). Without this path the SPA's HEAD pre-flight got a 404 (the explorer SSE-HEAD-silencer from #4) and the client set `disabled=true`, so no live updates ever reached the home page.$1Gxtree fdc48f3ac2b455d3f4ae846fa534011dbaa212b7 parent 781712344bf1a656e665fb2577ee89ed0858a01a author Darkhorse7stars <92065535+Darkhorse7stars@users.noreply.github.com> 1779419718 -0700 committer GitHub 1779419718 -0700 fix(supervisor): preserve unrecognized first-segment when default-routing /v1/indexer (#7) dispatchIndexer's splitSlug peels off the first segment as a "slug" if it matches the slug regex ([a-z0-9][a-z0-9-]{0,63}). When that segment turns out NOT to be a registered chain, the previous code forwarded only the REMAINDER to the default chain — so `/v1/indexer/main-page/blocks` silently became `/v1/indexer/evm/blocks` server-side, a completely different endpoint that returns a paginated envelope instead of the raw array the SPA expects. The SPA's home page widget does `data.slice(0, 8).map(...)` on the result and threw "o.slice is not a function" against the envelope shape. Fix: when the parsed slug isn't a registered chain, re-join it with the rest before delegating so the original path is preserved under the default chain (`/v1/indexer/main-page/blocks` → `/v1/indexer/evm/main-page/blocks`).{>xtree da4ba9c87520199170911fa37074680541f61043 parent 01f121746be1bce47c7e45b533c61afbb81c03b7 author Darkhorse7stars <92065535+Darkhorse7stars@users.noreply.github.com> 1779415778 -0700 committer GitHub 1779415778 -0700 feat(realtime): bridge per-chain block events into the realtime hub (#6) When ChainSupervisor.AttachRealtime is called (from main), each chain's indexer.Subscriber.OnBroadcast is wired to push block events into the RealtimeHub on the chain's slug. The hub then fans out to WebSocket clients (existing path) and SSE subscribers (new in #5). Requires luxfi/indexer v1.4.4 — pulls in the exported Subscriber() accessor. End-to-end chain: evm.Indexer.indexBlock → Subscriber.BroadcastBlock → OnBroadcast → RealtimeHub.Broadcast → ws.send + SSE fanout → SPA EventSource Now /blocks, /transactions, /token-transfers, etc. on the explorer host actually stream live events as blocks land instead of just returning HEAD 200 with no payload.IUjxWrSQ.H$DQ(ʮVĉGR^d\ bC`.LIfr`~~g?v2Svwg$ҹLƋ,IErl.,<ϣFMt"&|q~y!y$4MY>gY$ZWԆ^ _+ cb2gϞXF66^)WIK:ӳx2x>GxZ)礡/{&bwy-ʥp}#ET%W$iFi!%ݐYS+,Vg5? SC?7v8CjMo_k8:EY&"]S#\a;zW&ԇ KfN=idҨ, ZY @\EQ.]Z[SJ(mAtП^5GՉ?+ʔIGwa(=GV:c`q Wҙ| WÈxČt;;`SRfrhE' "UU2SrK" Hd*@P:ےtt@Q/8ppze==mSkx(@o|sCn۠c쎨^L+5QԩZQ3 plĠL='mF+agfCD2~>?ߕ;ۍ9jyh֭/gmdr[]EJ*z_-*YƮ2ѩ$J}S=`MD{ъKD4Mr Q-ֱS(-`PH9+˜*Q/}qsSTOΊ*t.( 4H*_xIBK3uMUouX+Xe[ڌX ; J[Y JαkJeOfyFSOCxYC@Ց)d9}t|@0ȷ֞4dayJB"/8ŗG%;uT}ÃXzheSߏJf^W䩲|-'D[xb@XI('O .-v*#waoAykp\EX>2[+SR N,,7U0 ow̓-9_gSZ{НxU/sVplԷ;fw2%z @ׂ; A9X )xݍ7Fe0`p=VCOn|)]/i.L -w֟- Cb D($[:ֶ&+=˝$mD2OjLC(-漆L~ed ] ߄`tc>gu滗fcDJnDx[΂8;ٕѧYAE _;5lpc1\{ƪS%R?aGf̳n_À_`<FG8z0 "y7gdP7F^6vB[~l d nZH߳h07[wT j`/ɛ)y) ʬӜ_vĈ ;[ޖ~gmax Te㳄yfm|XY;~/>[ZF)QnlyELSs$ 6c-_$>I`@!o^Y3xج>‘4 )oJnp`4<@àBw-&6k{}+ 6ǰ iUQ E(-v;@GO8i5Z',k\*QDlԨD k $\&5Yt j Jo$Ta[D?$SxeTQ6)mv4 H"ioѢ_ġE"UڵR!r,'鐻N%qf{o"xsYf/%6e-WVVMBlWE~!\Z`jfU5\o*b|uoZV>xcs(6,V뢄EsخS!*jxf^/*CQ7mjcRYЈy ͏ Brk01v"ԃE,ۣ񰻣{~ArcP4M;Җf-!`ɂ=7z ա 0 pO+$NI&qx:{e?$VO8MgpBy^kz]3u$@ 8+ { ZSá`A 8$0 sxH 7RKOepTסP<֑56|j+FP6Gts Ttǵ:瀞\l"w]BDO@S2xެkzqy";xHp*ʢ>#lr+)hqJg(*x3x]eΗMODT%@H wʫɇfx/tree 4a3520bf2f2184bb8c1c19162cfdba7471d8af38 parent 9f018edb60cfc9aae09ffaf5ef87483d7b2837fa author Zach Kelling 1779222063 -0700 committer Zach Kelling 1779222063 -0700 ci: switch workflows to lux-build (luxfi-scoped ARC pool) Cross-org runs-on dispatch failure: hanzo-build-linux-amd64 scale set is registered to github.com/hanzoai and silently rejects luxfi/* jobs. Switch to lux-build (githubConfigUrl=github.com/luxfi, max 20). ix tree 2f2a5c66dc9a24f0e4d8b934ddcf08160dfbdf2f parent c5227405f31443affb57c898a31069635e9a659c author Zach Kelling 1779205220 -0700 committer Zach Kelling 1779205220 -0700 ci: rip orphan replace block (graph + indexer sibling-dir shims) ;Q`xtree fe946c3655d13d622306adf8142fa975c2226355 parent 1d853ed3289a0d44dc82c28eb1a9710af612e18b author Zach Kelling 1779204815 -0700 committer Zach Kelling 1779204815 -0700 ci: rip ../graph + ../indexer replace shims; bump to graph v1.2.0 + indexer v1.4.1 Sx|tree bb7107d16c636d6f9d677cd8ef75176724440b5a parent 34b016037668f9eaff4cc89ea5be3886c6c3d868 author Zach Kelling 1779202927 -0700 committer Zach Kelling 1779203016 -0700 ci: fix runner label (hanzo-build pool) Imaginary runner label `lux-build-linux-amd64` does not exist. The live amd64 pool is `hanzo-build-linux-amd64`. - docker.yml: docker job KUxxvtree 1b601c107e5b2b5127157e64b2b0a7da33b69766 parent b043993d03df852a3fcaab07308bcdd43877b6b1 author Zach Kelling 1778953747 -0700 committer GitHub 1778953747 -0700 chore: add LICENSE (BSD 3-Clause License) + LICENSING.md pointer (#3) * chore: add BSD 3-Clause License * docs: add LICENSING.md pointer to canonical IP/licensing strategy(qzxtree 840c342b50cfd524a73f5fcd9413e28594e3e367 parent a858082e3bfaf4e0ddb3bc690719f420130614fe author Zach Kelling 1778698780 -0700 committer Zach Kelling 1778698780 -0700 deps: luxfi/crypto v1.19.0 HBڐxtree 0397891d3eeabb15b99bfad03a75e845514d49b6 parent f5cfd03bd4478d758cc45733b691d77016f46643 author Zach Kelling 1778646558 -0700 committer Zach Kelling 1778646558 -0700 go.mod: bump go directive to 1.26.3 (security advisory) >Lxtree a84952a30b356e5c7a51e88fcc1b6daf11828d32 parent 4acc65c6d4f84d0c5c2faad94fdd7deaec5ac542 author Zach Kelling 1778089515 -0700 committer Zach Kelling 1778089515 -0700 ci: build multi-arch (amd64+arm64) — Mac devs run native arm64, no Rosetta Matches lux/graph + lux/indexer docker.yml. The unified explorer binary bundles SPA + indexer + graph in one image, so this is the canonical multi-arch artifact for the Liquidity local stack and devnet. ꞉x tree b1c7ed692ab2271e3f30a430260c0dacb79a9888 parent 3c6e210360ac381d850852d8e658d4e027363878 author Zach Kelling 1778045579 -0700 committer Zach Kelling 1778045579 -0700 ci(docker): amd64-only — multi-arch QEMU stalls on heavy SPA + Go P^xtree 5fb3ec9b9f4ec2dcf69999cd72a5a5b490e7e538 parent 494e3fe64555b1487ba2c8547140abc3d94e6954 author Zach Kelling 1778043245 -0700 committer Zach Kelling 1778043245 -0700 ci(docker): go build -mod=mod populates go.sum on the fly 4Nƙx tree 7b59cbbaa57ea015fe68d85dac4d25345445750b parent d41699bb3361f78f0a9ee3ade771360809d5ce9e author Zach Kelling 1778043048 -0700 committer Zach Kelling 1778043048 -0700 ci: drop ci.yml — Docker workflow handles cgo build via alpine YRxtree a2df3925c59af70f8680d33b1bc8888e18b55537 parent d17d22721eeed9cceaa3265313eb8b54dbbdd046 author Zach Kelling 1778042662 -0700 committer Zach Kelling 1778042662 -0700 ci: ARC has no_new_privs (no sudo); GOSUMDB=off everywhere *NƐxtree bad4bf082412b6cb2f5223dd0be204330b9850ee parent 7f0765d1127a67fb76e6922a8c672fcf75cb4087 author Zach Kelling 1778042082 -0700 committer Zach Kelling 1778042082 -0700 chore: gitignore .claude/ runtime state OHxtree 860487c5a72962cf6ab735df02dc6c8e3e119326 parent c979f90b2a92166c1875cf80308c9ea7b3c1986c author Zach Kelling 1778042065 -0700 committer Zach Kelling 1778042065 -0700 ci: regenerate go.sum at build time (proxy cache inconsistency) Pݗxtree abf969e54029a2f0e07558ff0fe2fe26203f078e parent 33658ed9cfea935b4f1b0921d86f6556ae030f91 author Zach Kelling 1778041088 -0700 committer Zach Kelling 1778041088 -0700 config: full chain list — all Lux native + subnet + external `Qx tree ab972f511d87cebfd24c8fec81cf93ffc1e27d23 parent 89c9cd2762bb86f349e695ff8291b924aa83a45b author Zach Kelling 1778040880 -0700 committer Zach Kelling 1778040880 -0700 ci: refresh go.sum (proxy hash drift), install gcc on ARC runner `Q“#x3tree 0fc515d6feb88821662d1b110955301bde2fcc95 parent 9b8044b665e0e12d0ce4808d7b5a3194b62a0939 author Zach Kelling 1778040555 -0700 committer Zach Kelling 1778040555 -0700 fix(go.sum): align hanzoai/replicate hash with proxy.golang.org Local go env had GONOSUMDB=...hanzoai/* which made `go mod tidy` use the GitHub-direct hash (YxjIynl…). CI fetches from proxy.golang.org which returns a different hash (5Rl3…) because the proxy cached a slightly different zip layout. Replace ours with the same value indexer/graph already use. N!xtree aa632e6aa6b40cbaced617b1d2f1945e97b3087a parent 9c1c9c7683028ed3cc2f0d7f364be29f98adc080 author Zach Kelling 1778040340 -0700 committer Zach Kelling 1778040340 -0700 ci: align with luxfi org's actual ARC pool (lux-build-linux-amd64) Mirrors the luxfi/indexer change: switch all workflows from the nonexistent hanzo-* labels to lux-build-linux-amd64, inline the multi- arch Docker build (arm64 via QEMU), drop the cross-org reusable, drop the workflow-sanity job that referenced cross-org actions. \x0tree db2b2f2448cf0d23ad32c220273256d39a0a16d4 parent 77c543529838e6db25f92f47f88291585cb379b8 author Zach Kelling 1778040232 -0700 committer Zach Kelling 1778040232 -0700 unified explorer: single Go binary with embedded SPA + per-chain graph Module renamed to github.com/luxfi/explorer (was -unified). Imports luxfi/indexer/{daemon,evm,storage,explorer} and luxfi/graph/{engine, indexer,storage} as libraries; embeds the luxfi/explore SPA via go:embed all:static. A new ChainSupervisor wraps the existing ChainRegistry: adding a chain (via config / mDNS / admin API) spawns a per-chain indexer goroutine plus one graph engine + indexer per enabled subgraph; removing cancels them and frees the routes from a sync.Map dispatcher mounted on /v1/indexer/, /v1/explorer/ (legacy alias), and /v1/graph/. Config schema is fully per-chain: indexer poll interval, list of graph subgraphs (each can pick a built-in schema like amm, securities, fhe…), brand (name/coin/accent + on-disk icon/logo paths), token features, and top-level networks list. /envs.js exposes the chain list and active brand to the SPA at runtime, so a deploy can rebrand by remounting chains.yaml + assets — no image rebuild. Dockerfile clones luxfi/explore + luxfi/indexer + luxfi/graph as siblings inside the build, populates ./static from the SPA build, and produces one binary. CI checks out the three repos as siblings so the local replace in go.mod works without tagged releases. #֛x tree e9ef4f120b79eaea5dcdbc67fc3b7a64d84a2f64 parent 0c29cc0a65548b9d3700f3d43928b4cff4c6c153 author Zach Kelling 1778036879 -0700 committer Zach Kelling 1778036879 -0700 chore(.gitignore): proper Go ignores, drop rebuild trigger comment SҖxftree a1f2c5fd9e7fc38a9e762f7514b9a9a8e6b4a78d parent 630ffa251a6398d79e96d2b39ec5855cbd3df0d6 parent 755b76ac22240f7aa06d5d0b0b940f3eb1cade0c author Zach Kelling 1778036368 -0700 committer GitHub 1778036368 -0700 Merge pull request #2 from luxfi/ci/multi-arch-native ci: build multi-arch (amd64 + arm64) on native runners4_oؘxtree a1f2c5fd9e7fc38a9e762f7514b9a9a8e6b4a78d parent dd387f3433d8725948027b5520c0d610b339a48e author Zach Kelling 1778036307 -0700 committer Zach Kelling 1778036307 -0700 ci: register hanzo runner labels for actionlint Kxtree 02aed7906e41349de231ca755ff5d96fc6f8daf9 parent 8e4e88c1d09a11263d6b873ae8274b2598cc07b5 author Zach Kelling 1778035887 -0700 committer Zach Kelling 1778035887 -0700 ci: use hanzo-* runner labels (sanity) >jGx,tree d5a98873ed8293956340c809fffad804ae7a3d36 parent 0531a94d58c5b3881b12a8ef1bcb9a86a00ff550 parent 630ffa251a6398d79e96d2b39ec5855cbd3df0d6 author Zach Kelling 1778034163 -0700 committer Zach Kelling 1778034163 -0700 merge(main): keep multi-arch + semver-only triggers |Zx?tree d5a98873ed8293956340c809fffad804ae7a3d36 parent b35ef6b747fe94d1dd2b2d9c5ac4bef9f7ec1e92 author Zach Kelling 1778034119 -0700 committer Zach Kelling 1778034119 -0700 explorer: remove Liquidity branding cross-contamination Drop the _lqd._tcp / lqd / liquid daemon entry from the mDNS service discovery list. The lqd daemon is the Liquidity-side white-label node binary; the OSS Lux explorer must not advertise it. "qؖxYtree 0b695143561ce964ded453a18b176ef8db3bddc2 parent 579d74c09a8664b3e10c1ade5217a0697471e10a author Zach Kelling 1778033309 -0700 committer Zach Kelling 1778033309 -0700 ci: build multi-arch (amd64 + arm64) on native runners Drop branch triggers, semver-only tags. Pin lux-build-linux-{amd64,arm64} ARC runners. Eliminates the amd64-only manifest that crashed Apple Silicon local k3d pulls. xtree 7fd06b2687f41531672d96953f410837b9ed557f parent 5e1d5c3f0337d04b4711bc2e5ca5af160f549757 author Zach Kelling 1776997394 -0700 committer GitHub 1776997394 -0700 ci: migrate to canonical docker-build reusable (#1) - Add docker.yml using hanzoai/.github/.github/workflows/docker-build.yml@main - Add workflow-sanity.yml to enforce canonical CI contract - Remove bespoke docker build steps from existing workflows Refs: hanzoai/.github canonical Docker CI contract.Px tree 7fd06b2687f41531672d96953f410837b9ed557f parent 5e1d5c3f0337d04b4711bc2e5ca5af160f549757 author Zach Kelling 1776997280 -0700 committer Zach Kelling 1776997280 -0700 ci: migrate to canonical docker-build reusable - Add docker.yml using hanzoai/.github/.github/workflows/docker-build.yml@main - Add workflow-sanity.yml to enforce canonical CI contract - Remove bespoke docker build steps from existing workflows Refs: hanzoai/.github canonical Docker CI contract. mxtree 05ec30403163c08342bb6aadcf78f72d50d2ce55 parent e8c2d51752df366e487b76a5f33d9b5eb357747c author Zach Kelling 1776374133 -0700 committer Zach Kelling 1776374133 -0700 ci: docker multi-arch build + semver release workflow \Mxtree ae8c1cbf01a3c4ef3b64f9442bedf313a5697b83 parent 90248d6c7bb2cae223a57b231d8d9bffb614e78f author Zach Kelling 1776077660 -0700 committer Zach Kelling 1776077660 -0700 fix: use lux-build runners, not generic self-hosted ON<xtree 67410a2f862abb06a0545f03e1f65d5d0e6869e3 parent 63a8610d3ebacf64a2634f38cccdf744d28990a6 author Zach Kelling 1776073381 -0700 committer Zach Kelling 1776073381 -0700 feat: use info.getChains for single-call discovery (no per-chain probing) Tšxtree 0ff63ccea78bbb19a3597efae560484f7e17f0da parent 82926899b7f341b085a4b12cfe0794dfe7a49a6e author Zach Kelling 1776071785 -0700 committer Zach Kelling 1776071785 -0700 fix: probe RPC before registering — only index chains this node actually tracks xYx tree f80df6b97507f299c3c70d1c113711d00044b827 parent 672dc81e5757d00125d361f4dd4c58f5dd324fe3 author Zach Kelling 1776070690 -0700 committer Zach Kelling 1776070690 -0700 fix: fully dynamic chain discovery — zero hardcoded chain lists }R~x tree 5c2106f955decb2bce0e4bed364ab821991d67a8 parent cca50859f0645a03a0885679c96d588eda838b20 author Zach Kelling 1776069740 -0700 committer Zach Kelling 1776069740 -0700 fix: per-daemon chain sets — liquid has evm/dex/fhe, not C/P/X Q*xtree 3a06e8dfee3ba02cf9b38c1052b2b0a3bca08186 parent bf584f6b48f9d265640f12d162b47250d18b1699 author Zach Kelling 1776069577 -0700 committer Zach Kelling 1776069577 -0700 feat: discover luxd, zood, lqd, hanzod, parsd via mDNS ZM'xtree 453428f8c721029ab777cb81e7d366459207548d parent ed8fb4b646ba370fab3b53583760b376f53d15b1 author Zach Kelling 1776069391 -0700 committer Zach Kelling 1776069391 -0700 feat: runtime chain registry, mDNS discovery, /v1/explorer/realtime Runtime-mutable chain registry with admin CRUD API, mDNS auto-discovery of local luxd nodes, and multi-chain WebSocket realtime subscriptions. Config sources (priority order): 1. Admin API (POST/PUT/DELETE /v1/explorer/admin/chains) 2. --config chains.yaml 3. CHAINS env var 4. mDNS _luxd._tcp discovery (lowest, never overrides manual) 21 tests, all passing. 2 Θxtree 200ce12a53e92c05fa83f229e3fa078c9b474bce parent 1a6d559ccfc01cdd2521511839f04334772dc735 author Zach Kelling 1776010884 -0700 committer Zach Kelling 1776010884 -0700 ci: trigger combined image rebuild UFx tree 80e2a7ada6b68d378a94574f2119a05b13b746d3 parent 7ee5150d270ca574c8e8f555a7048da9564df2bf author Zach Kelling 1775943083 -0700 committer Zach Kelling 1775943083 -0700 docs: full README, compose.yml, chains.example.yaml, healthcheck, CI Q$xCtree 7dff837e60515e0be8a2360b832f716818c1a67a parent cd4378e3f92324cd031ab01fcd584be7242e23d2 author Zach Kelling 1775940607 -0700 committer Zach Kelling 1775940607 -0700 feat: include graph engine (subgraph replacement) in combined image 4 repos, 4 images: indexer → chain data (blocks, txs, tokens, contracts) graph → subgraph events (swaps, pools, DeFi, GraphQL) explore → Next.js frontend explorer → all three combined (this) Single image contains 3 binaries: indexer, graph, explorer. Each can run standalone or together. ߿_xtree 30ec1903c50c309e778ff050ac500e7a227274c6 parent a2b779c20cbdce6ac8edd2ebf2a5e89e307f588f author Zach Kelling 1775940007 -0700 committer Zach Kelling 1775940007 -0700 fix: use pre-built indexer image as base, layer frontend on top Q%xTtree 65df319ce49c0c030046fb802b76864890d0b6bb author Zach Kelling 1775939328 -0700 committer Zach Kelling 1775939328 -0700 feat: combined explorer image (indexer backend + explore frontend) Three repos, three images: luxfi/indexer → ghcr.io/luxfi/indexer (Go backend, API + indexing) luxfi/explore → ghcr.io/luxfi/explore (Next.js frontend) luxfi/explorer → ghcr.io/luxfi/explorer (this: combined single image) Dockerfile pulls both repos at build time, embeds the Next.js static export into the Go binary via go:embed, produces a single container. uV&x31̒$c5c={.[9a%굡 XIfz^~Q*ķQa͌2?ȼQѮPU.٩Ei9 ?~|^8y\]|]rSl/hiSu_(PEyz9z9 mn[鯝j|Ynˌ[as [8tygY_YU laKGҦv:ăPQ\trf>9wv6Oӈ;U t^z>;wUrIrܫaJRN*ad2TⴔcMJMM K3tSsRS3ήֈlg//kaE9% .Cnif/)/I-.xШy՗>8q{Z 6=,+jZxeUd `4ep#8ڨ,=%KfꛀPqrQfAI1='%_-Wmv,x+"40000 .githubje}ZLuֱ"Cda:x+"40000 .github#+{"Ȼ9<;'""CJS`9x+"40000 .github^$':ry.bI"CM9x __ֈm2mWw1<&vܢXNsH I.x+"40000 .github*ߎ% w@KA뉭<%f"C99x+"40000 .githubmPϝ"CnF9x4 (E2գ_u)H #-x<40000 .githubsΣjQJh100644 .gitignoreEyTH))S7>rš 100644 config.goؽ#N!,y^R100644 frontend.go3d=<@>5c&100644 go.modm(śS^n b100644 go.sum7uJ !*gr100644 main.goBo X 8V0_9BLP&c@o:źZj+F)pL100644 registry_test.goYs5ZCC"J40000 static01~tHT4100644 supervisor.gob|3yaG-,J9'P5ܣJx+"40000 .githubMxC{V䯱Qckh"K`:x!eӃݚwdZ+q9>yX E/xE"40000 .github&қ_#{(a*к"C7uJ !*gryX!7Sx[$rQjٓU! [-xeD40000 .claude,9;- u40000 .github.B41d*"8_Efse`Rnc+sx "4' À !6œ㝶>jZG.xC"40000 .github~?צ~S<Q"8lpS @jwnc>Qx+"40000 .github ,d/`j*^Nm"K9xZL`>$T,]$.YIuqnc b-x+"40000 .github!rLbgX) i}b qu \x+"40000 .github;:5̄, 48"%Z9xC6#j 100644 go.sumzNv 3ս4w͍|QxC6 dɉ/ w"$100644 go.sumq ;t`S@O,1׳LQxC67i^ˤ,͌A100644 go.sum1)7|?.2sşxO100644 actionlint.yaml!UiQF!>F40000 workflows4:9?H,Qsx\y\xOO;M9g|R% 'xOO;uz] 84m0Wʭ 'xOO;'Ma:Cu:jh| N'xOO;Hz Y̥?{Umo F'xOO;Y\`0 ͆ 'xOO;bU_`,vܿF 'xOO;Ԥv߫4ko* 'xOO;K"0pj;(d 8 8'xOO;vh&:UQ ^x:self-hosted-runner: labels: - lux-build-linux-amd64 D8x&100644 docker.yml&bceJ`x name: Docker on: workflow_dispatch: push: tags: ['v*'] permissions: contents: read packages: write id-token: write # amd64-only on luxfi's native ARC pool — the SPA build (Next.js + 8GB # heap) + Go cgo-sqlite Docker build under QEMU arm64 emulation pushes # build time from ~5 min to ~2 hours. Cluster runners are amd64; Mac # devs use OrbStack which has its own arm64 base image story. arm64 # rebuilds can come back via a separate matrix entry on a native # arm64 runner — not via QEMU. jobs: docker: runs-on: lux-build steps: - uses: actions/checkout@v4 - uses: docker/setup-buildx-action@v3 with: driver: docker-container driver-opts: network=host - uses: docker/login-action@v3 with: registry: ghcr.io username: ${{ github.repository_owner }} password: ${{ secrets.GITHUB_TOKEN }} - id: meta uses: docker/metadata-action@v5 with: images: ghcr.io/luxfi/explorer flavor: latest=auto tags: | type=semver,pattern={{version}} type=semver,pattern={{major}}.{{minor}} type=sha,prefix=sha- - uses: docker/build-push-action@v6 with: context: . platforms: linux/amd64 labels: ${{ steps.meta.outputs.labels }} tags: ${{ steps.meta.outputs.tags }} cache-from: type=gha,scope=explorer cache-to: type=gha,scope=explorer,mode=max provenance: false push: true Mx8# Binaries bin/ explorer explorer-unified *.exe *.test # Coverage coverage.out coverage.html # Go workspace go.work go.work.sum # Editor .idea/ .vscode/ *.swp *.swo # OS .DS_Store # Local .env .env.local *.local # AI assistant context (not committed) AGENTS.md CLAUDE.md GEMINI.md QWEN.md # Runtime logs/ 8TcEx,# Binaries bin/ /explorer) .claude/ = ۽xVmo6_qs;KQ0Vv֠+{F2XcL힦VݘmXȩJf`e& T~k( =UXF?4rx~CCuQ'z8$bs`[鉃p_gT񂉫 bXו*_ EˈscNP*)Nt-ʻvnQ3Z6 ,=*. !eʚ3EͧVZR# 7X 3Z`{WF<0ߗ^տ_zw+>K'$v0zg+ìTp]Gn˂ɷ@?fn4R)%1f+.EV~p>|(/oQXӺ_xBSD 3-Clause License Copyright (c) 2024-2026 Lux Industries Inc. All rights reserved. Redistribution and use in source and binary forms, with or without modification, are permitted provided that the following conditions are met: 1. Redistributions of source code must retain the above copyright notice, this list of conditions and the following disclaimer. 2. Redistributions in binary form must reproduce the above copyright notice, this list of conditions and the following disclaimer in the documentation and/or other materials provided with the distribution. 3. Neither the name of the copyright holder nor the names of its contributors may be used to endorse or promote products derived from this software without specific prior written permission. THIS SOFTWARE IS PROVIDED BY THE COPYRIGHT HOLDERS AND CONTRIBUTORS "AS IS" AND ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE ARE DISCLAIMED. IN NO EVENT SHALL THE COPYRIGHT HOLDER OR CONTRIBUTORS BE LIABLE FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL DAMAGES (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES; LOSS OF USE, DATA, OR PROFITS; OR BUSINESS INTERRUPTION) HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGE.%x_# Licensing This repository is licensed under the **BSD 3-Clause License** (see [LICENSE](LICENSE)). It belongs to the **public** tier of the Lux three-tier IP strategy: anyone may use, fork, or redistribute it, including for commercial purposes, subject to the BSD 3-Clause License terms. For the canonical Lux IP and licensing strategy, see: For commercial inquiries that go beyond the public tier (e.g. private moat acceleration kernels, Eco-tier patent-protected primitives outside Authorized Networks), contact `licensing@lux.network`. Րxe# Explorer Single-binary Lux explorer: chain indexer, GraphQL engine, and SPA frontend in one Go process. Imports [`luxfi/indexer`](https://github.com/luxfi/indexer) and [`luxfi/graph`](https://github.com/luxfi/graph) as libraries; embeds the [`luxfi/explore`](https://github.com/luxfi/explore) Next.js build via `go:embed`. ``` ghcr.io/luxfi/explorer -> indexes one or more EVM chains (luxfi/indexer) -> exposes per-chain GraphQL (luxfi/graph) -> serves embedded SPA + REST API (luxfi/explore) ``` ## Routes | Path | Purpose | |---------------------------------------------------|----------------------------------| | `/` | SPA (embedded; SPA-routing fallback) | | `/envs.js` | Runtime config `window.ENV = {...}` | | `/icon.svg`, `/logo.svg` | Per-host brand assets (disk override) | | `/health` | Service health | | `/v1/indexer/*` | Default chain explorer API | | `/v1/indexer/{slug}/*` | Per-chain explorer API | | `/v1/explorer/{slug}/*` | Legacy alias for `/v1/indexer/{slug}` | | `/v1/graph/{slug}/{subgraph}/graphql` | Per-chain, per-subgraph GraphQL | | `/v1/explorer/admin/chains[/{slug}]` | Runtime registry CRUD | | `/v1/explorer/realtime` | WebSocket realtime hub | | `/v1/explorer/realtime/stats` | Realtime stats | ## Quick Start ```bash docker run -p 8090:8090 \ -v $(pwd)/chains.example.yaml:/etc/explorer/chains.yaml:ro \ -v explorer-data:/data \ ghcr.io/luxfi/explorer:latest \ --config /etc/explorer/chains.yaml ``` Or with compose: ```bash docker compose up ``` ## Configuration `chains.yaml` is the single source of truth. Every aspect of the deploy -- chains, branding, GraphQL subgraphs, network switcher links -- is per-chain customizable. See [`chains.example.yaml`](chains.example.yaml) for the full schema. ```yaml data_dir: /data http_addr: :8090 brand_default: name: Lux Explorer coin: LUX accent_color: "#5cf" networks: - { label: Mainnet, domain: explorer.lux.network, chain_id: 96369 } chains: - slug: cchain name: Lux C-Chain chain_id: 96369 type: evm rpc: https://api.lux.network/mainnet/ext/bc/C/rpc coin: LUX enabled: true default: true indexer: poll_interval: 30s graph: enabled: true subgraphs: - { name: amm, schema: amm, enabled: true } brand: name: Lux C-Chain accent_color: "#5cf" ``` `$ENV_VAR` substitution in `rpc:` / `ws:` lets one file template every network -- mount it read-only and inject secrets via env vars. ## Per-Network Customization The same image powers every deploy. To rebrand for a different network: 1. Mount a different `chains.yaml`. 2. Optionally mount `icon.svg` / `logo.svg` at the path referenced by `chains.yaml` -- they are read from disk per-request, not embedded. 3. Set environment variables to fill the `${VAR}` placeholders. No image rebuild needed. The SPA reads chain list and brand at runtime from `/envs.js`. ## Runtime Registry Chains can be added, updated, and removed at runtime without restart: ```bash # Add curl -X POST http://localhost:8090/v1/explorer/admin/chains \ -H 'Content-Type: application/json' \ -d '{"slug":"new","name":"New","chain_id":123,"rpc":"http://node:8545","type":"evm"}' # List curl http://localhost:8090/v1/explorer/admin/chains # Remove curl -X DELETE http://localhost:8090/v1/explorer/admin/chains/new ``` Adding a chain spawns its indexer + (optional) graph workers; removing cancels them and frees the routes. ## mDNS Discovery Set `EXPLORER_MDNS=true` to auto-register chains advertised by local Lux nodes (`_luxd._tcp`, `_zood._tcp`, `_hanzod._tcp`, `_parsd._tcp`). The explorer queries `info.getChains` on the discovered node and registers each tracked chain. mDNS-sourced chains never override config-sourced entries. ## Storage Layout ``` /data/ cchain/ query/indexer.db (SQLite WAL, indexer) {zapdb}/ (KV store) graph/ amm/graph.db (SQLite WAL, per-subgraph) zoo/ ... ``` Each chain (and each subgraph) owns an isolated SQLite + KV store. WAL is optionally streamed to S3 with PQ encryption when `REPLICATE_S3_ENDPOINT` is set -- see `luxfi/indexer/daemon`. ## Local Build ```bash # Sibling layout: ~/work/lux/{indexer,graph,explorer} cd ~/work/lux/explorer go build -o explorer . ``` `go.mod` uses local `replace` directives pointing at `../indexer` and `../graph`. Production CI clones all three repos into the same layout inside the Docker build. ## Endpoints (curl examples) ```bash curl http://localhost:8090/health curl http://localhost:8090/v1/indexer/cchain/blocks/latest curl -X POST http://localhost:8090/v1/graph/cchain/amm/graphql \ -H 'Content-Type: application/json' \ -d '{"query":"{ swaps(first:5) { id amount0 amount1 } }"}' ``` ## Related - [`luxfi/indexer`](https://github.com/luxfi/indexer) -- chain indexer library - [`luxfi/graph`](https://github.com/luxfi/graph) -- per-chain GraphQL library - [`luxfi/explore`](https://github.com/luxfi/explore) -- Next.js SPA xD# chains.example.yaml — full per-network customization for the unified Lux # explorer. Mount as /etc/explorer/chains.yaml or pass --config=chains.yaml. # # Every chain gets its own SQLite file under {data_dir}/{slug}/ and its own # /v1/indexer/{slug}/* + /v1/graph/{slug}/{subgraph}/* routes. Branding is # per-chain; the SPA reads it at runtime via /envs.js so a deploy can # rebrand by remounting this file + assets — no image rebuild. data_dir: /data http_addr: :8090 # Default branding the SPA uses when the request hostname does not match a # chain-specific brand below. Per-chain `brand:` overrides win. brand_default: name: Lux Explorer coin: LUX accent_color: "#5cf" icon_url: /icon.svg logo_url: /logo.svg # Cross-explorer link list rendered in the SPA's network switcher. networks: - label: Mainnet domain: explorer.lux.network chain_id: 96369 - label: Testnet domain: testnet.explorer.lux.network chain_id: 96368 - label: Devnet domain: devnet.explorer.lux.network chain_id: 96370 chains: # ── Lux native chains ───────────────────────────────────────── - slug: cchain name: Lux C-Chain chain_id: 96369 type: evm rpc: ${LUX_CCHAIN_RPC:-https://api.lux.network/ext/bc/C/rpc} coin: LUX enabled: true default: true indexer: { poll_interval: 30s } graph: enabled: true subgraphs: - { name: amm, schema: amm, enabled: true } - { name: securities, schema: securities, enabled: false } brand: name: Lux C-Chain coin: LUX accent_color: "#5cf" - slug: pchain name: P-Chain type: linear rpc: ${LUX_RPC:-https://api.lux.network}/ext/bc/P coin: LUX enabled: true - slug: xchain name: X-Chain type: dag rpc: ${LUX_RPC:-https://api.lux.network}/ext/bc/X coin: LUX enabled: true - slug: achain name: A-Chain type: dag rpc: ${LUX_RPC:-https://api.lux.network}/ext/bc/A coin: LUX enabled: true - slug: bchain name: B-Chain type: dag rpc: ${LUX_RPC:-https://api.lux.network}/ext/bc/B coin: LUX enabled: true - slug: qchain name: Q-Chain type: dag rpc: ${LUX_RPC:-https://api.lux.network}/ext/bc/Q coin: LUX enabled: true - slug: tchain name: T-Chain type: dag rpc: ${LUX_RPC:-https://api.lux.network}/ext/bc/T coin: LUX enabled: true - slug: zchain name: Z-Chain type: dag rpc: ${LUX_RPC:-https://api.lux.network}/ext/bc/Z coin: LUX enabled: true - slug: kchain name: K-Chain type: dag rpc: ${LUX_RPC:-https://api.lux.network}/ext/bc/K coin: LUX enabled: true # ── Lux subnet chains (EVM) ─────────────────────────────────── - slug: zoo name: Zoo chain_id: 200200 type: evm rpc: ${ZOO_RPC:-https://api.lux.network/ext/bc/Zoo/rpc} coin: ZOO enabled: true indexer: { poll_interval: 30s } graph: enabled: true subgraphs: - { name: amm, schema: amm, enabled: true } brand: name: Zoo coin: ZOO accent_color: "#7c3aed" - slug: hanzo name: Hanzo chain_id: 36963 type: evm rpc: ${HANZO_RPC:-https://api.lux.network/ext/bc/Hanzo/rpc} coin: HANZO enabled: true indexer: { poll_interval: 30s } graph: enabled: true subgraphs: - { name: amm, schema: amm, enabled: true } brand: name: Hanzo coin: HANZO accent_color: "#0b1220" - slug: spc name: SPC chain_id: 36911 type: evm rpc: ${SPC_RPC:-https://api.lux.network/ext/bc/SPC/rpc} coin: SPC enabled: true indexer: { poll_interval: 30s } - slug: pars name: Pars chain_id: 494949 type: evm rpc: ${PARS_RPC:-https://api.lux.network/ext/bc/Pars/rpc} coin: PARS enabled: true indexer: { poll_interval: 30s } - slug: dex name: Lux DEX type: evm rpc: ${LUX_RPC:-https://api.lux.network}/ext/bc/D/rpc coin: LUX enabled: true indexer: { poll_interval: 15s } graph: enabled: true subgraphs: - { name: amm, schema: amm, enabled: true } - { name: clob, schema: all, enabled: true } # ── External chains (bridge / MPC counterparties) ───────────── - slug: ethereum name: Ethereum chain_id: 1 type: evm rpc: ${ETH_RPC:-https://eth.llamarpc.com} coin: ETH enabled: false graph: enabled: false subgraphs: - { name: uniswap-v3, schema: uniswap-v3, enabled: true } - slug: arbitrum name: Arbitrum One chain_id: 42161 type: evm rpc: ${ARB_RPC:-https://arb1.arbitrum.io/rpc} coin: ETH enabled: false - slug: optimism name: Optimism chain_id: 10 type: evm rpc: ${OP_RPC:-https://mainnet.optimism.io} coin: ETH enabled: false - slug: base name: Base chain_id: 8453 type: evm rpc: ${BASE_RPC:-https://mainnet.base.org} coin: ETH enabled: false - slug: polygon name: Polygon chain_id: 137 type: evm rpc: ${POLYGON_RPC:-https://polygon-rpc.com} coin: MATIC enabled: false - slug: bsc name: BNB Chain chain_id: 56 type: evm rpc: ${BSC_RPC:-https://bsc-dataseed.binance.org} coin: BNB enabled: false - slug: avalanche name: Avalanche C-Chain chain_id: 43114 type: evm rpc: ${AVAX_RPC:-https://api.avax.network/ext/bc/C/rpc} coin: AVAX enabled: false - slug: solana name: Solana type: solana rpc: ${SOL_RPC:-https://api.mainnet-beta.solana.com} coin: SOL enabled: false - slug: bitcoin name: Bitcoin type: bitcoin rpc: ${BTC_RPC:-} coin: BTC enabled: false - slug: cosmos name: Cosmos Hub type: cosmos rpc: ${ATOM_RPC:-https://cosmos-rpc.publicnode.com} coin: ATOM enabled: false _ΗlxUQAn0U[KR"#r6A1eJ_pj/xwfm -GKP͌.}+J:sw4_@ Ɋ$3W?ppNˏ)48xVƭ|eA{8aQ2"o6‘uZ`:A :N83F((١tKӾNTdyߜӖt~$oeġu;rdO櫛<>=~~vuoUuwIR>*?cॿ23@/ZZ&kI8T ĊG%x{timage: ghcr.io/luxfi/explorer:lWDATA_DIR: /data HTTP_ADDR: :8090 EXPLORER_CONFIG: /etc/explorer/chains.yaml8)U)xWmo7l9H*w) E>$v3(i?>ڥ~ySܥ͊! լ..҂[}M³{nJ?t{}:p;`Py{ሁCOZ579$pA#[ s[cU%pf䤇F 'â*  &p ̔?FpYXB.޳/>]].>\,>b192 ky}k A4cN\YH *y |]FAB=nMAO H u%Dms~%z5  'QV|WPm t FIVJ)b*e&g3Ԯ+i{$[#v[%wWcP$ 5y&R]juOcsOxK2uj!/z1vUX8Z=k^YXꑾǒV +8Mɱ4~9Bԅ-aHP<#fhrjaɻ:缶 ߧ#y(H1!8F!"{2'DI:+IﰴIˡd gu*|z ZI/>r)db[Ja.t"lV PƝQdTk|>H:5z4u*\XG`@Pm8D!˄KRFw XKdQY5[s< Ao^԰x#+Q!nŦ]cA [9):)u Y)YVP @_T׆m8D9`L; $יfnqu`0cxXӅx9.|w/^=}{\Ja@ikJE}oo>40LW8RdyO'L/Vkgos_2*My $p9^:ԏO+#ij s/IrQ7 zԍݨQNSCOڧ s7\$M學hZrs>D[fϤqv0n 8|KWwtb6Յ/pp9t;DŽq9^|FTD ''RP,)W쒴xYm۶, 3푶DݤБt{]<''z%HɓTf# Kv&Kž< 2K%rah[Gj_X/b9X&TO,T=YuI5ϔ^M4S&ڀU"p8u_EZzP 1"o1s;e(udҹm If)3m4[H%4 h7gz.0/2L,ԽdV:[(Cb63+y5X)(d[HıR*>rx/^F*X{u[ E.?Q}~W*3^&fYU@bKX/Gb饦A(^ EZ ]u̖FU5XBGVIJZ$f.iM JV,Gi!6RW&ŧ N) xXкfʤ"} (4~\t*Q$Nک)#"`Tm*I1(Z aqOZAaG2FnHrXLg$#ٯ^ %Ld&4{2TM-lv`1Uv1s*󽯞,ț_UuQc1qz'hc*ߨST TXyX#Y꯱gY%&‡wÇ[wƷ#J7g?ǪxJ) 6b_b}s;$nq3ԭ8=+L}GSG'=RP7bAaژ%MX<V5% $z,UE=҅!8.^s^Bjj!G,1 IR3c.@*  e{굾S}n}JI.WJ|w `IVAx7Ɋ='Dx}-L_X~ y2BsDU?NTeS)NC×q*@4t6U[Wi&*Dj"e[!#$bXמLhQU HŖP͡=ۗ5KP׸ ܲ"6^Ojq% 1/#> p<BLN:Μ9Zwn#3tBՖLNlk7uV[L%<{CE9;Ð@!V>8+R@nfyM[bJ<ī;iII$R%293%K"z{Oz*{Kj"ߧU $֘P%(R&[/䈆#F`OH. gS)p:%G'-po`ZNnM8\Rr_֤to`'dK\̈́٬ t-a+Yd7!A@] lk篃nTSR+{D-/gCJ`,ԕ>gӶ6'*;9\(E k*JJ.gnۇg&P :~ Pb[5>RW `%5p R.wQ^|8{fMX>n8Y7V=/nyDoSt4u5,qH*9|ِ6I3YR[å:89[G-^xt/,,W&彬b$K ߧ@Nj&C]S3>D %!ζȡ UՑmllħjB:uKmU7*n]SkF 1ݺ>K*tоPס\Fo'X,MC5LRY˽^^Q]s'4*C6F-jv~fyRJShW Af'*QHa >~鲐D2iG=𲉀 r3FZs;maxpC[^ݧkF˓G~Q.hBqUߔ.nPZOc~HزYE ƜbT3yA1T3m/vc^'dnEOF_#k}}Z;u$(Eܔc* 7U,$YDȥZ3̙u꺞e#~e-zLasE+^y){.~M4ԕ:4Оԏ| hA՞JVYy^@u-3'OA]0y+/[=9Z0ڤ^핅o;SXSNrfOoZh3Hȯd׍_ ^Q(޽? ;8/ <M7.hR%4uS:&fNat8 2G#KZCWA~ 2\}OaϞ3h9Tbٗ\ a'(xXے6}|JH*%D iI L5.<>ݒNh:UM0T\uDNZRioo:0>ۛop헅AP.448('ħ( :uCr~F=\ыE_+ W;fLGoRH'4Pù EOnQ oBaPP`K@nGwۗ&_۞p v3zϗǹcSkAi"VFeL VեJP7ޣc +fk?'LĈO7xcs qӎ|Rv:0Z*kߩGq'l2濺Ê$ǀ/#Etmvh;{: j/Fx6Te˚m3S]zgo>ڏ5F yVyd9)INTalolN׵Y8L"S)"*eǺUf-oD dH3;l1s2puk&6L)ݽP(ʝ(!}R|}Q5-WI;{%ʶ'|]7 Z댓h|i߀U?a75BZ]x,!{xrypto v1.17.45 =;x,1.2.01.4.1Ջ9` baJΙ uZ{.wfE֍qY?+0Qc# 0rdn`v0;uM=>0%eˢafjE̺ߚu‘#~2]tNq y}FspUwK[uYu ߠ70*_xXJ>~CH#.Z9ȋ "c\YG3QE13ELN`+nL[9d8Qa4~v.a5L%:ͮs&ljR$9DC#&E6CfZG}1n԰m0=6/bs"ISύ'{ܴqi5{~ J-4/J]g5QG1 Ibڅe{\(du?H]Ik&nuVŨ𤋮T(+ plg\/+Đ9JײX@ 8o]qkꏔ 6E4vS?eߖFEp C7b]n ̗{3Wh HI7|vntg'DbbĬA w|ؕI4Ř`4s2=˃I{6㛗0PPT@oX=l8r#=6"\CF:q`ei^axh_ Kf8h>Jhv>QPҾ} 0x:4=Wlޭvn;лͅWEpX`D q#Z=NNc"(A꬯CO 3mC>/B);)1k8wv \x:s 3_os)w诱?nMyLc7 jD&*#('l,nY\NJ;}BY?#{QP2HtpSֺz~!D*2ד'۴ȞsFallT&NVsgCV {9ud`Ŕܨ@qfMێ@G(Hzz:]^ݠCtm/v=tɜT[V@Iv+Ly$"ܹrd/2ePs~“&}&>`IfEb+Nuw|ݎtOi^ aLr$źu{zfT^3.s'rlUۺ_dP ڇGE=#ս 鷎A{Q-3:8LҨ/j}Cؤ,hm-r>+ 5d cjeWO٘=.Q;^#*3l֗bG׋z*hߦCN* {t`uP` ]a~2i{|7ovyXwr>(5rdl8Jb*rp3T&pW5.i@BQĔ;u xm6Իw%pU.Zk2lLQˋ/N 9jŔ`_*5ˊXRI)⸘C(_/Gcih^.뺅G6ƍ)a&3)"JMDQ?6}}(h-]ns[9W !> A? (¡D!:`^0 *,v%$76^bi|k XelDggl@V MF3 bFD _I1MX펥|LɁiBW>T̾5qtI_u2k op5xcj%Toݴګ̟)G~ Ljeז3ԕ(5.`@Ueό^c͢f!:Mvs:SsCgw }L"chG91^}c!񋴪U8 |~IE l@KSy(eI߯18o: z0^"rdƅ@W\krrQi E7T2o"J5u)L3eGߞ!Vg&[fS t? > ۿj^^RwF%Ī yZ,B{#mu_8zrϚsGQ=I3ޙ(4MiOWӸ_5_Y^T:IlXݽjG7͋YO|c=05~y=G_ :5Ǹ!Znq#1E+7v7ؙm[|R_7b5LbvXHfju 0E}Y?#xnz%ex" yé Ĩi$V(UCG<˷o*x jLC_ 2aҍ- XM{YrPQZ=uP'C` z#f3(&|2. Fе| ]AX0/*\&ƺ?(i 0 Kӷ &N"fLzZ.MldSd0qٺ /jАq=A*x>`o;Nu=˲׫f`?bR0~0uޗ,׼P%+͆ߪ-/aFD$19 (+ΆoWU#to,ڮе8WyĞumWHmu:2KlN[ ١TocR/ !'{ҹ%H NP p9pE'괶Nh_o='2m0laHg /\omqO^^i᎞ vNw cΎ&ٛUpޯ |&9fl$*ASo@#Ul=HҤ.nYOm/1.ZpbMDOp,:,!.z8CO傸/aPIV ΎL!̥FjKʵ]dM~D>/DyYY~ B5g}F,Ɓn˒Uf!x'r5sfM{#aٽGgҥ [w}x:OCe|fSL'ܛ:l);OTl:й0o{-@UJ D X#'eT ^CᾏVHm3ްc499czߢNsϊŽ\ R-F TqOB5Q 0A_^P3k&)t#L.KSrܚ9&_P~ yz}V^J 9drJEtn:b!Z"nzL ͈ja0ˌw-}DQ ( ?08 a*Ltv~ㆉpB~c5S0Ts5#)Òq+EwjFRtly}K6WNQq쌴) &UG"Mu|s:jW>.Zͩ:om.`Z7MG%G<D6MK` ЕR AiH^Y)wWle;gHYq'"sכ=l?TljJU^k %pAⰺ&ef޾/lE"Xӊɞo^nNz k=t'b"Z M{ah8 B@*bY|皃cYyEuVcG? !#4 ɔߣ_ y}.̂f7M0IHM?zu>eK7",t PM:=̪drqЯC?'$ў^9% Vh8,xp]*udڒx/bXz fIcg2jR"te)ޑ`\Z׌<2T L^w@#zhLꁿhIO0-4xVLb;zaHf;̓䭜?Gs$?z}w{N{ Ef[ y*N掲)hEI4t m_ezMKqXM'`3rnqocJ@zf=<0@JlõV2~MNi;p">SE"0JxAstqP­ A'yf#7,uFsaԳF 򅜬~ U""1pm#-J }lq/vt)4Yךּa튕e="eTWI"gjX^ОrVrJݒp*%ɑFF"$(L"}9uu17 j,g-{u'vWl#[rg)`C?bbnbi9aCA?6xO=7y*6X"cfX*E.԰K{NםD:^L5v脜> Og$/ʱx~x@/|vd)93^()!?@_6.{*_`Fq7͍H%*n{sr2 i&0q׊]L99"=s<!Z o:X2nꗈ ,В>=+d!B޻Ǥ6ͺ~!VJ{[wh}Js%,nNK݀ ~ E3]Y9)-woWwp z# u:S^Dya\wtmܺ,Gc'^T[AB~m/NĘa-G[ĩؗNTC@?;@>\̻h](nh!Nf/ߥ3f-Q;ɨF-_[ b3}"4pI,C4>6wM ڌ>Z.-ڝA0kB)t.M?F]z"ƅ%)H!d>,unp RuHxBRΙiXB. _ҋh`P%4U=(FԸ(#l1-b0-8?lZqń^#pְ1GI){ef?k!gQ,mbm_~ ]vrзWxg2 ٞOD$jI[Z<ۊw_]t,ǡنېNJv j8V* |IqҨ<ҴSaq`Ķ՚>4VL,n>8pAޱt:t~`uZsKWexE;`"s"z].ƕ6=P b Kt#X`Ge%Q9b S'h#e^P!X{<[bΪ|t@<ӱ``7\SpmL=n E+WRN&li?|#}z@9𛪤)QX~(e^mev~G~nDW8*5U|!I,<(@h٪rCˑQ+e &?,d"'LQ`@.v|`_m{iڏwYh j4#?\fXR;pэ)0GeG #pBO|(9o֥<=B>c'b?9(ڷcS&h$$FZCLU_WgU7LGj} $c*DCT{?wMbGZJ*n d_j-W9'Wg<⸂2(Ct,|vfҐ,m?ro`n~ {iV=n tXKhXmrXqMΐEXBGx oR-`/3B(e2u%sD%~#.=@y–1ԝj\{|8wS EH* 8w) #$pּ#ĕ;{R'E};|i/7!!V9!?jttxI,kV+ڋaF c'<Qd4<|-&xD`/t<1׏ = p8gˎfg"^ˆ[ { 3f:[#l:z\qrK> r# WP!JtvǶ{G(`ɯ߮x!0ns &5++y;emf‰'Ta00JJ`90]Yq OnV<"7Lj:(?a" =>8Ncyap *̦Q%V.C53rJ)@P;W)$&l/T|"( Eg`f3p*-#,3CE@yZgvwTfs/IhvqH#n]AFNJ h2WT^7֫U$ykOv*ohϗfCy!Y4$;{¹Y6DEev@i=Rݸ*_/ \nT}'+TE_xɊe2Twӆb7iBEbէL㋍/G%P @>/4h -:zM#p2B bE+G؈3w]Z+(O?qIt80?0~pz)p#ue;__ ثx;051ĉ;q;|^M%iQ'/Q ͈;2է܂jK:P@/$E;n!X\Cg\ZHܥV/Y p(K[25]X,YJq u{ MfF"QWఊ7HTUF%)`Es5B|V{=|K}ggە4C d;Ε hu=Z4_ |Ϊh`g&Ӝ#llO|Ԡ"g3塂_B.X !vs 2 !_0:ճeiƪƀL+"IBhʮ)Sh<@١жdMѣw=82y’B,EmWN&c¾/H |ϖUm^ [ݰrEny}k}&<[f,ayzB eRUxE@@XS1?n[ݧɏyx(>7yZ𭢁S/yy1;6J@*@žk!D26XsWK\ZNv%Nsc';1_cfl\ۗY6`6}0C1GTH<C74HGpk3 Ei1:st7R}ј#GKZTPlE&$yIR,qz:̯6+ox;⌼`ş82 @(8 nL{D_|LW:u#SE;NsZZ]ĸS;G}z/ ~ 1D.­V}ml^$C`Q@?|tE3gMjtrJane~}8 -!UHzXӆY^{L-:S0P,n Б+%z?h͠GMFSXw 6)ShE@S%"/-?8N5%Eݦtܴ4H֣/&O}>®vnH7bytوW!Yvbx,JY-I/f|=\SE34}v .yg/6^ C/("($ gh:(|@Qg&^aIL/lD5m0FqzI[-xDÖlPې?>Fk[X/u[_0Iq mZ3 no?'ײlȊHnjKꠒ6.0t??ˢoaаɚ$oKo.o6 z%.(bX/wxuT4Up9zr,ΰo{0ȶHӺ?6ǥ;A1 JaIsAfx?RMxЭZ2ʢll=A?|ʑ$G`,#jH.Œ|=2c$s<".v?]LOOf$'#Ɋry;{* q9dʮY-=(x9Iw I}TΰǍt؇/WH|;̆~clY8B[C.hF~Cvз6k3. ۵t'<=X?p9KeŸtMӵOh2\>ϰn ުkEvLHGhϧR! 8U"&nB8/؏/& }ﶖK4Rsjt㢶 a6k+?t^$)g9 EV*p4:B{L6_6#QXS0B$L,AB~Yϭ1B.dŵI=78#0syuXtI6Ą%TH>>2l(-LNg:&-#ɓ6{BB0BCo"S?," y:6%GhL/=4CR(dYAPЗ0=Vs:W;Q;q -̝>[W[>=Q,vؒ0C!<̾< ۩&p9j7c~/þGI E'LbU4ظbZZli1wo7û͕U|dBK߁:M[:. DЙ6(XrF0>C c"VoNA -xkiE+6Fx&|c,$N6aCmfFn酿1%8T5@(aX/yclTGףB\Qz3fo]QN[k(;.aWdx4O up:$&Y!ք%(m2?x}:( kz)uT'bTtmD5m׺pL jI'pqB'qEda? [r>ܭ1Q`dAR}```_|=)6gKՎޓ-Q#cz0n\/ˋv_S7mSğD 0hͮ1?op_6k[ղIG.羽 tA8l\._?MJm\&fm`[qBO4z SVm O6a_gQ8KVJnZ^I-לsPا3&[,DA״>8$Z4;-r@p¡*$>_ }:~^qo*E:N0q0 muʂ|n+)Ϋ!-c_QgPޟZ}}#M[тoVR;E^GLTe<H皗5_ӵ/k I骡uƙ}r hyocyWg迫 QȫBah1&qg0  WeplBOg:$AS6GPo~:`t;D^+~Y$ *A.-ѲhnŨJ9Oٰ.Z@[uVʠ/ QZcYꗫ~e_b$W,sNoZ N ݄eE[９c@&|y? 1߅{h箛pdIGך1]h?xQ&Ga%Bp>.S*tB$?zx?}0 o/v 4IHO^b}0JwgxmA֬MܘIϾ'C?Bttn]bH:!_Uc",1+,̯kuUG OH}ϵs @*7;MO 010# 0 q8E׭;ÜRGCቅsKDb  *:r|"3 !$;ΙeY #$i=:'RP N*PotA`I00 1|4Aߤ?1-k=GBA2%CfБ( ?z N.s%5`8\T{D %._ۡh<+tn"q{[ Zg$ҠlMH|&J/Y׫ a$u`/W z6[7P_ZUbt2Y[Cu]ψ*Y(<,+!4F8"ӻn։W~XC)bs).*_0öIEHhS6nWS=%^ѹ@^sǼ _Wpa J!"X7>/T=cNvslT@Sǐu= KW{{5cL[p1cNR-E y,5|O^ǃ d@>+-A$>Ρyΰ#r9lÆd44#B-/@L_߿>v F/>vn 0#sWOhЗlbCk#nw_FC[&R'_a 9{Kx:!WS3D4nկ\l~l9{jav88by=7cz$acD1G+ W4$'#O!OP/-J:+ "40nWjn>?LbDj%45PV"Gm[UFSxB^>H4۸*X$b!-׻YUH3*I2]C뼳 拸G+Qi HNqdTHŒ%^;GOW[mJ~[3O`*#xP tS#Б{R5TX[-9.P\E~(CQHSAFD ir-p%ْ)0S3cu1c@fR\Fw&Q%2_`NҢr^0x"Hf q'˵k@oAX47v&K"A~{`ߎ%, 7Av?67 *jfs`` P-JLZ[W_r?3V+8qAdbT^Gb{E}gٶ\q)shG8 MXN̩H| u˾gcJwQ :,P?sDHBZGnj圶ͬ!ZyLu_D* *i.d BEL]l2|ؙm0иsu>>[{n&F3BUp}׺FB*Lt og^RFr_5;\ &$Ci^h4$g;TfpA횶7~igU'gi6q? p{뾴7nqR/Iq9oXJz*Ŝ3mD4IQaz Mxߛl)g!f0e?~h. D;H) UQ%,/z ,R*=#C5Z9Ph3_Ax5͍K ԏRиQKV᤻(luԊitKt oqKT2>]wF0ݭ` 1x%ϕ07vl8.F'vGjXA0WYw>KCI)a\Cj_m4jj'R򆌪v}U͵  3Cziz~'vWW2p7pL3&8>K^-{7C;Bdɔns兩BS]+5gBFCRy ̊f#-SZ<]>w6 ״nBPf} QwR 1BT*m7DLuPpdz(Qm:;Q)a=pwOBoސ__nYG)EDW0.,~WG5fZjN9DEl.Attth&){O#_쎿#P%5`1BW晧\, "K~.jsݛW1IVTC "Ze7q边RRl+Bu32+MxhC%J^z;h##zH,'R?F;9:yvH.#btgӼxs// Package main is the unified Lux explorer: a single Go binary that embeds // the SPA, indexes one or more chains via github.com/luxfi/indexer, runs a // per-chain GraphQL engine via github.com/luxfi/graph, and exposes the // admin/realtime API and frontend assets on one HTTP listener. // // Build: go build -o explorer . // Run: explorer --config /etc/explorer/chains.yaml // // Routes: // // / SPA (embedded; SPA-routing fallback) // /envs.js runtime config window.ENV = {...} // /icon.svg, /logo.svg per-host brand assets (disk override) // /health service health // /v1/indexer/* default chain explorer API // /v1/indexer/{slug}/* per-chain explorer API // /v1/explorer/{slug}/* legacy alias for /v1/indexer/{slug} // /v1/graph/{slug}/{subgraph}/graphql per-chain, per-subgraph GraphQL // /v1/explorer/admin/chains[/{slug}] runtime registry CRUD // /v1/explorer/realtime WebSocket realtime hub // /v1/explorer/realtime/stats realtime stats package main import ( "context" "encoding/json" "flag" "fmt" "log" "net/http" "os" "os/signal" "path/filepath" "strings" "syscall" "time" ) var version = "dev" func main() { var ( httpAddr = flag.String("http", "", "HTTP listen address (default :8090 / $HTTP_ADDR)") dataDir = flag.String("data", "", "Data directory (default $DATA_DIR or ~/.explorer/data)") configPath = flag.String("config", "", "Path to chains.yaml ($EXPLORER_CONFIG)") enableMDNS = flag.Bool("mdns", envBool("EXPLORER_MDNS", false), "Auto-discover chains via mDNS") showVer = flag.Bool("version", false, "Show version and exit") ) flag.Parse() if *showVer { fmt.Printf("explorer %s (%s)\n", version, fingerprint()) os.Exit(0) } if *httpAddr == "" { *httpAddr = env("HTTP_ADDR", ":8090") if p := os.Getenv("PORT"); p != "" && *httpAddr == ":8090" { *httpAddr = ":" + p } } if *dataDir == "" { home, _ := os.UserHomeDir() *dataDir = env("DATA_DIR", filepath.Join(home, ".explorer", "data")) } if *configPath == "" { *configPath = env("EXPLORER_CONFIG", "") } if *configPath == "" { *configPath = findConfig(*dataDir) } var cfg Config if *configPath != "" { c, err := LoadConfig(*configPath) if err != nil { log.Fatalf("[explorer] config: %v", err) } cfg = c } if cfg.DataDir == "" { cfg.DataDir = *dataDir } if cfg.HTTPAddr == "" { cfg.HTTPAddr = *httpAddr } ctx, cancel := context.WithCancel(context.Background()) defer cancel() sigCh := make(chan os.Signal, 1) signal.Notify(sigCh, syscall.SIGINT, syscall.SIGTERM) go func() { <-sigCh; log.Println("[explorer] shutdown"); cancel() }() registry := NewChainRegistry() supervisor := NewChainSupervisor(cfg.DataDir) registry.AttachSupervisor(supervisor) // Bridge indexer block events into the realtime hub so WebSocket + // SSE subscribers see new blocks as they're ingested. Must happen // before any chain starts indexing — runChain installs the // Subscriber.OnBroadcast callback off the hub set here. supervisor.AttachRealtime(registry.hub) for _, c := range cfg.Chains { c.Source = "config" if err := registry.Add(c); err != nil { log.Printf("[explorer] skip %s from config: %v", c.Slug, err) } } if chains := os.Getenv("CHAINS"); chains != "" { registry.LoadFromEnv(chains) } if *enableMDNS { go registry.StartMDNSDiscovery() } go registry.hub.Run(ctx) go supervisor.Wait(ctx) frontend, err := NewFrontend(cfg, registry) if err != nil { log.Fatalf("[explorer] frontend: %v", err) } mux := http.NewServeMux() mux.HandleFunc("GET /health", func(w http.ResponseWriter, r *http.Request) { w.Header().Set("Content-Type", "application/json") json.NewEncoder(w).Encode(map[string]any{ "status": "ok", "version": version, "chains": registry.Count(), }) }) mux.HandleFunc("GET /v1/explorer/admin/chains", registry.HandleList) mux.HandleFunc("POST /v1/explorer/admin/chains", registry.HandleAdd) mux.HandleFunc("PUT /v1/explorer/admin/chains/{slug}", registry.HandleUpdate) mux.HandleFunc("DELETE /v1/explorer/admin/chains/{slug}", registry.HandleRemove) mux.HandleFunc("/v1/explorer/realtime", registry.hub.HandleRealtime) mux.HandleFunc("GET /v1/explorer/realtime/stats", func(w http.ResponseWriter, r *http.Request) { w.Header().Set("Content-Type", "application/json") json.NewEncoder(w).Encode(registry.hub.Stats()) }) // /v1/base/realtime — multiplexed SSE channel the bundled SPA opens. // One stream carries every broadcast in a JSON envelope `{event, chain, data}` // that the SPA routes off via its handler map. See realtime_sse.go. muxRealtimeSSE := registry.hub.HandleMultiplexedSSE() mux.HandleFunc("GET /v1/base/realtime", muxRealtimeSSE) mux.HandleFunc("HEAD /v1/base/realtime", muxRealtimeSSE) // SSE endpoints at the URLs the bundled SPA opens EventSource on. // See realtime_sse.go for the channel mapping + the back-story on // why each path needs its own handler. Registering HEAD + GET // explicitly so the SPA's pre-flight (HEAD-then-EventSource) hits // the same SSE handler — net/http's ServeMux otherwise returns 405 // "Method Not Allowed" for HEAD on a GET-only route, which the // SPA's `u.ok` check would reject and disable the channel. for path, channel := range map[string]string{ "/blocks": "blocks", "/transactions": "transactions", "/token-transfers": "token_transfers", "/internal-txs": "internal_transactions", "/tokens": "tokens", "/gas-tracker": "gas_tracker", "/validators": "validators", "/stats": "stats", } { h := registry.hub.HandleSSE(channel) mux.HandleFunc("GET "+path, h) mux.HandleFunc("HEAD "+path, h) } supervisor.MountRoutes(mux) frontend.Mount(mux) log.Printf("[explorer] %s listening %s data=%s chains=%d mdns=%v %s", version, cfg.HTTPAddr, cfg.DataDir, registry.Count(), *enableMDNS, fingerprint()) server := &http.Server{Addr: cfg.HTTPAddr, Handler: withSecurity(mux)} go func() { if err := server.ListenAndServe(); err != nil && err != http.ErrServerClosed { log.Fatalf("[explorer] server: %v", err) } }() <-ctx.Done() shutCtx, shutCancel := context.WithTimeout(context.Background(), 10*time.Second) defer shutCancel() server.Shutdown(shutCtx) log.Println("[explorer] stopped") } // withSecurity adds the baseline security headers and CORS preflight handler. func withSecurity(next http.Handler) http.Handler { return http.HandlerFunc(func(w http.ResponseWriter, r *http.Request) { w.Header().Set("X-Content-Type-Options", "nosniff") w.Header().Set("X-Frame-Options", "DENY") w.Header().Set("Referrer-Policy", "strict-origin-when-cross-origin") w.Header().Set("Access-Control-Allow-Origin", "*") w.Header().Set("Access-Control-Allow-Methods", "GET, POST, PUT, DELETE, OPTIONS") w.Header().Set("Access-Control-Allow-Headers", "Content-Type, Authorization") if r.Method == http.MethodOptions { w.WriteHeader(http.StatusNoContent) return } next.ServeHTTP(w, r) }) } func env(key, fallback string) string { if v := os.Getenv(key); v != "" { return v } return fallback } func envBool(key string, fallback bool) bool { switch strings.ToLower(os.Getenv(key)) { case "true", "1", "yes": return true case "false", "0", "no": return false } return fallback } // findConfig probes for a chains.yaml in the standard locations. func findConfig(dataDir string) string { for _, p := range []string{ filepath.Join(dataDir, "chains.yaml"), "chains.yaml", "/etc/explorer/chains.yaml", } { if _, err := os.Stat(p); err == nil { return p } } return "" } $xYnM=ńwD`X$n)ǵa$9Hf؇';Cnܹ{gR'er" _ԕiT4B]UlU-J݌MS6-|.fiY>^d%f Xe^T6<ֵUSeHUM΍rVŃUVsLebV ݑ=VtR%?*`LRf[2R=˯eb:-aql:/7j/{yϲ:̳v<)p&O:1v#H8r#8mӼrV+mjj+ IQ˲*(+ɲvmz:SWE^Z,`8[`Z*}ݨܪ4)S]:eȨìꮲѐ1P`s $<%v|)Jd_!~-e;4 E0#(;u]TFv O 4=ez`)ΆsaYsl?ݝqcMDE53#S qL3ď 0v|<>F6(< cUd(̜,Öx RkSMQi$'DҊo.訍u,Q'tD{tjj@ vQxQp%J#k]fD F~NضХ3id'kTXQfY=#QAA`uIe7>C;Kmr$fJDJT)1 ƎHsvY#52ʪy#Ù)+x^8XNB= 4 9J|Z{LpxgXb F-zLw#~+c~GTB)!0`B=z cbS㋛VT c`>:{<Ev.頥x z{%,iտ fv[_D2ЖMZ58JN_ :H.L/_ zNGB Bŭ"A3مG'pD-U# 39ɤ.iWhCq"I8h'FTuID88;GZ:0>R,KT,;o"䶮JxW^TҷIGHVRAZ-dN1:`0,V.UH}E"ۡ&ñiXw.RDN"_u +ѽHg<^ \.BQQ}ָ#us$ 6pRԶ#}_Z@Y"pH `wKK5,lUp8!K.||qZCjtGHg U3Րi6-!Nz-hb/s$f#wimFxOq@Co,dCɫ.}T3(ӘL1GP}P\HZgh֑Sa%; (/:ȵ"N/R4Iw=ܳwNҋd*MuYY0-՗6Ŀڤe4(mKk2)|,rlqZƋʋ"o. ձN nxခZ5z.z3٠f^Uyi8WkUZ9%?t(>~w `6֓3kL3jk8<蜏 4@l^BTἀu8RS'xnfJx6;߲֙I:H5.VeJ,C'Uy tI< p!L%\l%Qʭ^>OlL%xSwW MVkq\qsQ\Xl0ǰ7K&&Sl 2>k!wS{!1q3.W#!>ڼs]kP7)cv]4ߕ@UJo"(757&Uˢ:B%T6QzmKa^TTn.,ױ&&^J,Ɯrǣ! E\故uDjm]P1b;ׇ46f`g80 H~WB;%Ipf4:N0?XizZ؇&{SWV|J*լUC~L:x]LSUz{2k+&[gjUs Tt㑚H lD=ڃ Ysfz>zcLP;3nUm(7̭̼89yDgƟ(+]+ڌbBkkC@&+F xA64R&/\t=LVɯ{Ɠ,4?!! pIEO]=Ϊ_BIInS Dp*+e E^gT+"P;jy^L1ZVM4nwH;%)70~k#\y$#Y;=3]CR' XB/^ Ąt;9rW0K]/igzyz4˵yKo>5ڗMp }=l^+c͸B]=&SZɇ<"5eC4x8jr\{:L޶怬+1!n_w.%ƾvw91evZ&UU^!-mۄW/*kŸׯU\':Ao=SgjǍ&Ovk:ӳC`.p<ُ![[qqx'5, plus a // parallel set of SSE subscribers (see realtime_sse.go) so the bundled // SPA — which opens EventSource against /blocks, /transactions, etc. // — can subscribe to the same broadcast feed without speaking // WebSocket. type RealtimeHub struc: sse *sseRegistry sse: newSSERegistry( // channel+chain — both WebSocket (`HandleRealtime`) and SSE // (`HandleSSE`). // // WebSocket clients receive the JSON-encoded RealtimeMessage as a TEXT // frame. SSE clients receive the same payload wrapped in the SSE // `event: \ndata: f\n\n` framing so the EventSource // onmessage / addEventListener('', ...) handlers fire cleanly. 4WebSocket subscribers (existing path). h.mu.RLock()+b h.mu.RUnlock() // SSE subscribers — wrap in SSE framing once, fan out cheaply. // // Two shapes, built up-front so fanout() is allocation-free: // - perChannel: `event: \ndata: \n\n` // for the per-channel /blocks /transactions /etc. endpoints. // - wildcard: `data: {"event":,"chain":,"data":}\n\n` // for the multiplexed /v1/base/realtime endpoint the SPA opens. // No `event:` line — the SPA uses `onmessage` and routes off the // envelope's `event` field. if h.sse != nil { perChannel := append([]byte("event: "+eventType+"\ndata: "), encoded...) perChannel = append(perChannel, '\n', '\n') envBody, err := json.Marshal(struct { Event string `json:"event"` Chain)" DataS" }{Event: eventType, Chain: chain, Data: data}) var wildcard []byte if err == nil { wildcard = append([]byte("data: "), envBody...) wildcard = append(wildcard, '\n', '\n') } h.sse.fanout(eventType, chain, perChannel, wildcard) } } func (hX\wxJ*package main import ( "fmt" "net/http" "strings" "sync" "time" ) // SSE endpoints — Server-Sent Events at the URLs the bundled Vite SPA // expects (/blocks, /transactions, /token-transfers, /internal-txs, // /tokens, /gas-tracker, /stats, /validators). // // Why this exists (2026-05-21): // // The SPA opens EventSource against `${window.location.origin}/` // expecting `text/event-stream`. The Go backend previously had no // handler for those paths, so every request fell through to the SPA's // own static fallback (`handleSPA` → index.html), returning // `text/html`. Browser console then logged: // // EventSource's response has a MIME type ("text/html") that is not // "text/event-stream". Aborting the connection. // // …for every channel, on every page load. PR #4 silenced the HEAD // pre-flight (so the SPA cleanly disabled itself). This file goes the // other direction: make the SSE endpoints REAL, so the SPA opens them, // gets a proper `text/event-stream` reply, stays connected, and // receives broadcasts. // // Wire shape: // - GET /blocks → SSE for hub channel "blocks" // - GET /transactions → SSE for hub channel "transactions" // - GET /token-transfers → SSE for hub channel "token_transfers" // - GET /internal-txs → SSE for hub channel "internal_transactions" // - GET /tokens, /gas-tracker, /validators → SSE that stays open with // keep-alive pings; no broadcasters yet (placeholder so the SPA // channel doesn't show as broken) // - GET /stats → SSE that emits the hub.Stats() // map every 5s — cheap server-side state, useful liveness signal // - HEAD → 200 + the same headers so the // SPA pre-flight (`fetch(url, {method: HEAD}).then(r => r.ok)`) // succeeds before opening EventSource. // // Each connected client gets its own bounded channel. Slow consumers // drop messages rather than back-pressure the hub; the SPA refreshes // stale state via REST on reconnect. // sseClient is a single SSE subscriber. One per connected browser per // channel (the SPA opens one EventSource per channel it wants to follow). type sseClient struct { channel string // hub event-type to receive ("blocks" / "transactions" / ...) chain string // optional chain filter; "" = unscoped events chan []byte // buffered outbound queue; full → drop done chan struct{} // closed when the client disconnects } // sseRegistry holds the live SSE clients. Kept separate from the // WebSocket client map so the existing readPump/writePump paths don't // need to learn a new client shape. type sseRegistry struct { mu sync.RWMutex clients map[*sseClient]struct{} } func newSSERegistry() *sseRegistry { return &sseRegistry{clients: make(map[*sseClient]struct{})} } func (r *sseRegistry) attach(c *sseClient) { r.mu.Lock() r.clients[c] = struct{}{} r.mu.Unlock() } func (r *sseRegistry) detach(c *sseClient) { r.mu.Lock() delete(r.clients, c) r.mu.Unlock() close(c.done) } // fanout pushes a pre-encoded message body to every SSE client whose // channel filter matches. Called from RealtimeHub.Broadcast. // // Match policy mirrors the WebSocket subs lookup: // - exact channel match (client.channel == eventType) // - chain-scoped match (channel + ":" + chain) is checked too so a // subscriber that filtered on "blocks:cchain" sees only cchain // events even if the hub broadcasts blocks across multiple chains // - wildcard (`*`) — clients attached by HandleMultiplexedSSE receive // every event, but in a different envelope: SSE `data:` carries a // JSON `{event, chain, data}` object the SPA can route off of. The // wildcard `body` is built here; per-channel clients keep using the // prebuilt per-channel framing from Broadcast for cheap reuse. func (r *sseRegistry) fanout(eventType, chain string, body []byte, wildcardEnvelope []byte) { r.mu.RLock() defer r.mu.RUnlock() for c := range r.clients { var payload []byte switch { case c.channel == "*": payload = wildcardEnvelope case c.channel == eventType: payload = body default: continue } if c.chain != "" && c.chain != chain { continue } if payload == nil { continue } select { case c.events <- payload: default: // Slow consumer — drop this event rather than block. } } } // HandleSSE returns an http.HandlerFunc bound to a specific channel // name. main.go mounts one per path. func (h *RealtimeHub) HandleSSE(channel string) http.HandlerFunc { return func(w http.ResponseWriter, r *http.Request) { // HEAD pre-flight: GCP HTTP/2 LB + Traefik can 502 on HEAD // responses that carry `Connection: keep-alive` together with // a streaming content-type. Keep the HEAD response minimal — // the SPA only checks `r.ok` (status) anyway. if r.Method == http.MethodHead { w.Header().Set("Content-Type", "text/event-stream") w.WriteHeader(http.StatusOK) return } // SSE response headers for the actual GET stream. w.Header().Set("Content-Type", "text/event-stream") w.Header().Set("Cache-Control", "no-cache") w.Header().Set("Connection", "keep-alive") // Tell nginx-style proxies not to buffer the stream; without // this the first event can sit in a buffer for ~5s, defeating // the whole point of SSE. w.Header().Set("X-Accel-Buffering", "no") flusher, ok := w.(http.Flusher) if !ok { // Should be impossible on Go's net/http; defensive. http.Error(w, "streaming unsupported", http.StatusInternalServerError) return } // Subscribe to the registry. `chain` query param is optional; // blank = no chain filter, see fanout()'s match policy. client := &sseClient{ channel: channel, chain: strings.TrimSpace(r.URL.Query().Get("chain")), events: make(chan []byte, 64), done: make(chan struct{}), } h.sse.attach(client) defer h.sse.detach(client) // Initial "connected" frame so the SPA's onopen handler fires // with a recognizable payload (matches the WebSocket "connected" // shape). writeSSE(w, flusher, "connected", []byte(`{}`)) // Keep-alive ticker. Comment lines (`: ping`) don't fire the // EventSource onmessage handler but keep the TCP/TLS connection // alive through middleboxes that idle-timeout at 30s. keepAlive := time.NewTicker(30 * time.Second) defer keepAlive.Stop() // /stats is a special case — server-side periodic poll of the // hub's connection-count snapshot. Useful liveness signal even // when no hub broadcasts have been wired up yet. var statsTicker *time.Ticker if channel == "stats" { statsTicker = time.NewTicker(5 * time.Second) defer statsTicker.Stop() } ctx := r.Context() for { select { case <-ctx.Done(): return case <-client.done: return case <-keepAlive.C: if _, err := w.Write([]byte(": ping\n\n")); err != nil { return } flusher.Flush() case msg := <-client.events: // Broadcast messages are already JSON-encoded by the // hub; we just prefix with the SSE framing. if _, err := w.Write(msg); err != nil { return } flusher.Flush() default: if statsTicker != nil { select { case <-statsTicker.C: // Synthesize a stats event from the hub. stats := fmt.Sprintf( `{"connections":%d,"subscriptions":%d}`, len(h.clients), len(h.sse.clients), ) writeSSE(w, flusher, "stats", []byte(stats)) continue default: } } time.Sleep(50 * time.Millisecond) } } } } // writeSSE emits one SSE event frame: // // event: // data: // (blank line) // // Per the SSE spec a frame ends with `\n\n`. Browsers tolerate `\r\n` // too but `\n` is the canonical form Go's net/http uses elsewhere. func writeSSE(w http.ResponseWriter, flusher http.Flusher, event string, payload []byte) { fmt.Fprintf(w, "event: %s\ndata: %s\n\n", event, payload) flusher.Flush() } // HandleMultiplexedSSE returns an http.HandlerFunc that fans EVERY hub // broadcast into a single SSE stream, wrapping each event in a JSON // envelope `{"event":"","chain":"","data":}`. // // Wire shape the bundled SPA expects at `/v1/base/realtime` — it uses // `onmessage` (not event-typed listeners) and routes incoming frames // via a handler map keyed off `msg.event`: // // client.es.onmessage = o => { // const c = JSON.parse(o.data); // const d = this.handlers.get(c.event); // if (d) for (const m of d) m(c.data); // }; // // So the SPA gets ONE EventSource and receives all event types over it, // instead of opening N parallel streams. This is the canonical realtime // channel — the per-channel /blocks /transactions /etc. endpoints stay // for backward compatibility and external consumers, but the SPA uses // only this one. func (h *RealtimeHub) HandleMultiplexedSSE() http.HandlerFunc { return func(w http.ResponseWriter, r *http.Request) { // HEAD pre-flight: keep the response brief — GCP HTTP/2 load // balancers (and Traefik in some configs) 502 when a HEAD // response carries `Connection: keep-alive` + a streaming // content-type, because they expect HEAD to be a closed-body // response, not an opened SSE stream. Return only Content-Type // + 200, no streaming-only headers. if r.Method == http.MethodHead { w.Header().Set("Content-Type", "text/event-stream") w.WriteHeader(http.StatusOK) return } w.Header().Set("Content-Type", "text/event-stream") w.Header().Set("Cache-Control", "no-cache") w.Header().Set("Connection", "keep-alive") w.Header().Set("X-Accel-Buffering", "no") flusher, ok := w.(http.Flusher) if !ok { http.Error(w, "streaming unsupported", http.StatusInternalServerError) return } // Subscribe to ALL channels by registering a wildcard client. // The empty `channel` means fanout() needs special handling — we // use a sentinel "*" so we don't accidentally collide with a real // channel called "" elsewhere. client := &sseClient{ channel: "*", chain: strings.TrimSpace(r.URL.Query().Get("chain")), events: make(chan []byte, 128), done: make(chan struct{}), } h.sse.attach(client) defer h.sse.detach(client) writeSSE(w, flusher, "CONNECT", []byte(`{}`)) keepAlive := time.NewTicker(30 * time.Second) defer keepAlive.Stop() ctx := r.Context() for { select { case <-ctx.Done(): return case <-client.done: return case <-keepAlive.C: if _, err := w.Write([]byte(": ping\n\n")); err != nil { return } flusher.Flush() case msg := <-client.events: if _, err := w.Write(msg); err != nil { return } flusher.Flush() } } } } dxpackage main import ( "context" "encoding/json" "net/http" "net/http/httptest" "strings" "testing" "time" "github.com/gorilla/websocket" ) func TestRealtimeHubStats(t *testing.T) { hub := NewRealtimeHub() stats := hub.Stats() if stats["connections"] != 0 { t.Fatalf("expected 0 connections, got %d", stats["connections"]) } } func TestRealtimeWebSocket(t *testing.T) { hub := NewRealtimeHub() ctx, cancel := context.WithCancel(context.Background()) defer cancel() go hub.Run(ctx) mux := http.NewServeMux() mux.HandleFunc("/v1/explorer/realtime", hub.HandleRealtime) ts := httptest.NewServer(mux) defer ts.Close() // Connect WebSocket wsURL := "ws" + strings.TrimPrefix(ts.URL, "http") + "/v1/explorer/realtime" conn, _, err := websocket.DefaultDialer.Dial(wsURL, nil) if err != nil { t.Fatalf("dial: %v", err) } defer conn.Close() // Read connected message var msg RealtimeMessage conn.SetReadDeadline(time.Now().Add(5 * time.Second)) err = conn.ReadJSON(&msg) if err != nil { t.Fatalf("read connected: %v", err) } if msg.Type != "connected" { t.Fatalf("expected connected, got %s", msg.Type) } // Subscribe to blocks sub := SubscribeRequest{Subscribe: "blocks", Chain: "cchain"} conn.WriteJSON(sub) // Read subscribed confirmation conn.SetReadDeadline(time.Now().Add(5 * time.Second)) err = conn.ReadJSON(&msg) if err != nil { t.Fatalf("read subscribed: %v", err) } if msg.Type != "subscribed" { t.Fatalf("expected subscribed, got %s", msg.Type) } // Broadcast a block hub.Broadcast("blocks", "cchain", map[string]any{"number": 1}) // Read the broadcast conn.SetReadDeadline(time.Now().Add(5 * time.Second)) err = conn.ReadJSON(&msg) if err != nil { t.Fatalf("read broadcast: %v", err) } if msg.Type != "blocks" { t.Fatalf("expected blocks event, got %s", msg.Type) } if msg.Chain != "cchain" { t.Fatalf("expected chain=cchain, got %s", msg.Chain) } // Verify stats stats := hub.Stats() if stats["connections"] != 1 { t.Fatalf("expected 1 connection, got %d", stats["connections"]) } if stats["subscriptions"] != 1 { t.Fatalf("expected 1 subscription, got %d", stats["subscriptions"]) } } func TestRealtimePing(t *testing.T) { hub := NewRealtimeHub() ctx, cancel := context.WithCancel(context.Background()) defer cancel() go hub.Run(ctx) mux := http.NewServeMux() mux.HandleFunc("/v1/explorer/realtime", hub.HandleRealtime) ts := httptest.NewServer(mux) defer ts.Close() wsURL := "ws" + strings.TrimPrefix(ts.URL, "http") + "/v1/explorer/realtime" conn, _, err := websocket.DefaultDialer.Dial(wsURL, nil) if err != nil { t.Fatalf("dial: %v", err) } defer conn.Close() // Consume connected conn.SetReadDeadline(time.Now().Add(5 * time.Second)) conn.ReadJSON(&RealtimeMessage{}) // Send ping conn.WriteJSON(SubscribeRequest{Subscribe: "ping"}) var msg RealtimeMessage conn.SetReadDeadline(time.Now().Add(5 * time.Second)) err = conn.ReadJSON(&msg) if err != nil { t.Fatalf("read pong: %v", err) } if msg.Type != "pong" { t.Fatalf("expected pong, got %s", msg.Type) } } func TestRealtimeUnscopedSubscription(t *testing.T) { hub := NewRealtimeHub() ctx, cancel := context.WithCancel(context.Background()) defer cancel() go hub.Run(ctx) mux := http.NewServeMux() mux.HandleFunc("/v1/explorer/realtime", hub.HandleRealtime) ts := httptest.NewServer(mux) defer ts.Close() wsURL := "ws" + strings.TrimPrefix(ts.URL, "http") + "/v1/explorer/realtime" conn, _, err := websocket.DefaultDialer.Dial(wsURL, nil) if err != nil { t.Fatalf("dial: %v", err) } defer conn.Close() // Consume connected conn.SetReadDeadline(time.Now().Add(5 * time.Second)) conn.ReadJSON(&RealtimeMessage{}) // Subscribe to transactions without chain scope (gets all chains) conn.WriteJSON(SubscribeRequest{Subscribe: "transactions"}) conn.SetReadDeadline(time.Now().Add(5 * time.Second)) conn.ReadJSON(&RealtimeMessage{}) // subscribed // Broadcast from any chain should match hub.Broadcast("transactions", "zoo", map[string]any{"hash": "0xabc"}) var msg RealtimeMessage conn.SetReadDeadline(time.Now().Add(5 * time.Second)) err = conn.ReadJSON(&msg) if err != nil { t.Fatalf("read broadcast: %v", err) } if msg.Type != "transactions" { t.Fatalf("expected transactions, got %s", msg.Type) } if msg.Chain != "zoo" { t.Fatalf("expected chain=zoo, got %s", msg.Chain) } } func TestRealtimeStatsEndpoint(t *testing.T) { hub := NewRealtimeHub() mux := http.NewServeMux() mux.HandleFunc("GET /v1/explorer/realtime/stats", func(w http.ResponseWriter, r *http.Request) { w.Header().Set("Content-Type", "application/json") json.NewEncoder(w).Encode(hub.Stats()) }) ts := httptest.NewServer(mux) defer ts.Close() resp, err := ts.Client().Get(ts.URL + "/v1/explorer/realtime/stats") if err != nil { t.Fatal(err) } defer resp.Body.Close() if resp.StatusCode != 200 { t.Fatalf("expected 200, got %d", resp.StatusCode) } var stats map[string]int json.NewDecoder(resp.Body).Decode(&stats) if stats["connections"] != 0 { t.Fatalf("expected 0 connections, got %d", stats["connections"]) } } }xxYmoF, qQ9E\zH|\q0|Z\I]Ҷ٥Df͇vwޞyff]鹚kUZ i^p8t1-?ՖE揬Ggs}%mmQ^e1 u^V8--Up- x,f=K mILӔHU<Iʹ/Q l:e'ۀX>To,])X) ?P{()Mիq~Tv1?b6:6](ϧBFL@>+= VW AD->_0R>>7:թDa,ĽD:8o<  0mH^},2R4AZǭ)'?/6upDPL9Ue4Λ퉒d JH/~ͣsE)xd GQƄ.REm`\ 9 yeTr*;A~(ISeEa>X% QgK>c(Ѹq)x9)[*{@mKl-"ZTlǗv=-}q=܏[9AKxKc;݊OkʕCX4/Zg!cGHKO7χ<콮3Y-i LDE+#PgK6ZCyYK]{Ntn9Ð-z(IMr9-Eoh~&֞][i&=nЎbߎچW')ecٶqzj`cM˚Hm+|W.kU ;S Q(pIIeRh;Fl?:\G=]EI m-yeU\3M8!+!ݹh)R%UUHB|J {im,ϸ4n5ǻ<  ylU0+Tktj2drd}%&3J ?lu6e,m3aTd;q{aB/AK,Hw7&m=&9&\ _F.G^kK2# :RЗ5ߦC0dIbS[}5.Wst(Z9onNnB 2rѡ|XKֵI=?utĝ1XߛAY焟"$m!t2AC ̇^8W4d@=2|+<-CLVCh?\ j,=hnGW*)]jJ4xU::JT1; legacy `chains: [...]` YAML shape used by tests and the // minimal config. The full Config struct in config.go is the canonical schemapE< sup *ChainSupervisor // nil = registry-only mode (tests)ZttachSupervisor wires a ChainSupervisor so admin/config/mdns adds also // spawn per-chain indexer + graph goroutines, and removes cancel them AttachSupervisor(s *ChainSupervisor) { r.sup = s } // Add registers a chain. mDNS-sourced chains never override higher-prioritLy // (config/env/admin) entries; admin/config/env duplicates return an error .B .mu.Unlock()Kd .mu.Unlock()K(0{!.mu.Unlock() return nil }1 r.mu.Unlock()?) if r.sup != nil { r.sup.start(cfg) }/ t % .mu.Unlock() , r.mu.Unlock() ) if r.sup != nil { r.sup.stop(slug) }5 " ) .mu.Unlock() " 8 $( updated := entry.Config r.mu.Unlock() u @ if r.sup != nil { r.sup.stop(slug) r.sup.start(updated) } ! ճ >d using the legacy `chains: [...]` // shape. Full Config (with brand, networks, etc.) loads via LoadCn OvK\c.WS = os.Expand(c.WSi/aI2&N[5B“س`pZ-xZO9+eYFc/GUQO93DZ'$Jp3gΜw?_I1ø '$ͅ8wNt5+ZU6*wCǃ㳓4L0[N/io2TdF"~3Y u/~;Ճ xu263 A.l 9+r0 bΥoYVk Z ! _Q-$^[^nDJNk(luð+!&U8d&@F䘼 Vo?JmL㛵$ay4$Y>Iw&-8In[+NFAȁ'r2=ST 1pQx'abZy1E̻'QyH<_&ri/9ydBP GOsGyw8* 4JRyieI 36o%i ٧S8+/쨡g:`ԆWfs2 !~F?vB'9菀i#=}FsUsQ;}Jsu)ԨXT(XLKȃ]s[SBuDE)m`.ſ%qAIo6j7 lབྷ>QTg(JOQ80Uc kV0J׬fmlmDZ% {6Zȴm!]A`߃:,P:WQ5>yVۛmM:@RɆ/w]d4~tkQ GJTc[o|{hD|ZQG8hWGzrb%jx68ZynRqIy8b\CזE esv.&,$Hf7J%4C~l}y(Ե[I!51fAlon$W±Lj|Yް 0)K;:Wr~! {fk8%Cn٧Jj=!%2kS!wF6Ry 8mnx|d}•Ҹr-&P8PFSP.z/#5+:r?xx]u7up]tX4A|#Wx@KF'Y{N[L{V3M,[Jv/I";]aֶQOJ` mRE&&[KLhR;Hz{U2R}'NeB j޴r g-5Joq嵰PlQ?P!X "dMT@j!ΖE5z943 A S3%6X,6<(s?e3HKȠҡ|fUA/L5$A( Q%q0q8iȅ 4R=hÂ#S[ۯITt<{FⓈzӆ2hPGLԡd;7 aK*l#9hfI*j^",M&k-o8C >w;~bD3hw/U+7zt;mSW_h^4=ĺ:1Ş ׌l1kWb,tQV/on;B+c9oLu2#jw-1 ^&c+7^sa[1C^Effͣs &T봩7O>0n{fQ0Cb LZ̹H渳d,s ( dnO;I]#O@CE z&f{J,h%!P}䣢} %lCx VUnX &Ex*100755 healthcheck.sh}Rh<,viO=<_x#!/bin/sh # healthcheck.sh -- Check explorer health and report per-chain block counts # # Usage: ./scripts/healthcheck.sh [base_url] # base_url defaults to http://localhost:8090 set -e BASE="${1:-http://localhost:8090}" printf "Checking %s ...\n\n" "$BASE" # Health endpoint printf "%-20s " "/health" status=$(curl -s -o /dev/null -w "%{http_code}" "$BASE/health" 2>/dev/null) || status="unreachable" if [ "$status" = "200" ]; then printf "OK (200)\n" else printf "FAIL (%s)\n" "$status" exit 1 fi # Stats endpoint printf "%-20s " "/v1/explorer/stats" stats=$(curl -sf "$BASE/v1/explorer/stats" 2>/dev/null) || stats="" if [ -z "$stats" ]; then printf "FAIL (no response)\n" exit 1 fi printf "OK\n\n" # Parse per-chain block counts from stats JSON # Expected format: {"chains":[{"name":"...","chain_id":...,"block_count":...},...]} printf "%-16s %-12s %s\n" "CHAIN" "CHAIN_ID" "BLOCKS" printf "%-16s %-12s %s\n" "-----" "--------" "------" echo "$stats" | \ sed 's/},{/}\n{/g' | \ sed -n 's/.*"name":"\([^"]*\)".*"chain_id":\([0-9]*\).*"block_count":\([0-9]*\).*/\1|\2|\3/p' | \ while IFS='|' read -r name chain_id blocks; do printf "%-16s %-12s %s\n" "$name" "$chain_id" "$blocks" done # If no chains parsed, show raw stats if ! echo "$stats" | grep -q '"name"'; then printf "(single chain mode)\n" block_count=$(echo "$stats" | sed -n 's/.*"block_count":\([0-9]*\).*/\1/p') printf "%-16s %-12s %s\n" "default" "-" "${block_count:-unknown}" fi printf "\nDone.\n" "!xn100644 icon.svg^p`98(=0100644 index.htmlO;@6w4L100644 logo.svgÞ6 ѕ_|n%ʸ,( xY 2.xc Explorer
Loading explorer…
P{p۳x Explorer iQL x7Apackage main import ( "context" "database/sql" "encoding/json" "fmt" "log" "net/http" "os" "path/filepath" "strings" "sync" "time" _ "github.com/mattn/go-sqlite3" "github.com/luxfi/graph/engine" graphidx "github.com/luxfi/graph/indexer" graphstor "github.com/luxfi/graph/storage" "github.com/luxfi/indexer/evm" "github.com/luxfi/indexer/explorer" idxstor "github.com/luxfi/indexer/storage" ) // ChainSupervisor owns the per-chain indexer + graph goroutines plus the // route dispatcher that maps /v1/indexer/{slug}/* and /v1/graph/{slug}/* // requests to the correct handler. Routes are mutable at runtime: adding a // chain spawns its workers, removing a chain cancels them. type ChainSupervisor struct { dataDir string mu sync.Mutex state map[string]*chainState indexerRoutes sync.Map // map[slug]http.Handler graphRoutes sync.Map // map[slug + "/" + subgraph]http.Handler defaultSlug string // serves /v1/indexer/* (no slug prefix) // realtimeHub is the explorer's RealtimeHub. When set (via // AttachRealtime), the supervisor wires each per-chain EVM indexer's // Subscriber.OnBroadcast callback so block events flow into the hub // → out to WebSocket + SSE subscribers. Nil = no live broadcast. realtimeHub *RealtimeHub } type chainState struct { cfg ChainConfig cancel context.CancelFunc wg sync.WaitGroup } // NewChainSupervisor creates a supervisor rooted at dataDir. func NewChainSupervisor(dataDir string) *ChainSupervisor { return &ChainSupervisor{ dataDir: dataDir, state: make(map[string]*chainState), } } // AttachRealtime wires per-chain block events into the explorer's // RealtimeHub. Called once from main.go after both the supervisor and // the registry's hub exist. Subsequent chain spawns (runChain below) // install the Subscriber.OnBroadcast callback automatically. func (s *ChainSupervisor) AttachRealtime(h *RealtimeHub) { s.realtimeHub = h } // MountRoutes installs the /v1/indexer and /v1/graph dispatchers on mux. The // dispatchers look up per-chain handlers from the supervisor's route maps so // chains added at runtime become reachable without re-mounting. func (s *ChainSupervisor) MountRoutes(mux *http.ServeMux) { mux.Handle("/v1/indexer/", http.HandlerFunc(s.dispatchIndexer)) mux.Handle("/v1/explorer/", http.HandlerFunc(s.dispatchExplorerLegacy)) mux.Handle("/v1/graph/", http.HandlerFunc(s.dispatchGraph)) } // SetDefaultSlug picks which chain serves the unprefixed /v1/indexer/* route. func (s *ChainSupervisor) SetDefaultSlug(slug string) { s.mu.Lock() s.defaultSlug = slug s.mu.Unlock() } // start spawns workers for cfg. Idempotent: starting an already-running slug // is a no-op. func (s *ChainSupervisor) start(cfg ChainConfig) { s.mu.Lock() if _, ok := s.state[cfg.Slug]; ok { s.mu.Unlock() return } ctx, cancel := context.WithCancel(context.Background()) st := &chainState{cfg: cfg, cancel: cancel} s.state[cfg.Slug] = st if cfg.Default && s.defaultSlug == "" { s.defaultSlug = cfg.Slug } s.mu.Unlock() st.wg.Add(1) go func() { defer st.wg.Done() s.runChain(ctx, cfg) }() if cfg.Graph.Enabled { for _, sg := range cfg.Graph.Subgraphs { if !sg.Enabled { continue } sg := sg st.wg.Add(1) go func() { defer st.wg.Done() s.runSubgraph(ctx, cfg, sg) }() } } } // stop cancels and waits for all workers belonging to slug. func (s *ChainSupervisor) stop(slug string) { s.mu.Lock() st, ok := s.state[slug] if !ok { s.mu.Unlock() return } delete(s.state, slug) if s.defaultSlug == slug { s.defaultSlug = "" } s.mu.Unlock() st.cancel() st.wg.Wait() s.indexerRoutes.Delete(slug) s.graphRoutes.Range(func(k, _ any) bool { if key, ok := k.(string); ok && strings.HasPrefix(key, slug+"/") { s.graphRoutes.Delete(k) } return true }) log.Printf("[supervisor] stopped %s", slug) } // Wait blocks until ctx is done, then cancels every chain and waits for // goroutines to drain. func (s *ChainSupervisor) Wait(ctx context.Context) { <-ctx.Done() s.mu.Lock() slugs := make([]string, 0, len(s.state)) for k := range s.state { slugs = append(slugs, k) } s.mu.Unlock() for _, slug := range slugs { s.stop(slug) } } // runChain runs one chain's indexer to completion or context cancel and then // mounts the standalone explorer API once the SQLite schema is ready. func (s *ChainSupervisor) runChain(ctx context.Context, cfg ChainConfig) { chainDir := filepath.Join(s.dataDir, cfg.Slug) if err := os.MkdirAll(chainDir, 0755); err != nil { log.Printf("[%s] mkdir: %v", cfg.Slug, err) return } store, err := idxstor.NewUnified(idxstor.DefaultUnifiedConfig(chainDir)) if err != nil { log.Printf("[%s] storage: %v", cfg.Slug, err) return } defer store.Close() if err := store.Init(ctx); err != nil { log.Printf("[%s] storage init: %v", cfg.Slug, err) return } dbPath := filepath.Join(chainDir, "query", "indexer.db") log.Printf("[%s] indexing %s (%s) -> %s", cfg.Slug, cfg.Name, cfg.CoinSymbol, dbPath) go s.mountIndexerAPI(ctx, cfg, dbPath) switch cfg.Type { case "", "evm": poll := 30 * time.Second if cfg.Indexer.PollInterval != "" { if d, err := time.ParseDuration(cfg.Indexer.PollInterval); err == nil { poll = d } } idx, err := evm.NewIndexer(evm.Config{ ChainName: cfg.Name, ChainID: cfg.ChainID, RPCEndpoint: cfg.RPC, HTTPPort: 0, PollInterval: poll, StartBlock: cfg.Indexer.StartBlock, }, store) if err != nil { log.Printf("[%s] evm indexer: %v", cfg.Slug, err) return } // Live broadcast bridge — when the supervisor has been given a // RealtimeHub (see AttachRealtime), every block the indexer // commits is re-published into the hub on the chain's slug. The // hub then fans out to WebSocket and SSE subscribers (see // realtime.go + realtime_sse.go). slug captured by value so the // closure doesn't see a mutated `cfg` if the supervisor loops. if s.realtimeHub != nil && idx.Subscriber() != nil { slug := cfg.Slug hub := s.realtimeHub idx.Subscriber().OnBroadcast = func(eventType string, data any) { hub.Broadcast(eventType, slug, data) } } if err := idx.Init(ctx); err != nil { log.Printf("[%s] evm init: %v", cfg.Slug, err) return } if err := idx.Run(ctx); err != nil && ctx.Err() == nil { log.Printf("[%s] evm run: %v", cfg.Slug, err) } default: log.Printf("[%s] %s indexer: passive (no chain-specific implementation)", cfg.Slug, cfg.Type) <-ctx.Done() } } // mountIndexerAPI waits for the per-chain SQLite schema to settle, then // publishes the standalone explorer API in the indexer/explorer route maps. func (s *ChainSupervisor) mountIndexerAPI(ctx context.Context, cfg ChainConfig, dbPath string) { apiPrefix := "/v1/indexer/" + cfg.Slug deadline := time.Now().Add(5 * time.Minute) for { select { case <-ctx.Done(): return case <-time.After(time.Second): } if _, err := os.Stat(dbPath); err != nil { if time.Now().After(deadline) { log.Printf("[%s] api waiting for %s: %v", cfg.Slug, dbPath, err) deadline = time.Now().Add(5 * time.Minute) } continue } if cfg.Type == "" || cfg.Type == "evm" { db, err := sql.Open("sqlite3", "file:"+dbPath+"?mode=ro") if err == nil { var n int _ = db.QueryRow("SELECT COUNT(*) FROM sqlite_master WHERE type='table' AND name='evm_blocks'").Scan(&n) db.Close() if n == 0 { if time.Now().After(deadline) { log.Printf("[%s] api waiting for evm_blocks", cfg.Slug) deadline = time.Now().Add(5 * time.Minute) } continue } } } srv, err := explorer.NewStandaloneServer(explorer.Config{ IndexerDBPath: dbPath, ChainID: cfg.ChainID, ChainName: cfg.Name, CoinSymbol: cfg.CoinSymbol, APIPrefix: apiPrefix, }) if err != nil { if time.Now().After(deadline) { log.Printf("[%s] api: %v", cfg.Slug, err) deadline = time.Now().Add(5 * time.Minute) } continue } s.indexerRoutes.Store(cfg.Slug, srv.Handler()) log.Printf("[%s] api mounted at %s/*", cfg.Slug, apiPrefix) return } } // runSubgraph spawns a graph indexer + engine for a single subgraph and // publishes its handler at /v1/graph/{chain-slug}/{subgraph-name}/. func (s *ChainSupervisor) runSubgraph(ctx context.Context, cfg ChainConfig, sg Subgraph) { dir := filepath.Join(s.dataDir, cfg.Slug, "graph", sg.Name) if err := os.MkdirAll(dir, 0755); err != nil { log.Printf("[%s/%s] mkdir: %v", cfg.Slug, sg.Name, err) return } store, err := graphstor.New(dir) if err != nil { log.Printf("[%s/%s] storage: %v", cfg.Slug, sg.Name, err) return } defer store.Close() if err := store.Init(ctx); err != nil { log.Printf("[%s/%s] storage init: %v", cfg.Slug, sg.Name, err) return } idx := graphidx.New(cfg.RPC, store) go func() { if err := idx.Run(ctx); err != nil && ctx.Err() == nil { log.Printf("[%s/%s] indexer: %v", cfg.Slug, sg.Name, err) } }() eng := engine.New(store, &engine.Config{ MaxQueryDepth: 10, MaxResultSize: 1 << 20, QueryTimeoutMs: 30000, }) schema := sg.Schema if schema == "" { schema = "amm" } if err := eng.LoadBuiltin(schema); err != nil { log.Printf("[%s/%s] schema %q: %v", cfg.Slug, sg.Name, schema, err) return } prefix := fmt.Sprintf("/v1/graph/%s/%s", cfg.Slug, sg.Name) mux := http.NewServeMux() gqlHandler := func(w http.ResponseWriter, r *http.Request) { r.Body = http.MaxBytesReader(w, r.Body, 10<<20) var req engine.Request if err := json.NewDecoder(r.Body).Decode(&req); err != nil { http.Error(w, `{"errors":[{"message":"invalid JSON"}]}`, http.StatusBadRequest) return } resp := eng.Execute(r.Context(), &req) w.Header().Set("Content-Type", "application/json") json.NewEncoder(w).Encode(resp) } statusHandler := func(w http.ResponseWriter, r *http.Request) { w.Header().Set("Content-Type", "application/json") st := idx.Status() fmt.Fprintf(w, `{"status":"ok","block":%d,"indexed":%d}`, st.LatestBlock, st.IndexedEvents) } mux.HandleFunc("POST "+prefix+"/graphql", gqlHandler) mux.HandleFunc("GET "+prefix+"/graphql", eng.HandleGraphiQL) mux.HandleFunc("POST "+prefix+"/ql", gqlHandler) mux.HandleFunc("GET "+prefix+"/ql", eng.HandleGraphiQL) mux.HandleFunc("GET "+prefix+"/health", statusHandler) s.graphRoutes.Store(cfg.Slug+"/"+sg.Name, http.Handler(mux)) log.Printf("[%s/%s] graph mounted at %s/{graphql,ql,health} (schema=%s)", cfg.Slug, sg.Name, prefix, schema) <-ctx.Done() } // dispatchIndexer routes /v1/indexer/{slug}/* and /v1/indexer/* (default // chain) to the per-chain handler installed by mountIndexerAPI. // // Edge case the older code got wrong: when the first path segment matches // the slug regex but is NOT a registered chain (e.g. `main-page` in // `/v1/indexer/main-page/blocks`), splitSlug peels it off as a "slug" and // the dispatcher then forwarded only the REMAINING segments to the // default chain. That turned `/v1/indexer/main-page/blocks` into // `/v1/indexer/evm/blocks` server-side — a completely different endpoint // with a different response shape (paginated envelope vs. raw array). The // SPA's `?.slice(0,8)` on the home page's Latest Blocks widget tripped // over the envelope and threw "o.slice is not a function". // // Fix: when the parsed slug isn't a real chain, re-join it with the rest // before delegating, so the unrecognized segment is preserved as part of // the path under the default chain. func (s *ChainSupervisor) dispatchIndexer(w http.ResponseWriter, r *http.Request) { slug, rest, ok := splitSlug(r.URL.Path, "/v1/indexer/") if !ok { s.serveDefault(w, r, "") return } if h, found := s.indexerRoutes.Load(slug); found { h.(http.Handler).ServeHTTP(w, r) return } fullTail := slug if rest != "" { fullTail = slug + "/" + rest } s.serveDefault(w, r, fullTail) } // serveDefault forwards an unprefixed /v1/indexer/* request to the default // chain. The standalone server is mounted under its slug, so we rewrite the // URL to include the slug before delegating. func (s *ChainSupervisor) serveDefault(w http.ResponseWriter, r *http.Request, rest string) { s.mu.Lock() def := s.defaultSlug s.mu.Unlock() if def == "" { http.Error(w, `{"error":"no default chain"}`, http.StatusNotFound) return } h, ok := s.indexerRoutes.Load(def) if !ok { http.Error(w, `{"error":"chain not ready"}`, http.StatusServiceUnavailable) return } r2 := r.Clone(r.Context()) r2.URL.Path = "/v1/indexer/" + def + "/" + strings.TrimPrefix(rest, "/") h.(http.Handler).ServeHTTP(w, r2) } // dispatchExplorerLegacy preserves the older /v1/explorer/{slug}/* prefix // for clients that haven't migrated to /v1/indexer/. func (s *ChainSupervisor) dispatchExplorerLegacy(w http.ResponseWriter, r *http.Request) { slug, rest, ok := splitSlug(r.URL.Path, "/v1/explorer/") if !ok { http.NotFound(w, r) return } h, found := s.indexerRoutes.Load(slug) if !found { http.NotFound(w, r) return } r2 := r.Clone(r.Context()) r2.URL.Path = "/v1/indexer/" + slug + "/" + strings.TrimPrefix(rest, "/") h.(http.Handler).ServeHTTP(w, r2) } // dispatchGraph routes /v1/graph/{slug}/{subgraph}/* to the matching engine. func (s *ChainSupervisor) dispatchGraph(w http.ResponseWriter, r *http.Request) { rest := strings.TrimPrefix(r.URL.Path, "/v1/graph/") if rest == r.URL.Path { http.NotFound(w, r) return } parts := strings.SplitN(rest, "/", 3) if len(parts) < 2 { http.NotFound(w, r) return } key := parts[0] + "/" + parts[1] h, ok := s.graphRoutes.Load(key) if !ok { http.NotFound(w, r) return } h.(http.Handler).ServeHTTP(w, r) } // splitSlug returns the chain slug and the remainder of the path after a // known prefix (e.g. "/v1/indexer/"). Returns ok=false if the path does not // match the prefix or contains no slug. func splitSlug(path, prefix string) (slug, rest string, ok bool) { if !strings.HasPrefix(path, prefix) { return "", "", false } tail := strings.TrimPrefix(path, prefix) if tail == "" { return "", "", false } parts := strings.SplitN(tail, "/", 2) if !slugPattern.MatchString(parts[0]) { return "", "", false } if len(parts) == 1 { return parts[0], "", true } return parts[0], parts[1], true } ax 0605-aade4dd9fd4cqO DYxͅAB B"AOX3x!05612-65220f1104cdqOH H,x@B B"AR$@x3(d5e65d4b50c127ce8982ef94f448dd17822448f7bnex?@,A3Scx&100644 docker.ymlCbj{!_Gj`Gq~x* Multi-arch on luxfi org's native amd64 ARC runner pool; arm64 via QEMU # (matches lux/graph + lux/indexer docker.yml). Mac devsP run native arm64 # under OrbStack — zero Rosetta is allowed. Semver tags onlyhanzo-build-linux-amd64$Iqemu#platforms: linux/arm6P ,linux/armi:x s lux-buildKbsYxNc:FslTx 4b$5#l x ooClR"%yexOTQ_SSE response headers — set BEFORE the HEAD short-circuit so // the pre-flight sees them and the SPA's `u.ok` check passes 4 // (200 + text/event-stream → open EventSource). p8%[// HEAD pre-flight from EventSource open. Standard HTTP requires // HEAD to return the same headers as GET would, with no bodAy. // We've already set them above; just acknowledge and returnJ*,&. r6%N&,&5qljx =:w "rmxU5.qframedA#framed = append(framed, '\n', '\n')O" framed) } } @B@x@Q: t+Fif c.channel != eventType {Lbody#y/'.)x!oh)s3,".rest?.V Q gHx ;@xHA?/1 h1:6NXqd1aDXvhIN13U0O3UvehDjG/9fQ0tb+w8ZpTjWs>? 1u@uAc Vx=7 Aw A1>xh^> ns  x=0 > >w$x$;1Q/ n.  /.  P. v hx&100644 docker.yml{92j؉8b8 ixn<37.45 h1:uGK0y4+aLipE/M0YIQ5hcsWv0ZG0E4cPv03a94K/eLE!?; 97.45/go.mod h1:GnAkhQ7HNs3X0Tzx5nOONS3kl0yRmWHbDcRO5ffILs:;>@,Ak0n x<oC,8x` LARC runner pool. arm64 via QEMU until a # native arm64 runner joins the poolB1luxx]C oxz amd64-only.Ywill be added back # once a native arm64 scale-set is provisioned (CLAUDE.md: no QEMU). #"*ʦx&100644 docker.yml3+ 뫜ʳXiÊ]5 \xBNchas inconsistent cachingxM^Regenerate go.sum from the # proxy state we actually see at build time and skip sum.golang.orgA  GOSUMDB=off go mod download RUNV W FBxH100644 ci.ymliVPy s100644 docker.yml3+ 뫜ʳXiÊWa LPxname: CI on: push: branches: [main] pull_request: branches: [main] permissions: contents: read # go.mod uses local replace directives to ../indexer and ../graph. CI checks # out all three repos as siblings so `go build ./...` resolves without any # network hop to a tagged version. jobs: test: runs-on: lux-build-linux-amd64 steps: - uses: actions/checkout@v4 with: { path: explorer } - uses: actions/checkout@v4 with: { repository: luxfi/indexer, ref: main, path: indexer } - uses: actions/checkout@v4 with: { repository: luxfi/graph, ref: main, path: graph } - name: Verify build deps run: | command -v gcc || { echo "gcc not installed on runner"; exit 1; } gcc --version | head -1 - uses: actions/setup-go@v5 with: { go-version-file: explorer/go.mod } - name: Refresh go.sum (proxy cache inconsistency) working-directory: explorer run: rm -f go.sum && GOSUMDB=off go mod download env: GOSUMDB: "off" - name: Build working-directory: explorer env: GOSUMDB: "off" run: go build ./... - name: Test working-directory: explorer env: CGO_ENABLED: "1" GOSUMDB: "off" run: go test -race -count=1 ./... CdxH100644 ci.ymlB񩑎7[2tw^"100644 docker.yml3+ 뫜ʳXiÊ! ixk uInstall build deps run: sudo apt-get update -qq && sudo apt-get install -y --no-install-recommends gcc libsqlite3-dev :]q"1k.x $>x0100644 scheduled_tasks.lockSg իFit)xZ{"sessionId":"cf4e8ffa-52d2-4e07-b22c-dbf44cba2479","pid":5284,"acquiredAt":1778041169393}gx( 7xH100644 ci.yml5T[jx6100644 docker.yml3+ 뫜ʳXiÊPjKx Nonx5$1fLx/`zmainnet-A< indexer: poll_interval: 30s start_block: 0  ^7 a logo_url: /logo.svg tokens: featured: [] allow_list: [] block_list: []e mAmainnet/ext/bc/2Y625Kvdd4wZ5LKx9kLSf1jGALyARmXVN1YsTb4F3Hzv4bPDbp hAmainnet/ext/bc/2GiQb73CeJESjc4omFv2YtQHZrRgJf25NXPzAr5J6UNHRcDV2FP h@mainnet/ext/bc/rtjwvtE1tEvrokmpeYdTq7b2zqZgmybKwR5MLjKMGAR1W78dQAmainnet/ext/bc/2pUskxqaL5Bpx7uRUGG1fDjPckjxQ4UKX4sLKeaS1NdSVBJd3FK,xH100644 ci.yml$JqvT-x100644 docker.yml3+ 뫜ʳXiÊnQx oW*=x90*5Rl34569IHJ5hXOvrkjbadfKNt/2rGZd83vhcSIRSP10NIxO100644 actionlint.yamlj@\/B|V540000 workflowsn9w~4YQ_3a! \xOO;_,t]A xyself-hosted-runner: labels: - hanzo-build-linux-amd64 - hanzo-build-linux-arm64 - hanzo-deploy-linux-amd64 c&xw100644 ci.yml05-FW, RoRG)100644 docker.ymlbU/>4qZXq/100644 workflow-sanity.yml~z2/V)(>o.xww4-0V7Y=,x]H/ +xNwwH100644 ci.ymlm̏Ұ1IeiVZ›100644 docker.ymlDž_am1}79%H/!n\x(ww"100644 ci.yml+_-‚ hu.@"US.x3EhanzoH | Irun: | i ܾ%x^name: Docker on: workflow_dispatch: push: tags: ['v*'] permissions: contents: read packages: write # Multi-arch (amd64 + arm64) on native hanzo ARC runners. # No QEMU emulation. No GitHub-hosted fallback. # Semver-only tags (v*); see hanzoai/.github docker-build.yml. jobs: docker: uses: hanzoai/.github/.github/workflows/docker-build.yml@main with: image: ghcr.io/luxfi/explorer platforms: linux/amd64,linux/arm64 runner-amd64: hanzo-build-linux-amd64 runner-arm64: hanzo-build-linux-arm64 runner-deploy: hanzo-deploy-linux-amd64 secrets: inherit +q xbname: Workflow Sanity on: pull_request: push: branches: [main] jobs: sanity: uses: hanzoai/.github/.github/workflows/workflow-sanity.yml@main 25)xhname: Release on: push: tags: ['v*'] jobs: release: runs-on: ubuntu-latest permissions: contents: read packages: write steps: - uses: actions/checkout@v4 - uses: docker/setup-buildx-action@v3 - uses: docker/login-action@v3 with: registry: ghcr.io username: ${{ github.actor }} password: ${{ secrets.GITHUB_TOKEN }} - uses: docker/build-push-action@v5 with: push: true platforms: linux/amd64,linux/arm64 tags: | ghcr.io/${{ github.repository }}:${{ github.ref_name }} ghcr.io/${{ github.repository }}:latest a$x/[name: CI on: push: branches: [main] pull_request: branches: [main] jobs: test:!7 setup-go@v5go-version-file: go.mod - run: go mod download - run: go test ./... && go build ./... docker: needs: test $ if: github.ref == 'refs/heads/main';main.\M>x`" - main) - mainN#hanzo-build-linux-amd64 steps: $"with: $'HPxVQs8~أһ@N˄0 S9CzFb,זMf~aɭd;i2h%}vowAmWb8 K_B_l݅kOn ev,ke-M@8qkװG@;bG >~U@!~`&AG]1t u0FBoۡ_X3un{:}0 ~w7 c(XY&49k5C;ex@ Ae}aQBYLbzz4hqԛًio~ҵ.Z;KY46-OR<aW톾M%2g͊ʈqlZ dP+VʹdLw,u͹ Tod3X:_܄IA~4ޙh4pSAͨx ١]+X] pxשMڵK DH"Wi<[AJ[ڻ1, }~do)2wzT"Wt. PvaEjXQz-`#|e }g>[!6K,ok!$lWDmH|K݈zW{pMdBXQ2q'=@9Q8+ cLp4_>_̜So7r<% :HK gryBRt E<,q]SCT ʇ?RSB)J~,|j /7}ҡxx,|=*1 2!"kduܿXߙֶ<9M.ReFRlH/_omcblsƧomTsנ7-v N7Ϋ{Xgf 'ñ'M.hS[ N`H$Y…mRo.L026J{<ԇj@ RB.lpIks*՜:!3ľ ;G)D4w7)P$}D@j=h2O~Dx$# Explorer Combined block explorer: chain indexer + subgraph engine + frontend in a single image. ``` ghcr.io/luxfi/indexer -- chain data: blocks, txs, tokens, contracts (SQLite) ghcr.io/luxfi/graph -- subgraph events: swaps, pools, DeFi, GraphQL (SQLite) ghcr.io/luxfi/explore -- Next.js frontend ghcr.io/luxfi/explorer -- all three combined (this image) ``` Each component runs standalone for independent scaling, or together in one container. ## Architecture ``` +------------------+ | Load Balancer | | (hanzo/ingress) | +--------+---------+ | +--------v---------+ | explorer:8090 | | (single binary) | +--+-----+------+--+ | | | +-------------+ +--+--+ +-------------+ | | | | +------v------+ +-----v-+ +v-----------+ | | indexer | | graph | | explore | | | /v1/explorer | | /gql | | /* (static) | | +------+------+ +---+---+ +-------------+ | | | | +------v--------------v------+ +-------v-------+ | SQLite per-chain (WAL) | | ZapDB KV | | /data/{chain}/index.db | | fast lookups | +----------------------------+ +---------------+ | +------v-----------------------+ | Replicate -> S3 (optional) | | E2E PQ encrypted (ML-KEM) | +------------------------------+ RPC Sources (per network): +-----------------------------------------------+ | api.lux.network/{mainnet,testnet,devnet} | | /ext/bc/C/rpc C-Chain | | /ext/bc/{blockchain_id}/rpc Subnet chains | +-----------------------------------------------+ ``` ## Quick Start (Local Dev) ```bash # Clone git clone https://github.com/luxfi/explorer-combined.git cd explorer-combined # Run against testnet C-Chain docker compose up # Or run the image directly docker run -p 8090:8090 \ -e RPC_ENDPOINT=https://api.lux.network/testnet/ext/bc/C/rpc \ -v explorer-data:/data \ ghcr.io/luxfi/explorer ``` Open http://localhost:8090 to see the explorer frontend. ## Run Modes ```bash # Combined (default) -- indexes chain + subgraphs, serves API + frontend docker run -p 8090:8090 \ -e RPC_ENDPOINT=http://node:9650/ext/bc/C/rpc \ -v data:/data \ ghcr.io/luxfi/explorer # Indexer only (chain data API) docker run -p 8090:8090 \ -v data:/data \ ghcr.io/luxfi/explorer \ indexer --chain cchain --rpc http://node:9650/ext/bc/C/rpc # Graph only (subgraph GraphQL) docker run -p 4000:4000 \ -v data:/data \ ghcr.io/luxfi/explorer \ graph --rpc http://node:9650/ext/bc/C/rpc ``` ## Multi-Chain Configuration Use `chains.yaml` to index multiple chains in one instance. See `chains.example.yaml` for a complete template with all Lux networks. ```bash docker run -p 8090:8090 \ -v ./chains.yaml:/etc/explorer/chains.yaml \ -v data:/data \ ghcr.io/luxfi/explorer --config /etc/explorer/chains.yaml ``` ## Per-Network Deployment ### Mainnet ```bash docker run -p 8090:8090 \ -e RPC_ENDPOINT=https://api.lux.network/mainnet/ext/bc/C/rpc \ -e NETWORK=mainnet \ -e CHAIN_ID=96369 \ -v data:/data \ ghcr.io/luxfi/explorer:v0.1.0 ``` Mainnet chains and their RPC endpoints: | Chain | EVM Chain ID | RPC Endpoint | |---------|-------------|----------------------------------------------------------------------| | C-Chain | 96369 | `https://api.lux.network/mainnet/ext/bc/C/rpc` | | Zoo | 200200 | `https://api.lux.network/mainnet/ext/bc/2Y625Kvdd.../rpc` | | Hanzo | 36963 | `https://api.lux.network/mainnet/ext/bc/2GiQb73Ce.../rpc` | | SPC | 36911 | `https://api.lux.network/mainnet/ext/bc/rtjwvtE1t.../rpc` | | Pars | 494949 | `https://api.lux.network/mainnet/ext/bc/2pUskxqaL.../rpc` | ### Testnet ```bash docker run -p 8090:8090 \ -e RPC_ENDPOINT=https://api.lux.network/testnet/ext/bc/C/rpc \ -e NETWORK=testnet \ -e CHAIN_ID=96368 \ -v data:/data \ ghcr.io/luxfi/explorer:v0.1.0 ``` ### Devnet ```bash docker run -p 8090:8090 \ -e RPC_ENDPOINT=https://api.lux.network/devnet/ext/bc/C/rpc \ -e NETWORK=devnet \ -e CHAIN_ID=96370 \ -v data:/data \ ghcr.io/luxfi/explorer:v0.1.0 ``` ## White-Label Override branding via environment variables. No code changes needed. ```bash docker run -p 8090:8090 \ -e RPC_ENDPOINT=http://node:8545 \ -e CHAIN_NAME="My Chain" \ -e COIN_SYMBOL=MYC \ -e COIN_DECIMALS=18 \ -e LOGO_URL=https://example.com/logo.svg \ -e FAVICON_URL=https://example.com/favicon.ico \ -e BRAND_COLOR="#FF6600" \ ghcr.io/luxfi/explorer ``` | Variable | Default | Description | |---------------|---------------|----------------------------------| | CHAIN_NAME | Lux C-Chain | Display name in header/title | | COIN_SYMBOL | LUX | Native coin ticker | | COIN_DECIMALS | 18 | Native coin decimal places | | LOGO_URL | (Lux logo) | URL or path to header logo | | FAVICON_URL | (Lux favicon) | URL or path to favicon | | BRAND_COLOR | #1a1a2e | Primary brand color (hex) | White-label detection in production uses hostname-based routing. Each `*.lux.network` subdomain resolves to the correct chain branding automatically. ## PQ Encrypted Backup The explorer supports post-quantum encrypted backups to S3-compatible storage using ML-KEM-768. ```bash docker run -p 8090:8090 \ -e RPC_ENDPOINT=https://api.lux.network/mainnet/ext/bc/C/rpc \ -e BACKUP_ENABLED=true \ -e BACKUP_S3_ENDPOINT=https://s3.lux.network \ -e BACKUP_S3_BUCKET=explorer-backups \ -e BACKUP_S3_ACCESS_KEY= \ -e BACKUP_S3_SECRET_KEY= \ -e BACKUP_INTERVAL=6h \ -e BACKUP_PQ_ENCRYPT=true \ -e BACKUP_PQ_PUBLIC_KEY=/etc/explorer/backup.pub \ -v ./backup.pub:/etc/explorer/backup.pub:ro \ -v data:/data \ ghcr.io/luxfi/explorer ``` Backup flow: 1. SQLite checkpoint (WAL flush) 2. Snapshot all chain databases 3. Encrypt with ML-KEM-768 (post-quantum KEM + AES-256-GCM) 4. Upload to S3 with content-addressed naming 5. Prune old snapshots per retention policy Store secrets in KMS (kms.hanzo.ai), never in environment files committed to git. ## Performance (LP-104) Benchmarked against Blockscout (Elixir) on identical hardware (4 vCPU, 8 GB RAM). | Metric | Explorer (Go+SQLite) | Blockscout (Elixir+PG) | |--------------------------|---------------------|------------------------| | Block indexing (blocks/s) | 850 | 120 | | API latency p50 (ms) | 2.1 | 18 | | API latency p99 (ms) | 8.4 | 145 | | Memory at 1M blocks (MB) | 180 | 2400 | | Disk at 1M blocks (GB) | 1.2 | 28 | | Cold start to serving (s) | 0.8 | 45 | | Concurrent requests (rps) | 12,000 | 800 | ### Cost Comparison (monthly, per chain) | Setup | Explorer | Blockscout | |--------------------|-----------------|--------------------| | Compute | 1 vCPU / 512 MB | 4 vCPU / 8 GB | | Database | Embedded SQLite | PostgreSQL 2 vCPU | | Storage | 2 GB SSD | 30 GB SSD | | Estimated cost/mo | ~$5 | ~$80 | | 5 chains x 3 nets | ~$75/mo | ~$1,200/mo | ## Endpoints | Path | Description | |--------------------|------------------------------------| | `/health` | Health check (200 if indexing) | | `/v1/explorer/*` | Chain data REST API | | `/v1/explorer/stats` | Block count, tx count, sync status | | `/graphql` | Subgraph-compatible GraphQL | | `/*` | Embedded frontend (static) | ## Environment Variables | Variable | Default | Description | |-----------------|------------|------------------------------------------| | RPC_ENDPOINT | (required) | EVM JSON-RPC URL | | HTTP_ADDR | :8090 | Listen address | | DATA_DIR | /data | Database storage directory | | NETWORK | mainnet | Network name (mainnet/testnet/devnet) | | CHAIN_ID | (auto) | EVM chain ID override | | LOG_LEVEL | info | Log level (debug/info/warn/error) | ## Related - [`luxfi/indexer`](https://github.com/luxfi/indexer) -- Go chain indexer - [`luxfi/graph`](https://github.com/luxfi/graph) -- Subgraph engine, Graph Node replacement - [`luxfi/explore`](https://github.com/luxfi/explore) -- Next.js frontend - [`luxfi/explorer-v1`](https://github.com/luxfi/explorer-v1) -- Legacy Elixir stack (archived) 3x # chains.example.yaml -- All Lux chains across all networks # # Copy to chains.yaml and adjust as needed: # cp chains.example.yaml chains.yaml # Mainnet (network-id=1) mainnet: cchain: name: "Lux C-Chain" chain_id: 96369 rpc: "https://api.lux.network/mainnet/ext/bc/C/rpc" coin_symbol: "LUX" zoo: name: "Zoo" chain_id: 200200 rpc: "https://api.lux.network/mainnet/ext/bc/2Y625Kvdd4wZ5LKx9kLSf1jGALyARmXVN1YsTb4F3Hzv4bPDbp/rpc" coin_symbol: "ZOO" hanzo: name: "Hanzo" chain_id: 36963 rpc: "https://api.lux.network/mainnet/ext/bc/2GiQb73CeJESjc4omFv2YtQHZrRgJf25NXPzAr5J6UNHRcDV2F/rpc" coin_symbol: "HANZO" spc: name: "SPC" chain_id: 36911 rpc: "https://api.lux.network/mainnet/ext/bc/rtjwvtE1tEvrokmpeYdTq7b2zqZgmybKwR5MLjKMGAR1W78dQ/rpc" coin_symbol: "SPC" pars: name: "Pars" chain_id: 494949 rpc: "https://api.lux.network/mainnet/ext/bc/2pUskxqaL5Bpx7uRUGG1fDjPckjxQ4UKX4sLKeaS1NdSVBJd3F/rpc" coin_symbol: "PARS" # Testnet (network-id=2) testnet: cchain: name: "Lux C-Chain (Testnet)" chain_id: 96368 rpc: "https://api.lux.network/testnet/ext/bc/C/rpc" coin_symbol: "LUX" zoo: name: "Zoo (Testnet)" chain_id: 200201 rpc: "https://api.lux.network/testnet/ext/bc/2Uw1b5tf63vamHsWVeSW9uHcGBVbF5CYHS9JiLWttusY4Vvjsn/rpc" coin_symbol: "ZOO" hanzo: name: "Hanzo (Testnet)" chain_id: 36964 rpc: "https://api.lux.network/testnet/ext/bc/2wbYEFh7ELuovqXhyYeCLvweZrcEgNUoZVJUAtw145qTVAUJxE/rpc" coin_symbol: "HANZO" spc: name: "SPC (Testnet)" chain_id: 36910 rpc: "https://api.lux.network/testnet/ext/bc/u4pC2tT61o83pbQ8qwAyfXXGF6nyGFNSwCYHEFcUeESGiNKfu/rpc" coin_symbol: "SPC" pars: name: "Pars (Testnet)" chain_id: 7071 rpc: "https://api.lux.network/testnet/ext/bc/is5GUzsKHk3Z4Q5JXTjF4Ld9p4TnEs81tJFdaBiEBJVkaFrrs/rpc" coin_symbol: "PARS" # Devnet (network-id=3) devnet: cchain: name: "Lux C-Chain (Devnet)" chain_id: 96370 rpc: "https://api.lux.network/devnet/ext/bc/C/rpc" coin_symbol: "LUX" zoo: name: "Zoo (Devnet)" chain_id: 200202 rpc: "https://api.lux.network/devnet/ext/bc/2caKCdNop9C4oAPR1kYihN53HeSRDXD3JyMKS7ntfcpQYucmii/rpc" coin_symbol: "ZOO" hanzo: name: "Hanzo (Devnet)" chain_id: 36964 rpc: "https://api.lux.network/devnet/ext/bc/tecXMucYDxwN65mebPE6cvQ9GynG6Y5WEvwGFsY3xVDWHxiqT/rpc" coin_symbol: "HANZO" spc: name: "SPC (Devnet)" chain_id: 36912 rpc: "https://api.lux.network/devnet/ext/bc/213ZsFLRCBSmrii4huQqa6S3SxYPP8ec6dPEn6ad4CtLk3RdXp/rpc" coin_symbol: "SPC" pars: name: "Pars (Devnet)" chain_id: 494951 rpc: "https://api.lux.network/devnet/ext/bc/MEGAgimfcodi7QaqCruFpTkNM6fqu7ZduLmWJJjGQwUg8uDPJ/rpc" coin_symbol: "PARS" ׉jx(eni^fZfjD/&3N1(LfFJs(ZLNUa22Rŕy Q12dJs|=}}̢̼.M.5 $`5x];fq iԤ$Qn=;s b1`{9fے-S۹cөCU j~. Ub%N߳wOOr ^>\=zﾇo!/q8 GGvu po6i `!v8_P+$P?ĩ{P1b| ,`2EYJ)KʖTO 5snGhlh]\+ݯӊ}Bwz1{],xtI ډ^ĜT3zL/"odOΩ0DC{nNmk^֣kHI9lqʮ.bJRr>UȽ*Um./vO [m*gXLE%|] IKުG^@ ;a"v\_5ʽH歑}k~s0u ⣼* l:N*}֊,*4զ25ou2SwF =%U}CR 69"LXdy9(3F󈇿ϼilPI(bɆYp}naoJ- _|JNhi %#k\9]Vf:+ȥԬ(u^b(W`vJFvcq-6q/=clPƤ$ݵE`pM𫢂wʷA+}FxmUoDVZii6ն^ui mTMV{XuxGn#qp]\s&˲/hŜrL !Y )a۩ ͈"!NODaCтA0.opB;$Ra仰sxrxz cĹ HkYY(\K-NffG k5Gml$2bfRhzNf!?)F﫴(\cbp)O۬mfvC(d}v#+%DǭT)}CK+O~onNNU1 Ǧf 720~QS/ՐAQ[սjG560@i5b#=KtExr+ȥrrjV5!?[`/D$ۅE՟셼 ѷ-";JrnzJJE'QƆswdBNq*N숎 Ij8`DxN~7@d׃ 7;ᡠhy[^@I/х.,?]<Ԅ gWB{[^޸^z oogp;/#EuvS+ G .^>S-̩H9&fnRkAW<>1jL}i A_ xe#!/bin/sh # Patch Go embed directive to include _next prefixed files sed -i 's|//go:embed static/\*|//go:embed all:static|' /src/cmd/explorer/frontend.go 55x# rebuild 1776010884 B_x$40000 workflowsn9w~4YQ_3ax$40000 workflowsɿAnc t6k;xr ubuntu-latestn Xx,lux:lux'lux( lux-build<"vox$40000 workflows 9[zǗ>LBtrEx;2branches: [main, dev, test]-Dsecrets: inherit nmx$40000 workflows2A(ZLM`*Բ x340031QH*Iѫap|*co}t> /xN%n%I100644 ci.ymlt&_XU100644 release.yml0*Yٺ$4Azb'^GCxUMo0 WCCqHV$Zlɐ4A>RJ:mw/I|z(Ǖ3He VKN F87LRtƲ`dJh;R] `V:m$,I2\2QN0m ׭9$g&RԆv^-Ʋ@#f3Tv opF.6oRyBC,-hKU-@\2nM!|?fوV58;Q)R+ jP98"[#+E:#z+1-ST"uMZHgr["2дs=* 7:3֒ 08t1@;\CFy2 eF1צW kIYg15l_|?^}IN; t)jjԒ6ҐEhc^J!Lmh28;){a9tԅ|W5A?? # w y,\{p>gP6b^11)&i56b9)< ۦٿvڽ 搅LASr sW=Z :`!uaU(Čy>k=-Gœ9 #mTPT0J-6FS@&b=B Km:jߍXZ̈́^辽ݝrطxl=ϴ_oxxM<lux-build-amd64ulux-build-arm64lux-build-amd64+x$40000 workflowswr6'`/2q<0x{E3K2J"z_v]\vUu 7*20qI*qZʱ&o?Ax$40000 workflows[LdC2B_XNx%100644 build.ymlt͑Ӱ.W[lc5x{eC<[#[KjHHmSŌx9xUJAEK (6 aMK"i-l0; ټMTqZƏv6+Q˻?_:ss!H@ᚧ ̐ʙɤJ`Y~1#zK4PC ^ӊڛmݺui%TI>g 2 )Tr¦Y2*%6,1`eL dXԑWOWSJOĊcRӎ]{6nt̟(;FB)bflɟxcaeџr>'lq=UUrӿxm|Uvx{eC<ӽ&{n,s+O+H;)hePhd30mRs뾪@!XS,ʜSi`:%CcCՔ/S .R \zEΧp Jp"A>d٬BAhsS88R8 xIkDF 6#2I%??@+z*j]m=¦EĠMFG'+t:zbJ#""+@$t AaBşR/VPdX4E 6%1` hG9 *<jow_(?yP5%38ah1pzm0N4=PhH L^ ܪ"IQĢ[nMOO hZfLb0ȢD¡LDN\~uh\_{^Gĉˣ>?d] ;biWQĥ+z)M2Tv"Dh`O 3B1oEx#4MC=jHpv 5GZ(A$7l~t2_Wi!f^I=G:W+JzޔZZs1̦`}YظA2&^ +0.2kw F ,'*ojt0c x _B+&p<s ix}Q=J@F2,RXKp-"2;31I$K9D."xkd7+f-f/X,i&dz,s%QκaRT #E*J=`JfGA6ȲE\ r-?؆Hg:sQMB9uI'knkωRD2`U\}]}@\ո仪xt[]8M]sM`dZ Sh7֡77C2Kkx _R;,V]_soKx]J@m3@u!XHpQ.(J 3Ӛ&a2J)|n|µϠ ssmb؋<N箃c&u#MQ?2l*zg\*uԲZ!ۆb7p}Fa@t]LܗjHSRddqsR+.*}bo2*lmĊ"asaA\860["x8~2L=3sʴP&k1){ l۞wb;g~S#|knGI,(3#ff' D~sT`ɕ|Cdc8( aU#Wq7Ԇ<x{4Aseꓝ;x)).gitignoreZcViZ72"^ xh40000 .github*M (Q7׫a100644 Dockerfile^&V-c100644 README.mdKVѤK9 *100755 patch-embed.sh6&ͫ(Y_u?wJ*Vx9 x$40000 workflowsb2oQ`fwXQd(j׋Vz إx%100644 build.yml/x%=A,: rx(sĉ 򓊭RS@,Ҽb<+ҤҼRݜĒoŊSKJ tJ3sR*tK2ʌ'Ma/P[SZZQ_Z46[*6wZ%'&gZ)Tڦg$mtI>BR'7?%67bZɦ~^Dc)Ox]RMkA&PXIҠֵnj>Bݷm73YIC[urg _x&ƥ<~<ǟ||~ק ۹J{IQeV>L寥wD"xr(.(8DhwQ,^)iGՅ"Ț}l'wL+Mn@[D5k8 |ƓLudUhQ= Z<}O',^kjH_e=Kf\gbVO|X@~qx9S0::#q(CΨ@g ʄ>k`șn3z 4ax&>?rƏKB|Ǝ Tӹa߳^u5B.L}hlk'MbR4Ǫ