-module(lightspeed@ops@data_ergonomics_harness).
-compile([no_auto_import, nowarn_unused_vars, nowarn_unused_function, nowarn_nomatch, inline]).
-define(FILEPATH, "src/lightspeed/ops/data_ergonomics_harness.gleam").
-export([pass_fail_label/1, run_scenario/1, run_matrix/0, profile_version_label/0, scenario_label/1, signature/1, scenario/1, deterministic/1, outcomes/1, failed_scenarios/1, nondeterministic_failures/1, report_signature/1, snapshot_signature/0, snapshot_report_markdown/0]).
-export_type([scenario/0, scenario_outcome/0, report/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(" Deterministic ORM/data ergonomics parity harness for M57.\n").

-type scenario() :: crud_and_dashboard_ergonomics_coverage |
    nested_changeset_validation_propagation |
    unit_of_work_and_optimistic_concurrency_contracts |
    query_diagnostics_regression_signals |
    regression_gate_determinism.

-type scenario_outcome() :: {scenario_outcome,
        scenario(),
        boolean(),
        boolean(),
        binary()}.

-type report() :: {report, list(scenario_outcome()), integer(), integer()}.

-file("src/lightspeed/ops/data_ergonomics_harness.gleam", 418).
-spec count_nondeterministic(list(scenario_outcome())) -> integer().
count_nondeterministic(Outcomes) ->
    _pipe = Outcomes,
    _pipe@1 = gleam@list:filter(
        _pipe,
        fun(Outcome) -> not erlang:element(4, Outcome) end
    ),
    erlang:length(_pipe@1).

-file("src/lightspeed/ops/data_ergonomics_harness.gleam", 412).
-spec count_failed(list(scenario_outcome())) -> integer().
count_failed(Outcomes) ->
    _pipe = Outcomes,
    _pipe@1 = gleam@list:filter(
        _pipe,
        fun(Outcome) -> not erlang:element(3, Outcome) end
    ),
    erlang:length(_pipe@1).

-file("src/lightspeed/ops/data_ergonomics_harness.gleam", 95).
?DOC(" Stable pass/fail label.\n").
-spec pass_fail_label(scenario_outcome()) -> binary().
pass_fail_label(Outcome) ->
    case erlang:element(3, Outcome) of
        true ->
            <<"pass"/utf8>>;

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

-file("src/lightspeed/ops/data_ergonomics_harness.gleam", 327).
-spec evaluate_query_diagnostics_regression_signals() -> {boolean(), binary()}.
evaluate_query_diagnostics_regression_signals() ->
    Noisy = begin
        _pipe = lightspeed@data_ergonomics:query_shape(
            <<"dashboard_posts"/utf8>>,
            120,
            8,
            190,
            <<"trace-m57-a"/utf8>>
        ),
        lightspeed@data_ergonomics:diagnose_query(_pipe)
    end,
    Healthy = begin
        _pipe@1 = lightspeed@data_ergonomics:query_shape(
            <<"dashboard_posts"/utf8>>,
            120,
            2,
            45,
            <<"trace-m57-b"/utf8>>
        ),
        lightspeed@data_ergonomics:diagnose_query(_pipe@1)
    end,
    Noisy_signature = lightspeed@data_ergonomics:diagnostics_signature(Noisy),
    Healthy_signature = lightspeed@data_ergonomics:diagnostics_signature(
        Healthy
    ),
    Passed = (Noisy_signature =:= <<"n_plus_one:dashboard_posts:statements=8;slow_query:dashboard_posts:latency_ms=190;trace_correlated:trace-m57-a:query=dashboard_posts"/utf8>>)
    andalso (Healthy_signature =:= <<"trace_correlated:trace-m57-b:query=dashboard_posts"/utf8>>),
    {Passed,
        <<<<<<"noisy="/utf8, Noisy_signature/binary>>/binary, "|healthy="/utf8>>/binary,
            Healthy_signature/binary>>}.

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

        [First | Rest] ->
            gleam@list:fold(
                Rest,
                First,
                fun(Accumulator, Value) ->
                    <<<<Accumulator/binary, Separator/binary>>/binary,
                        Value/binary>>
                end
            )
    end.

-file("src/lightspeed/ops/data_ergonomics_harness.gleam", 395).
-spec published_changeset(binary()) -> lightspeed@data_ergonomics:changeset().
published_changeset(Title) ->
    lightspeed@data_ergonomics:changeset(
        <<"article"/utf8>>,
        [lightspeed@data_ergonomics:text_field(
                <<"title"/utf8>>,
                Title,
                [required, {min_length, 3}]
            ),
            lightspeed@data_ergonomics:text_field(
                <<"status"/utf8>>,
                <<"published"/utf8>>,
                [required]
            ),
            lightspeed@data_ergonomics:int_field(
                <<"views"/utf8>>,
                10,
                [{min_int, 0}]
            )],
        []
    ).

-file("src/lightspeed/ops/data_ergonomics_harness.gleam", 380).
-spec draft_changeset(binary()) -> lightspeed@data_ergonomics:changeset().
draft_changeset(Title) ->
    lightspeed@data_ergonomics:changeset(
        <<"article"/utf8>>,
        [lightspeed@data_ergonomics:text_field(
                <<"title"/utf8>>,
                Title,
                [required, {min_length, 3}]
            ),
            lightspeed@data_ergonomics:text_field(
                <<"status"/utf8>>,
                <<"draft"/utf8>>,
                [required]
            ),
            lightspeed@data_ergonomics:int_field(
                <<"views"/utf8>>,
                0,
                [{min_int, 0}]
            )],
        []
    ).

-file("src/lightspeed/ops/data_ergonomics_harness.gleam", 267).
-spec evaluate_unit_of_work_and_optimistic_concurrency_contracts() -> {boolean(),
    binary()}.
evaluate_unit_of_work_and_optimistic_concurrency_contracts() ->
    Runtime = lightspeed@data_ergonomics:new_runtime(),
    {Runtime@2, Created@1} = case lightspeed@data_ergonomics:create(
        Runtime,
        draft_changeset(<<"Article A"/utf8>>)
    ) of
        {ok, {Runtime@1, Created}} -> {Runtime@1, Created};
        _assert_fail ->
            erlang:error(#{gleam_error => let_assert,
                        message => <<"Pattern match failed, no pattern matched the value."/utf8>>,
                        file => <<?FILEPATH/utf8>>,
                        module => <<"lightspeed/ops/data_ergonomics_harness"/utf8>>,
                        function => <<"evaluate_unit_of_work_and_optimistic_concurrency_contracts"/utf8>>,
                        line => 272,
                        value => _assert_fail,
                        start => 7419,
                        'end' => 7521,
                        pattern_start => 7430,
                        pattern_end => 7453})
    end,
    Failing_uow = lightspeed@data_ergonomics:unit_of_work(
        <<"fail-fast"/utf8>>,
        [{update_from_changeset,
                erlang:element(2, Created@1),
                0,
                published_changeset(<<"Article A"/utf8>>)},
            {create_from_changeset, published_changeset(<<"Article B"/utf8>>)}]
    ),
    Failed_label = case lightspeed@data_ergonomics:run_unit_of_work(
        Runtime@2,
        Failing_uow
    ) of
        {error, Error} ->
            lightspeed@data_ergonomics:unit_of_work_error_label(Error);

        {ok, _} ->
            <<"unexpected_success"/utf8>>
    end,
    Successful_uow = lightspeed@data_ergonomics:unit_of_work(
        <<"success"/utf8>>,
        [{update_from_changeset,
                erlang:element(2, Created@1),
                erlang:element(3, Created@1),
                published_changeset(<<"Article A"/utf8>>)},
            {create_from_changeset, published_changeset(<<"Article B"/utf8>>)}]
    ),
    {Passed, Success_label} = case lightspeed@data_ergonomics:run_unit_of_work(
        Runtime@2,
        Successful_uow
    ) of
        {error, Error@1} ->
            {false,
                lightspeed@data_ergonomics:unit_of_work_error_label(Error@1)};

        {ok, {Next_runtime, Signatures}} ->
            {(Signatures =:= [<<"update:row-1:rev=2"/utf8>>,
                    <<"create:row-2:rev=1"/utf8>>])
                andalso (lightspeed@data_ergonomics:dashboard_signature(
                    lightspeed@data_ergonomics:dashboard_summary(Next_runtime)
                )
                =:= <<"total=2:draft=0:published=2:stale=0"/utf8>>),
                <<"signatures="/utf8,
                    (join_with(<<","/utf8>>, Signatures))/binary>>}
    end,
    {Passed andalso (Failed_label =:= <<"operation_failed:1:concurrency_conflict:row-1:expected=0:actual=1"/utf8>>),
        <<<<<<"failed="/utf8, Failed_label/binary>>/binary, "|success="/utf8>>/binary,
            Success_label/binary>>}.

-file("src/lightspeed/ops/data_ergonomics_harness.gleam", 233).
-spec evaluate_nested_changeset_validation_propagation() -> {boolean(),
    binary()}.
evaluate_nested_changeset_validation_propagation() ->
    Validated = begin
        _pipe = lightspeed@data_ergonomics:changeset(
            <<"invoice"/utf8>>,
            [lightspeed@data_ergonomics:text_field(
                    <<"customer_name"/utf8>>,
                    <<"ab"/utf8>>,
                    [required, {min_length, 3}]
                )],
            [lightspeed@data_ergonomics:changeset(
                    <<"line_item"/utf8>>,
                    [lightspeed@data_ergonomics:empty_field(
                            <<"sku"/utf8>>,
                            [required]
                        ),
                        lightspeed@data_ergonomics:int_field(
                            <<"quantity"/utf8>>,
                            -1,
                            [{min_int, 1}]
                        )],
                    []
                )]
        ),
        lightspeed@data_ergonomics:validate_changeset(_pipe)
    end,
    Signature = lightspeed@data_ergonomics:changeset_error_signature(Validated),
    Passed = ((not lightspeed@data_ergonomics:changeset_valid(Validated) andalso gleam_stdlib:contains_string(
        Signature,
        <<"min_length:customer_name:3"/utf8>>
    ))
    andalso gleam_stdlib:contains_string(
        Signature,
        <<"nested:line_item:required:sku"/utf8>>
    ))
    andalso gleam_stdlib:contains_string(
        Signature,
        <<"nested:line_item:min_int:quantity:1"/utf8>>
    ),
    {Passed, Signature}.

-file("src/lightspeed/ops/data_ergonomics_harness.gleam", 204).
-spec evaluate_crud_and_dashboard_ergonomics_coverage() -> {boolean(), binary()}.
evaluate_crud_and_dashboard_ergonomics_coverage() ->
    Runtime = lightspeed@data_ergonomics:new_runtime(),
    {Runtime@2, Created_a@1} = case lightspeed@data_ergonomics:create(
        Runtime,
        draft_changeset(<<"Draft A"/utf8>>)
    ) of
        {ok, {Runtime@1, Created_a}} -> {Runtime@1, Created_a};
        _assert_fail ->
            erlang:error(#{gleam_error => let_assert,
                        message => <<"Pattern match failed, no pattern matched the value."/utf8>>,
                        file => <<?FILEPATH/utf8>>,
                        module => <<"lightspeed/ops/data_ergonomics_harness"/utf8>>,
                        function => <<"evaluate_crud_and_dashboard_ergonomics_coverage"/utf8>>,
                        line => 206,
                        value => _assert_fail,
                        start => 5399,
                        'end' => 5501,
                        pattern_start => 5410,
                        pattern_end => 5435})
    end,
    Runtime@4 = case lightspeed@data_ergonomics:create(
        Runtime@2,
        published_changeset(<<"Published B"/utf8>>)
    ) of
        {ok, {Runtime@3, _}} -> Runtime@3;
        _assert_fail@1 ->
            erlang:error(#{gleam_error => let_assert,
                        message => <<"Pattern match failed, no pattern matched the value."/utf8>>,
                        file => <<?FILEPATH/utf8>>,
                        module => <<"lightspeed/ops/data_ergonomics_harness"/utf8>>,
                        function => <<"evaluate_crud_and_dashboard_ergonomics_coverage"/utf8>>,
                        line => 208,
                        value => _assert_fail@1,
                        start => 5504,
                        'end' => 5615,
                        pattern_start => 5515,
                        pattern_end => 5541})
    end,
    {Runtime@6, Updated_a@1} = case lightspeed@data_ergonomics:update(
        Runtime@4,
        erlang:element(2, Created_a@1),
        erlang:element(3, Created_a@1),
        published_changeset(<<"Published A"/utf8>>)
    ) of
        {ok, {Runtime@5, Updated_a}} -> {Runtime@5, Updated_a};
        _assert_fail@2 ->
            erlang:error(#{gleam_error => let_assert,
                        message => <<"Pattern match failed, no pattern matched the value."/utf8>>,
                        file => <<?FILEPATH/utf8>>,
                        module => <<"lightspeed/ops/data_ergonomics_harness"/utf8>>,
                        function => <<"evaluate_crud_and_dashboard_ergonomics_coverage"/utf8>>,
                        line => 210,
                        value => _assert_fail@2,
                        start => 5618,
                        'end' => 5793,
                        pattern_start => 5629,
                        pattern_end => 5654})
    end,
    Dashboard = lightspeed@data_ergonomics:dashboard_summary(Runtime@6),
    Passed = ((erlang:element(3, Updated_a@1) =:= 2) andalso (lightspeed@data_ergonomics:dashboard_signature(
        Dashboard
    )
    =:= <<"total=2:draft=0:published=2:stale=0"/utf8>>))
    andalso gleam_stdlib:contains_string(
        lightspeed@data_ergonomics:runtime_signature(Runtime@6),
        <<"rows=2"/utf8>>
    ),
    {Passed,
        <<<<<<"runtime="/utf8,
                    (lightspeed@data_ergonomics:runtime_signature(Runtime@6))/binary>>/binary,
                "|dashboard="/utf8>>/binary,
            (lightspeed@data_ergonomics:dashboard_signature(Dashboard))/binary>>}.

-file("src/lightspeed/ops/data_ergonomics_harness.gleam", 344).
-spec evaluate_regression_gate_determinism() -> {boolean(), binary()}.
evaluate_regression_gate_determinism() ->
    Crud = run_scenario(crud_and_dashboard_ergonomics_coverage),
    Nested = run_scenario(nested_changeset_validation_propagation),
    Uow = run_scenario(unit_of_work_and_optimistic_concurrency_contracts),
    Diagnostics = run_scenario(query_diagnostics_regression_signals),
    Passed = ((((((erlang:element(3, Crud) andalso erlang:element(3, Nested))
    andalso erlang:element(3, Uow))
    andalso erlang:element(3, Diagnostics))
    andalso erlang:element(4, Crud))
    andalso erlang:element(4, Nested))
    andalso erlang:element(4, Uow))
    andalso erlang:element(4, Diagnostics),
    {Passed,
        <<<<<<<<<<<<<<<<<<<<<<<<<<<<<<"crud="/utf8,
                                                                    (pass_fail_label(
                                                                        Crud
                                                                    ))/binary>>/binary,
                                                                ":"/utf8>>/binary,
                                                            (erlang:element(
                                                                5,
                                                                Crud
                                                            ))/binary>>/binary,
                                                        "|nested="/utf8>>/binary,
                                                    (pass_fail_label(Nested))/binary>>/binary,
                                                ":"/utf8>>/binary,
                                            (erlang:element(5, Nested))/binary>>/binary,
                                        "|uow="/utf8>>/binary,
                                    (pass_fail_label(Uow))/binary>>/binary,
                                ":"/utf8>>/binary,
                            (erlang:element(5, Uow))/binary>>/binary,
                        "|diagnostics="/utf8>>/binary,
                    (pass_fail_label(Diagnostics))/binary>>/binary,
                ":"/utf8>>/binary,
            (erlang:element(5, Diagnostics))/binary>>}.

