feat: add logic for search all regions

Author: jihyungSong

src/spaceone/monitoring/connector/__init__.py

@@ -1 +1,2 @@
 from spaceone.monitoring.connector.cloudtrail_connector import CloudTrailConnector
+from spaceone.monitoring.connector.ec2_connector import EC2Connector

src/spaceone/monitoring/connector/ec2_connector.py

@@ -0,0 +1,16 @@
+import logging
+from spaceone.core.utils import load_json
+from spaceone.monitoring.libs.connector import AWSConnector
+
+_LOGGER = logging.getLogger(__name__)
+
+
+class EC2Connector(AWSConnector):
+    service = 'ec2'
+
+    def __init__(self, **kwargs):
+        super().__init__(**kwargs)
+
+    def describe_regions(self):
+        response = self.client.describe_regions()
+        return response.get('Regions', [])

src/spaceone/monitoring/manager/monitoring_manager.py

@@ -3,6 +3,7 @@
 from spaceone.core.manager import BaseManager
 from spaceone.monitoring.conf.monitoring_conf import *
 from spaceone.monitoring.connector.cloudtrail_connector import CloudTrailConnector
+from spaceone.monitoring.connector.ec2_connector import EC2Connector
 from spaceone.monitoring.model.log_model import Log, Event
 
 _LOGGER = logging.getLogger(__name__)
@@ -20,6 +21,13 @@ def list_logs(self, params):
             event_vos = self.set_events(events, keyword, resource_type)
             yield Log({'results': event_vos})
 
+    def list_regions(self, params):
+        ec2_connector: EC2Connector = self.locator.get_connector('EC2Connector', **params)
+        ec2_connector.set_client('us-east-1')
+
+        regions_info = ec2_connector.describe_regions()
+        return [region_info.get('RegionName') for region_info in regions_info if region_info.get('RegionName')]
+
     def lookup_events(self, params):
         events = []
 
@@ -33,6 +41,8 @@ def lookup_events(self, params):
             events.extend(_events)
 
         if resource_type == 'AWS::IAM::User':
+            region_names = self.list_regions(params)
+
             console_login_target_user_name = ''
             iam_user_params = copy.deepcopy(params)
             iam_user_params['query']['LookupAttributes'] = \
@@ -42,10 +52,12 @@ def lookup_events(self, params):
             if _lookup_attr:
                 console_login_target_user_name = _lookup_attr[0].get('AttributeValue', '')
 
-            for iam_user_events in cloudtrail_connector.lookup_events(iam_user_params):
-                for _user_event in iam_user_events:
-                    if _user_event.get('Username') == console_login_target_user_name:
-                        events.append(_user_event)
+            for region_name in region_names:
+                cloudtrail_connector.set_client(region_name)
+                for iam_user_events in cloudtrail_connector.lookup_events(iam_user_params):
+                    for _user_event in iam_user_events:
+                        if _user_event.get('Username') == console_login_target_user_name:
+                            events.append(_user_event)
 
             events = sorted(events, key=lambda event: event.get('EventTime'))