-module(lightspeed@ops@operations_kit).
-compile([no_auto_import, nowarn_unused_vars, nowarn_unused_function, nowarn_nomatch, inline]).
-define(FILEPATH, "src/lightspeed/ops/operations_kit.gleam").
-export([canonical_runbooks/0, required_workflows/0, workflow_contract/1, workflow_plans/0, dashboards/0, drill_scenarios/0, runbook_valid/1, runbooks_cover_domains/0, workflow_contracts_safe/0, dashboards_cover_alert_contracts/0, drills_reproducible/0, operations_kit_ready/0, domain_label/1, workflow_label/1, runbook_signature/1, workflow_plan_signature/1, dashboard_signature/1, drill_signature/1, operations_kit_signature/0]).
-export_type([domain/0, workflow_action/0, step/0, runbook/0, workflow_plan/0, alert_contract/0, dashboard/0, drill_scenario/0]).

-if(?OTP_RELEASE >= 27).
-define(MODULEDOC(Str), -moduledoc(Str)).
-define(DOC(Str), -doc(Str)).
-else.
-define(MODULEDOC(Str), -compile([])).
-define(DOC(Str), -compile([])).
-endif.

?MODULEDOC(" Production app operations-kit contracts for M40.\n").

-type domain() :: runtime | transport | data | etl.

-type workflow_action() :: rollout | rollback | drain | replay | recover.

-type step() :: {step, binary(), binary(), binary(), boolean()}.

-type runbook() :: {runbook, domain(), binary(), binary(), list(step())}.

-type workflow_plan() :: {workflow_plan,
        workflow_action(),
        boolean(),
        boolean(),
        list(binary()),
        list(binary()),
        list(binary())}.

-type alert_contract() :: {alert_contract,
        binary(),
        binary(),
        binary(),
        binary(),
        binary()}.

-type dashboard() :: {dashboard,
        binary(),
        list(binary()),
        list(alert_contract())}.

-type drill_scenario() :: {drill_scenario,
        binary(),
        domain(),
        workflow_action(),
        binary(),
        list(binary()),
        binary()}.

-file("src/lightspeed/ops/operations_kit.gleam", 603).
-spec etl_reliability_runbook() -> runbook().
etl_reliability_runbook() ->
    {runbook,
        etl,
        <<"etl_reliability"/utf8>>,
        <<"slo_budget_failure_or_poison_message_escalation"/utf8>>,
        [{step,
                <<"pause_affected_pipelines"/utf8>>,
                <<"Pause affected pipelines and capture backlog profile."/utf8>>,
                <<"audit.etl.pause"/utf8>>,
                true},
            {step,
                <<"classify_failure_path"/utf8>>,
                <<"Classify outage, poison, replay, or schema fault class."/utf8>>,
                <<"audit.etl.classification"/utf8>>,
                false},
            {step,
                <<"apply_recovery_strategy"/utf8>>,
                <<"Apply drain or replay strategy with checkpoint evidence."/utf8>>,
                <<"audit.etl.recovery_strategy"/utf8>>,
                true},
            {step,
                <<"verify_slo_recovery"/utf8>>,
                <<"Verify lag, throughput, retry-rate, and replay SLO recovery."/utf8>>,
                <<"dashboard.etl.slo_recovery"/utf8>>,
                false},
            {step,
                <<"resume_and_handoff"/utf8>>,
                <<"Resume flows and publish on-call handoff summary."/utf8>>,
                <<"audit.etl.handoff"/utf8>>,
                true}]}.

-file("src/lightspeed/ops/operations_kit.gleam", 563).
-spec data_integrity_runbook() -> runbook().
data_integrity_runbook() ->
    {runbook,
        data,
        <<"data_integrity"/utf8>>,
        <<"checkpoint_drift_or_schema_quality_failure"/utf8>>,
        [{step,
                <<"freeze_mutating_writes"/utf8>>,
                <<"Freeze mutating writes for affected streams."/utf8>>,
                <<"audit.data.freeze"/utf8>>,
                true},
            {step,
                <<"select_replay_checkpoint"/utf8>>,
                <<"Select replay checkpoint and validate idempotency scope."/utf8>>,
                <<"audit.data.checkpoint"/utf8>>,
                true},
            {step,
                <<"run_quality_guard"/utf8>>,
                <<"Run payload-quality and schema compatibility guards."/utf8>>,
                <<"audit.data.quality_guard"/utf8>>,
                false},
            {step,
                <<"execute_replay"/utf8>>,
                <<"Replay affected windows with duplicate-sink suppression."/utf8>>,
                <<"audit.data.replay"/utf8>>,
                true},
            {step,
                <<"thaw_writes"/utf8>>,
                <<"Thaw writes after deterministic reconciliation checks."/utf8>>,
                <<"audit.data.thaw"/utf8>>,
                true}]}.

