cairn-mod 1.7.0

//! Layered config loading.
//!
//! Precedence (lowest → highest): compiled-in defaults, then TOML file,
//! then environment variables prefixed `CAIRN_`. CLI-flag overrides land
//! once the clap surface grows subcommands.
//!
//! Per §5.1, signing-key private material is NEVER sourced through this
//! path. `signing_key_path` points at a file; the bytes are read only by
//! [`crate::signing_key::SigningKey::load_from_file`] with explicit
//! permission, ownership, and env-var-reject checks.

use figment::{
    Figment,
    providers::{Env, Format, Toml},
};
use serde::Deserialize;
use std::collections::BTreeMap;
use std::net::SocketAddr;
use std::path::PathBuf;

use crate::error::Result;

/// Default bind address when `bind_addr` is absent from config.
/// §F13: "expects reverse proxy for TLS." Loopback-only by default;
/// operators knowingly opt into `0.0.0.0:3000` when they run without
/// a reverse proxy on the same host.
pub const DEFAULT_BIND_ADDR: &str = "127.0.0.1:3000";

/// Top-level Cairn configuration.
///
/// Fields grow with features; the struct is `non_exhaustive` so additions
/// are not a breaking change for downstream crates.
#[derive(Debug, Clone, Deserialize)]
#[non_exhaustive]
pub struct Config {
    /// The service DID Cairn runs as (§5.1).
    pub service_did: String,
    /// Publicly-reachable base URL where this Cairn instance serves HTTP
    /// and WebSocket endpoints (e.g., `https://labeler.example`). Emitted
    /// as the `serviceEndpoint` value in the `AtprotoLabeler` entry of
    /// `/.well-known/did.json` so consumers can discover where to call.
    ///
    /// This is distinct from [`Self::bind_addr`] — typical production
    /// deployments bind `127.0.0.1:3000` behind a reverse proxy but
    /// advertise the public `https://labeler.example` URL here.
    /// Validated at load time as a URL.
    pub service_endpoint: String,
    /// Where `cairn serve` binds its HTTP listener. Defaults to
    /// [`DEFAULT_BIND_ADDR`] (`127.0.0.1:3000`) if omitted.
    #[serde(default = "default_bind_addr")]
    pub bind_addr: SocketAddr,
    /// SQLite database file. Parent directory must exist; the file
    /// itself is created on first run by
    /// [`crate::storage::open`] alongside embedded migrations.
    pub db_path: PathBuf,
    /// Signing key file (§5.1). Mode 0600, owned by the running user,
    /// hex-encoded 32-byte secp256k1 private key. Env-var delivery of
    /// the key material is explicitly rejected — see
    /// [`crate::signing_key::SIGNING_KEY_ENV_REJECTED`].
    pub signing_key_path: PathBuf,
    /// Admin-endpoint policy (§F12). Defaults to an empty table,
    /// meaning `admin.applyLabel` accepts any label value ≤128 bytes
    /// (matches the existing [`crate::AdminConfig`] default).
    #[serde(default)]
    pub admin: AdminConfigToml,
    /// Labeler policy (§F1) — the `app.bsky.labeler.service` record
    /// content. Required for `cairn publish-service-record`; other
    /// subcommands don't consume it, so it's optional at load time.
    /// When absent, `publish-service-record` surfaces a clear error.
    #[serde(default)]
    pub labeler: Option<LabelerConfigToml>,
    /// Operator PDS auth surface (§F1 service record publishing).
    /// The operator's identity is the DID that OWNS the labeler
    /// account — distinct from moderators who authenticate to Cairn
    /// (§5.2) and distinct from Cairn's own signing key (§5.1).
    #[serde(default)]
    pub operator: Option<OperatorConfigToml>,
    /// Retention sweep execution policy (§F4 sweep task). Holds
    /// schedule + batching knobs only — the cutoff itself
    /// (`retention_days`) is owned by [`crate::SubscribeConfig`] so
    /// the read-side floor and the sweep cutoff stay tied to a
    /// single source of truth. Defaults match §F4 prose: enabled,
    /// 04:00 UTC, 1000-row batches.
    #[serde(default)]
    pub retention: RetentionConfigToml,
    /// Reason vocabulary for the v1.4 graduated-action moderation
    /// model (§F20, #47). TOML projection of the operator's
    /// `[moderation_reasons.<identifier>]` blocks; resolve to a
    /// runtime [`crate::moderation::reasons::ReasonVocabulary`] via
    /// `ReasonVocabulary::from_config`.
    ///
    /// Three states:
    /// - `None` — operator declared no blocks; the resolver loads
    ///   shipped defaults (eight reasons covering common categories).
    /// - `Some(empty)` — operator wrote a bare `[moderation_reasons]`
    ///   header with no sub-blocks; rejected at validate time as a
    ///   probable typo.
    /// - `Some(non_empty)` — operator's vocabulary is the complete
    ///   set; defaults are NOT merged in.
    #[serde(default)]
    pub moderation_reasons: Option<BTreeMap<String, ReasonDefToml>>,
    /// Strike policy for the v1.4 graduated-action moderation
    /// model (§F20, #48). TOML projection of the operator's
    /// `[strike_policy]` block; resolve to a runtime
    /// [`crate::moderation::policy::StrikePolicy`] via
    /// `StrikePolicy::from_config`.
    ///
    /// Two states:
    /// - `None` — operator declared no block; the resolver returns
    ///   shipped defaults (threshold 3, curve [1, 2], linear decay
    ///   over 90 days, suspensions freeze decay).
    /// - `Some(_)` — partial or full operator declaration. Per-field
    ///   serde defaults fill any unspecified sub-fields; the
    ///   resolved values are validated together (curve length
    ///   convention, strict-ascending curve, positive decay window).
    #[serde(default)]
    pub strike_policy: Option<StrikePolicyToml>,
    /// Label-emission policy for the v1.5 graduated-action moderation
    /// model (§F21, #58). TOML projection of the operator's
    /// `[label_emission]` block; resolve to a runtime
    /// [`crate::labels::policy::LabelEmissionPolicy`] via
    /// `LabelEmissionPolicy::from_config`.
    ///
    /// Two states:
    /// - `None` — operator declared no block; the resolver returns
    ///   shipped defaults (emission enabled, reason labels emitted,
    ///   warnings not emitted, default per-action mappings —
    ///   `!takedown`, `!hide`, `!warn`).
    /// - `Some(_)` — partial or full operator declaration. Per-field
    ///   serde defaults fill any unspecified sub-fields; the
    ///   resolved values are validated together (label-value naming
    ///   conventions, no-collision across action_type overrides,
    ///   valid action_type keys in override maps).
    #[serde(default)]
    pub label_emission: Option<LabelEmissionPolicyToml>,
    /// `[policy_automation]` block (§F22, #71). TOML projection of
    /// the operator's policy-automation surface; resolve to a
    /// runtime [`crate::policy::automation::PolicyAutomationPolicy`]
    /// via `PolicyAutomationPolicy::from_config`. Cross-validation
    /// against `[moderation_reasons]` (rule reason_codes must exist
    /// in the operator's vocabulary) lives at the [`Config::validate`]
    /// level, not on the resolver, mirroring the v1.4 / v1.5
    /// per-block-resolver convention.
    ///
    /// Two states:
    /// - `None` — operator declared no block; the resolver returns
    ///   shipped defaults (engine enabled, empty rule set — the
    ///   engine evaluates each recordAction and finds nothing to
    ///   fire).
    /// - `Some(_)` — operator-declared rules. Each rule gets
    ///   per-field validation (positive threshold, valid
    ///   action_type, valid mode, duration only on temp_suspension,
    ///   reason_codes match the `[moderation_reasons]` vocabulary).
    #[serde(default)]
    pub policy_automation: Option<PolicyAutomationPolicyToml>,
    /// `[pds_admin]` block (§F23, #83, v1.7). TOML projection of
    /// the operator's PDS-admin outbound bridge config; resolves
    /// to a runtime [`crate::pds_admin::PdsAdminPolicy`] via
    /// `PdsAdminPolicy::from_config`.
    ///
    /// Two states:
    /// - `None` — operator declared no block; the resolver returns
    ///   the disabled default (engine off; backend unconfigured;
    ///   action_map empty).
    /// - `Some(_)` — partial or full operator declaration. When
    ///   `enabled = true`, exactly one backend subsection must be
    ///   present (v1.7 supports `[pds_admin.ozone]` only); the
    ///   `[pds_admin.action_map]` table must cover every cairn-mod
    ///   action type. When `enabled = false`, subsections may be
    ///   present (forward-compat) but are not cross-validated.
    ///
    /// Cross-block validation against
    /// [`crate::moderation::types::ActionType`]'s vocabulary lives
    /// in [`Config::validate`] (every action_map key must parse
    /// via `ActionType::from_db_str`); the resolver in
    /// `crate::pds_admin::PdsAdminPolicy::from_config` handles
    /// per-block validation (URL scheme, env-var resolution,
    /// allowed-method set, with_lift_after gating).
    #[serde(default)]
    pub pds_admin: Option<PdsAdminConfigToml>,

