Merge pull request #327 from minos-framework/restyled/0.6.0

Restyle 0.6.0

Author: andrea-mucci

tutorials/stock-wallet/microservices/crypto/src/__init__.py

@@ -14,4 +14,4 @@
 from .queries import (
     CryptoQueryService,
     CryptoQueryServiceRepository,
-)
+)

tutorials/stock-wallet/microservices/crypto/src/__main__.py

@@ -3,4 +3,4 @@
 )
 
 if __name__ == "__main__":
-    main()
+    main()

tutorials/stock-wallet/microservices/crypto/src/aggregates.py

@@ -4,12 +4,13 @@
 
 from minos.aggregate import (
     Aggregate,
-    RootEntity
+    RootEntity,
 )
 
 
 class Crypto(RootEntity):
     """Crypto RootEntity class."""
+
     ticker: str
     updated: str
 

tutorials/stock-wallet/microservices/crypto/src/cli.py

@@ -1,28 +1,33 @@
 import logging
 import sys
 from pathlib import (
-    Path, )
+    Path,
+)
 from typing import (
-    Optional, )
+    Optional,
+)
 
 import typer
+
 from minos.common import (
-    EntrypointLauncher, )
+    EntrypointLauncher,
+)
 
 logging.getLogger("aiohttp.access").setLevel(logging.WARNING)
 
 app = typer.Typer()
 
 
 @app.command("start")
-def start(file_path: Optional[Path] = typer.Argument(
-    "config.yml",
-    help="Microservice configuration file.",
-    envvar="MINOS_CONFIGURATION_FILE_PATH",
-)):
+def start(
+    file_path: Optional[Path] = typer.Argument(
+        "config.yml",
+        help="Microservice configuration file.",
+        envvar="MINOS_CONFIGURATION_FILE_PATH",
+    )
+):
     """Start the microservice."""
-    launcher = EntrypointLauncher.from_config(
-        file_path, external_modules=[sys.modules["src"]])
+    launcher = EntrypointLauncher.from_config(file_path, external_modules=[sys.modules["src"]])
     launcher.launch()
 
 

tutorials/stock-wallet/microservices/crypto/src/commands/__init__.py

@@ -1,3 +1,3 @@
 from .services import (
     CryptoCommandService,
-)
+)

tutorials/stock-wallet/microservices/crypto/src/commands/services.py

@@ -1,25 +1,29 @@
 import logging
 import time
 
+import ccxt
 import pendulum
+
+from minos.aggregate import (
+    Event,
+)
+from minos.common import (
+    ModelType,
+)
 from minos.cqrs import (
     CommandService,
 )
-from minos.common import ModelType
-
 from minos.networks import (
+    BrokerMessageV1,
+    BrokerMessageV1Payload,
     Request,
     enroute,
-    BrokerMessageV1,
-    BrokerMessageV1Payload
-)
-from minos.aggregate import (
-    Event
 )
+
 from ..aggregates import (
     CryptoAggregate,
 )
-import ccxt
+
 logger = logging.getLogger(__name__)
 QuoteContent = ModelType.build("QuoteContent", {"ticker": str, "close": float, "volume": float, "when": str})
 
@@ -32,17 +36,18 @@ async def set_crypto_coin(self, request: Request):
         event: Event = await request.content()
         for ticker in event["tickers"]:
             logger.warning(ticker)
-            if ticker['flag'] == "crypto":
-                now = pendulum.parse('1975-08-27T05:00:00')
+            if ticker["flag"] == "crypto":
+                now = pendulum.parse("1975-08-27T05:00:00")
                 logger.warning("Added crypto to stock")
                 await CryptoAggregate.add_crypto_to_stock(ticker["ticker"], now.to_datetime_string())
 
     def call_remote(self, ticker, _from: float):