-file("src/lightspeed/ops/data_ergonomics_harness.gleam", 190).
-spec evaluate(scenario()) -> {boolean(), binary()}.
evaluate(Scenario) ->
    case Scenario of
        crud_and_dashboard_ergonomics_coverage ->
            evaluate_crud_and_dashboard_ergonomics_coverage();

        nested_changeset_validation_propagation ->
            evaluate_nested_changeset_validation_propagation();

        unit_of_work_and_optimistic_concurrency_contracts ->
            evaluate_unit_of_work_and_optimistic_concurrency_contracts();

        query_diagnostics_regression_signals ->
            evaluate_query_diagnostics_regression_signals();

        regression_gate_determinism ->
            evaluate_regression_gate_determinism()
    end.

-file("src/lightspeed/ops/data_ergonomics_harness.gleam", 60).
?DOC(" Run one M57 scenario twice and require deterministic parity.\n").
-spec run_scenario(scenario()) -> scenario_outcome().
run_scenario(Scenario) ->
    {First_passed, First_signature} = evaluate(Scenario),
    {Second_passed, Second_signature} = evaluate(Scenario),
    Deterministic = (First_passed =:= Second_passed) andalso (First_signature
    =:= Second_signature),
    Passed = (First_passed andalso Second_passed) andalso Deterministic,
    {scenario_outcome, Scenario, Passed, Deterministic, First_signature}.

