docs(refactoring): Some black code refactoring

Author: gaspect

PyWars/client.py

@@ -60,7 +60,7 @@ def __init__(
         work_dir: Union[str, Path] = "./.fchatwars",
         loop: asyncio.AbstractEventLoop = None,
         debug: bool = False,
-        loglevel: Union[str, int] = "warning"
+        loglevel: Union[str, int] = "warning",
     ) -> None:
 
         self._loop = loop if loop is not None else asyncio.get_event_loop()
@@ -77,7 +77,6 @@ def __init__(
         self._workdir = Path(work_dir)
         self._workdir.mkdir(exist_ok=True)
 
-
     # The properties are straigth forward so ... no explanations are needed
 
     @property
@@ -93,11 +92,11 @@ def version(self) -> "Client.Version":
         return self._version
 
     @property
-    def debug(self)->bool:
+    def debug(self) -> bool:
         return self._debug
 
     @property
-    def loglevel(self)->Union[str, int]:
+    def loglevel(self) -> Union[str, int]:
         return self._logleve
 
     # This is a faust topic builder with some cache (*just for internal use*)
@@ -120,7 +119,6 @@ def timer(self, seconds):
     @cached_property
     def _driven_functions(self) -> Tuple[Callable, Callable]:
 
-        
         worker = Worker(
             self._app,
             loop=self.loop,
@@ -129,12 +127,14 @@ def _driven_functions(self) -> Tuple[Callable, Callable]:
             workdir=self.workdir,
             quiet=True,
             redirect_stdouts=False,
-        ) # We remove or preset not important setting when we create the worker
+        )  # We remove or preset not important setting when we create the worker
 
-       
         worker.spinner = None  # Removing anoying spinner
 
-        return lambda : self.loop.run_until_complete(worker.start()), worker.stop_and_shutdown
+        return (
+            lambda: self.loop.run_until_complete(worker.start()),
+            worker.stop_and_shutdown,
+        )
 
     # This method starts the app execution loop
     def start(self):

PyWars/types/__init__.py

@@ -16,5 +16,5 @@
     YellowPage,
     AuctionDeal,
     AuctionDigest,
-    Specialization
+    Specialization,
 )

examples/printing.py

@@ -8,8 +8,11 @@
 
 # We define an agent to process deals
 
+
 @app.agent(Deal)  # this decorator define wath kind of topic we are specting for consume
-async def deals(stream: Stream[Deal]):  # as we consume 'deals' topic we recieve a stream of deals
+async def deals(
+    stream: Stream[Deal],
+):  # as we consume 'deals' topic we recieve a stream of deals
     async for deal in stream:  # we itterate over the deals
         print(deal)  # and we print every one of them
 

examples/telegram.py

@@ -1,12 +1,14 @@
 # # Example of how use it with Pyrogram
 
 # We start importing pyrogram client and our PyWars stuff
-from pyrogram import Client as Telegram 
+from pyrogram import Client as Telegram
 from PyWars import *
 
 # We create a telegram and a chat wars client
-telegram  = Telegram("my_account")
-chat_wars = Client(loglevel='info', )
+telegram = Telegram("my_account")
+chat_wars = Client(
+    loglevel="info",
+)
 
 # A bucket of deals
 bucket = {}
@@ -15,17 +17,20 @@
 @chat_wars.agent(Deal)
 async def bucket_builder(stream: Stream[Deal]):
     async for deal in stream:
-        msg = f"{deal.buyerName} buy {deal.qty} from  {deal.sellerName} a {deal.price} $"
+        msg = (
+            f"{deal.buyerName} buy {deal.qty} from  {deal.sellerName} a {deal.price} $"
+        )
         if deal.item in bucket:
             bucket[deal.item].append(msg)
         else:
             bucket[deal.item] = [msg]
 
+
 # And a timer for post the bucket every 10 seconds
 @chat_wars.timer(10)
 async def post_deals():
     me = await telegram.get_me()
-    # And late we build a post for that bucket   
+    # And late we build a post for that bucket
     post = ""
     for item, lines in bucket.items():
         post += f"{item}:\n\n"
@@ -35,5 +40,6 @@ async def post_deals():
         await telegram.send_message(me.id, post)
     bucket.clear()
 
+
 telegram.start()
-chat_wars.run()
+chat_wars.run()

pyproject.toml

@@ -1,6 +1,6 @@
 [tool.poetry]
 name = "PyWars"
-version = "0.1.0"
+version = "0.1.1"
 description = "Public topic consumer for Chat Wars API"
 authors = ["Jesús Enrique <[email protected]>"]
 license = "MIT"