open V1_LWT
open Lwt

let red fmt    = Printf.sprintf ("\027[31m"^^fmt^^"\027[m")
let green fmt  = Printf.sprintf ("\027[32m"^^fmt^^"\027[m")
let yellow fmt = Printf.sprintf ("\027[33m"^^fmt^^"\027[m")
let blue fmt   = Printf.sprintf ("\027[36m"^^fmt^^"\027[m")

module Main (C: CONSOLE) (N: NETWORK) = struct

  module E = Ethif.Make(N)

  let or_error c name fn t =
    fn t
    >>= function
    | `Error e -> fail (Failure ("Error starting " ^ name))
    | `Ok t -> return t

  let start c net0 net1 =
    or_error c "Ethif 0" E.connect net0
    >>= fun e0 ->

    or_error c "Ethif 1" E.connect net1
    >>= fun e1 ->

        (*ignore (N.listen net0 (
            N.write net1
        ));*)
        N.listen net0 (
            N.write net1
        )
        (*ignore (N.listen net1 (
            N.write net0
        ));

        C.log_s c "OK, everything started!" *)
end