Pathogen
/
monolith
2
0
Fork 0
Code Issues Pull Requests Projects Releases Wiki Activity

Implement indexing into Apache Druid #1

Closed
m wants to merge 263 commits from druid into master
pull from: druid
merge into: Pathogen:master
Conversation 1 Commits 263 Files Changed 128 +6 -4
2 changed files with 6 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files
Showing only changes of commit fc3a349cb3 - Show all commits

8
modules/regproc.py
View File

@ -42,7 +42,7 @@ def substitute(net, num, token=None):
def registerAccount(net, num): def registerAccount(net, num):
debug("Attempting to register: %s - %i" % (net, num)) debug("Attempting to register: %s - %i" % (net, num))
sinst = substitute(net, num) sinst = substitute(net, num)
if not inst["register"]: if not sinst["register"]:
error("Cannot register for %s: function disabled" % (net)) error("Cannot register for %s: function disabled" % (net))
return False return False
name = net+str(num) name = net+str(num)
@ -68,7 +68,10 @@ def confirmRegistration(net, num, negativepass=None):
return return
if name in main.IRCPool.keys(): if name in main.IRCPool.keys():
if main.IRCPool[name]._regAttempt: if main.IRCPool[name]._regAttempt:
main.IRCPool[name]._regAttempt.cancel() try:
main.IRCPool[name]._regAttempt.cancel()
except:
pass
obj.relays[num]["registered"] = True obj.relays[num]["registered"] = True
main.saveConf("network") main.saveConf("network")
@ -102,7 +105,6 @@ def registerTest(c):
return return
if inst["ping"]: if inst["ping"]:
if inst["checkmsg2"] in c["msg"] and c["nick"] == inst["entity"]: if inst["checkmsg2"] in c["msg"] and c["nick"] == inst["entity"]:
print("CHECKMSG2 SUCCEEDED", c["num"])
confirmRegistration(c["net"], c["num"]) confirmRegistration(c["net"], c["num"])
return return
if inst["checktype"] == "msg": if inst["checktype"] == "msg":