local setmetatable = setmetatable;

local pcall = pcall;

local type = type;

local t_concat = table.concat;

local print = print;

local socket_url = require "socket.url";

local http = require "socket.http";

local ltn12 = require "ltn12";

--local json = require "json";

local json = module:require("couchdb/json");

--module("couchdb")

local _M = {};

local function urlcat(url, path)

	return url:gsub("/*$", "").."/"..path:gsub("^/*", "");

end

local doc_mt = {};

doc_mt.__index = doc_mt;

function doc_mt:get()

	return self.db:get(socket_url.escape(self.id));

end

function doc_mt:put(val)

	return self.db:put(socket_url.escape(self.id), val);

end

function doc_mt:__tostring()

	return "couchdb.doc("..self.url..")";

end

local db_mt = {};

db_mt.__index = db_mt;

function db_mt:__tostring()

	return "couchdb.db("..self.url..")";

end

function db_mt:doc(id)

	local url = urlcat(self.url, socket_url.escape(id));

	return setmetatable({ url = url, db = self, id = id }, doc_mt);

end

function db_mt:get(id)

	local url = urlcat(self.url, id);

	local a,b = http.request(url);

	local r,x = pcall(json.decode, a);

	if r then a = x; end

	return a,b;

end

function db_mt:put(id, value)

	local url = urlcat(self.url, id);

	if type(value) == "table" then

		value = json.encode(value);

	elseif value ~= nil and type(value) ~= "string" then

		return nil, "Invalid type";

	end

	local t = {};

	local a,b = http.request {

		url = url,

		sink = ltn12.sink.table(t),

		source = ltn12.source.string(value),

		method = "PUT",

		headers = {

			["Content-Length"] = #value,

			["Content-Type"] = "application/json"

		}

	};

	a = t_concat(t);

	local r,x = pcall(json.decode, a);

	if r then a = x; end

	return a,b;

end

local server_mt = {};

server_mt.__index = server_mt;

function server_mt:db(name)

	local url = urlcat(self.url, socket_url.escape(name));

	return setmetatable({ url = url }, db_mt);

end

function server_mt:__tostring()

	return "couchdb.server("..self.url..")";

end

function _M.server(url)

	return setmetatable({ url = url }, server_mt);

end

function _M.db(url)

	return setmetatable({ url = url }, db_mt);

end

return _M;