From 142a4e388a0dc905188569138b5a347bbc3d9e68 Mon Sep 17 00:00:00 2001 From: Clombrong Date: Wed, 25 Jun 2025 18:26:42 +0200 Subject: feat(native_hello): use tcp_stream --- portal/tcp/portal_tcp.ml | 2 +- test/native/native_hello.ml | 13 +++++++++---- 2 files changed, 10 insertions(+), 5 deletions(-) diff --git a/portal/tcp/portal_tcp.ml b/portal/tcp/portal_tcp.ml index 3ee3716..1a672dd 100644 --- a/portal/tcp/portal_tcp.ml +++ b/portal/tcp/portal_tcp.ml @@ -33,4 +33,4 @@ let tcp_stream (domain : string) = in (stream, push) let connect (domain : string) = - xmpp_port domain |> string_of_int |> print_endline + tcp_stream domain diff --git a/test/native/native_hello.ml b/test/native/native_hello.ml index 308857f..f125763 100644 --- a/test/native/native_hello.ml +++ b/test/native/native_hello.ml @@ -1,7 +1,12 @@ +open! Lwt.Syntax open! Portal_tcp let () = - let jid = Sys.getenv "FLESH_JID" - and _password = Sys.getenv "FLESH_PASSWORD" - in let domain = (List.nth (String.split_on_char '@' jid) 1) - in connect domain + Lwt_main.run @@ + let jid = Sys.getenv "FLESH_JID" + and _password = Sys.getenv "FLESH_PASSWORD" + in let domain = (List.nth (String.split_on_char '@' jid) 1) + in let* stream, push = connect domain + in push (Some ""); + let+ s = Lwt_stream.get stream in + Option.get s |> print_endline -- cgit v1.2.3