    /// `[xrpc_gateway]` block (§F23 inbound surface, #91, v1.7).
    /// Operator-config-gated inbound XRPC listener for proxied
    /// Ozone moderation calls + forwarded createReport calls.
    /// Resolves to a runtime
    /// [`crate::xrpc_gateway::XrpcGatewayConfig`] via
    /// [`crate::xrpc_gateway::XrpcGatewayConfig::from_config`];
    /// absence (the v1.6-shape default) leaves the gateway off
    /// and the listener does not mount.
    #[serde(default)]
    pub xrpc_gateway: Option<crate::xrpc_gateway::XrpcGatewayConfigToml>,
}

/// TOML projection of [`crate::pds_admin::PdsAdminPolicy`] (§F23,
/// #83, v1.7). Tops the `[pds_admin]` block. v1.7 ships
/// bsky-PDS-only (`[pds_admin.ozone]`); `[pds_admin.locus]` is
/// reserved for v1.8 and rejected at config-load with a clear
/// "deferred to v1.8" message rather than silently ignored.
///
/// Unknown sibling subsections (anything other than the named
/// fields and `locus`) are captured into [`Self::other_backends`]
/// for the same reject-with-helpful-message treatment, so an
/// operator typo (`[pds_admin.ozonee]`) surfaces at config load
/// instead of silently disabling the bridge.
#[derive(Debug, Clone, Default, Deserialize)]
pub struct PdsAdminConfigToml {
    /// Master toggle. `false` (default) — engine off; the
    /// outbound bridge is not consulted on any recordAction.
    /// `true` — engine on; exactly one backend subsection must
    /// be present and the action_map must cover every cairn-mod
    /// action type.
    #[serde(default)]
    pub enabled: bool,
    /// `[pds_admin.ozone]` subsection — the bsky-PDS backend
    /// config. Required when `enabled = true`. May be present
    /// when `enabled = false` for forward-compat (the
    /// per-block resolver still validates it).
    #[serde(default)]
    pub ozone: Option<PdsAdminOzoneToml>,
    /// `[pds_admin.action_map]` subsection. Required when
    /// `enabled = true`. Maps cairn-mod action types
    /// (`takedown`, `temp_suspension`, etc.) to backend method
    /// names. Each value is either a bare string (the method
    /// name or `"skip"`) or a table (`{ method = "...",
    /// with_lift_after = bool }`); see [`PdsAdminActionMapValueToml`].
    #[serde(default)]
    pub action_map: Option<BTreeMap<String, PdsAdminActionMapValueToml>>,
    /// `[pds_admin.locus]` subsection — Aurora-Locus backend.
    /// Reserved for v1.8; rejected at config-load in v1.7 with
    /// a clear "deferred to v1.8" message. Parsed as opaque
    /// JSON so v1.7 doesn't have to know the v1.8 schema; only
    /// that the key was set.
    #[serde(default)]
    pub locus: Option<serde_json::Value>,
    /// Catch-all for unrecognized backend subsection names
    /// (e.g., a typo like `[pds_admin.ozonee]` or a future
    /// `[pds_admin.kestrel]`). v1.7 rejects each at
    /// config-load. The flatten attribute collects every
    /// unmatched key under `[pds_admin]` here; the named
    /// fields above (`enabled`, `ozone`, `action_map`, `locus`)
    /// are consumed first.
    #[serde(flatten, default)]
    pub other_backends: BTreeMap<String, serde_json::Value>,
}