-file("src/lightspeed/ops/operations_kit.gleam", 523).
-spec transport_degradation_runbook() -> runbook().
transport_degradation_runbook() ->
    {runbook,
        transport,
        <<"transport_degradation"/utf8>>,
        <<"ack_latency_or_receive_errors_over_budget"/utf8>>,
        [{step,
                <<"confirm_transport_profile"/utf8>>,
                <<"Confirm active transport profile and fallback state."/utf8>>,
                <<"audit.transport.profile"/utf8>>,
                false},
            {step,
                <<"drain_high_risk_topics"/utf8>>,
                <<"Drain high-risk channels and freeze high-churn pushes."/utf8>>,
                <<"audit.transport.drain"/utf8>>,
                true},
            {step,
                <<"activate_fallback_mode"/utf8>>,
                <<"Activate progressive fallback and rate controls."/utf8>>,
                <<"audit.transport.fallback"/utf8>>,
                true},
            {step,
                <<"verify_ack_recovery"/utf8>>,
                <<"Verify p95 ack-latency and receive-error recovery."/utf8>>,
                <<"dashboard.transport.recovery"/utf8>>,
                false},
            {step,
                <<"resume_normal_flow"/utf8>>,
                <<"Resume normal transport profile after guard checks."/utf8>>,
                <<"audit.transport.resume"/utf8>>,
                true}]}.

-file("src/lightspeed/ops/operations_kit.gleam", 483).
-spec runtime_incident_runbook() -> runbook().
runtime_incident_runbook() ->
    {runbook,
        runtime,
        <<"runtime_incident"/utf8>>,
        <<"crash_rate_or_heartbeat_timeout_spike"/utf8>>,
        [{step,
                <<"capture_release_fingerprint"/utf8>>,
                <<"Capture deploy digest and scope impacted sessions."/utf8>>,
                <<"audit.release.digest"/utf8>>,
                false},
            {step,
                <<"enable_guardrails"/utf8>>,
                <<"Enable mitigation controls for high-risk routes."/utf8>>,
                <<"audit.runtime.guardrail_change"/utf8>>,
                true},
            {step,
                <<"execute_safe_rollback"/utf8>>,
                <<"Rollback to last known good artifact with dual control."/utf8>>,
                <<"audit.runtime.rollback"/utf8>>,
                true},
            {step,
                <<"verify_session_recovery"/utf8>>,
                <<"Verify reconnect and patch-ack recovery across canary set."/utf8>>,
                <<"trace.runtime.recovery"/utf8>>,
                false},
            {step,
                <<"publish_handoff_summary"/utf8>>,
                <<"Publish incident timeline and next actions."/utf8>>,
                <<"audit.incident.handoff"/utf8>>,
                false}]}.

-file("src/lightspeed/ops/operations_kit.gleam", 73).
?DOC(" Canonical M40 runbooks.\n").
-spec canonical_runbooks() -> list(runbook()).
canonical_runbooks() ->
    [runtime_incident_runbook(),
        transport_degradation_runbook(),
        data_integrity_runbook(),
        etl_reliability_runbook()].

-file("src/lightspeed/ops/operations_kit.gleam", 83).
?DOC(" Required operator-safe workflows for M40.\n").
-spec required_workflows() -> list(workflow_action()).
required_workflows() ->
    [rollout, rollback, drain, replay, recover].

