core/go-blockchain
8
0
Fork 0
Code Issues 5 Pull requests Projects Releases Packages Wiki Activity Actions 2

feat: add service discovery actions (59 total Core Actions)
Some checks failed
Security Scan / security (push) Successful in 14s
Details
Test / Test (push) Failing after 35s
Details

Browse source 
New actions per code/core/network/RFC.md:
- blockchain.network.services — all services indexed by capability
  Returns {vpn:[...], dns:[...], proxy:[...]} with provider details
- blockchain.network.discover — find providers by capability filter
  Returns {capability, count, providers:[{name, address, type, caps}]}

Total Core Actions: 59 (was 55).

Co-Authored-By: Charon <charon@lethean.io>
This commit is contained in:
Claude 2026-04-02 06:23:50 +01:00
parent af32d58159
commit 61bd5fc65a
No known key found for this signature in database
GPG key ID: AF404715446AEB41
1 changed files with 73 additions and 0 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

73
actions.go
View file

@ -43,6 +43,8 @@ func RegisterActions(c *core.Core, ch *chain.Chain) {
c.Action("blockchain.network.topology", makeTopology(ch))
c.Action("blockchain.network.vpn", makeVPNGateways(ch))
c.Action("blockchain.network.dns", makeDNSGateways(ch))
c.Action("blockchain.network.services", makeNetworkServices(ch))
c.Action("blockchain.network.discover", makeServiceDiscover(ch))
// Supply
c.Action("blockchain.supply.total", makeSupplyTotal(ch))
@ -251,6 +253,77 @@ func makeDNSGateways(ch *chain.Chain) core.ActionHandler {
}
}
// makeNetworkServices returns all services indexed by capability.
//
// result := c.Action("blockchain.network.services").Run(ctx, opts)
// // {"vpn":["charon","gateway"], "dns":["charon","network"], ...}
func makeNetworkServices(ch *chain.Chain) core.ActionHandler {
return func(ctx context.Context, opts core.Options) core.Result {
all := ch.GetAllAliases()
services := make(map[string][]map[string]interface{})
for _, a := range all {
parsed := parseActionComment(a.Comment)
capsStr := parsed["cap"]
if capsStr == "" {
continue
}
// Parse caps list (e.g. "vpn,dns,proxy")
current := ""
for _, char := range capsStr {
if char == ',' {
if current != "" {
services[current] = append(services[current], map[string]interface{}{
"name": a.Name, "address": a.Address, "comment": a.Comment,
"type": parsed["type"], "hns": parsed["hns"],
})
}
current = ""
} else {
current += string(char)
}
}
if current != "" {
services[current] = append(services[current], map[string]interface{}{
"name": a.Name, "address": a.Address, "comment": a.Comment,
"type": parsed["type"], "hns": parsed["hns"],
})
}
}
return core.Result{Value: services, OK: true}
}
}
// makeServiceDiscover finds services matching a capability filter.
//
// result := c.Action("blockchain.network.discover").Run(ctx, opts{capability: "vpn"})
func makeServiceDiscover(ch *chain.Chain) core.ActionHandler {
return func(ctx context.Context, opts core.Options) core.Result {
capability := opts.String("capability")
if capability == "" {
return core.Result{OK: false}
}
all := ch.GetAllAliases()
var matches []map[string]interface{}
for _, a := range all {
if core.Contains(a.Comment, capability) {
parsed := parseActionComment(a.Comment)
matches = append(matches, map[string]interface{}{
"name": a.Name,
"address": a.Address,
"type": parsed["type"],
"caps": parsed["cap"],
"hns": parsed["hns"],
})
}
}
return core.Result{Value: map[string]interface{}{
"capability": capability,
"count": len(matches),
"providers": matches,
}, OK: true}
}
}
func makeSupplyTotal(ch *chain.Chain) core.ActionHandler {
return func(ctx context.Context, opts core.Options) core.Result {
h, _ := ch.Height()