/// TOML projection of the bsky-PDS backend config (§F23, #83).
/// Maps to the runtime
/// [`crate::pds_admin::OzoneBackendConfig`] via
/// [`crate::pds_admin::PdsAdminPolicy::from_config`], which:
/// - parses `pds_url` via [`url::Url::parse`] and rejects
///   non-https schemes (v1.7 is production-https-only — http
///   support via a future `[server].dev_mode` flag is deferred);
/// - reads the env var named by `admin_password_env` and
///   rejects empty/unset values;
/// - clamps `request_timeout_seconds` into `1..=60`.
#[derive(Debug, Clone, Deserialize)]
pub struct PdsAdminOzoneToml {
    /// Base URL of the bsky-PDS this cairn-mod talks to. Must
    /// parse via [`url::Url::parse`] and use the `https` scheme.
    /// http support is deferred to a future `[server].dev_mode`
    /// flag (#83 explicitly does NOT introduce that flag);
    /// operators wanting local-mode testing in v1.7 should run
    /// their bsky-PDS behind a localhost TLS proxy.
    pub pds_url: String,
    /// Name of the environment variable holding the PDS admin
    /// password (the bsky-PDS Basic-auth credential). Empty or
    /// unset values are rejected at config load. The variable's
    /// value is read once at config load and resolved into the
    /// runtime config; subsequent env mutations don't affect
    /// the running process.
    pub admin_password_env: String,
    /// Per-request HTTP timeout in seconds. Defaults to 10 when
    /// omitted; clamped to 1..=60 at validation time.
    #[serde(default = "default_pds_admin_request_timeout_seconds")]
    pub request_timeout_seconds: u32,
}

/// One entry in [`PdsAdminConfigToml::action_map`]. v1.7's TOML
/// shape supports two forms — a bare method name string, or a
/// `{ method, with_lift_after }` table. The table form is
/// reserved for the v1.8 deferred-execution layer
/// (`with_lift_after = true` triggers a follow-up restore call);
/// v1.7 parses the table syntactically (forward-compat) but
/// rejects `with_lift_after = true` at config load.
///
/// `serde(untagged)` handles the dual shape: try `Bare(String)`
/// first; fall through to `Table` if the value is a TOML table.
#[derive(Debug, Clone, Deserialize)]
#[serde(untagged)]
pub enum PdsAdminActionMapValueToml {
    /// Bare-string form: just the method name. Most actions use
    /// this form (`takedown = "takedown_account"`,
    /// `warning = "skip"`).
    Bare(String),
    /// Table form, e.g. `temp_suspension = { method =
    /// "takedown_account", with_lift_after = true }`. v1.7
    /// rejects `with_lift_after = true` at validation; the
    /// table form with `with_lift_after = false` (or omitted)
    /// is equivalent to the bare-string form.
    Table(PdsAdminActionMapTableToml),
}

