drop code dups

Author: arcan1s

src/systemd_monitor/journald_worker.py

@@ -89,30 +89,8 @@ def run(self):
         '''
         run thread
         '''
-        self.__load_states()
-        while self.__should_run:
-            try:
-                for line in self.__get_journal():
-                    self.__status = True
-                    # exit on no actions
-                    if not self.__should_run:
-                        break
-                    # parse line
-                    if isinstance(line, bytes):
-                        line = line.decode('utf8')
-                    data = json.loads(line)
-                    # check if it is unit related infomation
-                    if 'UNIT' not in data:
-                        continue
-                    # update internal storage
-                    with self.__lock:
-                        self.__states[
-                            data['UNIT']] = self.__systemd.get_unit(data['UNIT'])
-                        self.__lst = datetime.datetime.utcnow()
-            except Exception:
-                self.__logger.warning('Exception recieved', exc_info=True)
-                self.__status = False
-            time.sleep(60)
+        for unit, state in self.run_iterate():
+            pass
 
     def run_iterate(self):
         '''