Simplify job_run_file and return 404
This commit is contained in:
parent
bf1777b7cb
commit
f2ab0d797f
1 changed files with 26 additions and 23 deletions
|
@ -64,29 +64,32 @@ let routes (t : Model.t) =
|
|||
let job = Router.param req "job"
|
||||
and run = Router.param req "run"
|
||||
and file = Router.splat req |> String.concat "/" in
|
||||
let+ job_run =
|
||||
Lwt_result.lift (safe_seg job) >>= fun job ->
|
||||
Lwt_result.lift (safe_seg run) >>= fun run ->
|
||||
Model.read_full_with_digests t job run in
|
||||
match job_run with
|
||||
| Error (`Msg e) ->
|
||||
Log.warn (fun m -> m "Error getting job run: %s" e);
|
||||
Response.of_plain_text ~status:`Internal_server_error
|
||||
"Error getting job run"
|
||||
| Ok (job_run, digests) ->
|
||||
match List.find_opt (fun (p, _) -> Fpath.(equal (v file) p)) job_run.data with
|
||||
| None ->
|
||||
Log.debug (fun m -> m "Trying to get non-existent build artifact %s"
|
||||
file);
|
||||
Response.of_plain_text ~status:`Not_found
|
||||
("build artifact not found: " ^ file)
|
||||
| Some (path, data) ->
|
||||
(* Should never fail if caching is not broken, or 'full' file untampered *)
|
||||
let digest = snd (List.find (fun (p, _) -> Fpath.equal path p) digests) in
|
||||
let body = Body.of_string data in
|
||||
Response.make ~body ()
|
||||
|> Response.add_header ("Content-type", Magic_mime.lookup file)
|
||||
|> Response.set_etag (Base64.encode_string digest.sha256)
|
||||
match safe_seg job, safe_seg run, Fpath.of_string file with
|
||||
| Error (`Msg e), _, _ | _, Error (`Msg e), _ | _, _, Error (`Msg e) ->
|
||||
Log.debug (fun m -> m "bad path: %s" e);
|
||||
Response.of_plain_text ~status:`Not_found "File not found"
|
||||
|> Lwt.return
|
||||
| Ok job, Ok run, Ok filep ->
|
||||
let+ job_run = Model.read_full_with_digests t job run in
|
||||
match job_run with
|
||||
| Error (`Msg e) ->
|
||||
Log.warn (fun m -> m "Error getting job run: %s" e);
|
||||
Response.of_plain_text ~status:`Internal_server_error
|
||||
"Error getting job run"
|
||||
| Ok (job_run, digests) ->
|
||||
match List.find_opt (fun (p, _) -> Fpath.(equal filep p)) job_run.data with
|
||||
| None ->
|
||||
Log.debug (fun m -> m "Trying to get non-existent build artifact %s"
|
||||
file);
|
||||
Response.of_plain_text ~status:`Not_found
|
||||
("build artifact not found: " ^ file)
|
||||
| Some (path, data) ->
|
||||
(* Should never fail if caching is not broken, or 'full' file untampered *)
|
||||
let digest = snd (List.find (fun (p, _) -> Fpath.equal path p) digests) in
|
||||
let body = Body.of_string data in
|
||||
Response.make ~body ()
|
||||
|> Response.add_header ("Content-type", Magic_mime.lookup file)
|
||||
|> Response.set_etag (Base64.encode_string digest.sha256)
|
||||
in
|
||||
|
||||
[
|
||||
|
|
Loading…
Reference in a new issue