/// The table-form variant of [`PdsAdminActionMapValueToml`].
#[derive(Debug, Clone, Deserialize)]
pub struct PdsAdminActionMapTableToml {
    /// Backend method name. Same allowed set as the bare-string
    /// form: `takedown_account` / `suspend_account` /
    /// `restore_account` / `apply_label` / `negate_label` /
    /// `skip`.
    pub method: String,
    /// When `true`, cairn-mod is expected to schedule a follow-up
    /// `restore_account` call after the suspension expires.
    /// **v1.7 rejects this at config load** — the deferred-
    /// execution layer it requires is deferred to v1.8.
    /// Defaults to `false` so absent + table-form-without-flag
    /// is equivalent to the bare-string form.
    #[serde(default)]
    pub with_lift_after: bool,
}

fn default_pds_admin_request_timeout_seconds() -> u32 {
    10
}

/// TOML projection of one entry in
/// [`Config::moderation_reasons`]. The runtime equivalent
/// (with validated identifier) is
/// [`crate::moderation::reasons::ReasonDef`].
#[derive(Debug, Clone, Deserialize)]
pub struct ReasonDefToml {
    /// Strike weight applied at action time, before dampening.
    /// Validated at config-load time as `>= 1`.
    pub base_weight: u32,
    /// When `true`, this reason bypasses the dampening curve
    /// regardless of the subject's standing. Defaults to `false`
    /// when omitted from the TOML.
    #[serde(default)]
    pub severe: bool,
    /// Operator-facing label describing what the reason means.
    /// Required and non-empty; validated at config-load time.
    pub description: String,
}

/// TOML projection of [`crate::moderation::policy::StrikePolicy`].
/// Each sub-field carries a `#[serde(default = "...")]` so a partial
/// `[strike_policy]` declaration fills the rest from the shipped
/// defaults. The fully-defaulted struct matches
/// [`crate::moderation::policy::StrikePolicy::defaults`].
#[derive(Debug, Clone, Deserialize)]
pub struct StrikePolicyToml {
    /// Strike count at or below which a subject is in good standing.
    /// Default 3. Validated together with `dampening_curve` —
    /// curve length must equal `max(0, threshold - 1)`. See
    /// [`crate::moderation::policy`] module docs for the worked
    /// example.
    #[serde(default = "default_good_standing_threshold")]
    pub good_standing_threshold: u32,
    /// Per-position dampening weights for in-good-standing offenses.
    /// Default `[1, 2]`. Validated as strictly ascending with each
    /// entry `>= 1`; length tied to `good_standing_threshold`.
    #[serde(default = "default_dampening_curve")]
    pub dampening_curve: Vec<u32>,
    /// Decay shape applied to each action's strike contribution as
    /// time passes. Default [`crate::moderation::policy::DecayFunction::Linear`].
    /// Unknown variants fail at deserialize time.
    #[serde(default = "default_decay_function")]
    pub decay_function: crate::moderation::policy::DecayFunction,
    /// Window over which `decay_function` operates, in days. Default
    /// 90. Validated as `>= 1`; no upper bound.
    #[serde(default = "default_decay_window_days")]
    pub decay_window_days: u32,
    /// When `true`, decay halts while the subject has an active
    /// `indef_suspension` action. Default `true`.
    #[serde(default = "default_suspension_freezes_decay")]
    pub suspension_freezes_decay: bool,
    /// How long the `subject_strike_state` cache row remains
    /// "fresh" before a reader should recompute via the decay
    /// calculator (#55). Default 3600 (1 hour). Validated `>= 1`.
    /// Has no effect on v1.4 read endpoints, which always
    /// recompute from source-of-truth regardless; ships ahead of
    /// v1.5+ consumers that may read the cache directly.
    #[serde(default = "default_cache_freshness_window_seconds")]
    pub cache_freshness_window_seconds: u32,
}

impl Default for StrikePolicyToml {
    fn default() -> Self {
        Self {
            good_standing_threshold: default_good_standing_threshold(),
            dampening_curve: default_dampening_curve(),
            decay_function: default_decay_function(),
            decay_window_days: default_decay_window_days(),
            suspension_freezes_decay: default_suspension_freezes_decay(),
            cache_freshness_window_seconds: default_cache_freshness_window_seconds(),
        }
    }
}

fn default_good_standing_threshold() -> u32 {
    3
}
fn default_dampening_curve() -> Vec<u32> {
    vec![1, 2]
}
fn default_decay_function() -> crate::moderation::policy::DecayFunction {
    crate::moderation::policy::DecayFunction::Linear
}
fn default_decay_window_days() -> u32 {
    90
}
fn default_suspension_freezes_decay() -> bool {
    true
}
fn default_cache_freshness_window_seconds() -> u32 {
    3600
}

