local function GetRedisClient()
    local Host = plugin.ConfigGet('server')
    local Port = plugin.ConfigGet('port')
    local Pass = plugin.ConfigGet('pass')
    local Redis = redis.connect(Host, Port)
    if Redis == nil then
        return nil
    end
    Redis:auth(Pass)
    return Redis
end


local irc = nil

local CheckNotifications = function()
	local Redis = GetRedisClient()
	if Redis == nil then
		return
	end
	while true do
		local Data = Redis:rpoplpush('notifications:queue', 'notifications:processing')
		if Data == nil then
		        Redis:quit()
			return
		end
		local Notification = json.decode.decode(Data)
		local Line = ""
		print("Sending notification: " .. Line)
		if Notification['Notice'] ~= nil then
			irc:Notice(Notification['Receiver'], Notification['Message'])
		else
			irc:Say(Notification['Receiver'], Notification['Message'])
		end
		Redis:lrem('notifications:processing', -1, Data)
	end
	Redis:quit()
end

local LastGlobalChecked = 0
plugin.AddHook('irc.Message', 'notificationgrabirc', function(Username, Channel, Message)
	irc = Channel._irc
end)

plugin.AddHook('ReactorTick', 'notifications', function()
    if irc == nil then
        return
    end
    if LastGlobalChecked + 1 < os.time() then
        LastGlobalChecked = os.time()
        pcall(function()
            CheckNotifications(irc)
        end)
    end
end)

plugin.AddCommand('redis', -1, function(Username, Channel, String)
	local Redis = GetRedisClient()
	if Redis == nil then
		Channel:Say("Couldn't connect to Redis, lol.")
		return
	end
	local Result = Redis:raw_cmd(String)
	if Result == nil then
		Channel:Say("OK, nil result.")
	elseif type(Result) == "table" then
		Channel:Say(table.concat(Result, ", "))
	else
		Channel:Say(tostring(Result))
	end
	Redis:quit()
end, "Runs stuff in Redis", 100)