Ensure new files are added to a transports configuration. Closes #96. C…

…loses #101
python-beaver · Feb 24, 2013 · 0bc6395 · 0bc6395
1 parent 55b88af
commit 0bc6395
Show file tree

Hide file tree

Showing 3 changed files with 6 additions and 0 deletions.
diff --git a/beaver/queue.py b/beaver/queue.py
@@ -36,6 +36,8 @@ def run_queue(queue, beaver_config, file_config, logger=None):
                         transport.interrupt()
 
                         sys.exit(0)
+            elif command == "addglob":
+                transport.addglob(*data)
             elif command == "exit":
                 break
     except KeyboardInterrupt:

diff --git a/beaver/transport.py b/beaver/transport.py
@@ -86,6 +86,9 @@ def format(self, filename, timestamp, line):
             '@message': line.strip(os.linesep),
         })
 
+    def addglob(self, globname, globbed):
+        self._file_config.addglob(globname, globbed)
+
 
 class TransportException(Exception):
     pass
diff --git a/beaver/worker.py b/beaver/worker.py
@@ -127,6 +127,7 @@ def update_files(self):
                 globbed = [os.path.realpath(filename) for filename in eglob(name)]
                 files.extend(globbed)
                 self._file_config.addglob(name, globbed)
+                self._callback(("addglob", (name, globbed)))
         else:
             for name in self.listdir():
                 files.append(os.path.realpath(os.path.join(self._folder, name)))