/// TOML projection of [`crate::labels::policy::LabelEmissionPolicy`]
/// (§F21, #58). Each sub-field carries a `#[serde(default = "...")]`
/// so a partial `[label_emission]` declaration fills the rest from
/// shipped defaults. The fully-defaulted struct matches
/// [`crate::labels::policy::LabelEmissionPolicy::defaults`].
///
/// `action_label_overrides` keys are action-type strings
/// (`takedown`, `temp_suspension`, etc.) parsed at projection time
/// against [`crate::moderation::types::ActionType::from_db_str`];
/// invalid keys fail config load with a clear error rather than
/// silently mapping to nothing.
#[derive(Debug, Clone, Default, Deserialize)]
pub struct LabelEmissionPolicyToml {
    /// Master toggle. When `false`, no labels are emitted regardless
    /// of other policy fields. Default `true`.
    #[serde(default = "default_label_emission_enabled")]
    pub enabled: bool,
    /// Whether to emit `reason-<code>` labels alongside the action
    /// label. Default `true`.
    #[serde(default = "default_emit_reason_labels")]
    pub emit_reason_labels: bool,
    /// Whether `warning` actions emit a label. Default `false` —
    /// warnings are typically advisory and don't surface to AppViews.
    /// Operators that want to surface warnings (e.g., a "first
    /// strike" community signal) flip this to `true`.
    #[serde(default = "default_warning_emits_label")]
    pub warning_emits_label: bool,
    /// Prefix prepended to each `reason_code` to form the reason
    /// label's `val`. Default `"reason-"` so e.g. `hate-speech`
    /// becomes `reason-hate-speech`. Empty string permitted but
    /// surfaces a startup warning.
    #[serde(default = "default_reason_label_prefix")]
    pub reason_label_prefix: String,
    /// Per-action-type label override. Keys are action-type strings
    /// (`takedown`, `temp_suspension`, etc.); values are full
    /// [`LabelSpecToml`] declarations that replace the shipped
    /// defaults for that action type.
    #[serde(default)]
    pub action_label_overrides: BTreeMap<String, LabelSpecToml>,
    /// Per-action-type severity override. Keys are action-type
    /// strings; values are severities. Use this when only the
    /// severity needs adjustment without changing the label `val`.
    /// Ignored for action types that have a full
    /// [`LabelSpecToml`] in `action_label_overrides` — the explicit
    /// override wins.
    #[serde(default)]
    pub severity_overrides: BTreeMap<String, SeverityToml>,
}

/// TOML projection of one entry in
/// [`LabelEmissionPolicyToml::action_label_overrides`] (§F21, #58).
/// Same field shape as [`LabelValueDefinitionToml`] minus the
/// `identifier` (which is the action-type key in the parent map).
#[derive(Debug, Clone, Deserialize)]
pub struct LabelSpecToml {
    /// The label `val` emitted for this action type. Validated as
    /// 1..=128 bytes (§6.4 schema CHECK), lowercase ASCII letters +
    /// digits + `-`, optionally prefixed with `!` for ATProto global
    /// label values.
    pub val: String,
    /// Severity hint for consumer AppViews. Default
    /// [`SeverityToml::Alert`].
    #[serde(default = "default_label_spec_severity")]
    pub severity: SeverityToml,
    /// Optional blur policy. `None` means no blur signal — the
    /// label semantics are entirely consumer-determined. Most
    /// graduated-action labels do not specify blurs since they
    /// represent account-level state, not content-level visual
    /// treatment.
    #[serde(default)]
    pub blurs: Option<BlursToml>,
    /// Optional localized display strings. Mirrors §6.4 `locales`
    /// on label-value definitions; an emission-time policy can
    /// declare them so a future #56-style trust-chain consumer
    /// can present labels with operator-supplied display strings.
    /// Empty by default.
    #[serde(default)]
    pub locales: Vec<LocaleToml>,
}

fn default_label_emission_enabled() -> bool {
    true
}
fn default_emit_reason_labels() -> bool {
    true
}
fn default_warning_emits_label() -> bool {
    false
}
fn default_reason_label_prefix() -> String {
    "reason-".to_string()
}
fn default_label_spec_severity() -> SeverityToml {
    SeverityToml::Alert
}

/// TOML projection of [`crate::AdminConfig`]. Separate from the runtime
/// type because (a) `AdminConfig` is constructed from a vector of owned
/// strings and doesn't itself derive `Deserialize`, (b) keeping the
/// wire shape here avoids coupling the server module to figment/serde.
#[derive(Debug, Clone, Default, Deserialize)]
pub struct AdminConfigToml {
    /// Operator-declared label values. When `Some`, `applyLabel` only
    /// accepts values in this set. When absent, any val ≤128 bytes is
    /// accepted.
    #[serde(default)]
    pub label_values: Option<Vec<String>>,
}

/// Labeler policy (§F1, §6.4) — the content of the
/// `app.bsky.labeler.service` record that `cairn publish-service-record`
/// emits to the operator's PDS. Field-name mapping to the wire shape is
/// via `#[serde(rename)]` at the runtime-side boundary in
/// [`crate::service_record`]; TOML stays snake_case for operator ergonomics.
#[derive(Debug, Clone, serde::Serialize, Deserialize)]
pub struct LabelerConfigToml {
    /// Short-name list of labels this instance will emit (§6.4
    /// `policies.labelValues`). Every value here must also have a
    /// matching definition in `label_value_definitions` unless it's a
    /// global well-known value (§6.5). Publishing rejects if a non-
    /// global identifier has no definition.
    pub label_values: Vec<String>,
    /// Per-label metadata entries (§6.4
    /// `policies.labelValueDefinitions`). Empty vec is legal — means
    /// only global values, no custom definitions.
    #[serde(default)]
    pub label_value_definitions: Vec<LabelValueDefinitionToml>,
    /// Optional §6.4 `reasonTypes`. Typically the
    /// `com.atproto.moderation.defs#reason*` set matching createReport
    /// (§F11).
    #[serde(default)]
    pub reason_types: Vec<String>,
    /// Optional §6.4 `subjectTypes` (e.g. `["account", "record"]`).
    #[serde(default)]
    pub subject_types: Vec<String>,
    /// Optional §6.4 `subjectCollections` (e.g.
    /// `["app.bsky.feed.post"]`).
    #[serde(default)]
    pub subject_collections: Vec<String>,
}

