jyapayne/Nim
1
0
Fork 0
Code Issues Pull requests Projects Releases Packages Wiki Activity Actions

Added a timeout parameter to irc.reconnect.

Browse source
This commit is contained in:
Dominik Picheta 2013-01-21 14:44:23 +00:00
commit ddc8913ebb
1 changed files with 18 additions and 3 deletions
Download patch file Download diff file Expand all files Collapse all files

21
lib/pure/irc.nim
View file

@ -32,7 +32,7 @@
## **Warning:** The API of this module is unstable, and therefore is subject ## **Warning:** The API of this module is unstable, and therefore is subject
## to change. ## to change.
import sockets, strutils, parseutils, times, asyncio import sockets, strutils, parseutils, times, asyncio, os
type type
TIRC* = object of TObject TIRC* = object of TObject
@ -56,6 +56,7 @@ type
channelsToJoin: seq[string] channelsToJoin: seq[string]
msgLimit: bool msgLimit: bool
messageBuffer: seq[tuple[timeToSend: float, m: string]] messageBuffer: seq[tuple[timeToSend: float, m: string]]
lastReconnect: float
PIRC* = ref TIRC PIRC* = ref TIRC
@ -235,12 +236,19 @@ proc connect*(irc: PIRC) =
irc.send("NICK " & irc.nick, true) irc.send("NICK " & irc.nick, true)
irc.send("USER $1 * 0 :$2" % [irc.user, irc.realname], true) irc.send("USER $1 * 0 :$2" % [irc.user, irc.realname], true)
proc reconnect*(irc: PIRC) = proc reconnect*(irc: PIRC, timeout = 5000) =
## Reconnects to an IRC server. ## Reconnects to an IRC server.
## ##
## ``Timeout`` specifies the time to wait in miliseconds between multiple
## consecutive reconnections.
##
## This should be used when an ``EvDisconnected`` event occurs. ## This should be used when an ``EvDisconnected`` event occurs.
let secSinceReconnect = int(epochTime() - irc.lastReconnect)
if secSinceReconnect < timeout:
sleep(timeout - secSinceReconnect)
irc.sock = socket() irc.sock = socket()
irc.connect() irc.connect()
irc.lastReconnect = epochTime()
proc irc*(address: string, port: TPort = 6667.TPort, proc irc*(address: string, port: TPort = 6667.TPort,
nick = "NimrodBot", nick = "NimrodBot",
@ -409,15 +417,22 @@ proc connect*(irc: PAsyncIRC) =
irc.asyncSock.connect(irc.address, irc.port) irc.asyncSock.connect(irc.address, irc.port)
proc reconnect*(irc: PAsyncIRC) = proc reconnect*(irc: PAsyncIRC, timeout = 5000) =
## Reconnects to an IRC server. ## Reconnects to an IRC server.
## ##
## ``Timeout`` specifies the time to wait in miliseconds between multiple
## consecutive reconnections.
##
## This should be used when an ``EvDisconnected`` event occurs. ## This should be used when an ``EvDisconnected`` event occurs.
## ##
## When successfully reconnected an ``EvConnected`` event will occur. ## When successfully reconnected an ``EvConnected`` event will occur.
let secSinceReconnect = int(epochTime() - irc.lastReconnect)
if secSinceReconnect < timeout:
sleep(timeout - secSinceReconnect)
irc.asyncSock = AsyncSocket() irc.asyncSock = AsyncSocket()
irc.myDispatcher.register(irc) irc.myDispatcher.register(irc)
irc.connect() irc.connect()
irc.lastReconnect = epochTime()
proc asyncIRC*(address: string, port: TPort = 6667.TPort, proc asyncIRC*(address: string, port: TPort = 6667.TPort,
nick = "NimrodBot", nick = "NimrodBot",