X-Git-Url: http://git.tremily.us/?p=apachelog.git;a=blobdiff_plain;f=apachelog%2Fprocessor%2Ftime.py;fp=apachelog%2Fprocessor%2Ftime.py;h=3fe56e58d28096f974efd6f835b4fb701825c144;hp=0000000000000000000000000000000000000000;hb=813f0a7b41db0e44195337f72dcc1958f14fb3fc;hpb=66f165ab3e429349dd44b5320dd3f7f3d98ff96f

diff --git a/apachelog/processor/time.py b/apachelog/processor/time.py
new file mode 100644
index 0000000..3fe56e5
--- /dev/null
+++ b/apachelog/processor/time.py
@@ -0,0 +1,48 @@
+from __future__ import division
+
+import datetime as _datetime
+
+from ..date import parse_time as _parse_time
+from . import Processor as _Processor
+
+
+class LogTimeProcessor (_Processor):
+    r"""Track the initial and final request times.
+
+    >>> import StringIO
+    >>> from apachelog.parser import Parser, FORMATS
+    >>> from apachelog.processor import Processor, process
+    >>> class PrintLogTimeProcessor (Processor):
+    ...     def __init__(self, log_time_processor):
+    ...         self.log_time_processor = log_time_processor
+    ...     def process(self, data):
+    ...         print('{}: {}'.format(data['%t'], self.log_time_processor.last_time))
+    >>> stream = StringIO.StringIO('\n'.join([
+    ...         '192.168.0.1 - - [18/Feb/2012:10:25:43 -0500] "GET / HTTP/1.1" 200 561 "-" "Mozilla/5.0 (...)"',
+    ...         '192.168.0.2 - - [18/Feb/2012:10:25:58 -0500] "GET / HTTP/1.1" 200 561 "-" "Mozilla/5.0 (...)"',
+    ...         ]))
+    >>> parser = Parser(FORMATS['extended'])
+    >>> ltp = LogTimeProcessor()
+    >>> processors = [ltp, PrintLogTimeProcessor(ltp)]
+    >>> process(stream, parser, processors)
+    [18/Feb/2012:10:25:43 -0500]: 2012-02-18 10:25:43-05:00
+    [18/Feb/2012:10:25:58 -0500]: 2012-02-18 10:25:58-05:00
+    >>> ltp.total_seconds()
+    15.0
+    """
+    def __init__(self):
+        self.last_time = self.start_time = self.stop_time = None
+
+    def process(self, data):
+        time = _parse_time(data['%t'])
+        self.last_time = time  # for use by subclasses or other processors
+        if self.start_time is None or time < self.start_time:
+            self.start_time = time
+        if self.stop_time is None or time > self.stop_time:
+            self.stop_time = time
+
+    def total_seconds(self):
+        if self.start_time is None:
+            return 0
+        dt = self.stop_time - self.start_time
+        return dt.total_seconds()