-file("src/lightspeed/ops/data_ergonomics_harness.gleam", 41).
?DOC(" Run all M57 scenarios.\n").
-spec run_matrix() -> report().
run_matrix() ->
    Outcomes = begin
        _pipe = [crud_and_dashboard_ergonomics_coverage,
            nested_changeset_validation_propagation,
            unit_of_work_and_optimistic_concurrency_contracts,
            query_diagnostics_regression_signals,
            regression_gate_determinism],
        gleam@list:map(_pipe, fun run_scenario/1)
    end,
    {report, Outcomes, count_failed(Outcomes), count_nondeterministic(Outcomes)}.

-file("src/lightspeed/ops/data_ergonomics_harness.gleam", 76).
?DOC(" M57 profile version label.\n").
-spec profile_version_label() -> binary().
profile_version_label() ->
    <<"m57.profile.v"/utf8, (erlang:integer_to_binary(1))/binary>>.

-file("src/lightspeed/ops/data_ergonomics_harness.gleam", 81).
?DOC(" Scenario label.\n").
-spec scenario_label(scenario()) -> binary().
scenario_label(Scenario) ->
    case Scenario of
        crud_and_dashboard_ergonomics_coverage ->
            <<"crud_and_dashboard_ergonomics_coverage"/utf8>>;

        nested_changeset_validation_propagation ->
            <<"nested_changeset_validation_propagation"/utf8>>;

        unit_of_work_and_optimistic_concurrency_contracts ->
            <<"unit_of_work_and_optimistic_concurrency_contracts"/utf8>>;

        query_diagnostics_regression_signals ->
            <<"query_diagnostics_regression_signals"/utf8>>;

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

-file("src/lightspeed/ops/data_ergonomics_harness.gleam", 103).
?DOC(" Scenario signature accessor.\n").
-spec signature(scenario_outcome()) -> binary().
signature(Outcome) ->
    erlang:element(5, Outcome).

-file("src/lightspeed/ops/data_ergonomics_harness.gleam", 108).
?DOC(" Scenario accessor.\n").
-spec scenario(scenario_outcome()) -> scenario().
scenario(Outcome) ->
    erlang:element(2, Outcome).

-file("src/lightspeed/ops/data_ergonomics_harness.gleam", 113).
?DOC(" Determinism accessor.\n").
-spec deterministic(scenario_outcome()) -> boolean().
deterministic(Outcome) ->
    erlang:element(4, Outcome).

-file("src/lightspeed/ops/data_ergonomics_harness.gleam", 118).
?DOC(" Report outcomes accessor.\n").
-spec outcomes(report()) -> list(scenario_outcome()).
outcomes(Report) ->
    erlang:element(2, Report).

-file("src/lightspeed/ops/data_ergonomics_harness.gleam", 123).
?DOC(" Failed scenario count.\n").
-spec failed_scenarios(report()) -> integer().
failed_scenarios(Report) ->
    erlang:element(3, Report).

-file("src/lightspeed/ops/data_ergonomics_harness.gleam", 128).
?DOC(" Nondeterministic scenario count.\n").
-spec nondeterministic_failures(report()) -> integer().
nondeterministic_failures(Report) ->
    erlang:element(4, Report).

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

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

