Contents

# frozen_string_literal: true

require 'http'

require 'stealth/services/bandwidth/message_handler'
require 'stealth/services/bandwidth/reply_handler'
require 'stealth/services/bandwidth/setup'

module Stealth
  module Services
    module Bandwidth
      class Client < Stealth::Services::BaseClient

        attr_reader :http_client, :reply, :endpoint

        def initialize(reply:)
          @reply = reply
          account_id = Stealth.config.bandwidth.account_id
          username = Stealth.config.bandwidth.api_username
          password = Stealth.config.bandwidth.api_password
          application_id = Stealth.config.bandwidth.application_id
          @endpoint = "https://messaging.bandwidth.com/api/v2/users/#{account_id}/messages"
          @http_client = HTTP
                          .timeout(connect: 15, read: 30)
                          .basic_auth(user: username, pass: password)
                          .headers('Content-Type' => 'application/json')
        end

        def transmit
          # Don't transmit anything for delays
          return true if reply.blank?

          json_reply = Oj.dump(reply, mode: :compat)
          response = http_client.post(endpoint, body: json_reply)

          Stealth::Logger.l(
            topic: 'bandwidth',
            message: "Transmitting. Response: #{response.status.code}: #{response.body}"
          )
        end

      end
    end
  end
end

Version data entries

3 entries across 3 versions & 1 rubygems

Version	Path
stealth-bandwidth-1.1.0	lib/stealth/services/bandwidth/client.rb
stealth-bandwidth-1.0.1	lib/stealth/services/bandwidth/client.rb
stealth-bandwidth-1.0.0	lib/stealth/services/bandwidth/client.rb