class Couchdb

# File lib/couchdb_basic.rb, line 7
def initialize(url)
    @url = url
end

# File lib/couchdb_basic.rb, line 11
def _get(url="")
    r = RestClient.get "#{@url}#{url}"
    MultiJson.load(r.to_str, :symbolize_keys => true)
end

# File lib/couchdb_basic.rb, line 16
def _post(data,bulk=false)
    begin
        url = @url
        if bulk
          url = "#{url}/_bulk_docs"
        end
        r = RestClient.post "#{url}", MultiJson.dump(data), :content_type => :json, :accept => :json
    rescue RestClient::Forbidden => e
        puts e.response.to_str
        r = e.response
    end
    MultiJson.load(r.to_str, :symbolize_keys => true)
end

# File lib/couchdb_basic.rb, line 34
def create(doc)
    r = _post(doc)
    doc[:_id]  = r[:id]
    doc[:_rev] = r[:rev]
    doc
end

# File lib/couchdb_basic.rb, line 41
def create_bulk(docs)
    docs = {:docs=>docs}
    _post(docs,true)    
end

# File lib/couchdb_basic.rb, line 30
def db()
    _get()
end

# File lib/couchdb_basic.rb, line 63
def delete(doc)
    r = RestClient.delete "#{@url}/#{doc[:_id]}?rev=#{doc[:_rev]}", :content_type => :json
    nil
end

# File lib/couchdb_basic.rb, line 52
def get(id)
    begin
        _get "/#{id.to_uri}"
    rescue RestClient::ResourceNotFound
        nil
    rescue RestClient::BadRequest => e
        puts e.response.to_str
        nil
    end
end

# File lib/couchdb_basic.rb, line 85
def get_all(args={})
    url = "/_all_docs?include_docs=true"
    if args.has_key?( :skip )
        skip = MultiJson.dump( args[:skip] )
        url << "&skip=#{skip}"
    end
    if args.has_key?( :limit )
        limit = MultiJson.dump( args[:limit] )
        url << "&limit=#{limit}"
    end
    docs = []
    _get(url)[:rows].each{ | row | docs << row[:doc ] }
    docs
end

# File lib/couchdb_basic.rb, line 46
def update(doc)
    r = _post(doc)
    doc[:_rev] = r[:rev]
    doc
end

# File lib/couchdb_basic.rb, line 68
def view(design,view,args={})
    url = "/_design/#{design}/_view/#{view}?"
    if args.has_key?(:key)
        key = MultiJson.dump(args[:key]).to_uri
        url << "&key=#{key}"
    end
    if args.has_key?(:group)
        key = MultiJson.dump(args[:group]).to_uri
        url << "&group=#{key}"
    end
    if args.has_key?(:reduce)
        key = MultiJson.dump(args[:reduce]).to_uri
        url << "&reduce=#{key}"
    end
    _get(url)[:rows]
end