DP-1504 : update movai-core-shared (#201)

* Update setup.py

* update movai-core-shared, fix function names, lint

.pre-commit-config.yaml

@@ -18,7 +18,7 @@ repos:
     rev: 22.10.0
     hooks:
     - id: black
-      args: ["--line-length=120", "-S"]
+      args: ["--line-length=100", "-S"]
 
   - repo: https://github.com/pycqa/flake8    # static tests Python code
     rev: 5.0.4

backend/core/log_streaming/log_client.py

@@ -100,9 +100,7 @@ async def listen_to_client_msgs(self):
         async for msg in self._ws:
             if msg.type == WSMsgType.TEXT:
                 if msg.data == "close":
-                    self._logger.debug(
-                        "closing the websocket connection for client id: {self._id}"
-                    )
+                    self._logger.debug("closing the websocket connection for client id: {self._id}")
                     await self._ws.close()
             elif msg.type == WSMsgType.ERROR:
                 self._logger.error(

backend/core/log_streaming/log_streamer.py

@@ -23,6 +23,7 @@
 
 ZMQ_PUBLISHER_ADDR = f"tcp://message-server:{MESSAGE_SERVER_LOG_PUBLISHER_PORT}"
 
+
 class LogStreamer:
     def __init__(self, debug: bool = False) -> None:
         """Initializes the object.
@@ -32,7 +33,9 @@ def __init__(self, debug: bool = False) -> None:
         """
         self._debug = debug
         self._logger = logging.getLogger(self.__class__.__name__)
-        self._subscriber: AsyncZMQSubscriber = ZMQManager.get_client(ZMQ_PUBLISHER_ADDR, ZMQType.ASYNC_SUBSCRIBER)
+        self._subscriber: AsyncZMQSubscriber = ZMQManager.get_client(
+            ZMQ_PUBLISHER_ADDR, ZMQType.ASYNC_SUBSCRIBER
+        )
         self._clients = {}
         self._running = False
 
@@ -105,9 +108,9 @@ async def handle(self, request: dict) -> dict:
 
     async def listen(self):
         while self._running:
-            msg = await self._subscriber.recieve()
+            msg = await self._subscriber.receive()
             await self.handle(msg)
-            
+
     def start(self):
         self._running = True
         self._logger.info("starting log streamer server!")

backend/docs/git-v2-2.4.yaml

@@ -62,7 +62,7 @@ paths:
           schema:
             type: string
           description: relative path of the desired file inside the repo.
-      responses: 
+      responses:
         "200":
           description: a model json object. schema can be found in dal/validation/schema/
         "400":
@@ -107,7 +107,7 @@ paths:
           schema:
             type: string
           description: relative path of the desired file inside the repo.
-      responses: 
+      responses:
         "200":
           description: commit_sha
           content:
@@ -157,7 +157,7 @@ paths:
           schema:
             type: string
           description: relative path of the desired file inside the repo.
-      responses: 
+      responses:
         "200":
           description: commit_sha, the new commit created.
           content:
@@ -194,7 +194,7 @@ paths:
             type: string
         - in: path
           description: the project id.
-          name: project 
+          name: project
           required: true
           schema:
             type: string
@@ -210,7 +210,7 @@ paths:
           schema:
             type: string
           description: relative path of the desired file inside the repo.
-      responses: 
+      responses:
         "200":
           description: a model json object. schema can be found in dal/validation/schema/.
         "400":
@@ -242,7 +242,7 @@ paths:
             type: string
         - in: path
           description: the project id.
-          name: project 
+          name: project
           required: true
           schema:
             type: string
@@ -404,7 +404,7 @@ paths:
         "403":
           description: Git Server Permission Error or SSH key not found on system.
         "404":
-          description: File or repository NOT Found, the reason will be attached to 
+          description: File or repository NOT Found, the reason will be attached to
 
 
   /{remote}/{user}/{project}/version/{base_version}/{tag}:

backend/docs/notifications-v2-2.4.yaml

@@ -47,10 +47,10 @@ paths:
               recipients: ["[email protected]"]
               subject: "Error on Tugbot 8"
               body: "reset robot by pressing Emergency button"
-      responses: 
+      responses:
         "200":
           description: a model json object. schema can be found in dal/validation/schema/
- 
+
   /user:
     post:
       summary: send a user notification message.
@@ -80,8 +80,7 @@ paths:
             example:
               robot_name: ["tugbot2"]
               msg: "Error on Tugbot 8"
-      
-      responses: 
+
+      responses:
         "200":
           description: notification pushed successfully to the redis.
-

backend/endpoints/api/v1/__init__.py

@@ -13,4 +13,3 @@
    Root module of API web modules
 """
 from . import v1
-

backend/endpoints/api/v1/frontend/__init__.py

@@ -3,16 +3,7 @@
 from .taskmanager import taskmanager_action_map, taskmanager_enterprise_map
 
 frontend_map = {
-    "fleetmanager": {
-        "action": fleetmanager_action_map,
-        "enterprise": fleetmanager_enterprise_map
-    },
-    "ide": {
-        "action": ide_action_map,
-        "enterprise": ide_enterprise_map
-    },
-    "taskmanager": {
-        "action": taskmanager_action_map,
-        "enterprise": taskmanager_enterprise_map
-    }
+    "fleetmanager": {"action": fleetmanager_action_map, "enterprise": fleetmanager_enterprise_map},
+    "ide": {"action": ide_action_map, "enterprise": ide_enterprise_map},
+    "taskmanager": {"action": taskmanager_action_map, "enterprise": taskmanager_enterprise_map},
 }

backend/endpoints/api/v1/frontend/fleetmanager/__init__.py

@@ -22,7 +22,7 @@
     # Tasks
     "getTasks": Tasks.get_tasks,
     "saveTask": Tasks.save_task,
-    "deleteTask": Tasks.delete_task
+    "deleteTask": Tasks.delete_task,
 }
 
 fleetmanager_enterprise_map = {
@@ -33,5 +33,5 @@
     # Tasks
     "getTasks": Tasks.get_tasks,
     "saveTask": Tasks.save_task,
-    "deleteTask": Tasks.delete_task
+    "deleteTask": Tasks.delete_task,
 }

backend/endpoints/api/v1/frontend/taskmanager/__init__.py

@@ -18,5 +18,5 @@
     # Api
     "gen_task": on_gen_task,
     # genereate_sde
-    "gen_shared_data_entries": gen_shared_data_entries
+    "gen_shared_data_entries": gen_shared_data_entries,
 }

backend/endpoints/api/v1/frontend/taskmanager/api.py

@@ -11,7 +11,9 @@
 try:
     from movai_core_enterprise.gdnode.taskgenerator import TaskGenerator
 except ImportError:
-    LOGGER.warning("Failed to import TaskGenerator, because movai_core_enterprise is not installed.")
+    LOGGER.warning(
+        "Failed to import TaskGenerator, because movai_core_enterprise is not installed."
+    )
 
 
 def on_gen_task():

backend/endpoints/api/v1/frontend/taskmanager/generate_sde.py

@@ -19,7 +19,9 @@
 try:
     from movai_core_enterprise.scopes.shareddataentry import SharedDataEntry
 except ImportError:
-    LOGGER.warning("Failed to import SharedDataEntry, because movai_core_enterprise is not installed.")
+    LOGGER.warning(
+        "Failed to import SharedDataEntry, because movai_core_enterprise is not installed."
+    )
 
 
 def get_falsy_values(data_type="str"):

backend/endpoints/api/v1/restapi.py

@@ -169,7 +169,9 @@ async def frontend_apps(self, request: web.Request):
                 raise ValueError("the 'func' argument is missing in request's body!")
 
             if func not in action_map:
-                raise ValueError(f"{func} unknown function, it is not found in the {app} action map.")
+                raise ValueError(
+                    f"{func} unknown function, it is not found in the {app} action map."
+                )
 
             if func in enterprise_map and not is_enterprise():
                 raise NotSupported(f"The {func} method is not supported for community edition.")

backend/endpoints/api/v1/robot_reovery.py

@@ -45,10 +45,7 @@ def recovery_timeout(robot_id):
         recovery_state = var_scope.get(RECOVERY_STATE_KEY)
 
         if recovery_state == RecoveryStates.PUSHED.name:
-            response = {
-                "success": False,
-                "message": "Failed to recover robot"
-            }
+            response = {"success": False, "message": "Failed to recover robot"}
             var_scope.set(RECOVERY_RESPONSE_KEY, response)
             var_scope.set(RECOVERY_STATE_KEY, RecoveryStates.NOT_AVAILABLE.name)
     except Exception as exc:

backend/endpoints/api/v1/v1.py

@@ -69,7 +69,7 @@ def routes(self) -> List[web.RouteDef]:
             web.get(r"/{scope:%s}/" % REST_SCOPES, self._rest_api.get_scope),
             web.post(r"/{scope:%s}/" % REST_SCOPES, self._rest_api.post_to_scope),
             web.get(r"/callback-builtins/", self._rest_api.get_callback_builtins),
-            web.post(r"/frontend/{app}/", self._rest_api.frontend_apps)
+            web.post(r"/frontend/{app}/", self._rest_api.frontend_apps),
         ]
 
     @property

backend/endpoints/api/v2/__init__.py

@@ -18,4 +18,3 @@
 from . import ldapconfig
 from . import notifications
 from . import role
-

backend/endpoints/api/v2/alerts.py

@@ -45,7 +45,7 @@ def db_get(cls) -> "AlertsConfig":
 
     def db_set(self) -> None:
         """
-        Set current alerts config object in global Var with the recieved dict
+        Set current alerts config object in global Var with the received dict
         """
         setattr(self.Meta.var, self.Meta.ALERTS_GLOBAL_VAR_STR, self.dict())
 

backend/endpoints/api/v2/base.py

@@ -109,13 +109,11 @@ def extract_object(self, exception: MovaiException = DoesNotExist):
                 raise exception(error_msg)
 
     async def extract_data(self):
-        """Extracts payload data from the request.
-        """
+        """Extracts payload data from the request."""
         self._data = await self._request.json()
 
     async def extract_params(self):
-        """Extract parametes from query string.
-        """
+        """Extract parametes from query string."""
         for param in self._request.query_string.split("&"):
             name, value = param.split("=")
             self._params[name] = value

backend/endpoints/auth.py

@@ -248,5 +248,4 @@ def get_domains(self, request: web.Request) -> web.Response:
         return web.json_response(output, headers={"Server": "Movai-server"})
 
 
-
 WebAppManager.register("/auth/", AuthApp)

backend/endpoints/ws.py

@@ -60,7 +60,7 @@ def routes(self) -> List[web.RouteDef]:
         return [
             web.get("/widget/support", self.test_support),
             web.get(self.redis_sub.http_endpoint, self.redis_sub.handler),
-            web.get("/logs", stream_logs)
+            web.get("/logs", stream_logs),
         ]
 
     @property

backend/helpers/rest_helpers.py

@@ -1,5 +1,6 @@
 from aiohttp import web
 
+
 def deprecate_endpoint() -> None:
     """This is a helper function to deprecate unused functions
 
@@ -8,6 +9,7 @@ def deprecate_endpoint() -> None:
     """
     raise web.HTTPForbidden(reason="This endpoint is deprecated")
 
+
 def fetch_request_params(request: dict) -> dict:
     """fetches the params from the request and returns them in a dictionary.
 
@@ -26,4 +28,4 @@ def fetch_request_params(request: dict) -> dict:
         else:
             name, value = request.query_string.split("=")
             params[name] = value
-    return params
+    return params

docs/api/v2/email_alerts.yaml

@@ -77,7 +77,7 @@ paths:
               schema:
                 type: array
                 items:
-                  type: string 
+                  type: string
               example:
                 ["Battery", "Temparature"]
 components:
@@ -109,4 +109,3 @@ components:
           type: array
           items:
             type: string
-

setup.py

@@ -12,9 +12,9 @@
     "PyYAML==6.0",
     "email-validator==2.0.0",
     "pytz==2022.7.1",
-    "movai-core-shared==2.5.0.16",
+    "movai-core-shared==2.5.0.17",
     "data-access-layer==2.5.0.21",
-    "gd-node==2.5.0.17"
+    "gd-node==2.5.0.17",
 ]