send XML through sockets

1 files changed, 8 insertions, 6 deletions

diff --git a/lib/server.ml b/lib/server.ml
index 6544f81..22bee73 100644
--- a/lib/server.ml
+++ b/lib/server.ml
@@ -17,16 +17,18 @@ let client_read sock maxlen =
   let rec _read sock acc =
     Lwt_unix.read sock str 0 maxlen
     >>= fun recvlen -> Lwt_io.write_line Lwt_io.stdout (Printf.sprintf "[LOG] Received %d bytes from client" recvlen)
-    >>= fun () -> if recvlen <= maxlen
-                  then Lwt.return (acc ^ (Bytes.to_string (Bytes.sub str 0 recvlen)))
-                  else _read sock (acc ^ (Bytes.to_string (Bytes.sub str 0 recvlen)))
-  in _read sock ""
+    >>= fun () -> let acc = (acc ^ (Bytes.to_string (Bytes.sub str 0 recvlen))) in
+                  if recvlen <= maxlen
+                  then Lwt.return acc
+                  else _read sock acc in
+  _read sock String.empty
+  >>= fun _ -> match Relation.write_and_retrieve() with | Ok results -> return results | Error err -> return err
 
 let rec socket_read sock =
+  (* (Int32.of_int (String.length results))) *)
   Lwt_unix.accept sock
   >>= fun (client, _) -> client_read client 512
-  >>= fun results -> Lwt_io.write_line Lwt_io.stdout results
-  >>= fun () -> return results
+  (* >>= fun results -> Lwt_unix.send client (Data_encoding.Binary.to_bytes_exn Data_encoding.Encoding.int32 5l) 0 1 [] *)
   >>= fun results -> Lwt_unix.send client (Bytes.of_string results) 0 (String.length results) []
   >>= fun _ -> Lwt_unix.wait_write client
   >>= fun () -> Lwt_unix.close client