-file("src/lightspeed/ops/data_ergonomics_harness.gleam", 133).
?DOC(" Stable report signature.\n").
-spec report_signature(report()) -> binary().
report_signature(Report) ->
    Entries = gleam@list:map(
        erlang:element(2, Report),
        fun(Outcome) ->
            <<<<<<<<<<<<(scenario_label(erlang:element(2, Outcome)))/binary,
                                    "="/utf8>>/binary,
                                (pass_fail_label(Outcome))/binary>>/binary,
                            ":deterministic="/utf8>>/binary,
                        (bool_label(erlang:element(4, Outcome)))/binary>>/binary,
                    ":"/utf8>>/binary,
                (erlang:element(5, Outcome))/binary>>
        end
    ),
    join_with(<<";"/utf8>>, Entries).

-file("src/lightspeed/ops/data_ergonomics_harness.gleam", 149).
?DOC(" Deterministic snapshot signature for M57 fixture drift gates.\n").
-spec snapshot_signature() -> binary().
snapshot_signature() ->
    <<<<<<"m57.snapshot.v"/utf8, (erlang:integer_to_binary(1))/binary>>/binary,
            "|"/utf8>>/binary,
        (report_signature(run_matrix()))/binary>>.

-file("src/lightspeed/ops/data_ergonomics_harness.gleam", 157).
?DOC(" Deterministic markdown report for M57 fixture scripts.\n").
-spec snapshot_report_markdown() -> binary().
snapshot_report_markdown() ->
    Report = run_matrix(),
    Failed = failed_scenarios(Report),
    Nondeterministic = nondeterministic_failures(Report),
    Status = case (Failed =:= 0) andalso (Nondeterministic =:= 0) of
        true ->
            <<"OK"/utf8>>;

        false ->
            <<"FAIL"/utf8>>
    end,
    <<<<<<<<<<<<<<<<<<<<<<<<<<<<<<<<<<<<<<<<<<"# Data Ergonomics Fixture Report\n\n"/utf8,
                                                                                        "snapshot_version: "/utf8>>/binary,
                                                                                    (erlang:integer_to_binary(
                                                                                        1
                                                                                    ))/binary>>/binary,
                                                                                "\n"/utf8>>/binary,
                                                                            "profile_version: "/utf8>>/binary,
                                                                        (profile_version_label(
                                                                            
                                                                        ))/binary>>/binary,
                                                                    "\n"/utf8>>/binary,
                                                                "status: "/utf8>>/binary,
                                                            Status/binary>>/binary,
                                                        "\n"/utf8>>/binary,
                                                    "failed_scenarios: "/utf8>>/binary,
                                                (erlang:integer_to_binary(
                                                    Failed
                                                ))/binary>>/binary,
                                            "\n"/utf8>>/binary,
                                        "nondeterministic_failures: "/utf8>>/binary,
                                    (erlang:integer_to_binary(Nondeterministic))/binary>>/binary,
                                "\n\n"/utf8>>/binary,
                            "snapshot_signature: "/utf8>>/binary,
                        (snapshot_signature())/binary>>/binary,
                    "\n\n"/utf8>>/binary,
                "report_signature: "/utf8>>/binary,
            (report_signature(Report))/binary>>/binary,
        "\n"/utf8>>.