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

1
conf/templates/config.json
View File

@ -57,6 +57,7 @@
"Prefix": "*" "Prefix": "*"
}, },
"Delays": { "Delays": {
"WhoDelay": 3600,
"WhoLoop": 600, "WhoLoop": 600,
"WhoRange": 1800, "WhoRange": 1800,
"Timeout": 30, "Timeout": 30,

22
core/bot.py
View File

@ -690,17 +690,27 @@ class IRCBot(IRCClient):
if not self.authenticated: if not self.authenticated:
reactor.callLater(10, self.regPing) reactor.callLater(10, self.regPing)
def setup_who_loop(self, channel):
# if main.config["Toggles"]["Who"]:
lc = LoopingCall(self.who, channel)
self._getWho[channel] = lc
intrange = main.config["Tweaks"]["Delays"]["WhoRange"]
minint = main.config["Tweaks"]["Delays"]["WhoLoop"]
interval = randint(minint, minint + intrange)
lc.start(interval)
def joined(self, channel): def joined(self, channel):
if channel not in self.channels: if channel not in self.channels:
self.channels.append(channel) self.channels.append(channel)
self.names(channel).addCallback(self.got_names) self.names(channel).addCallback(self.got_names)
if main.config["Toggles"]["Who"]: if main.config["Toggles"]["Who"]:
lc = LoopingCall(self.who, channel) reactor.callLater(main.config["Tweaks"]["Delays"]["WhoDelay"], self.setup_who_loop, channel)
self._getWho[channel] = lc # lc = LoopingCall(self.who, channel)
intrange = main.config["Tweaks"]["Delays"]["WhoRange"] # self._getWho[channel] = lc
minint = main.config["Tweaks"]["Delays"]["WhoLoop"] # intrange = main.config["Tweaks"]["Delays"]["WhoRange"]
interval = randint(minint, minint + intrange) # minint = main.config["Tweaks"]["Delays"]["WhoLoop"]
lc.start(interval) # interval = randint(minint, minint + intrange)
# lc.start(interval)
def botLeft(self, channel): def botLeft(self, channel):
if channel in self.channels: if channel in self.channels: