Add support for ActiveSupport::Cache::Store (#38)

Author: hopsoft

README.md

@@ -206,6 +206,8 @@ The following extension datatypes ship with Universal ID:
 
 - `ActiveRecord::Base`
 - `ActiveRecord::Relation`
+- `ActiveSupport::Cache::Entry`
+- `ActiveSupport::Cache::Store`
 - `ActiveSupport::TimeWithZone`
 - `GlobalID`
 - `SignedGlobalID`

lib/universalid/extensions/active_support/cache/entry_message_pack_type.rb

@@ -0,0 +1,20 @@
+# frozen_string_literal: true
+
+if defined? ActiveSupport::Cache::Entry
+
+  UniversalID::MessagePackFactory.register(
+    type: ActiveSupport::Cache::Entry,
+    packer: ->(obj, packer) do
+      packer.write obj.value
+      packer.write obj.version
+      packer.write obj.expires_at
+    end,
+    unpacker: ->(unpacker) do
+      value = unpacker.read
+      version = unpacker.read
+      expires_at = unpacker.read
+      ActiveSupport::Cache::Entry.new value, version: version, expires_at: expires_at
+    end
+  )
+
+end

lib/universalid/extensions/active_support/cache/store_message_pack_type.rb

@@ -0,0 +1,22 @@
+# frozen_string_literal: true
+
+if defined? ActiveSupport::Cache::Store
+
+  UniversalID::MessagePackFactory.register(
+    type: ActiveSupport::Cache::Store,
+    packer: ->(obj, packer) do
+      packer.write obj.class.name
+      packer.write obj.options
+      packer.write obj.instance_variable_get(:@data)
+    end,
+    unpacker: ->(unpacker) do
+      class_name = unpacker.read
+      options = unpacker.read
+      data = unpacker.read
+      Object.const_get(class_name).new(options).tap do |store|
+        store.instance_variable_set :@data, data
+      end
+    end
+  )
+
+end

test/test_extension.rb

@@ -120,6 +120,27 @@ def assert_record(expected, actual)
     end
   end
 
+  def assert_active_support_cache_store(expected, actual, data: scalars, expires_in: nil)
+    refute data.blank?
+
+    data.keys.each do |key|
+      case key
+      when :nil_class
+        assert_nil expected.read(key)
+        assert_nil actual.read(key)
+      else
+        assert_equal expected.read(key), actual.read(key)
+      end
+    end
+
+    sleep expires_in.to_f
+
+    data.keys.each do |key|
+      assert_nil expected.read(key)
+      assert_nil actual.read(key)
+    end
+  end
+
   def self.scalars
     @scalars ||= {
       bigdecimal: BigDecimal("123.45"),

test/universalid/extensions/active_support/cache/store_test.rb

@@ -0,0 +1,47 @@
+# frozen_string_literal: true
+
+class UniversalID::Packer::ActiveSupportCacheStoreTest < Minitest::Test
+  def test_pack_unpack
+    expected = ActiveSupport::Cache::MemoryStore.new
+    scalars.each { |key, val| expected.write key, val, expires_in: 1.second }
+    packed = UniversalID::Packer.pack(expected)
+    actual = UniversalID::Packer.unpack(packed)
+    assert_active_support_cache_store expected, actual, expires_in: 1.second
+  end
+end
+
+class UniversalID::Encoder::ActiveSupportCacheStoreTest < Minitest::Test
+  def test_encode_decode
+    expected = ActiveSupport::Cache::MemoryStore.new
+    scalars.each { |key, val| expected.write key, val, expires_in: 1.second }
+    encoded = UniversalID::Encoder.encode(expected)
+    actual = UniversalID::Encoder.decode(encoded)
+    assert_active_support_cache_store expected, actual, expires_in: 1.second
+  end
+end
+
+class URI::UID::ActiveSupportCacheStoreTest < Minitest::Test
+  def test_build_parse_decode
+    expected = ActiveSupport::Cache::MemoryStore.new
+    scalars.each { |key, val| expected.write key, val, expires_in: 1.second }
+    uri = URI::UID.build(expected).to_s
+    actual = URI::UID.parse(uri).decode
+    assert_active_support_cache_store expected, actual, expires_in: 1.second
+  end
+
+  def test_global_id
+    expected = ActiveSupport::Cache::MemoryStore.new
+    scalars.each { |key, val| expected.write key, val, expires_in: 1.second }
+    gid = URI::UID.build(expected).to_gid_param
+    actual = URI::UID.from_gid(gid).decode
+    assert_active_support_cache_store expected, actual, expires_in: 1.second
+  end
+
+  def test_signed_global_id
+    expected = ActiveSupport::Cache::MemoryStore.new
+    scalars.each { |key, val| expected.write key, val, expires_in: 1.second }
+    sgid = URI::UID.build(expected).to_sgid_param
+    actual = URI::UID.from_sgid(sgid).decode
+    assert_active_support_cache_store expected, actual, expires_in: 1.second
+  end
+end