From 26a4ed180f9e8d81e0fe7ea814db2a13e694e593 Mon Sep 17 00:00:00 2001
From: Dirk Alders <dirk@mount-mockery.de>
Date: Wed, 23 Sep 2020 09:45:22 +0200
Subject: [PATCH] Timeout for current data implemented

---
 __init__.py | 14 +++++++++++++-
 1 file changed, 13 insertions(+), 1 deletion(-)

diff --git a/__init__.py b/__init__.py
index a92f6f7..eeaf227 100644
--- a/__init__.py
+++ b/__init__.py
@@ -1,7 +1,11 @@
+import logging
 import numbers
 import os
 import time
 
+logger_name = 'HELPERS'
+logger = logging.getLogger(logger_name)
+
 
 class continues_statistic(dict):
     KEY_SINGLE_VALUE = '_'
@@ -88,9 +92,11 @@ class ringbuffer(list):
 
 
 class data_collector(object):
-    def __init__(self, bufferlength):
+    def __init__(self, bufferlength, current_max_age=300.):
+        self.__current_max_age__ = current_max_age
         self.__current_data_rinbuffer__ = ringbuffer(length=3)
         #
+        self.__last_add_data__ = 0
         self.__continues_statistic__ = None
         self.__yesterdays_statistic__ = None
         self.__measurement_day__ = None
@@ -114,6 +120,8 @@ class data_collector(object):
 
 
     def add_data(self, **kwargs):
+        logger.debug('Got data %s', repr(kwargs))
+        self.__last_add_data__ = time.time()
         self.__current_data_rinbuffer__.append(kwargs)
         self.__process_continues_statistic__(**kwargs)
         self.__ringbuffer__.append(kwargs)
@@ -121,6 +129,10 @@ class data_collector(object):
     @property
     def current(self):
         if len(self.__current_data_rinbuffer__) == 0:
+            logger.info('No data available, yet.')
+            return None
+        elif  time.time() > self.__last_add_data__ + self.__current_max_age__:
+            logger.info('Data max age reached. No current data available.')
             return None
         elif  len(self.__current_data_rinbuffer__) < 3:
             return self.__current_data_rinbuffer__[-1]