feat(portal): change type t into a record

3 files changed, 21 insertions, 12 deletions

diff --git a/portal/portal.mli b/portal/portal.mli
index d57a839..1fe90ef 100644
--- a/portal/portal.mli
+++ b/portal/portal.mli
@@ -2,10 +2,13 @@ open Markup
 
 exception MalformedStanza of location * Error.t
 
-type t = (signal, async) stream * ((signal, sync) stream option -> unit)
-
 type socket
 
+type t = {
+    stream : (signal, async) stream;
+    push : (signal, sync) stream option -> unit;
+  }
+
 (** This is the XML namespace of the underlying element stream.
 
     You can rely on it on your code, as an escape hatch, but you should probably not,
diff --git a/portal/tcp/portal.ml b/portal/tcp/portal.ml
index 3477429..931cf93 100644
--- a/portal/tcp/portal.ml
+++ b/portal/tcp/portal.ml
@@ -2,15 +2,18 @@ open Lwt.Syntax
 open Lwt_unix
 open Markup
 
-type t = (signal, async) stream * ((signal, sync) stream option -> unit)
-
 type socket = file_descr
 
+type t = {
+    stream : (signal, async) stream;
+    push : (signal, sync) stream option -> unit;
+  }
+
 let xmlns = "http://etherx.jabber.org/streams"
 
 exception MalformedStanza of Markup.location * Markup.Error.t
 
-let header ?from domain ((stream, push) : t) =
+let header ?from domain ({stream; push} : t) =
   let stanza =
     let attributes =
       [(("", "to"), domain); (("", "version"), "1.0");
@@ -48,7 +51,7 @@ let header ?from domain ((stream, push) : t) =
         | None -> Lwt.fail_with "Invalid stream opening server-side."
 
 
-let close (_, push) = [`End_element] |> Markup.of_list |> Option.some |> push
+let close {push; _} = [`End_element] |> Markup.of_list |> Option.some |> push
 
 (** [xmpp_port domain] is the port where [domain]'s XMPP server is hosted.
 
@@ -99,4 +102,4 @@ let connect (domain : string) : t Lwt.t =
   in Lwt.async (fun () ->
          let* _ = lwt_stream xml_stream |> Markup_lwt.write_xml |> iter send
          in Lwt_unix.close tcp_socket);
-     stream, push
+     {stream; push}
diff --git a/portal/ws/portal.ml b/portal/ws/portal.ml
index b2d21e1..ee4b636 100644
--- a/portal/ws/portal.ml
+++ b/portal/ws/portal.ml
@@ -5,10 +5,13 @@ open Markup
 let jss = Js.string
 let sjs = Js.to_string
 
-type t = (signal, async) stream * ((signal, sync) stream option -> unit)
-
 type socket = WebSockets.webSocket Js.t
 
+type t = {
+    stream : (signal, async) stream;
+    push : (signal, sync) stream option -> unit;
+  }
+
 let xmlns = "urn:ietf:params:xml:ns:xmpp-framing"
 
 (* sic. XEP-0156: "host-meta files MUST be fetched only over HTTPS". I don't make the
@@ -18,7 +21,7 @@ let well_known_of (domain : string) = "https://" ^ domain ^ "/.well-known/host-m
 (** [open_stanza domain] is an <open /> stanza for [domain].
 
     If [from] is specified, the <open /> stanza has the from parameter. *)
-let header ?from domain (stream, push) =
+let header ?from domain {stream; push} =
   let stanza =
     let attributes =
       let open Option in
@@ -46,7 +49,7 @@ let header ?from domain (stream, push) =
         | Some id -> Lwt.return id
         | None -> Lwt.fail_with "Invalid stream opening server-side."
 
-let close (_, p) =
+let close {push=p; _} =
   {|<close xmlns="|} ^ xmlns ^ {|" />|} |> string |> parse_xml |> signals |> Option.some |> p
 
 exception MalformedStanza of Markup.location * Markup.Error.t
@@ -150,4 +153,4 @@ let connect domain =
                |> map (fun x -> write_xml x |> to_string)
                |> to_lwt_stream
                |> Lwt_stream.iter (fun s -> ws_push (Some s)));
-  stream, push
+  {stream; push}