099b188530
* Clarify uncommunicative variables in labor classes Single letter variable names are largely a question of preference, in some cases I think that convention mitigates the opaque nature of single letter variable names (e.g., e for error, i for index, etc). However, in some cases they can be unclear and there isn't much reason to use single letter variables unless for some reason character length is really important. In this case, I would prefer clarity in variable names over brevity of code so I've used Reek to identify short variable names and I'm changing them. It's pretty boring, but hopefully incremental code love changes like this one add up and improve readability and accessibility for those interested in reading this codebase. * Remove commented code from 2 years ago * Clarify uncommunicative naming in services classes There is some context for this change in 6b81880f * Clarify uncommunicative naming in models There is some context for this change in 6b81880f * Clarify uncommunicative naming in liquid_tags There is some context for this change in 6b81880f
96 lines
3 KiB
Ruby
96 lines
3 KiB
Ruby
class Message < ApplicationRecord
|
|
belongs_to :user
|
|
belongs_to :chat_channel
|
|
|
|
validates :message_html, presence: true
|
|
validates :message_markdown, presence: true, length: { maximum: 1024 }
|
|
validate :channel_permission
|
|
|
|
before_save :determine_user_validity
|
|
before_validation :evaluate_markdown
|
|
after_create :send_email_if_appropriate
|
|
after_create :update_chat_channel_last_message_at
|
|
after_create :update_all_has_unopened_messages_statuses
|
|
|
|
def preferred_user_color
|
|
color_options = [user.bg_color_hex || "#000000", user.text_color_hex || "#000000"]
|
|
HexComparer.new(color_options).brightness(0.9)
|
|
end
|
|
|
|
def determine_user_validity
|
|
raise unless chat_channel.status == "active" && (chat_channel.has_member?(user) || chat_channel.channel_type == "open")
|
|
end
|
|
|
|
def send_push
|
|
Messages::SendPushJob.perform_later(user.id, chat_channel.id, message_html)
|
|
end
|
|
|
|
def direct_receiver
|
|
return if chat_channel.channel_type != "direct"
|
|
|
|
chat_channel.users.where.not(id: user.id).first
|
|
end
|
|
|
|
private
|
|
|
|
def update_chat_channel_last_message_at
|
|
chat_channel.touch(:last_message_at)
|
|
chat_channel.index!
|
|
chat_channel.chat_channel_memberships.reindex!
|
|
chat_channel.delay.index!
|
|
end
|
|
|
|
def update_all_has_unopened_messages_statuses
|
|
chat_channel.
|
|
chat_channel_memberships.
|
|
where("last_opened_at < ?", 10.seconds.ago).
|
|
where.
|
|
not(user_id: user_id).
|
|
update_all(has_unopened_messages: true)
|
|
end
|
|
|
|
def evaluate_markdown
|
|
html = MarkdownParser.new(message_markdown).evaluate_markdown
|
|
html = append_rich_links(html)
|
|
self.message_html = html
|
|
end
|
|
|
|
def append_rich_links(html)
|
|
doc = Nokogiri::HTML(html)
|
|
rich_style = "border: 1px solid #0a0a0a; border-radius: 3px; padding: 8px;"
|
|
doc.css("a").each do |anchor|
|
|
if (article = rich_link_article(anchor))
|
|
html += "<a style='color: #0a0a0a' href='#{article.path}'
|
|
target='_blank' data-content='articles/#{article.id}'>
|
|
<h1 style='#{rich_style}' data-content='articles/#{article.id}'>
|
|
#{article.title}</h1></a>".html_safe
|
|
end
|
|
end
|
|
html
|
|
end
|
|
|
|
def channel_permission
|
|
errors.add(:base, "Must be part of channel.") if chat_channel_id.blank?
|
|
|
|
channel = ChatChannel.find(chat_channel_id)
|
|
return if channel.open?
|
|
|
|
errors.add(:base, "You are not a participant of this chat channel.") unless channel.has_member?(user)
|
|
end
|
|
|
|
def rich_link_article(link)
|
|
Article.find_by(slug: link["href"].split("/")[4].split("?")[0]) if link["href"].include?("//#{ApplicationConfig['APP_DOMAIN']}/") && link["href"].split("/")[4]
|
|
end
|
|
|
|
def send_email_if_appropriate
|
|
recipient = direct_receiver
|
|
return if !chat_channel.direct? ||
|
|
recipient.updated_at > 1.hour.ago ||
|
|
recipient.chat_channel_memberships.order("last_opened_at DESC").
|
|
first.last_opened_at > 15.hours.ago ||
|
|
chat_channel.last_message_at > 30.minutes.ago ||
|
|
recipient.email_connect_messages == false
|
|
|
|
NotifyMailer.new_message_email(self).deliver
|
|
end
|
|
end
|