forked from JakobOvrum/LuaIRC
-
Notifications
You must be signed in to change notification settings - Fork 2
Commit
This commit does not belong to any branch on this repository, and may belong to a fork outside of the repository.
- Loading branch information
1 parent
3308471
commit b1382c9
Showing
7 changed files
with
318 additions
and
350 deletions.
There are no files selected for viewing
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -1,255 +1,9 @@ | ||
| local socket = require "socket" | ||
|
|
||
| local error = error | ||
| local setmetatable = setmetatable | ||
| local rawget = rawget | ||
| local unpack = unpack | ||
| local pairs = pairs | ||
| local assert = assert | ||
| local require = require | ||
| local tonumber = tonumber | ||
| local type = type | ||
| local pcall = pcall | ||
| local remove = table.remove | ||
| local irc = require("irc.main") | ||
| require("irc.util") | ||
| require("irc.asyncoperations") | ||
| require("irc.handlers") | ||
| require("irc.messages") | ||
|
|
||
| module "irc" | ||
|
|
||
| local meta = {} | ||
| meta.__index = meta | ||
| _META = meta | ||
|
|
||
| require "irc.util" | ||
| require "irc.asyncoperations" | ||
| require "irc.handlers" | ||
| require "irc.messages" | ||
|
|
||
| local meta_preconnect = {} | ||
| function meta_preconnect.__index(o, k) | ||
| local v = rawget(meta_preconnect, k) | ||
|
|
||
| if not v and meta[k] then | ||
| error(("field '%s' is not accessible before connecting"):format(k), 2) | ||
| end | ||
| return v | ||
| end | ||
|
|
||
| function new(data) | ||
| local o = { | ||
| nick = assert(data.nick, "Field 'nick' is required"); | ||
| username = data.username or "lua"; | ||
| realname = data.realname or "Lua owns"; | ||
| nickGenerator = data.nickGenerator or defaultNickGenerator; | ||
| hooks = {}; | ||
| track_users = true; | ||
| supports = {}; | ||
| messageQueue = {}; | ||
| lastThought = 0; | ||
| recentMessages = 0; | ||
| } | ||
| assert(checkNick(o.nick), "Erroneous nickname passed to irc.new") | ||
| return setmetatable(o, meta_preconnect) | ||
| end | ||
|
|
||
| function meta:hook(name, id, f) | ||
| f = f or id | ||
| self.hooks[name] = self.hooks[name] or {} | ||
| self.hooks[name][id] = f | ||
| return id or f | ||
| end | ||
| meta_preconnect.hook = meta.hook | ||
|
|
||
|
|
||
| function meta:unhook(name, id) | ||
| local hooks = self.hooks[name] | ||
|
|
||
| assert(hooks, "no hooks exist for this event") | ||
| assert(hooks[id], "hook ID not found") | ||
|
|
||
| hooks[id] = nil | ||
| end | ||
| meta_preconnect.unhook = meta.unhook | ||
|
|
||
| function meta:invoke(name, ...) | ||
| local hooks = self.hooks[name] | ||
| if hooks then | ||
| for id, f in pairs(hooks) do | ||
| if f(...) then | ||
| return true | ||
| end | ||
| end | ||
| end | ||
| end | ||
|
|
||
| function meta_preconnect:connect(_host, _port) | ||
| local host, port, password, secure, timeout | ||
|
|
||
| if type(_host) == "table" then | ||
| host = _host.host | ||
| port = _host.port | ||
| timeout = _host.timeout | ||
| password = _host.password | ||
| secure = _host.secure | ||
| else | ||
| host = _host | ||
| port = _port | ||
| end | ||
|
|
||
| host = host or error("host name required to connect", 2) | ||
| port = port or 6667 | ||
|
|
||
| local s = socket.tcp() | ||
|
|
||
| s:settimeout(timeout or 30) | ||
| assert(s:connect(host, port)) | ||
|
|
||
| if secure then | ||
| local work, ssl = pcall(require, "ssl") | ||
| if not work then | ||
| error("LuaSec required for secure connections", 2) | ||
| end | ||
|
|
||
| local params | ||
| if type(secure) == "table" then | ||
| params = secure | ||
| else | ||
| params = {mode = "client", protocol = "tlsv1"} | ||
| end | ||
|
|
||
| s = ssl.wrap(s, params) | ||
| success, errmsg = s:dohandshake() | ||
| if not success then | ||
| error(("could not make secure connection: %s"):format(errmsg), 2) | ||
| end | ||
| end | ||
|
|
||
| self.socket = s | ||
| setmetatable(self, meta) | ||
|
|
||
| self:queue(Message({command="CAP", args={"REQ", "multi-prefix"}})) | ||
|
|
||
| self:invoke("PreRegister", self) | ||
| self:queue(Message({command="CAP", args={"END"}})) | ||
|
|
||
| if password then | ||
| self:queue(Message({command="PASS", args={password}})) | ||
| end | ||
|
|
||
| self:queue(msgs.nick(self.nick)) | ||
| self:queue(Message({command="USER", args={self.username, "0", "*", self.realname}})) | ||
|
|
||
| self.channels = {} | ||
|
|
||
| s:settimeout(0) | ||
|
|
||
| repeat | ||
| self:think() | ||
| socket.sleep(0.1) | ||
| until self.authed | ||
| end | ||
|
|
||
| function meta:disconnect(message) | ||
| message = message or "Bye!" | ||
|
|
||
| self:invoke("OnDisconnect", message, false) | ||
| self:send(msgs.quit(message)) | ||
|
|
||
| self:shutdown() | ||
| end | ||
|
|
||
| function meta:shutdown() | ||
| self.socket:close() | ||
| setmetatable(self, nil) | ||
| end | ||
|
|
||
| local function getline(self, errlevel) | ||
| local line, err = self.socket:receive("*l") | ||
|
|
||
| if not line and err ~= "timeout" and err ~= "wantread" then | ||
| self:invoke("OnDisconnect", err, true) | ||
| self:shutdown() | ||
| error(err, errlevel) | ||
| end | ||
|
|
||
| return line | ||
| end | ||
|
|
||
| function meta:think() | ||
| while true do | ||
| local line = getline(self, 3) | ||
| if line and #line > 0 then | ||
| if not self:invoke("OnRaw", line) then | ||
| self:handle(Message({raw=line})) | ||
| end | ||
| else | ||
| break | ||
| end | ||
| end | ||
|
|
||
| -- Handle outgoing message queue | ||
| local diff = socket.gettime() - self.lastThought | ||
| self.recentMessages = self.recentMessages - (diff * 2) | ||
| 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 = socket.gettime() | ||
| end | ||
|
|
||
| local handlers = handlers | ||
|
|
||
| function meta:handle(msg) | ||
| local handler = handlers[msg.command] | ||
| if handler then | ||
| handler(self, msg) | ||
| end | ||
| self:invoke("Do"..capitalize(msg.command), msg) | ||
| end | ||
|
|
||
| local whoisHandlers = { | ||
| ["311"] = "userinfo"; | ||
| ["312"] = "node"; | ||
| ["319"] = "channels"; | ||
| ["330"] = "account"; -- Freenode | ||
| ["307"] = "registered"; -- Unreal | ||
| } | ||
|
|
||
| function meta:whois(nick) | ||
| self:send(msgs.whois(nick)) | ||
|
|
||
| local result = {} | ||
|
|
||
| while true do | ||
| local line = getline(self, 3) | ||
| if line then | ||
| local msg = Message({raw=line}) | ||
|
|
||
| local handler = whoisHandlers[msg.command] | ||
| if handler then | ||
| result[handler] = msg.args | ||
| elseif cmd == "318" then | ||
| break | ||
| else | ||
| self:handle(msg) | ||
| end | ||
| end | ||
| end | ||
|
|
||
| if result.account then | ||
| result.account = result.account[3] | ||
| elseif result.registered then | ||
| result.account = result.registered[2] | ||
| end | ||
|
|
||
| return result | ||
| end | ||
|
|
||
| function meta:topic(channel) | ||
| self:queue(msgs.topic(channel)) | ||
| end | ||
| return irc | ||
|
|
Oops, something went wrong.