Ruby Critic

Updated 2024-03-05 17:21:25 -0300
app/use_cases/accounts/apps/chatwoots/webhooks / import_message.rb

97 lines of codes
11 methods
7.7 complexity/method
24 churn
84.8 complexity
0 duplications
class Accounts::Apps::Chatwoots::Webhooks::ImportMessage                                        IrresponsibleModule              
      Accounts::Apps::Chatwoots::Webhooks::ImportMessage has no descriptive comment          
  
  require 'open-uri'

  def initialize(chatwoot, contact, webhook)
    @chatwoot = chatwoot
    @contact = contact
    @webhook =  webhook
  end

  def call
    message = get_or_import_message()
    { ok: message }
  end

  def get_or_import_message()
    message = @contact.events.where(
      '? <@ additional_attributes', { chatwoot_id: @webhook['id'] }.to_json
    ).first
    if message.nil?                                        NilCheck              
      Accounts::Apps::Chatwoots::Webhooks::ImportMessage#get_or_import_message performs a nil-check          
  
      if attachments?
        message = import_message_with_attachments()
      else
        message = import_message()
      end
    end
    message
  end

  def import_message_with_attachments()
    @webhook['attachments'].reverse.map.with_index do |attachment, index|
      import_message(
        { attachment: attachment, order: index, last_element: last_element?(index)}
        )
    end
  end

  def last_element?(index)
    index == @webhook['attachments'].count - 1
  end

  def import_message(attachment_params = {})                                        HighComplexity              
      Accounts::Apps::Chatwoots::Webhooks::ImportMessage#import_message has a flog score of 25          
  
                                        TooManyStatements              
      Accounts::Apps::Chatwoots::Webhooks::ImportMessage#import_message has approx 7 statements          
  
    message = @contact.events.new(
      account: @chatwoot.account,
      kind: 'chatwoot_message',
      from_me: is_from_me?(),
      contact: @contact,
      done: true,
      done_at: build_done_at(attachment_params[:order]),
      app: @chatwoot
    )
    message.additional_attributes.merge!({ 'chatwoot_id' => @webhook['conversation']['messages'].first['id'] })

    if attachment_params.present?
      create_attachment(message, attachment_params[:attachment])
      message.content = @webhook['content'] if attachment_params[:last_element] == true                                        DuplicateMethodCall              
      Accounts::Apps::Chatwoots::Webhooks::ImportMessage#import_message calls '@webhook['content']' 2 times              Locations:                  0                  1                  
  
                                        DuplicateMethodCall              
      Accounts::Apps::Chatwoots::Webhooks::ImportMessage#import_message calls 'message.content = @webhook['content']' 2 times              Locations:                  0                  1                  
  
    else
      message.content = @webhook['content']                                        DuplicateMethodCall              
      Accounts::Apps::Chatwoots::Webhooks::ImportMessage#import_message calls '@webhook['content']' 2 times              Locations:                  0                  1                  
  
                                        DuplicateMethodCall              
      Accounts::Apps::Chatwoots::Webhooks::ImportMessage#import_message calls 'message.content = @webhook['content']' 2 times              Locations:                  0                  1                  
  
    end

    message.save
    message
  end

  def create_attachment(event, attachment_params)                                        UtilityFunction              
      Accounts::Apps::Chatwoots::Webhooks::ImportMessage#create_attachment doesn't depend on instance state (maybe move it to another class?)          
  
    begin
      downloaded_file = URI.open(attachment_params['data_url'])                                        DuplicateMethodCall              
      Accounts::Apps::Chatwoots::Webhooks::ImportMessage#create_attachment calls 'attachment_params['data_url']' 2 times              Locations:                  0                  1                  
  
      attachment = event.build_attachment(
        file_type: attachment_params['file_type']
      )
      attachment.file.attach(io: downloaded_file,
                             filename: File.basename(attachment_params['data_url']))                                        DuplicateMethodCall              
      Accounts::Apps::Chatwoots::Webhooks::ImportMessage#create_attachment calls 'attachment_params['data_url']' 2 times              Locations:                  0                  1                  
  
    rescue OpenURI::HTTPError
      event.status = 'failed'
    end
  end

  def build_done_at(order = nil)
    if order.present?
      created_at = @webhook['created_at'].dup                                        DuplicateMethodCall              
      Accounts::Apps::Chatwoots::Webhooks::ImportMessage#build_done_at calls '@webhook['created_at']' 2 times              Locations:                  0                  1                  
  
      created_at.to_time + miliseconds(order)
    else
      @webhook['created_at'].to_time                                        DuplicateMethodCall              
      Accounts::Apps::Chatwoots::Webhooks::ImportMessage#build_done_at calls '@webhook['created_at']' 2 times              Locations:                  0                  1                  
  
    end
  end

  def miliseconds(miliseconds)                                        UtilityFunction              
      Accounts::Apps::Chatwoots::Webhooks::ImportMessage#miliseconds doesn't depend on instance state (maybe move it to another class?)          
  
    miliseconds/1000.0
  end

  def attachments?()
    @webhook['attachments'].present?
  end

  def is_from_me?()
    @webhook.dig('sender', 'type') == 'user' if @webhook.dig('sender', 'id').present?
  end
end