Updated client to support new UDP server.

src/cljs/cli/timi/client/cli.cljs

@@ -5,7 +5,7 @@
     [clojusc.twig :as logger]
     [taoensso.timbre :as log]
     [timi.client.config :as config]
-    [timi.client.tcp :as tcp]))
+    [timi.client.udp :as udp]))
 
 ;;; CLI setup and functions
 
@@ -18,29 +18,31 @@
   [args]
   (str (string/join " "args) "\n"))
 
-;;; Callbacks
+(defn wait
+  []
+  (js/setTimeout #(log/info "UDP client timed out.")
+                 3000))
 
-(defn handle-connect
-  [client data]
-  (log/debug "Connected.")
-  (tcp/send client data))
+;;; UDP Callback
 
 (defn handle-receive
   [client data]
   (let [buffer (js/Buffer. data)]
     (log/debug "Received data:" data)
-    (tcp/disconnect client)
+    (udp/close client)
     (log/debug "Disconnected.")
-    (println (str data))))
+    (println (str data))
+    (.exit node/process)))
 
 ;;; Main
 
 (defn -main
   [& args]
   (log/debug "Got args:" args)
-  (let [client (tcp/connect config/data)
+  (let [client (udp/client)
         data (args->str args)]
-    (tcp/on-connect client #(handle-connect client data))
-    (tcp/on-receive client #(handle-receive client %))))
+    (udp/on-receive client #(handle-receive client %))
+    (udp/send client config/data data)
+    (wait)))
 
 (set! *main-cli-fn* -main)

src/cljs/cli/timi/client/udp.cljs

@@ -0,0 +1,37 @@
+(ns timi.client.udp
+  (:require
+    [cljs.nodejs :as node]
+    [taoensso.timbre :as log]))
+
+(def dgram (node/require "dgram"))
+
+(defn client
+  []
+  (log/debug "Creating datagram socket ...")
+  (.createSocket dgram "udp4"))
+
+(defn on-listen
+  [client callback]
+  (.on client "listening" callback))
+
+(defn send
+  [client config data]
+  (let [buf (js/Buffer. data)
+        cfg (get-in config [:cli :server])]
+    (log/debug cfg)
+    (log/debug "Sending data:" data)
+    (.send client
+           buf
+           0
+           buf.length
+           (get-in config [:cli :server :port]))))
+
+(defn close
+  [client]
+  (log/debug "Disconnecting ...")
+  (.close client))
+
+(defn on-receive
+  [client callback]
+  (log/debug "Receiving data ...")
+  (.on client "message" callback))