From c06bec5a90d80a4fed626becef52155957b50259 Mon Sep 17 00:00:00 2001
From: Johann Dreo <johann.dreo@thalesgroup.com>
Date: Mon, 22 Sep 2014 11:00:50 +0200
Subject: [PATCH] first version

---
 paternoster.py | 126 +++++++++++++++++++++++++++++++++++++++++++++++++
 1 file changed, 126 insertions(+)
 create mode 100755 paternoster.py

diff --git a/paternoster.py b/paternoster.py
new file mode 100755
index 0000000..5003483
--- /dev/null
+++ b/paternoster.py
@@ -0,0 +1,126 @@
+#!/usr/bin/env python3
+#encoding: utf-8
+
+# Licensed under the GPL version 3
+# 2012 (c) nojhan <nojhan@nojhan.net>
+
+
+import re
+import sys
+import argparse
+import subprocess
+
+
+def call( cmd, text, nowait=False ):
+
+    # If there is a string formatting mark
+    try:
+        # put the matching text in it
+        order = str(cmd % text).split()
+    except TypeError:
+        # else, do not
+        order = cmd.split()
+
+    # Join the command parts in the subprocess list format: [command,args]
+    behest = [order[0]," ".join(order[1:])]
+
+    with open("/dev/null") as dev_null:
+        if nowait:
+            subprocess.Popen( behest, stdout=sys.stdout, stderr=dev_null )
+        else:
+            subprocess.call(  behest, stdout=sys.stdout, stderr=dev_null )
+
+
+def parse( text, pattern, cmd="", nowait=False ):
+
+    regex = re.compile(pattern)
+    for match in regex.finditer(text):
+
+        # If no groups are specified
+        if not match.groups():
+            call( cmd, text, nowait )
+
+        else:
+            nb_groups = len(match.groups())
+
+            # Build a list of colors that match the number of grouped,
+            # If there is not enough commands, duplicate the last one.
+            cmds_l = cmd.split(",")
+            group_cmds = cmds_l + [cmds_l[-1]] * (nb_groups - len(cmds_l))
+
+            # For each group index.
+            # Note that match.groups returns a tuple (thus being indexed in [0,n[),
+            # but that match.start(0) refers to the whole match, the groups being indexed in [1,n].
+            # Thus, we need to range in [1,n+1[.
+            for group in range(1, nb_groups+1):
+                # If a group didn't match, there's nothing to do
+                if match.group(group) is not None:
+                    call( group_cmds[group-1], text[match.start(group):match.end(group)], nowait )
+
+
+def write( text, stream = sys.stdout):
+    """
+    Write "txt" on sys.stdout, then flush.
+    """
+    try:
+        stream.write(text)
+        stream.flush()
+
+    # Silently handle broken pipes
+    except IOError:
+        try:
+            stream.close()
+        except IOError:
+            pass
+
+
+def map_write( stream_in, stream_out, function, *args ):
+    """
+    Read the given file-like object as a non-blocking stream
+    and call the function on each item (line),
+    with the given extra arguments.
+
+    A call to "map_write(sys.stdin, function, *args)" will translate to the
+    non-blocking equivalent of:
+        for item in sys.stdin.readlines():
+            write( function( *args ) )
+    """
+    while True:
+        try:
+            item = stream_in.readline()
+        except UnicodeDecodeError:
+            continue
+        except KeyboardInterrupt:
+            break
+        if not item:
+            break
+
+        # Write the line being processed
+        write( item, stream_out )
+        # Then do something (blocking)
+        function(item, *args)
+
+
+if __name__ == "__main__":
+
+    parser = argparse.ArgumentParser(
+        description="Call a command for each input matching a pattern.")
+
+    parser.add_argument("pattern", metavar="REGEX", type=str, nargs=1,
+            help="A regular expression")
+
+    parser.add_argument("command", metavar="CMD", type=str, nargs='?',
+            default="espeak %s",
+            help="The command to run if REGEX match. \
+            If CMD contains a string formating placefolder (like \"%%s\"), \
+            it will be replaced by the matching text. \
+            Multiple commands may be specified as a list of comma-separated values. \
+            Commands will then be called for each matching group within REGEX.")
+
+    parser.add_argument("-w", "--no-wait", action="store_true",
+            help="Don't wait for the end of the current command before calling the next one.")
+
+    args = parser.parse_args()
+
+    map_write( sys.stdin, sys.stdout, parse, args.pattern[0], args.command, args.no_wait )
+