JPT
/
ftpbot
0
0
Fork 0
Code Issues Pull Requests Activity

[TASK] Implement delay for notification messages.

This commit is contained in:
Jan Philipp Timme 2014-05-15 17:41:06 +02:00
parent 9a0b7b9e65
commit a1da54494b
1 changed files with 14 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

16
twisted/plugins/monitorbot_plugin.py
View File

@ -22,6 +22,8 @@ class MonitorBotService(Service):
self._nickname = nickname self._nickname = nickname
self._realname = realname self._realname = realname
self._watch_path = filepath.FilePath(path) self._watch_path = filepath.FilePath(path)
self._messages = []
self.callid = None
def startService(self): def startService(self):
"""Construct a client & connect to server.""" """Construct a client & connect to server."""
@ -58,11 +60,21 @@ class MonitorBotService(Service):
return s return s
def fsnotify(ignored, filepath, mask): def fsnotify(ignored, filepath, mask):
if self._callid != None:
self._callid.cancel()
path_segments = filepath.segmentsFrom(self._watch_path) path_segments = filepath.segmentsFrom(self._watch_path)
new_path = '/'.join(path_segments) new_path = '/'.join(path_segments)
msg = "ftp> /%s (%s)" % (new_path, ', '.join(humanReadableMask(mask))) msg = "ftp> /%s (%s)" % (new_path, ', '.join(humanReadableMask(mask)))
self._bot.msg(self._channel, msg) self._messages.append(msg)
pass self._callid = reactor.callLater(5.0, sendQueuedMessages)
def sendQueuedMessages():
if len(self._messages) > 3:
self._bot.msg(self._channel, "ftp> %i Aktionen durchgeführt. Letzte Nachricht:" % len(self._messages))
self._bot.msg(self._channel, self._messages[len(self._messages)-1])
else:
for msg in self._messages:
self._bot.msg(self._channel, msg)
watchMask = ( inotify.IN_MODIFY watchMask = ( inotify.IN_MODIFY
| inotify.IN_CREATE | inotify.IN_CREATE