Contents

module NightcrawlerSwift
  class Connection
    attr_accessor :opts, :auth_response, :token_id, :expires_at, :admin_url, :upload_url

    # Hash with: bucket, tenant_name, username, password, auth_url
    #
    def initialize opts = {}
      @opts = OpenStruct.new opts
    end

    def connect!
      response = RestClient.post(
        opts.auth_url,
        {
          auth: {
            tenantName: opts.tenant_name,
            passwordCredentials: {username: opts.username, password: opts.password}
          }
        }.to_json,

        content_type: :json,
        accept: :json,
      )

      @auth_response = OpenStruct.new(JSON.parse(response.body))
      @token_id = @auth_response.access["token"]["id"]
      @expires_at = @auth_response.access["token"]["expires"]
      @expires_at = DateTime.parse(@expires_at).to_time

      @admin_url = @auth_response.access["serviceCatalog"].first["endpoints"].first["adminURL"]
      @upload_url = "#{@admin_url}/#{opts.bucket}"

      NightcrawlerSwift.logger.info  "Connected, token_id: #{@token_id}"
      self

    rescue StandardError => e
      raise Exceptions::ConnectionError.new(e)
    end

    def connected?
      !self.token_id.nil? and self.expires_at > Time.now
    end
  end
end

Version data entries

2 entries across 2 versions & 1 rubygems

Version	Path
nightcrawler_swift-0.1.1	lib/nightcrawler_swift/connection.rb
nightcrawler_swift-0.1.0	lib/nightcrawler_swift/connection.rb