282 lines
8.1 KiB
Lua
282 lines
8.1 KiB
Lua
local pluginc = import("classes.plugin")
|
|
local command = import("classes.command")
|
|
local plugin = pluginc("cron")
|
|
local cron = import("cron")
|
|
local fake_message = import("fake_message")
|
|
local md5 = import("md5")
|
|
local events = {
|
|
timer = {},
|
|
event = {}
|
|
}
|
|
|
|
local exec = function(v,command)
|
|
local channel = client:getChannel(v.channel)
|
|
if not channel then
|
|
log("ERROR","Unable to retrieve timer channel: "..tostring(v.channel))
|
|
return
|
|
end
|
|
local msg = channel:getMessage(v.id)
|
|
if not msg then
|
|
log("ERROR","Unable to retrieve timer message: "..tostring(v.id))
|
|
return
|
|
end
|
|
command_handler:handle(fake_message(msg,{
|
|
delete = function() end,
|
|
content = command
|
|
}))
|
|
end
|
|
|
|
if not config.events then
|
|
config.events = {
|
|
timer = {},
|
|
event = {message = {}}
|
|
}
|
|
end
|
|
|
|
local create_event = function(msg,cronjob,create_entry)
|
|
local arg = cronjob
|
|
local func,functype = cron.parse_line(arg)
|
|
if not func then
|
|
msg:reply(functype)
|
|
return false
|
|
end
|
|
local hash = md5.sumhexa(arg):sub(1,16)
|
|
if functype == "directive" then
|
|
local event_name = arg:match("^@(%w+)")
|
|
if not events.event[event_name] then events.event[event_name] = {} end
|
|
events.event[event_name][hash] = {
|
|
comm = func,
|
|
channel = tostring(msg.channel.id),
|
|
id = tostring(msg.id),
|
|
user = tostring(msg.author.id),
|
|
type = functype
|
|
}
|
|
if create_entry then return true end
|
|
if not config.events.event[event_name] then config.events.event[event_name] = {} end
|
|
config.events.event[event_name][hash] = {
|
|
comm = arg,
|
|
channel = tostring(msg.channel.id),
|
|
id = tostring(msg.id),
|
|
user = tostring(msg.author.id),
|
|
type = functype
|
|
}
|
|
else
|
|
events.timer[hash] = {
|
|
comm = func,
|
|
channel = tostring(msg.channel.id),
|
|
id = tostring(msg.id),
|
|
user = tostring(msg.author.id),
|
|
type = functype
|
|
}
|
|
if create_entry then return true end
|
|
config.events.timer[hash] = {
|
|
comm = arg,
|
|
channel = tostring(msg.channel.id),
|
|
id = tostring(msg.id),
|
|
user = tostring(msg.author.id),
|
|
type = functype
|
|
}
|
|
end
|
|
return true
|
|
end
|
|
|
|
-- load timer events
|
|
for k,v in pairs(config.events.timer) do
|
|
local channel = client:getChannel(v.channel)
|
|
if channel then
|
|
local message = channel:getMessage(v.id)
|
|
if message then
|
|
create_event(message,v.comm,true)
|
|
else
|
|
log("ERROR","No message with id "..v.id)
|
|
end
|
|
else
|
|
log("ERROR","No channel with id "..v.channel)
|
|
end
|
|
end
|
|
|
|
-- load named events
|
|
for _,evtype in pairs(config.events.event) do
|
|
events.event[_] = {}
|
|
for k,v in pairs(evtype) do
|
|
local channel = client:getChannel(v.channel)
|
|
if channel then
|
|
local message = channel:getMessage(v.id)
|
|
if message then
|
|
create_event(message,v.comm,true)
|
|
else
|
|
log("ERROR","No message with id "..v.id)
|
|
end
|
|
else
|
|
log("ERROR","No channel with id "..v.channel)
|
|
end
|
|
end
|
|
end
|
|
|
|
local event = command("event",{
|
|
help = {embed={
|
|
title = "Add a cron event",
|
|
description = "Description coming soon",
|
|
fields = {
|
|
{name = "Usage:",value = "event ..."},
|
|
{name = "Perms:",value = "administrator"},
|
|
}
|
|
}},
|
|
perms = {
|
|
"administrator"
|
|
},
|
|
exec = function(msg,args,opts)
|
|
return create_event(msg,table.concat(args," "))
|
|
end
|
|
})
|
|
plugin:add_command(event)
|
|
|
|
local delay = command("delay",{
|
|
help = {embed={
|
|
title = "Delay a command",
|
|
description = "Delay fromat is <number><unit>, where unit is one of the follwing:\n\"h\" - hour,\n\"m\" - minute,\n\"d\" - day,\n\"w\" - week,\n\"y\" - year",
|
|
fields = {
|
|
{name = "Usage:",value = "delay <delayformat> <command>"},
|
|
{name = "Perms:",value = "any"},
|
|
}
|
|
}},
|
|
exec = function(msg,args,opts)
|
|
local format = args[1]
|
|
table.remove(args,1)
|
|
local arg = os.date("%d.%m.%y %H:%M ",cron.convert_delay(format))..table.concat(args," ")
|
|
return create_event(msg,arg)
|
|
end
|
|
})
|
|
plugin:add_command(delay)
|
|
|
|
local events_comm = command("events",{
|
|
help = {embed={
|
|
title = "View your running events",
|
|
description = "nuff said.",
|
|
fields = {
|
|
{name = "Usage:",value = "events <page>"},
|
|
{name = "Perms:",value = "any"},
|
|
}
|
|
}},
|
|
args = {
|
|
"number"
|
|
},
|
|
exec = function(msg,args,opts)
|
|
local uevents = {}
|
|
local uhashes = {}
|
|
local upto = 5*args[1]
|
|
for k,v in pairs(config.events.timer) do
|
|
if v.user == tostring(msg.author.id) then
|
|
table.insert(uevents,v)
|
|
table.insert(uhashes,k)
|
|
end
|
|
if #events == upto then
|
|
break
|
|
end
|
|
end
|
|
local stop = false
|
|
for _,evtype in pairs(config.events.event) do
|
|
for k,v in pairs(evtype) do
|
|
if v.user == tostring(msg.author.id) then
|
|
table.insert(uevents,v)
|
|
table.insert(uhashes,k)
|
|
end
|
|
if #events == upto then
|
|
stop = true
|
|
break
|
|
end
|
|
end
|
|
if stop then
|
|
break
|
|
end
|
|
end
|
|
local message = {embed = {
|
|
title = "Your events: ",
|
|
description = "",
|
|
footer = {
|
|
text = "Events "..tostring(upto-4).." - "..tostring(upto)
|
|
}
|
|
}}
|
|
for I = upto-4,upto do
|
|
if not uhashes[I] then
|
|
break
|
|
end
|
|
message.embed.description = message.embed.description.."["..uhashes[I].."] `"..uevents[I].comm.."`\n"
|
|
end
|
|
msg:reply(message)
|
|
end
|
|
})
|
|
plugin:add_command(events_comm)
|
|
|
|
local remove_event= command("remove-event",{
|
|
help = {embed={
|
|
title = "Remove an event",
|
|
description = "nuff said.",
|
|
fields = {
|
|
{name = "Usage:",value = "remove-event <id>"},
|
|
{name = "Perms:",value = "any"},
|
|
}
|
|
}},
|
|
args = {
|
|
"string"
|
|
},
|
|
exec = function(msg,args,opts)
|
|
for k,v in pairs(config.events.timer) do
|
|
if (k == args[1]) and (v.user == tostring(msg.author.id)) then
|
|
config.events.timer[k] = nil
|
|
events.timer[k] = nil
|
|
return true
|
|
end
|
|
end
|
|
for evname,evtype in pairs(config.events.event) do
|
|
for k,v in pairs(evtype) do
|
|
if (k == args[1]) and (v.user == tostring(msg.author.id)) then
|
|
config.events.event[evname][k] = nil
|
|
events.event[evname][k] = nil
|
|
return true
|
|
end
|
|
end
|
|
end
|
|
msg:reply("Not found")
|
|
return false
|
|
end
|
|
})
|
|
plugin:add_command(remove_event)
|
|
|
|
local timer = discordia.Clock()
|
|
timer:on("min",function()
|
|
for k,v in pairs(events.timer) do
|
|
local status,command = v.comm(os.date("*t"))
|
|
if status then
|
|
exec(v,command)
|
|
if v.type == "onetime" then
|
|
events.timer[k] = nil
|
|
config.events.timer[k] = nil
|
|
end
|
|
end
|
|
end
|
|
end)
|
|
|
|
client:on("messageCreate",function(msg)
|
|
if (not msg.guild) or (tostring(msg.guild.id) ~= tostring(id)) then
|
|
return
|
|
end
|
|
local content = msg.content
|
|
local user = msg.author.id
|
|
local channelid = msg.channel.id
|
|
for k,v in pairs(events.event.message or {}) do
|
|
local status,command = v.comm({content,user,channelid})
|
|
if status then
|
|
exec(v,command)
|
|
end
|
|
end
|
|
for k,v in pairs(events.event.messageOnce or {}) do
|
|
local status,command = v.comm({content,user,channelid})
|
|
events.event.messageOnce[k] = nil
|
|
config.events.event.messageOnce[k] = nil
|
|
end
|
|
end)
|
|
|
|
timer:start(true)
|
|
return plugin
|