Merge pull request #21 from r0man/edn-opts

Make EDN serde configurable

src/jackdaw/serdes/edn.clj

@@ -27,12 +27,15 @@
 
 (defn deserializer
   "Returns an EDN deserializer."
-  []
-  (jsfn/new-deserializer {:deserialize (fn [_ _ data]
-                                         (-> (from-bytes data)
-                                             clojure.edn/read-string))}))
+  ([]
+   (deserializer {}))
+  ([opts]
+   (let [opts (into {} opts)]
+     (jsfn/new-deserializer {:deserialize (fn [_ _ data]
+                                            (->> (from-bytes data)
+                                                 (clojure.edn/read-string opts)))}))))
 
 (defn serde
   "Returns an EDN serde."
-  []
-  (Serdes/serdeFrom (serializer) (deserializer)))
+  [& [opts]]
+  (Serdes/serdeFrom (serializer) (deserializer opts)))

test/jackdaw/serdes/edn_test.clj

@@ -1,5 +1,6 @@
 (ns jackdaw.serdes.edn-test
-  (:require [clojure.test :refer :all]
+  (:require [clojure.spec.alpha :as s]
+            [clojure.test :refer :all]
             [clojure.test.check.clojure-test :refer [defspec]]
             [clojure.test.check.generators :as gen]
             [clojure.test.check.properties :as prop]
@@ -18,3 +19,15 @@
         (is (= (seq bytes)
                (seq (->> (.deserialize (jse/deserializer) nil bytes)
                          (.serialize (jse/serializer) nil)))))))))
+
+(defmethod print-method java.net.URI
+  [obj writer]
+  (.write writer "#jackdaw/uri ")
+  (.write writer (pr-str (str obj))))
+
+(defspec edn-roundtrip-custom-reader 20
+  (testing "custom EDN reader"
+    (let [opts {:readers {'jackdaw/uri #(java.net.URI. %)}}]
+      (prop/for-all [x (s/gen uri?)]
+        (is (= x (->> (.serialize (jse/serializer) nil x)
+                      (.deserialize (jse/deserializer opts) nil))))))))