feat: allow to filter deeploy jobs by project id (#342)

Author: aledefra

extensions/business/deeploy/deeploy_manager_api.py

@@ -123,7 +123,10 @@ def get_apps(
       sender, inputs = self.deeploy_verify_and_get_inputs(request)
       auth_result = self.deeploy_get_auth_result(inputs)
 
-      apps = self._get_online_apps(owner=auth_result[DEEPLOY_KEYS.ESCROW_OWNER])
+      apps = self._get_online_apps(
+        owner=auth_result[DEEPLOY_KEYS.ESCROW_OWNER],
+        project_id=inputs.get(DEEPLOY_KEYS.PROJECT_ID, None)
+      )
 
       result = {
         DEEPLOY_KEYS.STATUS : DEEPLOY_STATUS.SUCCESS,

extensions/business/deeploy/deeploy_mixin.py

@@ -2383,7 +2383,7 @@ def delete_pipeline_from_nodes(self, app_id=None, job_id=None, owner=None, allow
     #endfor each target node
     return discovered_instances
 
-  def _get_online_apps(self, owner=None, target_nodes=None, job_id=None):
+  def _get_online_apps(self, owner=None, target_nodes=None, job_id=None, project_id=None):
     """
     if self.cfg_deeploy_verbose:
       full_data = self.netmon.network_known_nodes()
@@ -2425,6 +2425,14 @@ def _get_online_apps(self, owner=None, target_nodes=None, job_id=None):
             continue
           filtered_result[node][app_name] = app_data
       result = filtered_result
+    if project_id is not None:
+      filtered_result = self.defaultdict(dict)
+      for node, apps in result.items():
+        for app_name, app_data in apps.items():
+          if app_data.get(NetMonCt.DEEPLOY_SPECS, {}).get(DEEPLOY_KEYS.PROJECT_ID, None) != project_id:
+            continue
+          filtered_result[node][app_name] = app_data
+      result = filtered_result
     return result
 
   # TODO: REMOVE THIS, once instance_id is coming from ui for instances that have to be updated

ver.py

@@ -1 +1 @@
-__VER__ = '2.9.992'
+__VER__ = '2.9.993'