-file("src/lightspeed/ops/operations_kit.gleam", 99).
?DOC(" Contract for one operator workflow.\n").
-spec workflow_contract(workflow_action()) -> workflow_plan().
workflow_contract(Action) ->
    case Action of
        rollout ->
            {workflow_plan,
                rollout,
                true,
                true,
                [<<"change_ticket_linked"/utf8>>,
                    <<"canary_budget_green"/utf8>>,
                    <<"rollback_artifact_ready"/utf8>>],
                [<<"operator_identity"/utf8>>,
                    <<"approver_identity"/utf8>>,
                    <<"artifact_digest"/utf8>>],
                [<<"synthetic_smoke_green"/utf8>>,
                    <<"error_budget_guard_green"/utf8>>,
                    <<"customer_path_sample_green"/utf8>>]};

        rollback ->
            {workflow_plan,
                rollback,
                true,
                true,
                [<<"incident_ticket_linked"/utf8>>,
                    <<"last_known_good_digest_available"/utf8>>,
                    <<"data_migration_guard_confirmed"/utf8>>],
                [<<"operator_identity"/utf8>>,
                    <<"rollback_reason"/utf8>>,
                    <<"rollback_target_digest"/utf8>>],
                [<<"crash_rate_recovered"/utf8>>,
                    <<"latency_budget_recovered"/utf8>>,
                    <<"drift_gate_revalidated"/utf8>>]};

        drain ->
            {workflow_plan,
                drain,
                true,
                true,
                [<<"backlog_depth_measured"/utf8>>,
                    <<"downstream_sinks_healthy"/utf8>>,
                    <<"replay_window_checkpointed"/utf8>>],
                [<<"operator_identity"/utf8>>,
                    <<"drain_scope"/utf8>>,
                    <<"checkpoint_revision"/utf8>>],
                [<<"in_flight_zero"/utf8>>,
                    <<"queue_depth_flat"/utf8>>,
                    <<"replay_window_consistent"/utf8>>]};

        replay ->
            {workflow_plan,
                replay,
                true,
                true,
                [<<"checkpoint_revision_selected"/utf8>>,
                    <<"payload_quality_gate_green"/utf8>>,
                    <<"idempotency_keys_confirmed"/utf8>>],
                [<<"operator_identity"/utf8>>,
                    <<"replay_start_checkpoint"/utf8>>,
                    <<"replay_target_scope"/utf8>>],
                [<<"replay_completion_green"/utf8>>,
                    <<"duplicate_sink_guard_green"/utf8>>,
                    <<"etl_budget_recovered"/utf8>>]};

        recover ->
            {workflow_plan,
                recover,
                true,
                true,
                [<<"incident_classified"/utf8>>,
                    <<"safe_mode_controls_applied"/utf8>>,
                    <<"communications_window_open"/utf8>>],
                [<<"operator_identity"/utf8>>,
                    <<"recovery_strategy"/utf8>>,
                    <<"timeline_reference"/utf8>>],
                [<<"all_alerts_acknowledged"/utf8>>,
                    <<"runbook_followups_created"/utf8>>,
                    <<"handoff_note_published"/utf8>>]}
    end.

-file("src/lightspeed/ops/operations_kit.gleam", 88).
?DOC(" M40 workflow plans.\n").
-spec workflow_plans() -> list(workflow_plan()).
workflow_plans() ->
    [workflow_contract(rollout),
        workflow_contract(rollback),
        workflow_contract(drain),
        workflow_contract(replay),
        workflow_contract(recover)].

-file("src/lightspeed/ops/operations_kit.gleam", 214).
?DOC(" Standardized M40 dashboards and alert contracts.\n").
-spec dashboards() -> list(dashboard()).
dashboards() ->
    [{dashboard,
            <<"runtime_transport_baseline"/utf8>>,
            [<<"lightspeed.session.crashed_total"/utf8>>,
                <<"lightspeed.session.heartbeat_timeout_total"/utf8>>,
                <<"lightspeed.transport.receive.error_total"/utf8>>,
                <<"lightspeed.transport.ack_latency_p95_ms"/utf8>>],
            [{alert_contract,
                    <<"lightspeed.session.crashed_total"/utf8>>,
                    <<">=3"/utf8>>,
                    <<"5m"/utf8>>,
                    <<"page"/utf8>>,
                    <<"runtime_incident"/utf8>>},
                {alert_contract,
                    <<"lightspeed.transport.ack_latency_p95_ms"/utf8>>,
                    <<">=250"/utf8>>,
                    <<"10m"/utf8>>,
                    <<"ticket"/utf8>>,
                    <<"transport_degradation"/utf8>>}]},
        {dashboard,
            <<"data_pipeline_baseline"/utf8>>,
            [<<"lightspeed.pipeline.lag_ms"/utf8>>,
                <<"lightspeed.pipeline.retry_total"/utf8>>,
                <<"lightspeed.pipeline.dead_letter_total"/utf8>>,
                <<"lightspeed.pipeline.checkpoint_drift_total"/utf8>>],
            [{alert_contract,
                    <<"lightspeed.pipeline.checkpoint_drift_total"/utf8>>,
                    <<">=1"/utf8>>,
                    <<"5m"/utf8>>,
                    <<"page"/utf8>>,
                    <<"data_integrity"/utf8>>},
                {alert_contract,
                    <<"lightspeed.pipeline.lag_ms"/utf8>>,
                    <<">=120000"/utf8>>,
                    <<"15m"/utf8>>,
                    <<"ticket"/utf8>>,
                    <<"etl_reliability"/utf8>>}]},
        {dashboard,
            <<"etl_reliability_baseline"/utf8>>,
            [<<"lightspeed.etl.slo_budget_failures_total"/utf8>>,
                <<"lightspeed.etl.replay_recovery_ms"/utf8>>,
                <<"lightspeed.etl.poison_message_total"/utf8>>,
                <<"lightspeed.etl.schema_quality_failures_total"/utf8>>],
            [{alert_contract,
                    <<"lightspeed.etl.slo_budget_failures_total"/utf8>>,
                    <<">=1"/utf8>>,
                    <<"5m"/utf8>>,
                    <<"page"/utf8>>,
                    <<"etl_reliability"/utf8>>},
                {alert_contract,
                    <<"lightspeed.etl.schema_quality_failures_total"/utf8>>,
                    <<">=1"/utf8>>,
                    <<"10m"/utf8>>,
                    <<"ticket"/utf8>>,
                    <<"data_integrity"/utf8>>}]}].

