diff --git a/dist/app-1.0.0-py3-none-any.whl b/dist/app-1.0.0-py3-none-any.whl index 48bab7c..918af48 100644 Binary files a/dist/app-1.0.0-py3-none-any.whl and b/dist/app-1.0.0-py3-none-any.whl differ diff --git a/dist/app-1.0.0.tar.gz b/dist/app-1.0.0.tar.gz index c74ea22..03aeb0b 100644 Binary files a/dist/app-1.0.0.tar.gz and b/dist/app-1.0.0.tar.gz differ diff --git a/src/app/app.py b/src/app/app.py index a2ae932..9acb190 100644 --- a/src/app/app.py +++ b/src/app/app.py @@ -38,7 +38,7 @@ class BaseApplication(web.Application): super().__init__(*args, **kwargs) def run(self, *args, **kwargs): - web.run_app(self,*args,**kwargs) + web.run_app(self, *args, **kwargs) async def authenticate(self, username, password): return self.username == username and self.password == password @@ -109,7 +109,7 @@ class WebDbApplication(BaseApplication): self.db_web = db_web self.db_path = db_path self.db = db or dataset.connect(self.db_path) - + super().__init__(*args, **kwargs) if not self.db_web: return @@ -122,9 +122,9 @@ class WebDbApplication(BaseApplication): self.router.add_post("/db/get", self.get_handler) self.router.add_post("/db/set", self.set_handler) - async def set_handler(self,request): + async def set_handler(self, request): obj = await request.json() - response = await self.set(obj.get("key"),obj.get("value")) + response = await self.set(obj.get("key"), obj.get("value")) return web.json_response(response) async def get_handler(self, request): @@ -153,7 +153,7 @@ class WebDbApplication(BaseApplication): async def find_handler(self, request): obj = await request.json() - response = await self.find(obj.get("table"), obj.get("where", {})) + response = await self.find(obj.get("table"), obj.get("where", {})) return web.json_response(response) async def find_one_handler(self, request): diff --git a/src/app/cli.py b/src/app/cli.py index 994a58e..4ca943a 100644 --- a/src/app/cli.py +++ b/src/app/cli.py @@ -30,7 +30,7 @@ async def bench(url): while True: index += 1 try: - async with session.get(url.rstrip("/") + "/stat") as response: + async with session.get(url.rstrip("/") + "/stat"): pass time_end = time.time() duration = time_end - time_start @@ -39,7 +39,10 @@ async def bench(url): except Exception as ex: log.exception(ex) await asyncio.sleep(1) - log.info("{} requests per second. Made {} requests in total in duration of {} seconds.".format(index/duration_limit,index,duration)) + log.info( + f"{index / duration_limit} requests per second. Made {index} requests in total in duration of {duration} seconds." + ) + def cli_bench(): args = parse_args() diff --git a/src/app/repl.py b/src/app/repl.py index c8546cf..65218a7 100644 --- a/src/app/repl.py +++ b/src/app/repl.py @@ -2,15 +2,13 @@ from IPython.terminal.embed import InteractiveShellEmbed def repl(**kwargs): - from .app import Application + variables = {} variables.update(globals().copy()) variables.update(locals()) variables.update(kwargs) - - shell = InteractiveShellEmbed( - exit_msg="Exiting..." - ) + + shell = InteractiveShellEmbed(exit_msg="Exiting...") shell(local_ns=variables)