-        kraken = ccxt.kraken({
-            'enableRateLimit': True,
-            'apiKey': 'MilT+OBywOBlgMPZnsCNSSlwxOGEtGfhnNXJl0pi87MCltuKRA+IoiVc',
-            'secret': 'sGQpkVLH6sIPy7sjuro1sFiMYHC+hhN7j/bWrNr+AHdTIZNR8jb+13+ZhVevo5hyCxRijUqhUWG47Ox0SokOig==',
-        }
+        kraken = ccxt.kraken(
+            {
+                "enableRateLimit": True,
+                "apiKey": "MilT+OBywOBlgMPZnsCNSSlwxOGEtGfhnNXJl0pi87MCltuKRA+IoiVc",
+                "secret": "sGQpkVLH6sIPy7sjuro1sFiMYHC+hhN7j/bWrNr+AHdTIZNR8jb+13+ZhVevo5hyCxRijUqhUWG47Ox0SokOig==",
+            }
         )
         now = kraken.milliseconds()
         timeframe = "1h"
@@ -62,11 +67,19 @@ def call_remote(self, ticker, _from: float):
                 fetch_since = (values[-1][0] + 3600000) if len(values) else (fetch_since + timedelta)
                 data = data + values
                 if len(values):
-                    logger.info("{} candles in total from {} to {}".format(len(values), kraken.iso8601(values[0][0]),
-                                                                           kraken.iso8601(values[-1][0])))
+                    logger.info(
+                        "{} candles in total from {} to {}".format(
+                            len(values), kraken.iso8601(values[0][0]), kraken.iso8601(values[-1][0])
+                        )
+                    )
                 else:
                     logger.info("{} candles in total from {}".format(len(values), kraken.iso8601(fetch_since)))
-            except (ccxt.ExchangeError, ccxt.AuthenticationError, ccxt.ExchangeNotAvailable, ccxt.RequestTimeout) as error:
+            except (
+                ccxt.ExchangeError,
+                ccxt.AuthenticationError,
+                ccxt.ExchangeNotAvailable,
+                ccxt.RequestTimeout,
+            ) as error:
                 logger.error(error)
                 time.sleep(30)
         return kraken.filter_by_since_limit(data, since, None, key=0)
@@ -88,7 +101,7 @@ async def get_crypto_values(self, request: Request):
                         await CryptoAggregate.update_time_ticker(ticker["uuid"], result_date.to_datetime_string())
                         when = result_date.to_datetime_string()
                         message = BrokerMessageV1(
-                            "QuotesChannel", BrokerMessageV1Payload(QuoteContent(ticker["ticker"], result[4],
-                                                                                 result[5], when))
+                            "QuotesChannel",
+                            BrokerMessageV1Payload(QuoteContent(ticker["ticker"], result[4], result[5], when)),
                         )
                         await self.broker_publisher.send(message)

tutorials/stock-wallet/microservices/crypto/src/queries/__init__.py

@@ -1,7 +1,6 @@
+from .repository import (
+    CryptoQueryServiceRepository,
+)
 from .services import (
     CryptoQueryService,
 )
-
-from .repository import (
-    CryptoQueryServiceRepository,
-)

tutorials/stock-wallet/microservices/crypto/src/queries/models.py

@@ -1,3 +1,5 @@
-from sqlalchemy.orm import declarative_base
+from sqlalchemy.orm import (
+    declarative_base,
+)
 
-Base = declarative_base()
+Base = declarative_base()

tutorials/stock-wallet/microservices/crypto/src/queries/repository.py

@@ -1,7 +1,17 @@
-from minos.common import MinosSetup, MinosConfig
-from sqlalchemy import create_engine
-from sqlalchemy.orm import sessionmaker
-from src.queries.models import Base
+from sqlalchemy import (
+    create_engine,
+)
+from sqlalchemy.orm import (
+    sessionmaker,
+)
+from src.queries.models import (
+    Base,
+)
+
+from minos.common import (
+    MinosConfig,
+    MinosSetup,
+)
 
 
 class CryptoQueryServiceRepository(MinosSetup):
@@ -15,4 +25,4 @@ async def _setup(self) -> None:
 
     @classmethod
     def _from_config(cls, *args, config: MinosConfig, **kwargs):
-        return cls(*args, **(config.query_repository._asdict()) | kwargs)
+        return cls(*args, **(config.query_repository._asdict()) | kwargs)

tutorials/stock-wallet/microservices/crypto/src/queries/services.py

@@ -1,7 +1,6 @@
 from dependency_injector.wiring import (
     Provide,
 )
-
 from src.queries.repository import (
     CryptoQueryServiceRepository,
 )