-file("src/lightspeed/ops/operations_kit.gleam", 295).
?DOC(" Deterministic M40 operations drills.\n").
-spec drill_scenarios() -> list(drill_scenario()).
drill_scenarios() ->
    [{drill_scenario,
            <<"runtime_rollback_drill"/utf8>>,
            runtime,
            rollback,
            <<"runtime_incident"/utf8>>,
            [<<"audit.runtime.rollback.timeline"/utf8>>,
                <<"trace.runtime.recovery.span"/utf8>>,
                <<"dashboard.runtime_transport_baseline.snapshot"/utf8>>],
            <<"m40-runtime-rollback-001"/utf8>>},
        {drill_scenario,
            <<"transport_drain_recover_drill"/utf8>>,
            transport,
            drain,
            <<"transport_degradation"/utf8>>,
            [<<"audit.transport.drain.timeline"/utf8>>,
                <<"queue.transport.backlog.snapshot"/utf8>>,
                <<"dashboard.runtime_transport_baseline.snapshot"/utf8>>],
            <<"m40-transport-drain-001"/utf8>>},
        {drill_scenario,
            <<"data_replay_integrity_drill"/utf8>>,
            data,
            replay,
            <<"data_integrity"/utf8>>,
            [<<"audit.data.replay.timeline"/utf8>>,
                <<"checkpoint.data.replay.selection"/utf8>>,
                <<"dashboard.data_pipeline_baseline.snapshot"/utf8>>],
            <<"m40-data-replay-001"/utf8>>},
        {drill_scenario,
            <<"etl_recovery_drill"/utf8>>,
            etl,
            recover,
            <<"etl_reliability"/utf8>>,
            [<<"audit.etl.recovery.timeline"/utf8>>,
                <<"slo.etl.budget.after_mitigation"/utf8>>,
                <<"dashboard.etl_reliability_baseline.snapshot"/utf8>>],
            <<"m40-etl-recovery-001"/utf8>>}].

-file("src/lightspeed/ops/operations_kit.gleam", 654).
-spec has_reversible_step(list(step())) -> boolean().
has_reversible_step(Steps) ->
    case Steps of
        [] ->
            false;

        [Step | Rest] ->
            erlang:element(5, Step) orelse has_reversible_step(Rest)
    end.

-file("src/lightspeed/ops/operations_kit.gleam", 643).
-spec steps_valid(list(step())) -> boolean().
steps_valid(Steps) ->
    case Steps of
        [] ->
            true;

        [Step | Rest] ->
            (((erlang:element(2, Step) /= <<""/utf8>>) andalso (erlang:element(
                3,
                Step
            )
            /= <<""/utf8>>))
            andalso (erlang:element(4, Step) /= <<""/utf8>>))
            andalso steps_valid(Rest)
    end.

-file("src/lightspeed/ops/operations_kit.gleam", 349).
?DOC(" Validate one runbook contract.\n").
-spec runbook_valid(runbook()) -> boolean().
runbook_valid(Runbook) ->
    ((((erlang:element(3, Runbook) /= <<""/utf8>>) andalso (erlang:element(
        4,
        Runbook
    )
    /= <<""/utf8>>))
    andalso (erlang:length(erlang:element(5, Runbook)) >= 4))
    andalso steps_valid(erlang:element(5, Runbook)))
    andalso has_reversible_step(erlang:element(5, Runbook)).

-file("src/lightspeed/ops/operations_kit.gleam", 668).
-spec all_runbooks_valid(list(runbook())) -> boolean().
all_runbooks_valid(Runbooks) ->
    case Runbooks of
        [] ->
            true;

        [Runbook | Rest] ->
            runbook_valid(Runbook) andalso all_runbooks_valid(Rest)
    end.

