Fix time fetch logic; simmplified fetching data from db; more info about services status

Author: CoolCoderCarl

datapath.py

@@ -7,7 +7,6 @@
 import dynaconfig
 import news_db
 
-current_time = datetime.now().strftime("%H:%M")
 # Time range for sending messages
 TIME_TO_SEND_START = datetime.now().replace(hour=10, minute=00).strftime("%H:%M")
 TIME_TO_SEND_END = datetime.now().replace(hour=20, minute=00).strftime("%H:%M")
@@ -42,10 +41,13 @@ def send_news_to_telegram(message):
 
 
 if __name__ == "__main__":
+    data_from_db = news_db.create_connection(news_db.DB_FILE)
     while True:
+        current_time = datetime.now().strftime("%H:%M")
         if TIME_TO_SEND_START < current_time < TIME_TO_SEND_END:
-            for news in news_db.send_all_news(
-                news_db.create_connection(news_db.DB_FILE)
-            ):
-                time.sleep(300)
+            logging.info(f"Time: {current_time}. Time to send has come !")
+            for news in news_db.send_all_news(data_from_db):
                 send_news_to_telegram(news)
+                time.sleep(300)
+        else:
+            logging.info(f"Time: {current_time}. Still waiting to send.")

news_db.py

@@ -1,12 +1,10 @@
 import logging
 import sqlite3
+import time
 from datetime import datetime
 from pathlib import Path
 from sqlite3 import Error
 
-now = datetime.now()
-
-CURRENT_TIME = now.strftime("%H:%M")
 TIME_TO_PURGE = "00:00"
 
 
@@ -120,10 +118,14 @@ def delete_all_news(conn):
         create_table(conn, CREATE_TABLE_SQL)
 
     while True:
+        time.sleep(1)
+        CURRENT_TIME = datetime.now().strftime("%H:%M")
         if conn is not None:
             send_all_news(conn)
             if CURRENT_TIME == TIME_TO_PURGE:
-                logging.info("Time to purge has come !")
+                logging.info(f"Time: {CURRENT_TIME}. Time to purge has come !")
                 delete_all_news(conn)
+            else:
+                logging.info(f"Time: {CURRENT_TIME}. Still waiting for purging.")
         else:
             logging.error("Error! Cannot create the database connection.")

truth_seeker.py

@@ -1,4 +1,5 @@
 import logging
+import time
 from datetime import date, datetime, timedelta
 
 from newsapi import NewsApiClient
@@ -14,10 +15,7 @@
 
 newsapi = NewsApiClient(api_key=API_KEY)
 
-now = datetime.now()
-
-CURRENT_TIME = now.strftime("%H:%M")
-TIME_TO_SEARCH = "01:00"
+TIME_TO_SEARCH = "14:10"
 
 
 # Logging
@@ -71,10 +69,14 @@ def load_to_db(fetch_info: dict):
 
 if __name__ == "__main__":
     while True:
+        time.sleep(1)
+        CURRENT_TIME = datetime.now().strftime("%H:%M")
         # Pull too much info
         if CURRENT_TIME == TIME_TO_SEARCH:
-            logging.info("Time to search has come !")
+            logging.info(f"Time: {CURRENT_TIME}. Time to search has come !")
             try:
                 load_to_db(fetch_info())
             except BaseException as base_err:
                 logging.error(base_err)
+        else:
+            logging.info(f"Time: {CURRENT_TIME}. Still waiting for searching.")