local xmpp_conf = {
	jid='wilson@ubq323.website',
	server='ubq323.website',
	auth='AHdpbHNvbgBncmVnb3J5PDM=',
	resource='cheese',
	muc='d@conference.ubq323.website',
}

local cqueues = require'cqueues'
local socket = require'cqueues.socket'
local xml = require'xml'
local X = xml.X
local xmlify = xml.xmlify
local pprint=require'pprint'
local discord=require'discord'


local function connect(conf)
	local sock = assert(socket.connect(conf.server, 5222))
	sock:setmode('bn','bn')

	local start = ([[
<?xml version='1.0'?><stream:stream from='%s' to='%s' version='1.0' xml:lang='en' xmlns='jabber:client' xmlns:stream='http://etherx.jabber.org/streams'>]]):format(conf.jid, conf.server)

	-- state of the art xml parser
	local function check_and_send(test, text)
		local x = sock:read('-2048')
		assert(x:find(test))
		if text then sock:write(text) end
	end
	local function ietf_urn(v) return 'urn:ietf:params:xml:ns:xmpp-'..v end

	sock:write(start)
	check_and_send('starttls', xmlify(X.starttls{xmlns=ietf_urn"tls"}))
	check_and_send('proceed', nil)
	sock:starttls()
	sock:write(start)
	check_and_send('PLAIN',
		xmlify(X.auth{xmlns=ietf_urn"sasl", mechanism='PLAIN', conf.auth}))
	check_and_send('success',start)
	check_and_send('bind',
		xmlify(X.iq{type='set', id='aaaa',
			X.bind{xmlns=ietf_urn"bind", X.resource{conf.resource}}}))
	check_and_send('jid',X.presence{X.show{'chat'}})

	return sock
end


-- local mucs = {
-- 	'ja@conference.ubq323.website',
-- 	'a@conference.ubq323.website',
-- }


local function run_xmpp(cq)
	local sock = connect(xmpp_conf)

	-- sock:write(xmlify(
	-- 	X.presence{to=xmpp_conf.muc..'/wilson',
	-- 		X.x{xmlns='http://jabber.org/protocol/muc',
	-- 			X.history{maxstanzas='0'}}}))


	-- cq:wrap(function()
	-- 	local n = 1
	-- 	while true do
	-- 		sock:write(xmlify(
	-- 			X.message{to=xmpp_conf.muc, type='groupchat',
	-- 				id='wilson_episode_'..n,
	-- 				X.body{'i too am in episode '..n}}))
	-- 		n=n+1
	-- 		cqueues.sleep(60)
	-- 	end
	-- end)

	sock:write(xmlify(
		X.iq{type='get',to=xmpp_conf.muc, id='info1',
			X.query{xmlns='http://jabber.org/protocol/disco#info'}}))


	for x in xml.stanzae(function() return sock:read('-2048') end) do
		pprint(x)
		print(xmlify(x))
		local body = x'body' and x'body'[1]
		if x.label == 'message' then
			pprint('M', x.xarg.from, body)
			if body == 'hi wilson' then
				sock:write(xmlify(
					X.message{to=xmpp_conf.muc, type='groupchat',
						X.body{'hi '..x.xarg.from..'.'}}))
			end
			-- discord.grom(x.xarg.from, body or '*(there\'s no body here)*')
		end
	end
end

local cq = cqueues.new()
cq:wrap(run_xmpp, cq)

pprint(cq:loop())