-file("src/lightspeed/ops/operations_kit.gleam", 661).
-spec has_domain(list(runbook()), domain()) -> boolean().
has_domain(Runbooks, Domain) ->
    case Runbooks of
        [] ->
            false;

        [Runbook | Rest] ->
            (erlang:element(2, Runbook) =:= Domain) orelse has_domain(
                Rest,
                Domain
            )
    end.

-file("src/lightspeed/ops/operations_kit.gleam", 358).
?DOC(" Validate M40 runbook-domain coverage.\n").
-spec runbooks_cover_domains() -> boolean().
runbooks_cover_domains() ->
    Runbooks = canonical_runbooks(),
    (((has_domain(Runbooks, runtime) andalso has_domain(Runbooks, transport))
    andalso has_domain(Runbooks, data))
    andalso has_domain(Runbooks, etl))
    andalso all_runbooks_valid(Runbooks).

-file("src/lightspeed/ops/operations_kit.gleam", 832).
-spec string_entries_non_empty(list(binary())) -> boolean().
string_entries_non_empty(Values) ->
    case Values of
        [] ->
            true;

        [Value | Rest] ->
            (Value /= <<""/utf8>>) andalso string_entries_non_empty(Rest)
    end.

-file("src/lightspeed/ops/operations_kit.gleam", 683).
-spec workflow_plan_valid(workflow_plan()) -> boolean().
workflow_plan_valid(Plan) ->
    ((((((erlang:element(3, Plan) andalso erlang:element(4, Plan)) andalso (erlang:length(
        erlang:element(5, Plan)
    )
    >= 3))
    andalso (erlang:length(erlang:element(6, Plan)) >= 3))
    andalso (erlang:length(erlang:element(7, Plan)) >= 3))
    andalso string_entries_non_empty(erlang:element(5, Plan)))
    andalso string_entries_non_empty(erlang:element(6, Plan)))
    andalso string_entries_non_empty(erlang:element(7, Plan)).

-file("src/lightspeed/ops/operations_kit.gleam", 675).
-spec all_workflow_plans_valid(list(workflow_plan())) -> boolean().
all_workflow_plans_valid(Plans) ->
    case Plans of
        [] ->
            true;

        [Plan | Rest] ->
            workflow_plan_valid(Plan) andalso all_workflow_plans_valid(Rest)
    end.

-file("src/lightspeed/ops/operations_kit.gleam", 368).
?DOC(" Validate operator-safe workflow contracts.\n").
-spec workflow_contracts_safe() -> boolean().
workflow_contracts_safe() ->
    _pipe = workflow_plans(),
    all_workflow_plans_valid(_pipe).

-file("src/lightspeed/ops/operations_kit.gleam", 739).
-spec has_runbook(list(runbook()), binary()) -> boolean().
has_runbook(Runbooks, Name) ->
    case Runbooks of
        [] ->
            false;

        [Runbook | Rest] ->
            (erlang:element(3, Runbook) =:= Name) orelse has_runbook(Rest, Name)
    end.

-file("src/lightspeed/ops/operations_kit.gleam", 734).
-spec known_runbook(binary()) -> boolean().
known_runbook(Name) ->
    _pipe = canonical_runbooks(),
    has_runbook(_pipe, Name).

-file("src/lightspeed/ops/operations_kit.gleam", 730).
-spec standard_window(binary()) -> boolean().
standard_window(Window) ->
    ((Window =:= <<"5m"/utf8>>) orelse (Window =:= <<"10m"/utf8>>)) orelse (Window
    =:= <<"15m"/utf8>>).

-file("src/lightspeed/ops/operations_kit.gleam", 825).
-spec has_string(list(binary()), binary()) -> boolean().
has_string(Values, Target) ->
    case Values of
        [] ->
            false;

        [Value | Rest] ->
            (Value =:= Target) orelse has_string(Rest, Target)
    end.

-file("src/lightspeed/ops/operations_kit.gleam", 718).
-spec alert_valid(alert_contract(), list(binary())) -> boolean().
alert_valid(Alert, Metrics) ->
    ((((((((erlang:element(2, Alert) /= <<""/utf8>>) andalso (erlang:element(
        3,
        Alert
    )
    /= <<""/utf8>>))
    andalso (erlang:element(4, Alert) /= <<""/utf8>>))
    andalso (erlang:element(5, Alert) /= <<""/utf8>>))
    andalso (erlang:element(6, Alert) /= <<""/utf8>>))
    andalso has_string(Metrics, erlang:element(2, Alert)))
    andalso ((erlang:element(5, Alert) =:= <<"page"/utf8>>) orelse (erlang:element(
        5,
        Alert
    )
    =:= <<"ticket"/utf8>>)))
    andalso standard_window(erlang:element(4, Alert)))
    andalso known_runbook(erlang:element(6, Alert)).

