⚡ Use thread

Author: Freed-Wu

src/repl_python_wakatime/backends/__init__.py

@@ -60,7 +60,7 @@ def get_project(
     def __or__(self, hook: Self) -> "Hook":
         return Hook(hooks=(self, hook))
 
-    async def __call__(self) -> None:
+    def __call__(self) -> None:
         r"""Run hook"""
         for hook in self.hooks:
-            await hook()
+            hook()

src/repl_python_wakatime/backends/codestats.py

@@ -6,11 +6,13 @@
 `_.
 """
 
+import asyncio
 import json
 import logging
 from dataclasses import dataclass
 from datetime import datetime
 from socket import gethostname
+from threading import Thread
 from time import time
 
 from aiohttp import ClientSession
@@ -58,10 +60,10 @@ def __post_init__(
         }
         self.datetime = datetime.now().astimezone()
         if self.timeout is None:
-            self.timeout = ClientTimeout(1)
+            self.timeout = ClientTimeout(10)
         self.session = None
 
-    async def __call__(self, xp: int = 1) -> None:
+    def __call__(self, xp: int = 1) -> None:
         """Add xp.
 
         Sem sections are super small so this should be quick if it blocks.
@@ -71,20 +73,18 @@ async def __call__(self, xp: int = 1) -> None:
         :rtype: None
         """
         self.data["xps"][0]["xp"] += xp
-        if time() - self.datetime.timestamp() > self.interval:
-            await self.send_xp()
-
-    async def __del__(self) -> None:
-        await self.send_xp()
+        if (
+            time() - self.datetime.timestamp() > self.interval
+            and self.data["xps"][0]["xp"] > 0
+        ):
+            co = self.send_xp()
+            Thread(target=asyncio.run, args=(co,)).run()
 
     async def send_xp(self) -> str:
         """Send xp.
 
         :rtype: str
         """
-        if self.data["xps"][0]["xp"] == 0:
-            return ""
-
         self.datetime = datetime.now().astimezone()
         self.data["coded_at"] = self.datetime.isoformat()
         data = json.dumps(self.data).encode("utf-8")

src/repl_python_wakatime/backends/wakatime.py

@@ -29,7 +29,7 @@ def get_wakatime_args(args: dict[str, str]) -> list[str]:
             f"--{k}={v}" for k, v in args.items()
         ]
 
-    async def __call__(self) -> None:
+    def __call__(self) -> None:
         """Send wakatime heartbeat."""
         self.data["project"] = self.get_project(self.filenames)
         Popen(self.get_wakatime_args(self.data))

src/repl_python_wakatime/frontends/__init__.py

@@ -2,7 +2,6 @@
 =============
 """
 
-import asyncio
 from dataclasses import dataclass
 
 from ..backends import Hook
@@ -16,4 +15,4 @@ def __post_init__(self) -> None:
         self.hook.frontend = self.__class__.__name__.lower()
 
     def __call__(self):
-        asyncio.run(self.hook())
+        self.hook()