Extract broadcastable and trimmable to concerns

app/models/solid_cable/message.rb

@@ -2,19 +2,9 @@
 
 module SolidCable
  class Message < SolidCable::Record
- scope :trimmable, lambda {
- where(created_at: ..::SolidCable.message_retention.ago)
- }
- scope :broadcastable, lambda { |channels, last_id|
- where(channel_hash: channel_hashes_for(channels)).
- where(id: (last_id + 1)..).order(:id)
- }
+ include Broadcastable, Trimmable
 
  class << self
- def broadcast(channel, payload)
- insert({ channel:, payload:, channel_hash: channel_hash_for(channel) })
- end
-
  def channel_hashes_for(channels)
  channels.map { |channel| channel_hash_for(channel) }
  end

app/models/solid_cable/message/broadcastable.rb

@@ -0,0 +1,20 @@
+# frozen_string_literal: true
+
+module SolidCable
+ module Message::Broadcastable
+ extend ActiveSupport::Concern
+
+ included do
+ scope :broadcastable, lambda { |channels, last_id|
+ where(channel_hash: channel_hashes_for(channels)).
+ where(id: (last_id + 1)..).order(:id)
+ }
+ end
+
+ class_methods do
+ def broadcast(channel, payload)
+ insert({ channel:, payload:, channel_hash: channel_hash_for(channel) })
+ end
+ end
+ end
+end

app/models/solid_cable/message/trimmable.rb

@@ -0,0 +1,13 @@
+# frozen_string_literal: true
+
+module SolidCable
+ module Message::Trimmable
+ extend ActiveSupport::Concern
+
+ included do
+ scope :trimmable, lambda {
+ where(created_at: ..::SolidCable.message_retention.ago)
+ }
+ end
+ end
+end