package awskit-s3-sim

  1. Overview
  2. Docs
package awskit-s3-sim
Legend:
Page
Library
Module
Module type
Parameter
Class
Class type
Source

Source file simulator_error.ml

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
open Awskit_s3
open Simulator_support
open Simulator_state

let service ?message ?(headers = []) ~status ~code () =
  Awskit.Error.service
    {
      status;
      code = Some code;
      message;
      request_id = None;
      host_id = None;
      headers;
      body = None;
    }

let no_such_bucket () = service ~status:404 ~code:"NoSuchBucket" ()
let no_such_key () = service ~status:404 ~code:"NoSuchKey" ()
let no_such_upload () = service ~status:404 ~code:"NoSuchUpload" ()

let method_not_allowed ?headers () =
  service ?headers ~status:405 ~code:"MethodNotAllowed" ()

let precondition_failed () = service ~status:412 ~code:"PreconditionFailed" ()
let not_modified () = service ~status:304 ~code:"NotModified" ()
let response ?headers status = Awskit.Response.create_exn ~status ?headers ()

let record ?(faulted = false) t op bucket key =
  record_operation ~faulted t op bucket key

let fault_error = function
  | Slow_down -> service ~status:503 ~code:"SlowDown" ()
  | Internal_error -> service ~status:500 ~code:"InternalError" ()
  | Connection_reset ->
      Awskit.Error.transport ~retryable:true "simulated connection reset"
  | Response_lost -> Awskit.Error.body "simulated response body loss"

let take_fault t = Simulator_state.take_fault t

let operation_fault t op bucket key =
  match take_fault t with
  | None ->
      record t op bucket key;
      None
  | Some fault ->
      record ~faulted:true t op bucket key;
      Some (fault_error fault)