-file("src/lightspeed/ops/operations_kit.gleam", 710).
-spec alerts_valid(list(alert_contract()), list(binary())) -> boolean().
alerts_valid(Alerts, Metrics) ->
    case Alerts of
        [] ->
            true;

        [Alert | Rest] ->
            alert_valid(Alert, Metrics) andalso alerts_valid(Rest, Metrics)
    end.

-file("src/lightspeed/ops/operations_kit.gleam", 702).
-spec dashboard_valid(dashboard()) -> boolean().
dashboard_valid(Contract) ->
    ((((erlang:element(2, Contract) /= <<""/utf8>>) andalso (erlang:length(
        erlang:element(3, Contract)
    )
    >= 4))
    andalso (erlang:length(erlang:element(4, Contract)) >= 2))
    andalso string_entries_non_empty(erlang:element(3, Contract)))
    andalso alerts_valid(
        erlang:element(4, Contract),
        erlang:element(3, Contract)
    ).

-file("src/lightspeed/ops/operations_kit.gleam", 694).
-spec all_dashboards_valid(list(dashboard())) -> boolean().
all_dashboards_valid(Contracts) ->
    case Contracts of
        [] ->
            true;

        [Contract | Rest] ->
            dashboard_valid(Contract) andalso all_dashboards_valid(Rest)
    end.

-file("src/lightspeed/ops/operations_kit.gleam", 374).
?DOC(" Validate dashboard + alert contracts.\n").
-spec dashboards_cover_alert_contracts() -> boolean().
dashboards_cover_alert_contracts() ->
    Contracts = dashboards(),
    (erlang:length(Contracts) >= 3) andalso all_dashboards_valid(Contracts).

-file("src/lightspeed/ops/operations_kit.gleam", 814).
-spec unique_strings_loop(list(binary()), list(binary())) -> boolean().
unique_strings_loop(Values, Seen) ->
    case Values of
        [] ->
            true;

        [Value | Rest] ->
            case has_string(Seen, Value) of
                true ->
                    false;

                false ->
                    unique_strings_loop(Rest, [Value | Seen])
            end
    end.

-file("src/lightspeed/ops/operations_kit.gleam", 810).
-spec unique_strings(list(binary())) -> boolean().
unique_strings(Values) ->
    unique_strings_loop(Values, []).

-file("src/lightspeed/ops/operations_kit.gleam", 800).
-spec collect_drill_seeds(list(drill_scenario()), list(binary())) -> list(binary()).
collect_drill_seeds(Drills, Acc) ->
    case Drills of
        [] ->
            lists:reverse(Acc);

        [Drill | Rest] ->
            collect_drill_seeds(Rest, [erlang:element(7, Drill) | Acc])
    end.

-file("src/lightspeed/ops/operations_kit.gleam", 784).
-spec unique_drill_seeds(list(drill_scenario())) -> boolean().
unique_drill_seeds(Drills) ->
    _pipe = Drills,
    _pipe@1 = collect_drill_seeds(_pipe, []),
    unique_strings(_pipe@1).

-file("src/lightspeed/ops/operations_kit.gleam", 790).
-spec collect_drill_names(list(drill_scenario()), list(binary())) -> list(binary()).
collect_drill_names(Drills, Acc) ->
    case Drills of
        [] ->
            lists:reverse(Acc);

        [Drill | Rest] ->
            collect_drill_names(Rest, [erlang:element(2, Drill) | Acc])
    end.

-file("src/lightspeed/ops/operations_kit.gleam", 778).
-spec unique_drill_names(list(drill_scenario())) -> boolean().
unique_drill_names(Drills) ->
    _pipe = Drills,
    _pipe@1 = collect_drill_names(_pipe, []),
    unique_strings(_pipe@1).

-file("src/lightspeed/ops/operations_kit.gleam", 768).
-spec has_workflow(list(workflow_action()), workflow_action()) -> boolean().
has_workflow(Workflows, Action) ->
    case Workflows of
        [] ->
            false;

        [Workflow | Rest] ->
            (Workflow =:= Action) orelse has_workflow(Rest, Action)
    end.

-file("src/lightspeed/ops/operations_kit.gleam", 763).
-spec required_workflow(workflow_action()) -> boolean().
required_workflow(Action) ->
    _pipe = required_workflows(),
    has_workflow(_pipe, Action).

