Correctly handle jobs when ActiveSupport.parse_json_times is enabled

Author: npezza93

app/models/solid_queue/job.rb

@@ -6,7 +6,11 @@ class EnqueueError < StandardError; end
 
     include Executable, Clearable, Recurrable
 
-    serialize :arguments, coder: JSON
+    if Rails.gem_version < Gem::Version.new("8.1")
+      serialize :arguments, coder: ::SolidQueue::Coders::JSON
+    else
+      serialize :arguments, coder: ::SolidQueue::Coders::JSON.new
+    end
 
     class << self
       def enqueue_all(active_jobs)

lib/solid_queue.rb

@@ -2,6 +2,7 @@
 
 require "solid_queue/version"
 require "solid_queue/engine"
+require "solid_queue/coders/json"
 
 require "active_job"
 require "active_job/queue_adapters"

lib/solid_queue/coders/json.rb

@@ -0,0 +1,27 @@
+# frozen_string_literal: true
+
+if Rails.gem_version < Gem::Version.new("8.1")
+  module SolidQueue
+    module Coders
+      class JSON
+        class << self
+          delegate :dump, to: ::ActiveRecord::Coders::JSON
+        end
+
+        def self.load(json)
+          ::JSON.parse(json) unless json.blank?
+        end
+      end
+    end
+  end
+else
+  module SolidQueue
+    module Coders
+      class JSON < ::ActiveRecord::Coders::JSON
+        def load(json)
+          ::JSON.parse(json, @options) unless json.blank?
+        end
+      end
+    end
+  end
+end

test/models/solid_queue/job_test.rb

@@ -64,6 +64,30 @@ class DiscardableNonOverlappingGroupedJob2 < NonOverlappingJob
     assert_equal 8, execution.priority
   end
 
+  test "enqueue active job to be executed right away when active support is set to parse dates" do
+    ActiveSupport.parse_json_times = true
+    active_job = AddToBufferJob.new(1).set(priority: 8, queue: "test")
+
+    assert_ready do
+      SolidQueue::Job.enqueue(active_job)
+    end
+
+    solid_queue_job = SolidQueue::Job.last
+    assert solid_queue_job.ready?
+    assert_equal :ready, solid_queue_job.status
+    assert_equal solid_queue_job.id, active_job.provider_job_id
+    assert_equal 8, solid_queue_job.priority
+    assert_equal "test", solid_queue_job.queue_name
+    assert_equal "AddToBufferJob", solid_queue_job.class_name
+    assert Time.now >= solid_queue_job.scheduled_at
+    assert_equal [ 1 ], solid_queue_job.arguments["arguments"]
+
+    execution = SolidQueue::ReadyExecution.last
+    assert_equal solid_queue_job, execution.job
+    assert_equal "test", execution.queue_name
+    assert_equal 8, execution.priority
+  end
+
   test "enqueue active job to be scheduled in the future" do
     active_job = AddToBufferJob.new(1).set(priority: 8, queue: "test")