aboutsummaryrefslogtreecommitdiffstats
path: root/activejob/lib/active_job/serializers/duration_serializer.rb
diff options
context:
space:
mode:
Diffstat (limited to 'activejob/lib/active_job/serializers/duration_serializer.rb')
-rw-r--r--activejob/lib/active_job/serializers/duration_serializer.rb42
1 files changed, 42 insertions, 0 deletions
diff --git a/activejob/lib/active_job/serializers/duration_serializer.rb b/activejob/lib/active_job/serializers/duration_serializer.rb
new file mode 100644
index 0000000000..72b7b9528a
--- /dev/null
+++ b/activejob/lib/active_job/serializers/duration_serializer.rb
@@ -0,0 +1,42 @@
+# frozen_string_literal: true
+
+module ActiveJob
+ module Serializers
+ # Provides methods to serialize and deserialize `ActiveSupport::Duration` (`1.day`, `2.weeks`, ...)
+ class DurationSerializer < ObjectSerializer
+ class << self
+ def serialize(duration)
+ {
+ key => duration.value,
+ parts_key => ::ActiveJob::Serializers.serialize(duration.parts)
+ }
+ end
+
+ def deserialize(hash)
+ value = hash[key]
+ parts = ::ActiveJob::Serializers.deserialize(hash[parts_key])
+
+ klass.new(value, parts)
+ end
+
+ def key
+ "_aj_activesupport_duration"
+ end
+
+ private
+
+ def klass
+ ::ActiveSupport::Duration
+ end
+
+ def keys
+ super.push parts_key
+ end
+
+ def parts_key
+ "parts"
+ end
+ end
+ end
+ end
+end