-file("src/lightspeed/ops/operations_kit.gleam", 753).
-spec drill_valid(drill_scenario()) -> boolean().
drill_valid(Drill) ->
    ((((((erlang:element(2, Drill) /= <<""/utf8>>) andalso (erlang:element(
        5,
        Drill
    )
    /= <<""/utf8>>))
    andalso (erlang:element(7, Drill) /= <<""/utf8>>))
    andalso (erlang:length(erlang:element(6, Drill)) >= 3))
    andalso string_entries_non_empty(erlang:element(6, Drill)))
    andalso known_runbook(erlang:element(5, Drill)))
    andalso required_workflow(erlang:element(4, Drill)).

-file("src/lightspeed/ops/operations_kit.gleam", 746).
-spec all_drills_valid(list(drill_scenario())) -> boolean().
all_drills_valid(Drills) ->
    case Drills of
        [] ->
            true;

        [Drill | Rest] ->
            drill_valid(Drill) andalso all_drills_valid(Rest)
    end.

-file("src/lightspeed/ops/operations_kit.gleam", 380).
?DOC(" Validate deterministic and reproducible drill contracts.\n").
-spec drills_reproducible() -> boolean().
drills_reproducible() ->
    Drills = drill_scenarios(),
    (((erlang:length(Drills) >= 4) andalso all_drills_valid(Drills)) andalso unique_drill_names(
        Drills
    ))
    andalso unique_drill_seeds(Drills).

-file("src/lightspeed/ops/operations_kit.gleam", 389).
?DOC(" Full M40 readiness guard.\n").
-spec operations_kit_ready() -> boolean().
operations_kit_ready() ->
    ((runbooks_cover_domains() andalso workflow_contracts_safe()) andalso dashboards_cover_alert_contracts(
        
    ))
    andalso drills_reproducible().

-file("src/lightspeed/ops/operations_kit.gleam", 397).
?DOC(" Domain label.\n").
-spec domain_label(domain()) -> binary().
domain_label(Domain) ->
    case Domain of
        runtime ->
            <<"runtime"/utf8>>;

        transport ->
            <<"transport"/utf8>>;

        data ->
            <<"data"/utf8>>;

        etl ->
            <<"etl"/utf8>>
    end.

-file("src/lightspeed/ops/operations_kit.gleam", 407).
?DOC(" Workflow label.\n").
-spec workflow_label(workflow_action()) -> binary().
workflow_label(Action) ->
    case Action of
        rollout ->
            <<"rollout"/utf8>>;

        rollback ->
            <<"rollback"/utf8>>;

        drain ->
            <<"drain"/utf8>>;

        replay ->
            <<"replay"/utf8>>;

        recover ->
            <<"recover"/utf8>>
    end.

-file("src/lightspeed/ops/operations_kit.gleam", 867).
-spec bool_label(boolean()) -> binary().
bool_label(Value) ->
    case Value of
        true ->
            <<"true"/utf8>>;

        false ->
            <<"false"/utf8>>
    end.

-file("src/lightspeed/ops/operations_kit.gleam", 839).
-spec step_signature(step()) -> binary().
step_signature(Step) ->
    <<<<<<<<(erlang:element(2, Step))/binary, ":reversible="/utf8>>/binary,
                (bool_label(erlang:element(5, Step)))/binary>>/binary,
            ":evidence="/utf8>>/binary,
        (erlang:element(4, Step))/binary>>.

-file("src/lightspeed/ops/operations_kit.gleam", 859).
-spec join_with(binary(), list(binary())) -> binary().
join_with(Separator, Values) ->
    case Values of
        [] ->
            <<""/utf8>>;

        [Value] ->
            Value;

        [Value@1 | Rest] ->
            <<<<Value@1/binary, Separator/binary>>/binary,
                (join_with(Separator, Rest))/binary>>
    end.

-file("src/lightspeed/ops/operations_kit.gleam", 418).
?DOC(" Stable runbook signature.\n").
-spec runbook_signature(runbook()) -> binary().
runbook_signature(Runbook) ->
    <<<<<<<<<<<<<<"runbook:"/utf8,
                                (domain_label(erlang:element(2, Runbook)))/binary>>/binary,
                            ":"/utf8>>/binary,
                        (erlang:element(3, Runbook))/binary>>/binary,
                    "|trigger="/utf8>>/binary,
                (erlang:element(4, Runbook))/binary>>/binary,
            "|steps="/utf8>>/binary,
        (join_with(
            <<";"/utf8>>,
            gleam@list:map(erlang:element(5, Runbook), fun step_signature/1)
        ))/binary>>.

