finished file logging changes

Author: rob

sysdata/mongodb/mongo_log.py renamed to sysdata/_DEPRECATED/mongo_log.py

@@ -20,72 +20,6 @@
 LOG_COLLECTION_NAME = "Logs"
 
 
-class logToMongod(logToDb):
-    """
-    Logs to a mongodb
-
-    """
-
-    def __init__(
-        self,
-        type: str,
-        data=None,
-        log_level: str = "Off",
-        mongo_db: mongoDb = arg_not_supplied,
-        **kwargs,
-    ):
-        super().__init__(type=type, data=data, log_level=log_level, **kwargs)
-        self._mongo_data = mongoDataWithSingleKey(
-            LOG_COLLECTION_NAME, LOG_RECORD_ID, mongo_db=mongo_db
-        )
-
-    @property
-    def mongo_data(self):
-        return self._mongo_data
-
-    def get_next_log_id(self) -> int:
-        # slightly complicated to deal with race conditions
-        invalid_id = True
-        counter = 0
-        while invalid_id:
-            last_id = self._get_last_used_log_id()
-            next_id = last_id + 1
-            reserved_okay = self._reserve_log_id(next_id)
-            if reserved_okay:
-                break
-            counter = counter + 1
-            if counter > 100:
-                raise Exception("Couldn't reserve log ID")
-
-        return next_id
-
-    def _get_last_used_log_id(self) -> int:
-        """
-        Get last used log id. Returns None if not present
-
-        :return: int or None
-        """
-        current_max = self.mongo_data.get_max_of_keys()
-        if current_max == None:
-            return 0
-
-        return current_max
-
-    def _reserve_log_id(self, next_id: int) -> bool:
-        try:
-            self.mongo_data.add_data(next_id, {})
-        except existingData:
-            return False
-        else:
-            return True
-
-    def add_log_record(self, log_entry: logEntry):
-        record_as_dict = log_entry.log_as_dict()
-        key = record_as_dict[LOG_RECORD_ID]
-
-        self.mongo_data.add_data(key, record_as_dict, allow_overwrite=True)
-
-
 class mongoLogData(logData):
     def __init__(
         self, mongo_db: mongoDb = arg_not_supplied, log=logtoscreen("mongoLogData")

syslogdiag/_DEPRECATED/__init__.py

@@ -0,0 +1,24 @@
+import datetime
+import itertools
+
+from syscore.constants import arg_not_supplied
+from syscore.exceptions import missingData
+from sysdata.base_data import baseData
+from syslogdiag.logger import logger, DEFAULT_LOG_LEVEL
+from syslogdiag.log_entry import INVERSE_MAP, LEVEL_ID, logEntry
+from syslogdiag.log_to_screen import logtoscreen
+
+from syslogdiag.email_via_db_interface import send_production_mail_msg
+
+LOG_COLLECTION_NAME = "Logs"
+EMAIL_ON_LOG_LEVEL = [4]
+
+
+class logData(baseData):
+    def __init__(self, log: logger = logtoscreen("logData")):
+        super().__init__(log=log)
+
+    def delete_log_items_from_before_n_days(self, lookback_days: int = 365):
+        # need something to delete old log records, eg more than x months ago
+
+        raise NotImplementedError

syslogdiag/_DEPRECATED/database_log.py

@@ -0,0 +1,21 @@
+from sysdata._DEPRECATED.mongo_log import mongoLogData
+from sysdata.data_blob import dataBlob
+from syslogdiag._DEPRECATED.database_log import logData
+from sysproduction.data.generic_production_data import productionDataLayerGeneric
+
+#### BASICALLY DEPRECATED KEEP ON TO CLEAN OLD LOGS OUT
+
+
+class diagLogs(productionDataLayerGeneric):
+    def _add_required_classes_to_data(self, data) -> dataBlob:
+        data.add_class_object(mongoLogData)
+        return data
+
+    @property
+    def db_log_data(self) -> logData:
+        return self.data.db_log
+
+    def delete_log_items_from_before_n_days(self, days: int = 365):
+        # need something to delete old log records, eg more than x months ago
+
+        self.db_log_data.delete_log_items_from_before_n_days(lookback_days=days)