Added method sonicprobe.libs.workerpool.WorkerPool.run_args.

CHANGELOG

@@ -1,3 +1,9 @@
+python-sonicprobe (0.3.24) unstable; urgency=medium
+
+  * Added method sonicprobe.libs.workerpool.WorkerPool.run_args.
+
+ -- Adrien DELLE CAVE (Decryptus) <adc@doowan.net>  Mon, 13 Jan 2020 09:40:38 +0100
+
 python-sonicprobe (0.3.23) unstable; urgency=medium
 
   * Added function helpers.get_nb_workers 

RELEASE

@@ -1 +1 @@
-0.3.23
+0.3.24

VERSION

@@ -1 +1 @@
-0.3.23
+0.3.24

requirements.txt

@@ -1,4 +1,4 @@
-httpdis>=0.6.10
+httpdis>=0.6.11
 pyOpenSSL
 python-magic
 psutil>=2.1

setup.yml

@@ -4,8 +4,8 @@ description: sonicprobe
 author: Adrien Delle Cave
 author_email: pypi@doowan.net
 copyright: '2020 Adrien Delle Cave'
-release: '0.3.23'
-version: '0.3.23'
+release: '0.3.24'
+version: '0.3.24'
 license: License GPL-3
 url: https://github.com/decryptus/sonicprobe
 python_requires:

sonicprobe/libs/workerpool.py

@@ -253,6 +253,20 @@ def run(self, target, callback = None, name = None, complete = None, qpriority =
             qpriority = time.time()
         self.tasks.put((qpriority, (target, callback, name, complete, args, kargs)))
 
+    def run_args(self, target, *args, **kwargs):
+        callback  = kwargs.pop('_callback_', None)
+        name      = kwargs.pop('_name_', None)
+        complete  = kwargs.pop('_complete_', None)
+        qpriority = kwargs.pop('_qpriority_', None)
+
+        self.run(target    = target,
+                 callback  = callback,
+                 name      = name,
+                 complete  = complete,
+                 qpriority = qpriority,
+                 *args,
+                 **kwargs)
+
     def killall(self, wait = None):
         """
         Kill all active workers.

sonicprobe/sp_logging/handlers.py

@@ -0,0 +1,87 @@
+# -*- coding: utf-8 -*-
+# Copyright (C) 2015-2019 Adrien Delle Cave
+# SPDX-License-Identifier: GPL-3.0-or-later
+"""sonicprobe.sp_logging.handlers"""
+
+import smtplib
+
+try:
+    from email.utils import formatdate
+except ImportError:
+    from email.Utils import formatdate
+
+from logging.handlers import SMTPHandler
+
+import six
+
+
+class QueueSMTPHandler(SMTPHandler):
+    def __init__(self, mailhost, fromaddr, toaddrs, subject,
+                 credentials = None, secure = None, timeout = 5.0, logger_name = None):
+        self.queues      = {}
+        self.logger_name = logger_name
+        self._timeout    = timeout
+
+        if six.PY2:
+            SMTPHandler.__init__(self, mailhost, fromaddr, toaddrs, subject, credentials, secure)
+        else:
+            SMTPHandler.__init__(self, mailhost, fromaddr, toaddrs, subject, credentials, secure, timeout)
+
+    def isEmpty(self):
+        return len(self.queues) == 0
+
+    def getSubject(self, record):
+        if self.logger_name:
+            return "[%s] %s Event" % (self.logger_name, record.levelname)
+        return "%s Event" % record.levelname
+
+    def emit(self, record):
+        if record.levelname not in self.queues:
+            self.queues[record.levelname] = []
+
+        self.queues[record.levelname].append(record)
+
+    def purge(self):
+        if self.isEmpty():
+            return
+
+        queues      = dict(self.queues)
+        self.queues = {}
+
+        for records in six.itervalues(queues):
+            msg     = ""
+            record  = None
+
+            for record in records:
+                msg += "%s\n" % self.format(record)
+
+            if not record:
+                continue
+
+            smtp = None
+
+            try:
+                port = self.mailport
+                if not port:
+                    port = smtplib.SMTP_PORT
+                smtp = smtplib.SMTP(self.mailhost, port, timeout=self._timeout)
+                msg = ("From: %s\r\nTo: %s\r\nSubject: %s\r\nDate: %s\r\n\r\n%s" %
+                       (self.fromaddr,
+                        ",".join(self.toaddrs),
+                        self.getSubject(record),
+                        formatdate(),
+                        msg))
+                if self.username:
+                    if self.secure is not None:
+                        smtp.ehlo()
+                        smtp.starttls(*self.secure)
+                        smtp.ehlo()
+                    smtp.login(self.username, self.password)
+                smtp.sendmail(self.fromaddr, self.toaddrs, msg)
+            except (KeyboardInterrupt, SystemExit):
+                raise
+            except Exception:
+                self.handleError(record)
+            finally:
+                if smtp:
+                    smtp.quit()