/// Single entry in `labelValueDefinitions`. §6.4 constraints:
/// `severity` + `blurs` + `locales` required; `locales` must be
/// non-empty; `default_setting` + `adult_only` optional.
#[derive(Debug, Clone, serde::Serialize, Deserialize)]
pub struct LabelValueDefinitionToml {
    /// The label value this definition describes (matches an entry
    /// in [`LabelerConfigToml::label_values`]).
    pub identifier: String,
    /// §6.4 severity — how consumers should weight this label.
    pub severity: SeverityToml,
    /// §6.4 blur policy — whether consumer UIs should obscure
    /// content or media on a match.
    pub blurs: BlursToml,
    /// Optional §6.4 default consumer-side setting. Omit to let
    /// consumers pick their own default.
    #[serde(default)]
    pub default_setting: Option<DefaultSettingToml>,
    /// Optional §6.4 flag marking the label as 18+ only.
    #[serde(default)]
    pub adult_only: Option<bool>,
    /// Non-empty list of localized display strings (§6.4 requires
    /// ≥1 locale per definition).
    pub locales: Vec<LocaleToml>,
}

/// §6.4 severity enum.
#[derive(Debug, Clone, Copy, PartialEq, Eq, serde::Serialize, Deserialize)]
#[serde(rename_all = "lowercase")]
pub enum SeverityToml {
    /// Informational; consumers typically don't gate on this.
    Inform,
    /// Alert the viewer; consumers generally surface a warning.
    Alert,
    /// No severity signal.
    None,
}

/// §6.4 blur policy — what consumer UIs should obscure on a match.
#[derive(Debug, Clone, Copy, PartialEq, Eq, serde::Serialize, Deserialize)]
#[serde(rename_all = "lowercase")]
pub enum BlursToml {
    /// Blur the post / record body.
    Content,
    /// Blur embedded media only.
    Media,
    /// No blurring.
    None,
}

/// §6.4 default consumer-side setting.
#[derive(Debug, Clone, Copy, serde::Serialize, Deserialize)]
#[serde(rename_all = "lowercase")]
pub enum DefaultSettingToml {
    /// Consumers default to showing the content with no treatment.
    Ignore,
    /// Consumers default to surfacing a warning.
    Warn,
    /// Consumers default to hiding the content.
    Hide,
}

/// Localized display strings for a label value definition (§6.4).
#[derive(Debug, Clone, PartialEq, Eq, serde::Serialize, Deserialize)]
pub struct LocaleToml {
    /// BCP-47 language tag (e.g. `"en"`, `"fr-CA"`).
    pub lang: String,
    /// Short display name shown in consumer UIs.
    pub name: String,
    /// Longer explanation, typically shown on tooltip / expand.
    pub description: String,
}

/// TOML projection of [`crate::RetentionConfig`]. Field names match
/// the runtime struct one-for-one; serde defaults mirror
/// [`crate::RetentionConfig::default()`] so an absent `[retention]`
/// block produces the §F4 default policy without operator opt-in.
///
/// `retention_days` is *not* on this struct — it lives under
/// [`crate::SubscribeConfig`] and is consumed by both the read-side
/// floor (`query_oldest_retained`) and the sweep cutoff. Splitting
/// it would risk drift between the floor and the sweep window.
#[derive(Debug, Clone, Deserialize)]
pub struct RetentionConfigToml {
    /// Master toggle for the scheduled sweep. Default `true`.
    #[serde(default = "default_sweep_enabled")]
    pub sweep_enabled: bool,
    /// UTC hour-of-day (0..=23) for the scheduled sweep. Default 4.
    /// Validated by [`Config::validate`].
    #[serde(default = "default_sweep_run_at_utc_hour")]
    pub sweep_run_at_utc_hour: u8,
    /// Rows per DELETE transaction. Default 1000.
    #[serde(default = "default_sweep_batch_size")]
    pub sweep_batch_size: i64,
}

impl Default for RetentionConfigToml {
    fn default() -> Self {
        Self {
            sweep_enabled: default_sweep_enabled(),
            sweep_run_at_utc_hour: default_sweep_run_at_utc_hour(),
            sweep_batch_size: default_sweep_batch_size(),
        }
    }
}

fn default_sweep_enabled() -> bool {
    true
}
fn default_sweep_run_at_utc_hour() -> u8 {
    4
}
fn default_sweep_batch_size() -> i64 {
    1000
}

