Compare commits
No commits in common. "c670df643e6020ea2c495dd7fc532879a862c447" and "63223b8c461b696a3d0a6a18defe32ff84bea615" have entirely different histories.
c670df643e
...
63223b8c46
3 changed files with 41 additions and 32 deletions
|
@ -50,10 +50,10 @@ depends: [
|
|||
"decompress" {>= "1.5.0"}
|
||||
"digestif" {>= "1.2.0"}
|
||||
"uuidm" {>= "0.9.9"}
|
||||
"yojson"
|
||||
"alcotest" {>= "1.2.0" & with-test}
|
||||
"ppx_deriving" {with-test}
|
||||
"ppx_deriving_yojson" {with-test}
|
||||
"yojson" {with-test}
|
||||
]
|
||||
|
||||
synopsis: "Web interface for builder"
|
||||
|
|
|
@ -330,6 +330,15 @@ let routes ~datadir ~cachedir ~configdir ~expired_jobs =
|
|||
Dream.sql req (Model.latest_successful_build_uuid job_id platform))
|
||||
>>= Model.not_found
|
||||
|> if_error "Error getting job" >>= fun build ->
|
||||
match Dream.header req "Accept" with
|
||||
| Some accept when String.starts_with ~prefix:"application/json" accept ->
|
||||
let json_response =
|
||||
`Assoc [
|
||||
"uuid", `String (Uuidm.to_string build);
|
||||
] |> Yojson.Basic.to_string
|
||||
in
|
||||
Dream.json ~status:`OK json_response |> Lwt_result.ok
|
||||
| _ ->
|
||||
Dream.redirect req
|
||||
(Link.Job_build_artifact.make_from_string ~job_name ~build ~artifact ())
|
||||
|> Lwt_result.ok
|
||||
|
@ -404,8 +413,8 @@ let routes ~datadir ~cachedir ~configdir ~expired_jobs =
|
|||
"job_name", `String job_name;
|
||||
"uuid", `String (Uuidm.to_string build.uuid);
|
||||
"platform", `String build.platform;
|
||||
"start_time", `String (Ptime.to_rfc3339 build.start);
|
||||
"finish_time", `String (Ptime.to_rfc3339 build.finish);
|
||||
"build_start_time", `String (Ptime.to_rfc3339 build.start);
|
||||
"build_finish_time", `String (Ptime.to_rfc3339 build.finish);
|
||||
"main_binary", (match build.main_binary with Some _ -> `Bool true | None -> `Bool false)
|
||||
] |> Yojson.Basic.to_string
|
||||
in
|
||||
|
@ -552,12 +561,15 @@ let routes ~datadir ~cachedir ~configdir ~expired_jobs =
|
|||
in
|
||||
|
||||
|
||||
let resolve_artifact_size id_opt conn =
|
||||
let resolve_artifact id_opt conn =
|
||||
let default_file : Builder_db.file = {
|
||||
filepath = Fpath.v "null";
|
||||
sha256 = "0";
|
||||
size = -1;
|
||||
} in
|
||||
match id_opt with
|
||||
| None -> Lwt.return_ok None
|
||||
| Some id ->
|
||||
Model.build_artifact_by_id id conn >|= fun file ->
|
||||
Some file.size
|
||||
| None -> Lwt.return_ok default_file
|
||||
| Some id -> Model.build_artifact_by_id id conn
|
||||
|
||||
in
|
||||
|
||||
|
@ -581,16 +593,16 @@ let routes ~datadir ~cachedir ~configdir ~expired_jobs =
|
|||
Model.build_artifact_data datadir >>= fun build_env_right ->
|
||||
Model.build_artifact build_right.Builder_db.Build.uuid (Fpath.v "system-packages") conn >>=
|
||||
Model.build_artifact_data datadir >>= fun system_packages_right ->
|
||||
resolve_artifact_size build_left.Builder_db.Build.main_binary conn >>= fun build_left_file_size ->
|
||||
resolve_artifact_size build_right.Builder_db.Build.main_binary conn >>= fun build_right_file_size ->
|
||||
resolve_artifact build_left.Builder_db.Build.main_binary conn >>= fun build_left_file ->
|
||||
resolve_artifact build_right.Builder_db.Build.main_binary conn >>= fun build_right_file ->
|
||||
Model.job_name build_left.job_id conn >>= fun job_left ->
|
||||
Model.job_name build_right.job_id conn >|= fun job_right ->
|
||||
(job_left, job_right, build_left, build_right, build_left_file_size,
|
||||
build_right_file_size, switch_left, build_env_left, system_packages_left,
|
||||
(job_left, job_right, build_left, build_right, build_left_file,
|
||||
build_right_file, switch_left, build_env_left, system_packages_left,
|
||||
switch_right, build_env_right, system_packages_right))
|
||||
|> if_error "Internal server error"
|
||||
>>= fun (job_left, job_right, build_left, build_right, build_left_file_size,
|
||||
build_right_file_size, switch_left, build_env_left, system_packages_left,
|
||||
>>= fun (job_left, job_right, build_left, build_right, build_left_file,
|
||||
build_right_file, switch_left, build_env_left, system_packages_left,
|
||||
switch_right, build_env_right, system_packages_right) ->
|
||||
let env_diff = Utils.compare_env build_env_left build_env_right
|
||||
and pkg_diff = Utils.compare_pkgs system_packages_left system_packages_right
|
||||
|
@ -598,36 +610,33 @@ let routes ~datadir ~cachedir ~configdir ~expired_jobs =
|
|||
let switch_left = OpamFile.SwitchExport.read_from_string switch_left
|
||||
and switch_right = OpamFile.SwitchExport.read_from_string switch_right in
|
||||
let opam_diff = Opamdiff.compare switch_left switch_right in
|
||||
(job_left, job_right, build_left, build_right, build_left_file_size, build_right_file_size, env_diff, pkg_diff, opam_diff)
|
||||
(job_left, job_right, build_left, build_right, build_left_file, build_right_file, env_diff, pkg_diff, opam_diff)
|
||||
|> Lwt.return_ok
|
||||
|
||||
in
|
||||
|
||||
let compare_builds req =
|
||||
process_comparison req >>= fun
|
||||
(job_left, job_right, build_left, build_right, build_left_file_size, build_right_file_size, env_diff, pkg_diff, opam_diff) ->
|
||||
(job_left, job_right, build_left, build_right, build_left_file, build_right_file, env_diff, pkg_diff, opam_diff) ->
|
||||
match Dream.header req "Accept" with
|
||||
| Some accept when String.starts_with ~prefix:"application/json" accept ->
|
||||
let file_size_json = Option.fold ~none:`Null ~some:(fun size -> `Int size) in
|
||||
let json_response =
|
||||
`Assoc [
|
||||
"left", `Assoc [
|
||||
"job_name", `String job_left;
|
||||
"uuid", `String (Uuidm.to_string build_left.uuid);
|
||||
"job", `String job_left;
|
||||
"build", `String (Uuidm.to_string build_left.uuid);
|
||||
"platform", `String build_left.platform;
|
||||
"start_time", `String (Ptime.to_rfc3339 build_left.start);
|
||||
"finish_time", `String (Ptime.to_rfc3339 build_left.finish);
|
||||
"main_binary", `Bool (Option.is_some build_left_file_size);
|
||||
"main_binary_size", file_size_json build_left_file_size;
|
||||
"build_start_time", `String (Ptime.to_rfc3339 build_left.start);
|
||||
"build_finish_time", `String (Ptime.to_rfc3339 build_left.finish);
|
||||
"build_size", `Int (build_left_file.size)
|
||||
];
|
||||
"right", `Assoc [
|
||||
"job_name", `String job_right;
|
||||
"job", `String job_right;
|
||||
"build", `String (Uuidm.to_string build_right.uuid);
|
||||
"platform", `String build_right.platform;
|
||||
"start_time", `String (Ptime.to_rfc3339 build_right.start);
|
||||
"finish_time", `String (Ptime.to_rfc3339 build_right.finish);
|
||||
"main_binary", `Bool (Option.is_some build_right_file_size);
|
||||
"main_binary_size", file_size_json build_right_file_size;
|
||||
"build_start_time", `String (Ptime.to_rfc3339 build_right.start);
|
||||
"build_finish_time", `String (Ptime.to_rfc3339 build_right.finish);
|
||||
"build_size", `Int (build_right_file.size)
|
||||
];
|
||||
"env_diff", Utils.diff_map_to_json env_diff;
|
||||
"package_diff", Utils.diff_map_to_json pkg_diff;
|
||||
|
|
|
@ -1,3 +1,3 @@
|
|||
(library
|
||||
(name opamdiff)
|
||||
(libraries opam-core opam-format yojson))
|
||||
(libraries opam-core opam-format))
|
||||
|
|
Loading…
Reference in a new issue