add container test

Author: amprix

main.py

@@ -1,20 +1,22 @@
 from piper.services import TestMessageAdder, StringValue
 from piper.envs import CurrentEnv
+from piper.configurations import get_configuration
 
 import asyncio
 from loguru import logger
-logger.add("file.log", level="INFO")
+logger.add("file.log", level="INFO", backtrace=True, diagnose=True, rotation='5 MB')
 
 if __name__ == '__main__':
+    cfg = get_configuration()
     loop = asyncio.get_event_loop()
     with CurrentEnv() as env:
         x = StringValue(value="hello, world")
-        adder = TestMessageAdder(appender="!", port=8788)
+        adder = TestMessageAdder(appender="!", port=cfg.docker_app_port)
         result = loop.run_until_complete(adder(x))
         print(result)
 
     x = StringValue(value="hello, world")
-    adder = TestMessageAdder(appender="!", port=8788)
+    adder = TestMessageAdder(appender="!", port=cfg.docker_app_port)
     result = loop.run_until_complete(adder(x))
     print(result)
     adder.rm_container()

piper/base/executors.py

@@ -68,7 +68,9 @@ async def __call__(self, *args, **kwargs):
             request_dict = inputs_to_dict(*args, **kwargs)
             print('request_dict', request_dict)
             async with aiohttp.ClientSession() as session:
-                async with session.post(f'http://{self.host}:{self.port}/{function}', json=request_dict) as resp:
+                url = f'http://{self.host}:{self.port}/{function}'
+                logger.info(f'run function with url {url} and data {request_dict}')
+                async with session.post(url, json=request_dict) as resp:
                     return await resp.json()
 
 

piper/configurations.py

@@ -1,10 +1,16 @@
 class Configuration:
     path = "/Users/olegsokolov/PycharmProjects/piper/applications"
     path = "/home/pavel/repo/piper_new_out/"
+    test_path = "/home/pavel/repo/piper_test_out/"
     piper_path = "piper"
     default_env = "docker"
+    docker_app_port = 8788
     env = None
 
+    # start time and counter
+    wait_on_iter = 0.5
+    n_iters = 10
+
 
 def get_configuration():
     return Configuration

tests/container_test.py

@@ -1,22 +1,26 @@
+import docker
 import os
 import sys
+import asyncio
 root_dir = os.path.join(os.path.realpath(os.path.pardir), 'piper')
 sys.path.insert(1, root_dir)
 
 from piper.utils import docker_utils as du
 from piper.envs import CurrentEnv
+from piper.envs import is_docker_env
+from piper.configurations import get_configuration
+from piper.base.executors import copy_piper, copy_scripts
+from piper.services import TestMessageAdder, StringValue
 
 def test_start_container():
-    with CurrentEnv() as env:
-        print(env)
-    assert True == True
+    cfg = get_configuration()
+    loop = asyncio.get_event_loop()
+    init_value = "TEST_container_"
+    x = StringValue(value=init_value)
+    need_result = f'{init_value}TEST'
+    adder = TestMessageAdder(appender="!", port=cfg.docker_app_port)
+    result = loop.run_until_complete(adder(x))
+    print(result)
+    adder.rm_container()
 
-# du.get_container('asba', 'dkfja')
-
-
-import os
-
-def test_dummy():
-    print(f'file {os.path.dirname(__file__)}')
-    print(f'name', os.path.dirname(__name__))
-    assert True == True
+    assert result.get('value') == need_result