97 lines
3.0 KiB
Lua
97 lines
3.0 KiB
Lua
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 function GetPackStatus(ID)
|
|
local URL = "http://ppsa.app.q3k.org/api/1/parcel/" .. ID .. ".json"
|
|
local Body, Code, Headers = http.request(URL)
|
|
if Code ~= 200 then
|
|
return "Invalid", true
|
|
end
|
|
local Data = json.decode.decode(Body)
|
|
if Data.data.last ~= nil then
|
|
return Data.data.last.name, Data.data.last.ending
|
|
end
|
|
return "Unknown", true
|
|
end
|
|
|
|
local function CheckPPSA(IRC, Force)
|
|
Force = Force or false
|
|
local Now = os.time()
|
|
local Redis = GetRedisClient()
|
|
if Redis == nil then
|
|
return
|
|
end
|
|
|
|
for _, ID in pairs(Redis:smembers("poczta:ids")) do
|
|
local LastChecked = tonumber(Redis:hget("poczta:objects:" .. ID, "lastchecked"))
|
|
local LastStatus = Redis:hget("poczta:objects:" .. ID, "status")
|
|
|
|
if Now > LastChecked + 600 or Force then
|
|
Redis:hset("poczta:objects:" .. ID, "lastchecked", Now)
|
|
local NewStatus, Ending = GetPackStatus(ID)
|
|
if NewStatus ~= LastStatus then
|
|
Redis:hset("poczta:objects:" .. ID, "status", NewStatus)
|
|
local Message = string.format("PPSA %s status changed (%s -> %s)", ID, LastStatus, NewStatus)
|
|
IRC:Say("#hackerspace-pl", Message)
|
|
end
|
|
if Ending then
|
|
local Message = string.format("PPSA %s done, removing.", ID)
|
|
IRC:Say("#hackerspace-pl", Message)
|
|
Redis:srem("poczta:ids", ID)
|
|
Redis:del("poczta:objects:" .. ID)
|
|
end
|
|
end
|
|
end
|
|
Redis:quit()
|
|
end
|
|
|
|
plugin.AddCommand('poczta', 1, function(Username, Channel, ID)
|
|
local Status, Last = GetPackStatus(ID)
|
|
Channel:Say(Username .. ": " .. Status)
|
|
end)
|
|
|
|
plugin.AddCommand('add-poczta', 1, function(Username, Channel, ID)
|
|
local Redis = GetRedisClient()
|
|
Redis:transaction(function(t)
|
|
t:sadd('poczta:ids', ID)
|
|
t:hset("poczta:objects:" .. ID, "lastchecked", 0)
|
|
t:hset("poczta:objects:" .. ID, "status", "none")
|
|
end)
|
|
CheckPPSA(Channel._irc)
|
|
Redis:quit()
|
|
end, "Add a PPSA tracking number", 10)
|
|
|
|
local LastGlobalChecked = 0
|
|
plugin.AddHook('irc.Message', 'testmate', function(Username, Channel, Message)
|
|
if LastGlobalChecked + 10 < os.time() then
|
|
LastGlobalChecked = os.time()
|
|
pcall(function()
|
|
CheckPPSA(Channel._irc)
|
|
end)
|
|
end
|
|
end)
|
|
|
|
plugin.AddCommand('list-poczta', 0, function(Username, Channel)
|
|
local Redis = GetRedisClient()
|
|
for _, ID in pairs(Redis:smembers("poczta:ids")) do
|
|
local LastStatus = Redis:hget("poczta:objects:" .. ID, "status")
|
|
Channel:Say(string.format(" - %s, status: %s", ID, LastStatus))
|
|
end
|
|
Redis:quit()
|
|
end)
|
|
|
|
plugin.AddCommand('check-poczta', 0, function(Username, Channel)
|
|
CheckPPSA(Channel._irc, true)
|
|
Channel:Say("Done.")
|
|
end)
|