summaryrefslogtreecommitdiff
path: root/bs5/server/api
diff options
context:
space:
mode:
Diffstat (limited to 'bs5/server/api')
-rw-r--r--bs5/server/api/dune5
-rw-r--r--bs5/server/api/json.ml13
-rw-r--r--bs5/server/api/stream.ml18
-rw-r--r--bs5/server/api/upload.ml37
4 files changed, 73 insertions, 0 deletions
diff --git a/bs5/server/api/dune b/bs5/server/api/dune
new file mode 100644
index 0000000..9dc8d84
--- /dev/null
+++ b/bs5/server/api/dune
@@ -0,0 +1,5 @@
+(library
+ (name api)
+ (libraries dream lwt yojson)
+ (preprocess
+ (pps lwt_ppx ppx_yojson_conv)))
diff --git a/bs5/server/api/json.ml b/bs5/server/api/json.ml
new file mode 100644
index 0000000..3e4c68c
--- /dev/null
+++ b/bs5/server/api/json.ml
@@ -0,0 +1,13 @@
+open Ppx_yojson_conv_lib.Yojson_conv.Primitives
+
+type message_object = { message : string } [@@deriving yojson]
+
+let routes =
+ [
+ Dream.post "/json" (fun req ->
+ let%lwt body = Dream.body req in
+ let message_object =
+ body |> Yojson.Safe.from_string |> message_object_of_yojson
+ in
+ `String message_object.message |> Yojson.Safe.to_string |> Dream.json);
+ ]
diff --git a/bs5/server/api/stream.ml b/bs5/server/api/stream.ml
new file mode 100644
index 0000000..8bfaa86
--- /dev/null
+++ b/bs5/server/api/stream.ml
@@ -0,0 +1,18 @@
+let streams =
+ [
+ Dream.post "/stream" (fun request ->
+ let request_stream = Dream.body_stream request in
+
+ Dream.stream
+ ~headers:[ ("Content-Type", "application/octet-stream") ]
+ (fun response_stream ->
+ let rec loop () =
+ match%lwt Dream.read request_stream with
+ | None -> Dream.close response_stream
+ | Some chunk ->
+ let%lwt () = Dream.write response_stream chunk in
+ let%lwt () = Dream.flush response_stream in
+ loop ()
+ in
+ loop ()));
+ ]
diff --git a/bs5/server/api/upload.ml b/bs5/server/api/upload.ml
new file mode 100644
index 0000000..4ba5fb7
--- /dev/null
+++ b/bs5/server/api/upload.ml
@@ -0,0 +1,37 @@
+(* let home request = *)
+(* <html> *)
+(* <body> *)
+(* <form method="POST" action="/" enctype="multipart/form-data"> *)
+(* <%s! Dream.csrf_tag request %> *)
+(* <input name="files" type="file" multiple> *)
+(* <button>Submit!</button> *)
+(* </form> *)
+(* </body> *)
+(* </html> *)
+
+(* let report files = *)
+(* <html> *)
+(* <body> *)
+(* % files |> List.iter begin fun (name, content) -> *)
+(* % let name = *)
+(* % match name with *)
+(* % | None -> "None" *)
+(* % | Some name -> name *)
+(* % in *)
+(* <p><%s name %>, <%i String.length content %> bytes</p> *)
+(* % end; *)
+(* </body> *)
+(* </html> *)
+
+(* let uploads = *)
+(* [ *)
+
+(* Dream.get "/" (fun request -> *)
+(* Dream.html (home request)); *)
+
+(* Dream.post "/" (fun request -> *)
+(* match%lwt Dream.multipart request with *)
+(* | `Ok ["files", files] -> Dream.html (report files) *)
+(* | _ -> Dream.empty `Bad_Request); *)
+
+(* ] *)