summaryrefslogtreecommitdiff
path: root/lib/nickserver/couch_db/source.rb
blob: 7799edeb7b311e6a4f5281c506a6ab76ac36beb8 (plain)
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
#
# This class allows querying couch for public keys.
#
require 'nickserver/source'
require 'nickserver/couch_db/response'
require 'nickserver/config'

module Nickserver::CouchDB
  class Error < StandardError; end

  class Source < Nickserver::Source
    VIEW = '/_design/Identity/_view/keys_by_email'.freeze
    UNEXPECTED_RESPONSE_CODES = [401, 500].freeze

    def query(nick)
      status, body = adapter.get url, query: query_for(nick)
      handle_unexpected_responses(status, body)
      Response.new(nick, status: status, body: body)
    end

    protected

    def handle_unexpected_responses(status, body)
      if UNEXPECTED_RESPONSE_CODES.include? status
        raise Error, "Couch responded with #{status}: #{body}"
      end
    end

    def url
      Nickserver::Config.couch_url + VIEW
    end

    def query_for(nick)
      { reduce: 'false', key: "\"#{nick}\"" }
    end

    attr_reader :config
  end
end