src/gmser_dyn.erl

@@ -26,7 +26,6 @@
 %% register a type schema, inspect existing schema
 -export([ register_types/1
         , registered_types/0
-        , registered_types/1
         , latest_vsn/0
         , get_opts/1
         , set_opts/1
@@ -53,54 +52,50 @@
 
 serialize(Term) ->
     Vsn = latest_vsn(),
-    rlp_encode(encode(Term, Vsn, registered_types(Vsn))).
+    rlp_encode(encode_(Term, Vsn, registered_types(Vsn))).
 
-serialize(Term, Types0) ->
-    Types = proper_types(Types0),
+serialize(Term, Types) ->
     Vsn = types_vsn(Types),
-    rlp_encode(encode(Term, Vsn, Types)).
+    rlp_encode(encode_(Term, Vsn, Types)).
 
 serialize(Term, Vsn, Types) ->
-    rlp_encode(encode(Term, Vsn, proper_types(Types, Vsn))).
+    rlp_encode(encode_(Term, Vsn, Types)).
 
 serialize_typed(Type, Term) ->
     Vsn = latest_vsn(),
-    rlp_encode(encode_typed(Type, Term, Vsn, registered_types(Vsn))).
+    rlp_encode(encode_typed_(Type, Term, Vsn, registered_types(Vsn))).
 
-serialize_typed(Type, Term, Types0) ->
-    Types = proper_types(Types0),
+serialize_typed(Type, Term, Types) ->
     Vsn = types_vsn(Types),
-    rlp_encode(encode_typed(Type, Term, Vsn, Types)).
+    rlp_encode(encode_typed_(Type, Term, Vsn, Types)).
 
 serialize_typed(Type, Term, Vsn, Types) ->
-    rlp_encode(encode_typed(Type, Term, Vsn, proper_types(Types, Vsn))).
+    rlp_encode(encode_typed_(Type, Term, Vsn, Types)).
 
 deserialize(Binary) ->
     Fields0 = rlp_decode(Binary),
     case decode_tag_and_vsn(Fields0) of
         {0, Vsn, Fields} ->
-            decode_(Fields, Vsn, registered_types(Vsn));
+            decode(Fields, Vsn, registered_types(Vsn));
         Other ->
             error({illegal_serialization, Other})
     end.
 
-deserialize(Binary, Types0) ->
-    Types = proper_types(Types0),
-    Vsn0 = types_vsn(Types),
+deserialize(Binary, Types) ->
+    Vsn0 = maps:get(vsn, Types, undefined),
     Fields0 = rlp_decode(Binary),
     case decode_tag_and_vsn(Fields0) of
         {0, Vsn, Fields} when Vsn0 == undefined; Vsn0 == Vsn ->
-            decode_(Fields, Vsn, Types);
+            decode(Fields, Vsn, Types);
         Other ->
             error({illegal_serialization, Other})
     end.
             
-deserialize(Binary, Vsn, Types0) ->
-    Types = proper_types(Types0),
+deserialize(Binary, Vsn, Types) ->
     Fields0 = rlp_decode(Binary),
     case decode_tag_and_vsn(Fields0) of
         {0, Vsn, Fields} ->
-            decode_(Fields, Vsn, Types);
+            decode(Fields, Vsn, Types);
         Other ->
             error({illegal_serialization, Other})
     end.
@@ -109,12 +104,11 @@ encode(Term) ->
     Vsn = latest_vsn(),
     encode(Term, Vsn, registered_types(Vsn)).
 
-encode(Term, Types0) ->
-    Types = proper_types(Types0),
+encode(Term, Types) ->
     encode(Term, types_vsn(Types), Types).
 
 encode(Term, Vsn, Types0) ->
-    Types = proper_types(Types0, Vsn),
+    Types = assert_vsn(Vsn, Types0),
     [ encode_basic(int, 0)
     , encode_basic(int, Vsn)
     , encode_(Term, Vsn, Types) ].
@@ -123,12 +117,11 @@ encode_typed(Type, Term) ->
     Vsn = latest_vsn(),
     encode_typed(Type, Term, Vsn, registered_types(Vsn)).
 
-encode_typed(Type, Term, Types0) ->
-    Types = proper_types(Types0),
+encode_typed(Type, Term, Types) ->
     encode_typed(Type, Term, types_vsn(Types), Types).
 
 encode_typed(Type, Term, Vsn, Types0) ->
-    Types = proper_types(Types0, Vsn),
+    Types = assert_vsn(Vsn, Types0),
     [ encode_basic(int, 0)
     , encode_basic(int, Vsn)
     , encode_typed_(Type, Term, Vsn, Types) ].
@@ -137,12 +130,11 @@ decode(Fields) ->
     Vsn = latest_vsn(),
     decode(Fields, Vsn, registered_types(Vsn)).
 
-decode(Fields, Types0) ->
-    Types = proper_types(Types0),
+decode(Fields, Types) ->
     decode(Fields, types_vsn(Types), Types).
 
 decode(Fields0, Vsn, Types0) ->
-    Types = proper_types(Types0, Vsn),
+    Types = assert_vsn(Vsn, Types0),
     case decode_tag_and_vsn(Fields0) of
         {0, Vsn, Fields} ->
             decode_(Fields, Vsn, Types);
@@ -154,12 +146,11 @@ decode_typed(Type, Fields) ->
     Vsn = latest_vsn(),
     decode_typed(Type, Fields, Vsn, registered_types(Vsn)).
 
-decode_typed(Type, Fields, Types0) ->
-    Types = proper_types(Types0),
+decode_typed(Type, Fields, Types) ->
     decode_typed(Type, Fields, types_vsn(Types), Types).
 
 decode_typed(Type, Fields0, Vsn, Types0) ->
-    Types = proper_types(Types0, Vsn),
+    Types = assert_vsn(Vsn, Types0),
     case decode_tag_and_vsn(Fields0) of
         {0, Vsn, Fields} ->
             decode_from_template(Type, Fields, Vsn, Types);
@@ -172,16 +163,6 @@ decode_tag_and_vsn([TagBin, VsnBin, Fields]) ->
      decode_basic(int, VsnBin),
      Fields}.
 
-proper_types(undefined) ->
-    registered_types(latest_vsn());
-proper_types(#{} = Types) ->
-    Types.
-
-proper_types(undefined, Vsn) ->
-    registered_types(Vsn);
-proper_types(#{} = Types, Vsn) ->
-    assert_vsn(Vsn, Types).
-
 types_vsn(#{vsn := Vsn}) -> Vsn;
 types_vsn(_) -> latest_vsn().
 
@@ -787,11 +768,6 @@ round_trip_test_() ->
         T <- t_sample_types()
     ].
 
-ser_round_trip_test_() ->
-    [?_test(t_ser_round_trip(T)) ||
-        T <- t_sample_types()
-    ].
-
 t_sample_types() ->
     [ 5
     , -5
@@ -837,11 +813,6 @@ t_round_trip(T) ->
     ?debugVal(T),
     ?assertMatch({T, T}, {T, decode(encode(T))}).
 
-t_ser_round_trip(T) ->
-    Data = serialize(T),
-    ?debugFmt("Data (~p) = ~p~n", [T, Data]),
-    ?assertMatch({T, T}, {T, deserialize(Data)}).
-
 t_round_trip_typed(Type, T) ->
     ?debugVal(T),
     ?assertMatch({T, T}, {T, decode(encode_typed(Type, T))}).