MORE. LOGS.

README.md

@@ -104,6 +104,10 @@ connection error!!!)
 #### modules
 More about them later
 
+#### loglevel
+Self-explanatory, logging level. Can be either `DEBUG`, `INFO`, `WARNING` or
+`ERROR`. Defaults to `INFO`
+
 ### Modules
 There's two types of modules supported at this point: `telegram` and `discord`.
 Both of them are self-explanatory, but we'll go over them real quick.

mastoposter/__main__.py

@@ -1,7 +1,7 @@
 #!/usr/bin/env python3
 from asyncio import run
 from configparser import ConfigParser, ExtendedInterpolation
-from logging import INFO, Formatter, StreamHandler, getLogger
+from logging import INFO, Formatter, StreamHandler, getLevelName, getLogger
 from sys import stdout
 from mastoposter import execute_integrations, load_integrations_from
 from mastoposter.integrations import FilteredIntegration
@@ -72,10 +72,10 @@ async def listen(
 
 
 def main(config_path: str):
-    init_logger()
     conf = ConfigParser(interpolation=ExtendedInterpolation())
     conf.read(config_path)
 
+    init_logger(getLevelName(conf["main"].get("loglevel", "INFO")))
     normalize_config(conf)
 
     modules: List[FilteredIntegration] = load_integrations_from(conf)

mastoposter/integrations/discord/__init__.py

@@ -41,12 +41,14 @@ class DiscordIntegration(BaseIntegration):
 
             logger.debug("Executing webhook with %r", json)
 
-            return (
+            result = (
                 await c.post(
                     self.webhook,
                     json=json,
                 )
             ).json()
+            logger.debug("Result: %r", result)
+            return result
 
     async def __call__(self, status: Status) -> Optional[str]:
         source = status.reblog or status
@@ -88,6 +90,11 @@ class DiscordIntegration(BaseIntegration):
                         ),
                     )
                 )
+            else:
+                logger.warn(
+                    "Unsupported attachment %r for Discord Embed",
+                    attachment.type,
+                )
 
         await self.execute_webhook(
             username=status.account.acct,

mastoposter/integrations/telegram.py

@@ -88,12 +88,15 @@ class TelegramIntegration(BaseIntegration):
     async def _tg_request(self, method: str, **kwargs) -> TGResponse:
         url = API_URL.format(self.token, method)
         async with AsyncClient() as client:
+            logger.debug("TG request: %s(%r)", method, kwargs)
             response = TGResponse.from_dict(
                 (await client.post(url, json=kwargs)).json(), kwargs
             )
             if not response.ok:
                 logger.error("TG error: %r", response.error)
                 logger.error("parameters: %r", kwargs)
+            else:
+                logger.debug("Result: %r", response.result)
             return response
 
     async def _post_plaintext(self, text: str) -> TGResponse:

mastoposter/sources.py

@@ -1,10 +1,13 @@
 from asyncio import exceptions
 from json import loads
+from logging import getLogger
 from typing import AsyncGenerator
 from urllib.parse import urlencode
 
 from mastoposter.types import Status
 
+logger = getLogger("sources")
+
 
 async def websocket_source(
     url: str, reconnect: bool = False, **params
@@ -22,6 +25,20 @@ async def websocket_source(
                         raise Exception(event["error"])
                     if event["event"] == "update":
                         yield Status.from_dict(loads(event["payload"]))
-        except (WebSocketException, TimeoutError, exceptions.TimeoutError):
+                    else:
+                        logger.warn("unknown event type %r", event["event"])
+                        logger.debug("data: %r", event)
+        except (
+            WebSocketException,
+            TimeoutError,
+            exceptions.TimeoutError,
+        ) as e:
             if not reconnect:
                 raise
+            else:
+                logger.warn("%r caught, reconnecting", e)
+        else:
+            logger.info(
+                "WebSocket closed connection without any errors, "
+                "but we're not done yet"
+            )