RUBYCRITIC
RUBYCRITIC
# == Schema Information
#
# Table name: apps_chatwoots
#
# id :bigint not null, primary key
# chatwoot_endpoint_url :string default(""), not null
# chatwoot_user_token :string default(""), not null
# embedding_token :string default(""), not null
# inboxes :jsonb not null
# name :string
# status :string default("active"), not null
# created_at :datetime not null
# updated_at :datetime not null
# chatwoot_account_id :integer not null
# chatwoot_dashboard_app_id :integer not null
# chatwoot_webhook_id :integer not null
#
class Apps::Chatwoot < ApplicationRecord
scope :actives, -> { where(active: true) }
normalizes :chatwoot_endpoint_url, with: ->(value) { value&.gsub(/\/+\z/, '') }
enum status: {
'inactive': 'inactive',
'active': 'active',
'sync': 'sync',
'pair': 'pair'
}
validate :validate_chatwoot, on: :create
before_destroy :chatwoot_delete_flow
def request_headers
{ 'api_access_token': chatwoot_user_token.to_s, 'Content-Type': 'application/json' }
end
def validate_chatwoot
if invalid_token?
errors.add(:chatwoot_user_token, I18n.t('activerecord.errors.messages.invalid_chatwoot_token'))
return
end
chatwoot_create_flow
if chatwoot_dashboard_app_id.blank? || chatwoot_webhook_id.blank?
errors.add(:chatwoot_endpoint_url, I18n.t('activerecord.errors.messages.invalid_chatwoot_configuration')) -
errors.add(:chatwoot_user_token, I18n.t('activerecord.errors.messages.invalid_chatwoot_configuration')) -
end
end
def invalid_token?
!valid_token?
end
def valid_token? - Apps::Chatwoot#valid_token? has approx 8 statements
return false if chatwoot_account_is_suspended?
response = Apps::Chatwoot::ApiClient.new(self).user_profile
return false if response[:error].present?
account = response[:ok]['accounts'].select do |acc|
acc['id'] == chatwoot_account_id
end
return true if account&.dig(0, 'role') == 'administrator'
false
rescue
false
end
def chatwoot_create_flow - Apps::Chatwoot#chatwoot_create_flow has a flog score of 50
- Apps::Chatwoot#chatwoot_create_flow has approx 14 statements
self.embedding_token = generate_token
dashboard_apps_response = Faraday.post(
"#{chatwoot_endpoint_url}/api/v1/accounts/#{chatwoot_account_id}/dashboard_apps",
{
"title": 'WoofedCRM',
"content": [{ "type": 'frame', "url": woofedcrm_embedding_url }]
}.to_json,
{ 'api_access_token': chatwoot_user_token.to_s, 'Content-Type': 'application/json' }
)
webhook_response = Faraday.post(
"#{chatwoot_endpoint_url}/api/v1/accounts/#{chatwoot_account_id}/webhooks",
{
"webhook": {
"url": woofedcrm_webhooks_url,
"subscriptions": %w[
contact_created
contact_updated
conversation_created
conversation_status_changed
conversation_updated
message_created
message_updated
webwidget_triggered
]
}
}.to_json,
{ 'api_access_token': chatwoot_user_token.to_s, 'Content-Type': 'application/json' }
)
self.inboxes = Accounts::Apps::Chatwoots::GetInboxes.call(self)[:ok]
if dashboard_apps_response.status == 200 && webhook_response.status == 200
dashboard_apps_body = JSON.parse(dashboard_apps_response.body)
webhook_body = JSON.parse(webhook_response.body)
self.chatwoot_dashboard_app_id = dashboard_apps_body['id']
self.chatwoot_webhook_id = webhook_body['payload']['webhook']['id']
true
else
false
end
rescue Exception => e - Apps::Chatwoot#chatwoot_create_flow has the variable name 'e'
Rails.logger.error('Chatwoot connection error') -
Rails.logger.error(e.inspect) -
false
end
def chatwoot_delete_flow
dashboard_apps_response = Faraday.delete( -
"#{chatwoot_endpoint_url}/api/v1/accounts/#{chatwoot_account_id}/dashboard_apps/#{chatwoot_dashboard_app_id}",
{},
{ 'api_access_token': chatwoot_user_token.to_s, 'Content-Type': 'application/json' }
)
webhook_response = Faraday.delete( -
"#{chatwoot_endpoint_url}/api/v1/accounts/#{chatwoot_account_id}/webhooks/#{chatwoot_webhook_id}",
{},
{ 'api_access_token': chatwoot_user_token.to_s, 'Content-Type': 'application/json' }
)
true
rescue StandardError
true
end
def chatwoot_account_is_suspended?
response = Accounts::Apps::Chatwoots::GetInboxes.call(self)
response.key?(:error) && JSON.parse(response[:error]) == {"error"=>"Account is suspended"} - Apps::Chatwoot#chatwoot_account_is_suspended? refers to 'response' more than self (maybe move it to another class?)
rescue Faraday::TimeoutError, Faraday::ConnectionFailed
false
end
private
def woofedcrm_webhooks_url
"#{ENV['FRONTEND_URL']}/apps/chatwoots/webhooks?token=#{embedding_token}"
end
def woofedcrm_embedding_url
"#{ENV['FRONTEND_URL']}/apps/chatwoots/embedding?token=#{embedding_token}"
end
def generate_token
loop do
token = SecureRandom.hex(10)
break token unless Apps::Chatwoot.where(embedding_token: token).exists?
end
end
end