"""Install the per-bottle MITM CA into the agent container's trust store. Post-PRD-0017 the CA depends on the agent's HTTP_PROXY target: - Bottle declares `egress.routes[]` → agent's HTTP_PROXY points at egress; the cert the agent must trust is the one egress mints leaf certs with (the egress CA). - No egress routes → agent's HTTP_PROXY points straight at pipelock; the cert the agent must trust is pipelock's CA (the pre-cutover behavior). By the time this provisioner runs, the corresponding `tls_init` helper has generated the chosen CA under `plan.stage_dir`, and the sidecar (pipelock or egress) is up referencing the in-container CA paths. Cert lands on Debian's standard source path (`/usr/local/share/ca-certificates/`); `update-ca-certificates` rebuilds `/etc/ssl/certs/ca-certificates.crt`, which is what curl, Python `ssl`, and OpenSSL-based tools all read by default. The env trio set on the agent's `docker run` covers Node (`NODE_EXTRA_CA_CERTS`) and Python `requests` / `SSL_CERT_FILE`-honoring libraries that don't load the system bundle. The fingerprint is computed via stdlib (`ssl.PEM_cert_to_DER_cert` + `hashlib.sha256`) and logged once to stderr. The private key stays on the host (under `stage_dir`) until teardown wipes the stage dir; nothing in the agent ever sees it.""" from __future__ import annotations import subprocess from ...util import AGENT_CA_PATH, log_ca_fingerprint, select_ca_cert from ..bottle_plan import DockerBottlePlan def provision_ca(plan: DockerBottlePlan, target: str) -> None: """Copy the agent-facing CA cert into the agent, rebuild the trust bundle, emit a one-line fingerprint log. Called from `BottleBackend.provision` after the agent container is up.""" container = target cert_host_path, label = select_ca_cert(plan.egress_plan, plan.proxy_plan) subprocess.run( ["docker", "cp", str(cert_host_path), f"{container}:{AGENT_CA_PATH}"], stdout=subprocess.DEVNULL, check=True, ) subprocess.run( ["docker", "exec", "-u", "0", container, "chmod", "644", AGENT_CA_PATH], stdout=subprocess.DEVNULL, check=True, ) subprocess.run( ["docker", "exec", "-u", "0", container, "update-ca-certificates"], stdout=subprocess.DEVNULL, check=True, ) log_ca_fingerprint(cert_host_path, label)