RUBYCRITIC
RUBYCRITIC
# == Schema Information
#
# Table name: events
#
# id :bigint not null, primary key
# additional_attributes :jsonb
# app_type :string
# auto_done :boolean default(FALSE)
# custom_attributes :jsonb
# done_at :datetime
# from_me :boolean
# kind :string not null
# scheduled_at :datetime
# status :integer
# title :string default(""), not null
# created_at :datetime not null
# updated_at :datetime not null
# app_id :bigint
# contact_id :bigint
# deal_id :bigint
#
# Indexes
#
# index_events_on_app (app_type,app_id)
# index_events_on_contact_id (contact_id)
# index_events_on_deal_id (deal_id)
#
class Event < ApplicationRecord - Event assumes too much for instance variable '@result'
- Event has at least 26 methods
include Deal::Broadcastable
# default_scope { order('created_at DESC') }
DEAL_UPDATE_KINDS = %w[deal_stage_change deal_opened deal_won deal_lost deal_reopened deal_product_added
deal_product_removed].freeze
belongs_to :deal, optional: true
belongs_to :contact
# belongs_to :event_kind, default: -> { EventKind }
# belongs_to :record, polymorphic: true
belongs_to :app, polymorphic: true, optional: true
has_rich_text :content
alias original_content content
attribute :done, :boolean
attribute :send_now, :boolean
validates :kind, presence: true
has_one :attachment, as: :attachable
after_commit do
# To refactory
if send_now == true
Accounts::Contacts::Events::SendNow.call(self)
elsif scheduled_delivery_event?
Accounts::Contacts::Events::EnqueueWorker.perform_async(id)
end
schedule_webpush_notifications
end
attribute :files, default: []
attribute :files_events, default: []
attribute :invalid_files
validate :validate_invalid_files
def validate_invalid_files
errors.add(:files, 'Invalid files') if invalid_files == true
end
def save - Event#save has approx 6 statements
ActiveRecord::Base.transaction do
@result = super
return @result if @result == false
if files_events.present?
files_events.each do |file_event|
file_event.save!
end
end
end
@result
end
def schedule_webpush_notifications
return unless scheduled_at.present? && saved_change_to_scheduled_at? && !send_now
Pwa::SendNotificationsWorker.set(wait_until: scheduled_at).perform_later(id)
end
def content=(value)
original_content.body = value
end
def content
if text_content? && original_content.body.present? -
original_content.body.to_plain_text -
else
original_content
end
end
def text_content?
chatwoot_message? || evolution_api_message?
end
def generate_content_hash(key, value)
if content_is_blank?(value)
{ key.to_s => '' } -
-
else
{ key.to_s => value } -
-
end
end
def content_is_blank?(value) - Event#content_is_blank? doesn't depend on instance state (maybe move it to another class?)
value.respond_to?(:body) - Event#content_is_blank? manually dispatches method call
end
def should_delivery_event_scheduled?
!done? && (Time.current.in_time_zone > scheduled_at)
end
def changed_scheduled_values?
saved_change_to_scheduled_at? || saved_change_to_auto_done?
end
def scheduled_delivery_event?
changed_scheduled_values? && (auto_done == true && scheduled_at.present? && done_at.blank?)
end
def done
done_at.present?
end
def done?
done
end
def done=(value)
value_boolean = ActiveRecord::Type::Boolean.new.cast(value)
return if value_boolean == done
self.done_at = (Time.now if value_boolean == true)
end
def send_now=(value)
self[:send_now] = ActiveRecord::Type::Boolean.new.cast(value)
end
scope :to_do, lambda {
where('done_at IS NULL').order(:scheduled_at)
}
scope :planned, lambda {
to_do.where('auto_done = false AND scheduled_at IS NOT NULL').order(:scheduled_at)
}
scope :scheduled, lambda {
to_do.where('auto_done = true AND scheduled_at IS NOT NULL')
}
scope :planned_overdue, lambda {
planned.where('scheduled_at < ?', DateTime.current)
}
scope :planned_without_date, lambda {
to_do.where('auto_done = false AND scheduled_at IS NULL')
}
scope :done, lambda {
where('done_at IS NOT NULL').order(done_at: :desc)
}
scope :by_message_id, lambda { |message_id|
where("additional_attributes ->> 'message_id' = ?", message_id)
}
enum kind: {
'note': 'note',
'evolution_api_message': 'evolution_api_message',
'activity': 'activity',
'chatwoot_message': 'chatwoot_message',
'deal_stage_change': 'deal_stage_change',
'deal_opened': 'deal_opened',
'deal_won': 'deal_won',
'deal_lost': 'deal_lost',
'deal_reopened': 'deal_reopened',
'deal_product_added': 'deal_product_added',
'deal_product_removed': 'deal_product_removed'
}
enum status: { sent: 0, delivered: 1, read: 2, failed: 3 }
before_validation do
self.done = false if scheduled_at.present? && done.nil?
end
def icon_key
if note?
'menu-square'
elsif activity?
'calendar-check-2'
elsif chatwoot_message?
'message-circle'
end
end
def editable?
return true if %w[note activity].include?(kind)
return true if %w[chatwoot_message evolution_api_message].include?(kind) && !done?
false
end
def deal_updates?
DEAL_UPDATE_KINDS.include?(kind)
end
def kind_message?
chatwoot_message? || evolution_api_message?
end
def overdue?
return false if done == true || scheduled_at.blank?
DateTime.current > scheduled_at
end
def primary_date
if scheduled_at.present?
scheduled_at.iso8601
else
created_at.iso8601
end
end
def from
if from_me == true
'from-me'
else
'from-contacts'
end
end
def scheduled_kind
if done == true
'done'
else
'scheduled'
end
end
def has_media_attachment?
attachment.present? && (attachment.image? || attachment.file? || attachment.video?)
end
## Events
include Wisper::Publisher
after_commit :publish_created, on: :create
after_commit :publish_updated, on: :update
private
def publish_created
broadcast(:event_created, self)
end
def publish_updated
broadcast(:event_updated, self)
end
end