/// TOML projection of [`crate::policy::automation::PolicyAutomationPolicy`]
/// (§F22, #71). The `enabled` field carries a serde default so a partial
/// `[policy_automation]` declaration with only rules picks up the
/// shipped default (`true`); operators wanting the engine fully off
/// declare `enabled = false` explicitly.
#[derive(Debug, Clone, Deserialize)]
pub struct PolicyAutomationPolicyToml {
    /// Master toggle. `true` (default) — engine evaluates rules on
    /// every recordAction. `false` — engine skips evaluation
    /// entirely; declared rules don't fire even if their thresholds
    /// would match.
    #[serde(default = "default_policy_automation_enabled")]
    pub enabled: bool,
    /// `[policy_automation.rules.<rule_name>]` sub-blocks. Map key
    /// is the rule's identifier (validated at load time as
    /// lowercase a-z / 0-9 / underscore, must start with a letter,
    /// 1-64 chars). Empty map is the default — when
    /// `[policy_automation]` is declared without any rules, the
    /// engine is on but has nothing to fire.
    #[serde(default)]
    pub rules: BTreeMap<String, PolicyRuleToml>,
}

/// One rule entry under
/// [`PolicyAutomationPolicyToml::rules`]. The runtime equivalent
/// (with parsed action_type, validated mode, parsed duration,
/// resolved reason_codes) is
/// [`crate::policy::automation::PolicyRule`].
#[derive(Debug, Clone, Deserialize)]
pub struct PolicyRuleToml {
    /// Strike count crossing point that triggers the rule.
    /// Validated `> 0` at config-load time. Rule fires only on
    /// crossing — pre-action count below threshold AND post-action
    /// count at or above. See [`crate::policy::automation`] module
    /// docs for the full semantic.
    pub threshold_strikes: i64,
    /// Action type the rule produces when it fires. One of
    /// `warning` / `note` / `temp_suspension` / `indef_suspension`
    /// / `takedown`. Validated via
    /// [`crate::moderation::types::ActionType::from_db_str`].
    pub action_type: String,
    /// `auto` (cairn-mod records the action directly inside the
    /// triggering recordAction transaction) or `flag` (cairn-mod
    /// records a `pending_policy_actions` row awaiting moderator
    /// review). Case-sensitive at parse.
    pub mode: String,
    /// ISO-8601 duration string (e.g. `"P3D"`). Required iff
    /// `action_type == "temp_suspension"`; rejected for other
    /// types. Same parser as v1.4 #51's `duration_iso` surface
    /// (no Y/M support — see `crate::writer::parse_iso8601_duration`,
    /// `pub(crate)` for cross-module reuse).
    pub duration: Option<String>,
    /// Reason codes attached to the action this rule produces.
    /// Each entry must exist in the operator's
    /// `[moderation_reasons]` vocabulary; cross-validation lives
    /// at [`Config::validate`]. When omitted, the resolver
    /// substitutes a single-element `["policy-threshold"]` — that
    /// identifier must therefore appear in the vocabulary, or the
    /// operator must specify `reason_codes` explicitly on every
    /// rule.
    #[serde(default)]
    pub reason_codes: Option<Vec<String>>,
}

fn default_policy_automation_enabled() -> bool {
    true
}

/// Operator-side PDS auth config (§F1). Scope is narrow — just the
/// PDS URL + session file path. Named `[operator]` today; if future
/// operator-identity fields land (contact, alerts, etc.) the table
/// stays small enough to nest those in, or split to `[operator.pds]`
/// then.
#[derive(Debug, Clone, Deserialize)]
pub struct OperatorConfigToml {
    /// PDS base URL (e.g. `https://bsky.social`). No default — the
    /// labeler owner's PDS varies per deployment.
    pub pds_url: String,
    /// On-disk path for the operator session file. Written by
    /// `cairn operator-login`, read by `cairn publish-service-record`.
    /// Same §5.3 invariants as the moderator session file (mode 0600,
    /// owned by running user) via the shared
    /// `crate::credential_file` helper.
    pub session_path: std::path::PathBuf,
}

fn default_bind_addr() -> SocketAddr {
    DEFAULT_BIND_ADDR
        .parse()
        .expect("DEFAULT_BIND_ADDR is a valid socket address")
}