-file("src/lightspeed/ops/operations_kit.gleam", 430).
?DOC(" Stable workflow-plan signature.\n").
-spec workflow_plan_signature(workflow_plan()) -> binary().
workflow_plan_signature(Plan) ->
    <<<<<<<<<<<<<<<<<<<<<<"workflow:"/utf8,
                                                (workflow_label(
                                                    erlang:element(2, Plan)
                                                ))/binary>>/binary,
                                            "|dual_control="/utf8>>/binary,
                                        (bool_label(erlang:element(3, Plan)))/binary>>/binary,
                                    "|reversible="/utf8>>/binary,
                                (bool_label(erlang:element(4, Plan)))/binary>>/binary,
                            "|preflight="/utf8>>/binary,
                        (join_with(<<","/utf8>>, erlang:element(5, Plan)))/binary>>/binary,
                    "|audit="/utf8>>/binary,
                (join_with(<<","/utf8>>, erlang:element(6, Plan)))/binary>>/binary,
            "|post="/utf8>>/binary,
        (join_with(<<","/utf8>>, erlang:element(7, Plan)))/binary>>.

-file("src/lightspeed/ops/operations_kit.gleam", 847).
-spec alert_signature(alert_contract()) -> binary().
alert_signature(Alert) ->
    <<<<<<<<<<<<<<<<(erlang:element(2, Alert))/binary, ":threshold="/utf8>>/binary,
                                (erlang:element(3, Alert))/binary>>/binary,
                            ":window="/utf8>>/binary,
                        (erlang:element(4, Alert))/binary>>/binary,
                    ":severity="/utf8>>/binary,
                (erlang:element(5, Alert))/binary>>/binary,
            ":runbook="/utf8>>/binary,
        (erlang:element(6, Alert))/binary>>.

-file("src/lightspeed/ops/operations_kit.gleam", 446).
?DOC(" Stable dashboard signature.\n").
-spec dashboard_signature(dashboard()) -> binary().
dashboard_signature(Dashboard) ->
    <<<<<<<<<<"dashboard:"/utf8, (erlang:element(2, Dashboard))/binary>>/binary,
                    "|metrics="/utf8>>/binary,
                (join_with(<<","/utf8>>, erlang:element(3, Dashboard)))/binary>>/binary,
            "|alerts="/utf8>>/binary,
        (join_with(
            <<";"/utf8>>,
            gleam@list:map(erlang:element(4, Dashboard), fun alert_signature/1)
        ))/binary>>.

-file("src/lightspeed/ops/operations_kit.gleam", 456).
?DOC(" Stable drill signature.\n").
-spec drill_signature(drill_scenario()) -> binary().
drill_signature(Drill) ->
    <<<<<<<<<<<<<<<<<<<<<<"drill:"/utf8, (erlang:element(2, Drill))/binary>>/binary,
                                            "|domain="/utf8>>/binary,
                                        (domain_label(erlang:element(3, Drill)))/binary>>/binary,
                                    "|workflow="/utf8>>/binary,
                                (workflow_label(erlang:element(4, Drill)))/binary>>/binary,
                            "|runbook="/utf8>>/binary,
                        (erlang:element(5, Drill))/binary>>/binary,
                    "|seed="/utf8>>/binary,
                (erlang:element(7, Drill))/binary>>/binary,
            "|evidence="/utf8>>/binary,
        (join_with(<<","/utf8>>, erlang:element(6, Drill)))/binary>>.

-file("src/lightspeed/ops/operations_kit.gleam", 472).
?DOC(" Stable full-kit signature for deterministic M40 fixtures.\n").
-spec operations_kit_signature() -> binary().
operations_kit_signature() ->
    <<<<<<<<<<<<<<"runbooks="/utf8,
                                (join_with(
                                    <<";"/utf8>>,
                                    gleam@list:map(
                                        canonical_runbooks(),
                                        fun runbook_signature/1
                                    )
                                ))/binary>>/binary,
                            "|workflows="/utf8>>/binary,
                        (join_with(
                            <<";"/utf8>>,
                            gleam@list:map(
                                workflow_plans(),
                                fun workflow_plan_signature/1
                            )
                        ))/binary>>/binary,
                    "|dashboards="/utf8>>/binary,
                (join_with(
                    <<";"/utf8>>,
                    gleam@list:map(dashboards(), fun dashboard_signature/1)
                ))/binary>>/binary,
            "|drills="/utf8>>/binary,
        (join_with(
            <<";"/utf8>>,
            gleam@list:map(drill_scenarios(), fun drill_signature/1)
        ))/binary>>.