84 lines
2.3 KiB
Ruby
84 lines
2.3 KiB
Ruby
# == Schema Information
|
|
#
|
|
# Table name: channel_sms
|
|
#
|
|
# id :bigint not null, primary key
|
|
# phone_number :string not null
|
|
# provider :string default("default")
|
|
# provider_config :jsonb
|
|
# created_at :datetime not null
|
|
# updated_at :datetime not null
|
|
# account_id :integer not null
|
|
#
|
|
# Indexes
|
|
#
|
|
# index_channel_sms_on_phone_number (phone_number) UNIQUE
|
|
#
|
|
|
|
class Channel::Sms < ApplicationRecord
|
|
include Channelable
|
|
|
|
self.table_name = 'channel_sms'
|
|
EDITABLE_ATTRS = [:phone_number, { provider_config: {} }].freeze
|
|
|
|
validates :phone_number, presence: true, uniqueness: true
|
|
# before_save :validate_provider_config
|
|
|
|
def name
|
|
'Sms'
|
|
end
|
|
|
|
# all this should happen in provider service . but hack mode on
|
|
def api_base_path
|
|
'https://messaging.bandwidth.com/api/v2'
|
|
end
|
|
|
|
def send_message(contact_number, message)
|
|
body = message_body(contact_number, message.content)
|
|
body['media'] = message.attachments.map(&:download_url) if message.attachments.present?
|
|
|
|
send_to_bandwidth(body)
|
|
end
|
|
|
|
def send_text_message(contact_number, message_content)
|
|
body = message_body(contact_number, message_content)
|
|
send_to_bandwidth(body)
|
|
end
|
|
|
|
private
|
|
|
|
def message_body(contact_number, message_content)
|
|
{
|
|
'to' => contact_number,
|
|
'from' => phone_number,
|
|
'text' => message_content,
|
|
'applicationId' => provider_config['application_id']
|
|
}
|
|
end
|
|
|
|
def send_to_bandwidth(body)
|
|
response = HTTParty.post(
|
|
"#{api_base_path}/users/#{provider_config['account_id']}/messages",
|
|
basic_auth: bandwidth_auth,
|
|
headers: { 'Content-Type' => 'application/json' },
|
|
body: body.to_json
|
|
)
|
|
|
|
response.success? ? response.parsed_response['id'] : nil
|
|
end
|
|
|
|
def bandwidth_auth
|
|
{ username: provider_config['api_key'], password: provider_config['api_secret'] }
|
|
end
|
|
|
|
# Extract later into provider Service
|
|
# let's revisit later
|
|
def validate_provider_config
|
|
response = HTTParty.post(
|
|
"#{api_base_path}/users/#{provider_config['account_id']}/messages",
|
|
basic_auth: bandwidth_auth,
|
|
headers: { 'Content-Type': 'application/json' }
|
|
)
|
|
errors.add(:provider_config, 'error setting up') unless response.success?
|
|
end
|
|
end
|