[nop] Packer benching

Author: ptaoussanis

src/taoensso/sente.cljc

@@ -83,7 +83,8 @@
    [taoensso.encore.timers :as timers]
    [taoensso.truss         :as truss]
    [taoensso.trove         :as trove]
-   [taoensso.sente.interfaces :as i])
+   [taoensso.sente.interfaces :as i]
+   [taoensso.sente.packers.edn :as edn-packer])
 
   #?(:cljs
      (:require-macros
@@ -179,14 +180,8 @@
 
 ;;;; Packing (see `i/IPacker2`)
 
-(def ^:no-doc edn-packer
-  "Sente packer that uses the EDN text format.
-  A reasonable default choice."
-  (reify i/IPacker2
-    (pack   [_ ws? clj    cb-fn] (cb-fn {:value (enc/pr-edn      clj)}))
-    (unpack [_ ws? packed cb-fn] (cb-fn {:value (enc/read-edn packed)}))))
-
-(defn- coerce-packer [x] (if (= x :edn) edn-packer (truss/have [:satisfies? i/IPacker2] x)))
+(def ^:no-doc edn-packer (edn-packer/get-packer))
+(defn-     coerce-packer [x] (if (= x :edn) edn-packer (truss/have [:satisfies? i/IPacker2] x)))
 
 (defn- on-packed [packer ws? clj ?cb-uuid error-fn value-fn]
   (truss/try*

src/taoensso/sente/packers/edn.cljc

@@ -0,0 +1,20 @@
+(ns taoensso.sente.packers.edn
+  {:author "Peter Taoussanis (@ptaoussanis)"}
+  (:require
+   [taoensso.encore :as enc]
+   [taoensso.sente.interfaces :as i]))
+
+(defn get-packer
+  "Returns Sente packer that uses the EDN text format.
+  A reasonable default choice for most users."
+  []
+  (reify i/IPacker2
+    (pack   [_ ws? clj    cb-fn] (cb-fn {:value (enc/pr-edn      clj)}))
+    (unpack [_ ws? packed cb-fn] (cb-fn {:value (enc/read-edn packed)}))))
+
+(comment
+  (let [p (get-packer)]
+    (i/pack p :ws [:chsk/ws-ping "foo"]
+      (fn [{packed :value}]
+        (i/unpack p :ws packed
+          (fn [{clj :value}] clj))))))

test/taoensso/sente_tests.cljc

@@ -14,19 +14,78 @@
    ;; [clojure.test.check            :as tc]
    ;; [clojure.test.check.generators :as tc-gens]
    ;; [clojure.test.check.properties :as tc-props]
-   [clojure.string :as str]
+   [clojure.string  :as str]
+   [taoensso.encore :as enc]
 
    ;; :cljs cannot compile taoensso.sente under :nodejs target
-   #?(:clj  [taoensso.sente :as sente])))
+   #?(:clj  [taoensso.sente :as sente])
+
+   [taoensso.sente.interfaces      :as i]
+   [taoensso.sente.packers.edn     :as ep]
+   [taoensso.sente.packers.transit :as tp]
+   [taoensso.sente.packers.msgpack :as mp])
+
+  #?(:cljs
+     (:require-macros
+      [taoensso.sente-tests :refer [get-bench-data]])))
 
 (comment
   (remove-ns      'taoensso.sente-tests)
   (test/run-tests 'taoensso.sente-tests))
 
 ;;;;
 
-#?(:clj  (deftest _test-clj  (is (= 1 1))))
-#?(:cljs (deftest _test-cljs (is (= 1 1))))
+(defn get-bench-data []
+  #_{:a :A :b :B :c "foo", :v (vec (range 128)), :s (set (range 128))}
+  {:ids (vec (repeatedly 1024 (fn [] (rand-int 32767))))
+   :data
+   (vec
+     (repeatedly 128
+       (fn []
+         {:children-types [(enc/uuid-str 8) (enc/uuid-str 8) (enc/uuid-str 8)]
+          :description ""
+          :tips nil
+          :a-url-in-text nil
+          :name (enc/uuid-str)
+          :parents-ids nil
+          :type-id 1
+          :experimental false
+          :duration 61
+          :warnings nil
+          :a-simple-string (enc/uuid-str 16)
+          :a-double-number (rand 32767)
+          :a-boolean-i-think-cant-recall nil
+          :archive-date nil
+          :another-number (rand-int 32767)
+          :internal-notes nil
+          :id (rand-int 32767)
+          :a-boolean false
+          :submit-date  (str (enc/now-inst))
+          :display-name (enc/uuid-str)
+          :user nil
+          :a-vector-of-integers (vec (repeatedly 64 (fn [] (rand-int 128))))
+          :children-count (rand-int 1024)
+          :a-usually-absent-string nil})))})
+
+(defn packed-len [x]
+  #?(:cljs (if (instance? js/Uint8Array x) (.-length x) (count x))
+     :clj (count x)))
+
+(defn bench1 [packer laps data]
+  {:time (enc/qb laps (i/pack packer nil data (fn [x] (i/unpack packer nil (get x :value) (fn [y] (get y :value))))))
+   :size (packed-len  (i/pack packer nil data (fn [x]                      (get x :value))))})
+
+(deftest bench-packers
+  (let [laps 1e2
+        bd (get-bench-data)
+        ep (ep/get-packer)
+        tp (tp/get-packer)
+        mp (mp/get-packer)]
+
+    (println "Benching comparison:"
+      {:ep (bench1 ep laps bd)
+       :tp (bench1 tp laps bd)
+       :mp (bench1 mp laps bd)})))
 
 ;;;;