# v2 git bundle 5e1d5c3f0337d04b4711bc2e5ca5af160f549757 refs/heads/bundle 5e1d5c3f0337d04b4711bc2e5ca5af160f549757 HEAD PACK@xtree 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ֱ"Cdax$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+)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.\Mx# rebuild 1776010884 B_xVQs8~أһ@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" ׉j¼xUQAn0U[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"xV0SRO644ŧ7 |;3s@|~40}eWkP%|}B̞l&=f(n+AK:Jauƪ>nN|8EYT{>,_*(܋a1&d/c{:hР^|,hoJ_!m1|!Z'&s a;q JZ )耒zudtG]!܆}?SxYZWw}%(*t͢ϭۛoUcHߘk0sa4^J-'t.mk^4924`=u+h9_I*p1ErSz;@ |9kaY"K y/q[MME6ODTYi$9`T! .6(m7uݕGJNYvgudcqr6Au() >1JUVX9qN,ҁ,I 5ÍdJ8c'/tJipcdܭV LA-YuXE;nε~|#rX"75#"HKҝ{M3.&S#!<E[CQ q3ʾe;7Jݣ\xQ]3}\6c]譜OdhkS)4\!Tx%}^\v͗K?BsxI$D6e;692o'*T&GDn[ $<ݭl .)'%&=HzwJAɂ8iFT-1cTL+3|71%zN.2 c%Beцv:<"Evϋx5? O.ά+: (8ܡOn!vn_3teW4{ȋE $-R31m-+EnnXpO)+;5~g..9\4Tj)Yq9UT(jZ;s=kܞVREB.ާO'kʎ)>Ir]gFc;Z$;L׽b3' *f S Z0ӢYqR>7'3 ނ3a uaK&X xD晓ѡmH1][٠ѺDQa-I=땬ZG;&Q0ӾizJf6]{H*ïə/d3lxR4i2Ȕg/y!d $xWn6}8RҢMǹ"h[L]G %R{[@ə3ù+\%O%K f2"a)ϔ i*&FQ)M{i&X@-iY͘%i=.v/c?"KX1A;+eL}vHx!~x)׃[C=AݎͲ j=8*`j=Q*=U h׭Q{U0p\8U)P!q]҉S\"C= oU)?HGtA$`K |,*1yFtǜͤ Gg9#Fx`&OX&QYyHW"wj;Ϥ5]}mk:s5H3ݍx$۫POL%sEx3ۈo p F =D3@@JD+ӌglֺ鳝Fxgk!H5ū6L_TP:oZpHvfhD8[k@b“ӊXE9a#VC(;_P.˧nx;,!xn,J\O.tAd4LayX5(-H95qS#ti/Eal>X@1` I7YZԢt^S8 bOxAù >ۋ.xVg,C&ӱ}`;=w}] 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<ُ![[xpackage 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*)]j⽱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}䣢} %x*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" "!x$40000 workflowswr6'`/2q<0ax{E3K2J"z_v]\vUu 7*93ox$40000 workflows[LdC2B_XNx%100644 build.ymlt͑Ӱ.W[lcx{eC<[#[KjHHmSŌxfxUJAEK (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 ,'*ojt0cx _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֡77C2KQx _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Ԇ<xx{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,: *x(sĉ 򓊭RS@,Ҽb<+ҤҼRݜĒoŊSKJ tJ3sR*tK2ʌ'Ma/P[SZZQ_Z46[*6wZ%'&gZ)Tڦg$mtI>BR'7?%67bZɦ~^Dc)Jx]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Ǫ