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 +15 -20
2 changed files with 15 additions and 20 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files
Showing only changes of commit 5c4904ba56 - Show all commits

23
core/bot.py
View File

@ -640,23 +640,30 @@ class IRCBot(IRCClient):
if reset: if reset:
self._negativePass = None self._negativePass = None
debug(
(f"regProc() {self.net} - {self.num}: _negativePass:{self._negativepass} " f"negativepass:{negativepass}")
)
if self._negativePass is None: if self._negativePass is None:
# We have failed, the blacklisted message has been found # We have failed, the blacklisted message has been found
if negativepass is False: if negativepass is False:
self._negativePass = False self._negativePass = False
debug(f"regPing() {self.net}: negativepass is False for {self.num}") debug(
(
f"registerTest() {self.net} - {self.num} not passed negative:checknegativemsg "
f"check, {sinst['checknegativemsg']} present in message"
)
)
return return
# End of negative output reached with no blacklisted message # End of negative output reached with no blacklisted message
elif negativepass is True: elif negativepass is True:
if self._negativePass is None: # check if it's not failed yet if self._negativePass is None: # check if it's not failed yet
self._negativePass = True self._negativePass = True
debug(f"regPing() {self.net}: negpass:True positive registration check - {self.num}") debug(
# if sinst["ping"]: (
# debug("Sending ping - %s - %i" % (self.net, self.num)) f"registerTest() {self.net} - {self.num} passed negative:checkendnegative "
# self.msg(sinst["entity"], sinst["pingmsg"]) f"check, {sinst['checkendnegative']} present in message"
# debug(f"regPing() {self.net}: sent ping '{sinst['pingmsg']}' )
# to {sinst['entity']} - {self.num}") )
# return
else: else:
debug(f"regPing() {self.net}: negative registration check - {self.num}") debug(f"regPing() {self.net}: negative registration check - {self.num}")
return return

12
modules/regproc.py
View File

@ -190,23 +190,11 @@ def registerTest(c):
confirmRegistration( confirmRegistration(
c["net"], c["num"], negativepass=False c["net"], c["num"], negativepass=False
) # Not passed negative check, report back ) # Not passed negative check, report back
debug(
(
f"registerTest() {net} - {num} not passed negative:checknegativemsg "
f"check, {sinst['checknegativemsg']} present in message"
)
)
return return
if sinst["checkendnegative"] in c["msg"]: if sinst["checkendnegative"] in c["msg"]:
confirmRegistration( confirmRegistration(
c["net"], c["num"], negativepass=True c["net"], c["num"], negativepass=True
) # Passed the negative check, report back ) # Passed the negative check, report back
debug(
(
f"registerTest() {net} - {num} passed negative:checkendnegative "
f"check, {sinst['checkendnegative']} present in message"
)
)
return return
if sinst["ping"]: if sinst["ping"]:
if sinst["checkmsg2"] in c["msg"] and c["nick"] == sinst["entity"]: if sinst["checkmsg2"] in c["msg"] and c["nick"] == sinst["entity"]: