[new] Example project: add msgpack support

Author: ptaoussanis

example-project/src/example/client.cljs

@@ -69,12 +69,15 @@
   client<->server transit.
 
   Default is to use edn, but this reference example uses a dynamic
-  packer that can swap between edn/transit/binary for testing.
+  packer that can swap between several packers for testing.
 
   Client and server should use the same packer."
 
   #_:edn ; Default
-  (example.dynamic-packer/get-packer))
+  #_(taoensso.sente.packers.transit/get-packer)
+  #_(taoensso.sente.packers.msgpack/get-packer) ; Experimental
+  (example.dynamic-packer/get-packer) ; For testing
+  )
 
 (def chsk-client
   (sente/make-channel-socket-client!

example-project/src/example/dynamic_packer.cljc

@@ -1,16 +1,17 @@
 (ns example.dynamic-packer
   "A dynamic Sente packer that can dynamically switch
-  between edn/transit/binary modes.
+  between #{:edn/txt :edn/bin :transit :msgpack} modes.
 
   Handy for testing, you wouldn't normally need/want
   something like this in production!"
   (:require
    [taoensso.encore :as encore]
    [taoensso.sente  :as sente]
    [taoensso.sente.interfaces :as i]
-   [taoensso.sente.packers.transit]))
+   [taoensso.sente.packers.transit]
+   [taoensso.sente.packers.msgpack]))
 
-(defonce mode_ (atom :edn))
+(defonce mode_ (atom :edn/txt))
 
 (defn- str->bytes [s]
   #?(:clj  (.getBytes ^String s java.nio.charset.StandardCharsets/UTF_8)
@@ -24,22 +25,23 @@
 
 (defn get-packer []
   (let [ep sente/edn-packer
-        tp (taoensso.sente.packers.transit/get-packer)
-
         bp ; Simple binary edn packer
         (reify
           i/IPacker2
           (pack   [_ ws? clj    cb-fn] (cb-fn {:value (str->bytes (encore/pr-edn clj))}))
           (unpack [_ ws? packed cb-fn] (cb-fn {:value (encore/read-edn (bytes->str packed))})))
 
+        tp (taoensso.sente.packers.transit/get-packer)
+        mp (taoensso.sente.packers.msgpack/get-packer)
+
         get-packer
         (fn []
           (case @mode_
-            :edn     ep
+            :edn/txt ep
+            :edn/bin bp
             :transit tp
-            :bin     bp))]
+            :msgpack mp))]
 
-    (reify
-      i/IPacker2
+    (reify i/IPacker2
       (pack   [_ ws? clj    cb-fn] (i/pack   (get-packer) ws? clj    cb-fn))
       (unpack [_ ws? packed cb-fn] (i/unpack (get-packer) ws? packed cb-fn)))))

example-project/src/example/server.clj

@@ -55,12 +55,15 @@
   client<->server transit.
 
   Default is to use edn, but this reference example uses a dynamic
-  packer that can swap between edn/transit/binary for testing.
+  packer that can swap between several packers for testing.
 
   Client and server should use the same packer."
 
   #_:edn ; Default
-  (example.dynamic-packer/get-packer))
+  #_(taoensso.sente.packers.transit/get-packer)
+  #_(taoensso.sente.packers.msgpack/get-packer) ; Experimental
+  (example.dynamic-packer/get-packer) ; For testing
+  )
 
 (defonce chsk-server
   (sente/make-channel-socket-server!
@@ -276,9 +279,10 @@
   [{:as ev-msg :keys [?reply-fn]}]
   (let [new-mode
         (case @example.dynamic-packer/mode_
-          :edn     :transit
-          :transit :bin
-          :bin     :edn)]
+          :edn/txt :edn/bin
+          :edn/bin :transit
+          :transit :msgpack
+          :msgpack :edn/txt)]
 
     (?reply-fn new-mode)
     (reset! example.dynamic-packer/mode_ new-mode)))