mirror of
https://github.com/discourse/discourse.git
synced 2024-11-30 17:24:42 +08:00
243793ec6e
Currently, the logic for creating a new chat message is scattered between a controller and an “old” service. This patch address this issue by creating a new service (using the “new” sevice object system) encapsulating all the necessary logic. (authorization, publishing events, etc.)
61 lines
1.6 KiB
Ruby
61 lines
1.6 KiB
Ruby
# frozen_string_literal: true
|
|
|
|
require "discourse_dev/record"
|
|
require "faker"
|
|
|
|
module DiscourseDev
|
|
class Thread < Record
|
|
def initialize(channel_id:, message_count: nil, ignore_current_count: false)
|
|
@channel_id = channel_id
|
|
@message_count = message_count&.to_i || 30
|
|
@ignore_current_count = ignore_current_count
|
|
super(::Chat::Thread, 1)
|
|
end
|
|
|
|
def data
|
|
channel = ::Chat::Channel.find(@channel_id)
|
|
return if !channel
|
|
|
|
if !channel.threading_enabled
|
|
puts "Enabling threads in channel #{channel.id}"
|
|
channel.update!(threading_enabled: true)
|
|
end
|
|
|
|
membership =
|
|
::Chat::UserChatChannelMembership.where(chat_channel: channel).order("RANDOM()").first
|
|
user = membership.user
|
|
|
|
om =
|
|
Chat::CreateMessage.call(
|
|
guardian: user.guardian,
|
|
message: Faker::Lorem.paragraph,
|
|
chat_channel_id: channel.id,
|
|
).message
|
|
|
|
{ original_message_user: user, original_message: om, channel: channel }
|
|
end
|
|
|
|
def create!
|
|
super do |thread|
|
|
thread.original_message.update!(thread: thread)
|
|
user =
|
|
::Chat::UserChatChannelMembership
|
|
.where(chat_channel: thread.channel)
|
|
.order("RANDOM()")
|
|
.first
|
|
.user
|
|
@message_count.times do
|
|
Chat::CreateMessage.call(
|
|
{
|
|
guardian: user.guardian,
|
|
chat_channel_id: thread.channel_id,
|
|
message: Faker::Lorem.paragraph,
|
|
thread_id: thread.id,
|
|
},
|
|
)
|
|
end
|
|
end
|
|
end
|
|
end
|
|
end
|