mirror of
https://github.com/ShadowNinja/LuaIRC.git
synced 2025-07-20 16:40:26 +02:00
Compare commits
1 Commits
Author | SHA1 | Date | |
---|---|---|---|
1bd7833f18 |
@ -21,8 +21,6 @@ function meta:send(msg, ...)
|
|||||||
end
|
end
|
||||||
end
|
end
|
||||||
|
|
||||||
meta.queue = meta.send
|
|
||||||
|
|
||||||
local function verify(str, errLevel)
|
local function verify(str, errLevel)
|
||||||
if str:find("^:") or str:find("%s%z") then
|
if str:find("^:") or str:find("%s%z") then
|
||||||
error(("malformed parameter '%s' to irc command"):format(str), errLevel)
|
error(("malformed parameter '%s' to irc command"):format(str), errLevel)
|
||||||
@ -34,28 +32,28 @@ end
|
|||||||
function meta:sendChat(target, msg)
|
function meta:sendChat(target, msg)
|
||||||
-- Split the message into segments if it includes newlines.
|
-- Split the message into segments if it includes newlines.
|
||||||
for line in msg:gmatch("([^\r\n]+)") do
|
for line in msg:gmatch("([^\r\n]+)") do
|
||||||
self:queue("PRIVMSG %s :%s", verify(target, 3), line)
|
self:send("PRIVMSG %s :%s", verify(target, 3), line)
|
||||||
end
|
end
|
||||||
end
|
end
|
||||||
|
|
||||||
function meta:sendNotice(target, msg)
|
function meta:sendNotice(target, msg)
|
||||||
-- Split the message into segments if it includes newlines.
|
-- Split the message into segments if it includes newlines.
|
||||||
for line in msg:gmatch("([^\r\n]+)") do
|
for line in msg:gmatch("([^\r\n]+)") do
|
||||||
self:queue("NOTICE %s :%s", verify(target, 3), line)
|
self:send("NOTICE %s :%s", verify(target, 3), line)
|
||||||
end
|
end
|
||||||
end
|
end
|
||||||
|
|
||||||
function meta:join(channel, key)
|
function meta:join(channel, key)
|
||||||
if key then
|
if key then
|
||||||
self:queue("JOIN %s :%s", verify(channel, 3), verify(key, 3))
|
self:send("JOIN %s :%s", verify(channel, 3), verify(key, 3))
|
||||||
else
|
else
|
||||||
self:queue("JOIN %s", verify(channel, 3))
|
self:send("JOIN %s", verify(channel, 3))
|
||||||
end
|
end
|
||||||
end
|
end
|
||||||
|
|
||||||
function meta:part(channel)
|
function meta:part(channel)
|
||||||
channel = verify(channel, 3)
|
channel = verify(channel, 3)
|
||||||
self:queue("PART %s", channel)
|
self:send("PART %s", channel)
|
||||||
if self.track_users then
|
if self.track_users then
|
||||||
self.channels[channel] = nil
|
self.channels[channel] = nil
|
||||||
end
|
end
|
||||||
@ -85,5 +83,5 @@ function meta:setMode(t)
|
|||||||
mode = table.concat{mode, "-", verify(rem, 3)}
|
mode = table.concat{mode, "-", verify(rem, 3)}
|
||||||
end
|
end
|
||||||
|
|
||||||
self:queue("MODE %s %s", verify(target, 3), mode)
|
self:send("MODE %s %s", verify(target, 3), mode)
|
||||||
end
|
end
|
||||||
|
@ -159,12 +159,3 @@ function irc:shutdown()
|
|||||||
-- Apart from <code>nick</code>, fields may be missing. To fill them in, enable user tracking and use irc:whois.
|
-- Apart from <code>nick</code>, fields may be missing. To fill them in, enable user tracking and use irc:whois.
|
||||||
-- @name User
|
-- @name User
|
||||||
-- @class table
|
-- @class table
|
||||||
|
|
||||||
-- If you need a simple queue you can enable one by requiring "irc.queue".
|
|
||||||
-- Doind so will add the following features:
|
|
||||||
|
|
||||||
--- Queue a raw line of IRC to be sent to the server as soon as possible.
|
|
||||||
-- @param msg Line to be sent, excluding newline characters.
|
|
||||||
-- @param ... Format parameters for <code>msg</code>, with <code>string.format</code> semantics. [optional]
|
|
||||||
function irc:queue(msg, ...)
|
|
||||||
|
|
||||||
|
20
handlers.lua
20
handlers.lua
@ -8,7 +8,7 @@ module "irc"
|
|||||||
handlers = {}
|
handlers = {}
|
||||||
|
|
||||||
handlers["PING"] = function(o, prefix, query)
|
handlers["PING"] = function(o, prefix, query)
|
||||||
o:queue("PONG :%s", query)
|
o:send("PONG :%s", query)
|
||||||
end
|
end
|
||||||
|
|
||||||
handlers["001"] = function(o, prefix, me)
|
handlers["001"] = function(o, prefix, me)
|
||||||
@ -81,7 +81,7 @@ end
|
|||||||
|
|
||||||
local function needNewNick(o, prefix, target, badnick)
|
local function needNewNick(o, prefix, target, badnick)
|
||||||
local newnick = o.nickGenerator(badnick)
|
local newnick = o.nickGenerator(badnick)
|
||||||
o:queue("NICK %s", newnick)
|
o:send("NICK %s", newnick)
|
||||||
end
|
end
|
||||||
|
|
||||||
-- ERR_ERRONEUSNICKNAME (Misspelt but remains for historical reasons)
|
-- ERR_ERRONEUSNICKNAME (Misspelt but remains for historical reasons)
|
||||||
@ -90,6 +90,22 @@ handlers["432"] = needNewNick
|
|||||||
-- ERR_NICKNAMEINUSE
|
-- ERR_NICKNAMEINUSE
|
||||||
handlers["433"] = needNewNick
|
handlers["433"] = needNewNick
|
||||||
|
|
||||||
|
-- RPL_ISUPPORT
|
||||||
|
handlers["005"] = function(o, prefix, nick, ...)
|
||||||
|
local list = {...}
|
||||||
|
local listlen = #list
|
||||||
|
-- Skip last parameter (info)
|
||||||
|
for i = 1, listlen - 1 do
|
||||||
|
local item = list[i]
|
||||||
|
local pos = item:find("=")
|
||||||
|
if pos then
|
||||||
|
o.supports[item:sub(1, pos - 1)] = item:sub(pos + 1)
|
||||||
|
else
|
||||||
|
o.supports[item] = true
|
||||||
|
end
|
||||||
|
end
|
||||||
|
end
|
||||||
|
|
||||||
--NAMES list
|
--NAMES list
|
||||||
handlers["353"] = function(o, prefix, me, chanType, channel, names)
|
handlers["353"] = function(o, prefix, me, chanType, channel, names)
|
||||||
if o.track_users then
|
if o.track_users then
|
||||||
|
13
init.lua
13
init.lua
@ -39,6 +39,7 @@ function new(data)
|
|||||||
nickGenerator = data.nickGenerator or defaultNickGenerator;
|
nickGenerator = data.nickGenerator or defaultNickGenerator;
|
||||||
hooks = {};
|
hooks = {};
|
||||||
track_users = true;
|
track_users = true;
|
||||||
|
supports = {};
|
||||||
}
|
}
|
||||||
assert(checkNick(o.nick), "Erroneous nickname passed to irc.new")
|
assert(checkNick(o.nick), "Erroneous nickname passed to irc.new")
|
||||||
return setmetatable(o, meta_preconnect)
|
return setmetatable(o, meta_preconnect)
|
||||||
@ -119,17 +120,17 @@ function meta_preconnect:connect(_host, _port)
|
|||||||
self.socket = s
|
self.socket = s
|
||||||
setmetatable(self, meta)
|
setmetatable(self, meta)
|
||||||
|
|
||||||
self:queue("CAP REQ multi-prefix")
|
self:send("CAP REQ multi-prefix")
|
||||||
|
|
||||||
self:invoke("PreRegister", self)
|
self:invoke("PreRegister", self)
|
||||||
self:queue("CAP END")
|
self:send("CAP END")
|
||||||
|
|
||||||
if password then
|
if password then
|
||||||
self:queue("PASS %s", password)
|
self:send("PASS %s", password)
|
||||||
end
|
end
|
||||||
|
|
||||||
self:queue("NICK %s", self.nick)
|
self:send("NICK %s", self.nick)
|
||||||
self:queue("USER %s 0 * :%s", self.username, self.realname)
|
self:send("USER %s 0 * :%s", self.username, self.realname)
|
||||||
|
|
||||||
self.channels = {}
|
self.channels = {}
|
||||||
|
|
||||||
@ -227,6 +228,6 @@ function meta:whois(nick)
|
|||||||
end
|
end
|
||||||
|
|
||||||
function meta:topic(channel)
|
function meta:topic(channel)
|
||||||
self:queue("TOPIC %s", channel)
|
self:send("TOPIC %s", channel)
|
||||||
end
|
end
|
||||||
|
|
||||||
|
45
queue.lua
45
queue.lua
@ -1,45 +0,0 @@
|
|||||||
local getmetatable = getmetatable
|
|
||||||
local clock = os.clock
|
|
||||||
local remove = table.remove
|
|
||||||
local insert = table.insert
|
|
||||||
local select = select
|
|
||||||
|
|
||||||
module "irc"
|
|
||||||
|
|
||||||
local meta = _META
|
|
||||||
|
|
||||||
local old_new = new
|
|
||||||
function new(...)
|
|
||||||
local o = old_new(...)
|
|
||||||
o.messageQueue = {}
|
|
||||||
o.lastThought = 0
|
|
||||||
o.recentMessages = 0
|
|
||||||
return o
|
|
||||||
end
|
|
||||||
|
|
||||||
local old_think = meta.think
|
|
||||||
function meta:think(...)
|
|
||||||
old_think(self, ...) -- Call old meta:think
|
|
||||||
|
|
||||||
-- Handle outgoing message queue
|
|
||||||
self.recentMessages = self.recentMessages - ((clock() - self.lastThought) * 8000)
|
|
||||||
if self.recentMessages < 0 then
|
|
||||||
self.recentMessages = 0
|
|
||||||
end
|
|
||||||
for i = 1, #self.messageQueue do
|
|
||||||
if self.recentMessages > 4 then
|
|
||||||
break
|
|
||||||
end
|
|
||||||
self:send(remove(self.messageQueue, 1))
|
|
||||||
self.recentMessages = self.recentMessages + 1
|
|
||||||
end
|
|
||||||
self.lastThought = clock()
|
|
||||||
end
|
|
||||||
|
|
||||||
function meta:queue(msg, ...)
|
|
||||||
if select("#", ...) > 0 then
|
|
||||||
msg = msg:format(...)
|
|
||||||
end
|
|
||||||
insert(self.messageQueue, msg)
|
|
||||||
end
|
|
||||||
|
|
Reference in New Issue
Block a user