Add direct connection logs

Author: Fireye04

src/sasquatchbackpack/sasquatch.py

@@ -219,7 +219,7 @@ def _get_source_records(self) -> list[dict] | None:
             if self.redis.get(self.source.get_redis_key(record)) is None
         ]
 
-    async def direct_connect(self) -> None:
+    async def direct_connect(self) -> tuple[str, list]:
         """Assemble a schema and payload from the given source,
         and route data directly to kafka.
         """
@@ -228,15 +228,22 @@ async def direct_connect(self) -> None:
         await kafka_broker.connect()
 
         @kafka_broker.publisher(self.config.namespace)
-        async def dothing(self: Self) -> list[dict] | None:
+        async def dothing(self: Self) -> tuple[str, list]:
             records: list[dict] | None = self._get_source_records()
             if records is None:
-                return None
+                return (
+                    "Warning: No entries found, aborting POST request",
+                    [],
+                )
             if len(records) == 0:
-                return None
-            return records
-
-        await dothing(self)
+                return (
+                    "Warning: All entries already present,"
+                    " aborting POST request",
+                    records,
+                )
+            return "Sent thing", records
+
+        return await dothing(self)
 
     def post(self) -> tuple[str, list]:
         """Assemble schema and payload from the given source, then