mirror of
https://github.com/hanzoai/kms.git
synced 2026-10-30 14:57:36 +00:00
ZAP binary protocol duplex RPC standardizes on :9999 across every service. Lux validator staking/RPC ports (9630/9631 mainnet, 9650/9651 devnet) are unchanged — those are luxd network protocol ports, not ZAP. One ZAP port everywhere (was a mix of 9651/9652/9653/9633/9900).
68 lines
1.9 KiB
Go
68 lines
1.9 KiB
Go
// Copyright (C) 2020-2026, Hanzo AI Inc. All rights reserved.
|
|
// See the file LICENSE for licensing terms.
|
|
|
|
// Command basic demonstrates the ZK-KMS client SDK.
|
|
//
|
|
// All encryption and decryption happens client-side. The CEK (Customer
|
|
// Encryption Key) is derived from the passphrase and never leaves the client.
|
|
// MPC nodes only store encrypted blobs.
|
|
package main
|
|
|
|
import (
|
|
"fmt"
|
|
"log"
|
|
|
|
kms "github.com/hanzoai/kms/sdk/go"
|
|
)
|
|
|
|
func main() {
|
|
client, err := kms.NewClient(kms.Config{
|
|
Nodes: []string{"https://kms-mpc-0:9999", "https://kms-mpc-1:9999", "https://kms-mpc-2:9999"},
|
|
OrgSlug: "hanzo",
|
|
Threshold: 2,
|
|
})
|
|
if err != nil {
|
|
log.Fatal(err)
|
|
}
|
|
|
|
// First time: bootstrap creates the org and derives the master key.
|
|
// client.Bootstrap("super-secret-passphrase")
|
|
|
|
// Unlock derives the CEK client-side from the passphrase.
|
|
// The passphrase is never transmitted to any node.
|
|
if err := client.Unlock("super-secret-passphrase"); err != nil {
|
|
log.Fatal(err)
|
|
}
|
|
defer client.Lock() // zeros CEK from memory
|
|
|
|
// Set a secret — encrypted client-side with CEK, stored on MPC nodes.
|
|
// Nodes never see the plaintext value or the key name.
|
|
if err := client.Set("DATABASE_URL", []byte("postgresql://user:pass@db:5432/app")); err != nil {
|
|
log.Fatal(err)
|
|
}
|
|
fmt.Println("Set DATABASE_URL (encrypted on MPC nodes)")
|
|
|
|
// Get a secret — fetched as encrypted blob, decrypted client-side.
|
|
val, err := client.Get("DATABASE_URL")
|
|
if err != nil {
|
|
log.Fatal(err)
|
|
}
|
|
fmt.Printf("DATABASE_URL = %s\n", val)
|
|
|
|
// List all secrets — names are encrypted on nodes, decrypted client-side.
|
|
names, err := client.List()
|
|
if err != nil {
|
|
log.Fatal(err)
|
|
}
|
|
fmt.Printf("Secrets: %v\n", names)
|
|
|
|
// Check MPC node health.
|
|
statuses, err := client.Status()
|
|
if err != nil {
|
|
log.Fatal(err)
|
|
}
|
|
for _, s := range statuses {
|
|
fmt.Printf("Node %s: healthy=%v latency=%dms\n", s.Address, s.Healthy, s.Latency)
|
|
}
|
|
}
|