impl Config {
    /// Post-load validation run by [`Config::load`]. Exposed so call
    /// sites that construct a `Config` directly (e.g., tests) can
    /// share the same rule set.
    pub fn validate(&self) -> Result<()> {
        url::Url::parse(&self.service_endpoint).map_err(|e| {
            crate::error::Error::Signing(format!("config.service_endpoint is not a valid URL: {e}"))
        })?;
        if self.retention.sweep_run_at_utc_hour >= 24 {
            return Err(crate::error::Error::Signing(format!(
                "config.retention.sweep_run_at_utc_hour={} is out of range (0..=23)",
                self.retention.sweep_run_at_utc_hour
            )));
        }
        if self.retention.sweep_batch_size <= 0 {
            return Err(crate::error::Error::Signing(format!(
                "config.retention.sweep_batch_size={} must be > 0",
                self.retention.sweep_batch_size
            )));
        }
        // Reason vocabulary (§F20, #47): build via the canonical
        // resolver and bind it for the §F22 #71 cross-check below.
        // If the operator declared an empty [moderation_reasons]
        // section, an invalid identifier, a zero base_weight, or
        // an empty description, the resolver returns an
        // Error::Signing here that surfaces as a config-load
        // failure at startup.
        let vocab = crate::moderation::reasons::ReasonVocabulary::from_config(self)?;
        // Strike policy (§F20, #48): same single-source-of-truth
        // pattern. The resolver applies the curve-length convention
        // (`max(0, threshold - 1)`), strict-ascending check, and
        // decay-window-days >= 1 check. See
        // [`crate::moderation::policy`] for the full validation
        // rules.
        let _ = crate::moderation::policy::StrikePolicy::from_config(self)?;
        // Label emission policy (§F21, #58): same single-source-of-
        // truth pattern. The resolver applies the label-value naming
        // conventions, no-collision check across action_label_overrides
        // entries, and valid-action_type-key check on the override
        // maps. See [`crate::labels::policy`] for the full validation
        // rules.
        let _ = crate::labels::policy::LabelEmissionPolicy::from_config(self)?;
        // Policy automation (§F22, #71): each rule's per-field
        // validation runs in from_config; the cross-block check —
        // every rule's reason_codes must exist in the operator's
        // [moderation_reasons] vocabulary — runs here, where both
        // resolvers have completed. Each loader stays focused on
        // its own block; cross-block validation lives at the
        // Config level.
        let policy_automation =
            crate::policy::automation::PolicyAutomationPolicy::from_config(self)?;
        policy_automation.validate_reason_codes_against(&vocab)?;
        // PDS-admin policy (§F23, #83, v1.7): per-block validation
        // (URL scheme, env-var resolution, allowed-method set,
        // with_lift_after gating, every-action-type-mapped check)
        // runs in from_config. No cross-block check beyond
        // ActionType::from_db_str validation in the resolver
        // itself; the bridge's destination is the PDS, not
        // cairn-mod's reason vocabulary, so [moderation_reasons]
        // is unrelated. See [`crate::pds_admin::PdsAdminPolicy`]
        // for the full validation rules.
        let _ = crate::pds_admin::PdsAdminPolicy::from_config(self)?;
        // [xrpc_gateway] (§F23 inbound, #91, v1.7). Run the
        // resolver for its side effect: enforces required-field
        // presence when enabled, malformed-DID rejection,
        // bounds-checking on numeric tunables, unknown-extras-key
        // rejection. The resolved config is rebuilt at
        // `serve::run` startup; here we only care that the
        // validation passes.
        let _ = crate::xrpc_gateway::XrpcGatewayConfig::from_config(self)?;
        // Path existence of db_path / signing_key_path is checked at
        // use time by storage::open and SigningKey::load_from_file —
        // duplicating here would just double-fail and lose the
        // specific cause.
        Ok(())
    }

    /// Load configuration from the default TOML location + env
    /// overrides (see [`Self::load_from`] for the full precedence
    /// rules). The default location is `CAIRN_CONFIG` env var, or
    /// `/etc/cairn/cairn.toml` if unset.
    pub fn load() -> Result<Self> {
        let toml_path: PathBuf = std::env::var_os("CAIRN_CONFIG")
            .map(PathBuf::from)
            .unwrap_or_else(|| PathBuf::from("/etc/cairn/cairn.toml"));
        Self::load_from(Some(&toml_path))
    }

    /// Load configuration with an explicit TOML path (or `None` to
    /// skip the file layer entirely and rely on env overrides).
    ///
    /// Sources, low to high precedence:
    /// 1. Compiled-in defaults (`bind_addr` if unset, empty admin
    ///    table).
    /// 2. `toml_path` if `Some` and the file exists.
    /// 3. Environment variables prefixed `CAIRN_`
    ///    (e.g. `CAIRN_SERVICE_DID`).
    ///
    /// `cairn serve --config <path>` routes through this without
    /// mutating process env (which is `unsafe` under Rust 2024 and
    /// blocked by the crate's `#![forbid(unsafe_code)]`).
    pub fn load_from(toml_path: Option<&std::path::Path>) -> Result<Self> {
        let mut fig = Figment::new();
        if let Some(p) = toml_path
            && p.is_file()
        {
            fig = fig.merge(Toml::file(p));
        }
        fig = fig.merge(Env::prefixed("CAIRN_"));

        let cfg: Config = fig.extract()?;
        cfg.validate()?;
        Ok(cfg)
    }
}

impl From<AdminConfigToml> for crate::AdminConfig {
    fn from(t: AdminConfigToml) -> Self {
        // service_did / service_endpoint / declared_label_values are
        // populated separately at admin_router-construction time
        // (see `serve::run`) — they live elsewhere in `Config` and
        // would needlessly couple [admin] to those fields if pulled
        // through here.
        crate::AdminConfig {
            label_values: t.label_values,
            ..Default::default()
        }
    }
}

impl From<RetentionConfigToml> for crate::RetentionConfig {
    fn from(t: RetentionConfigToml) -> Self {
        crate::RetentionConfig {
            sweep_enabled: t.sweep_enabled,
            sweep_run_at_utc_hour: t.sweep_run_at_utc_hour,
            sweep_batch_size: t.sweep_batch_size,
        }
    }
}