From 8bbc0fbfaba11d043ff76e57febdd696894b758d Mon Sep 17 00:00:00 2001 From: Nick Pezza Date: Tue, 17 Sep 2024 19:15:28 -0400 Subject: [PATCH] Fix postgres tests where its not setting created at correctly --- app/models/solid_cable/message.rb | 5 +++-- .../action_cable/subscription_adapter/solid_cable_test.rb | 2 +- 2 files changed, 4 insertions(+), 3 deletions(-) diff --git a/app/models/solid_cable/message.rb b/app/models/solid_cable/message.rb index 09f1f4f..193d45a 100644 --- a/app/models/solid_cable/message.rb +++ b/app/models/solid_cable/message.rb @@ -3,7 +3,7 @@ module SolidCable class Message < SolidCable::Record scope :trimmable, lambda { - where(created_at: ..::SolidCable.message_retention.ago) + where(created_at: ...::SolidCable.message_retention.ago) } scope :broadcastable, lambda { |channels, last_id| where(channel_hash: channel_hashes_for(channels)). @@ -12,7 +12,8 @@ class Message < SolidCable::Record class << self def broadcast(channel, payload) - insert({ channel:, payload:, channel_hash: channel_hash_for(channel) }) + insert({ created_at: Time.current, channel:, payload:, + channel_hash: channel_hash_for(channel) }) end def channel_hashes_for(channels) diff --git a/test/lib/action_cable/subscription_adapter/solid_cable_test.rb b/test/lib/action_cable/subscription_adapter/solid_cable_test.rb index 92c7870..c09e587 100644 --- a/test/lib/action_cable/subscription_adapter/solid_cable_test.rb +++ b/test/lib/action_cable/subscription_adapter/solid_cable_test.rb @@ -64,7 +64,7 @@ class ActionCable::SubscriptionAdapter::SolidCableTest < ActionCable::TestCase test "trims_after_unsubscribe" do SolidCable.stub(:trim_chance, 99.999999) do - with_cable_config message_retention: "2.seconds", trim_batch_size: 1 do + with_cable_config message_retention: "2.seconds", trim_batch_size: 2 do subscribe_as_queue("channel") do |queue| 4.times do @tx_adapter.broadcast("channel", "hello world")