new columns for demon usage record

Author: pratik-vii

metering/requirements.txt

@@ -5,4 +5,5 @@ PyMySQL==0.9.3
 python-dateutil==2.8.0
 python-editor==1.0.4
 six==1.12.0
-SQLAlchemy==1.3.6
+SQLAlchemy==1.3.6
+requests==2.22.0

metering/services.py

@@ -1,6 +1,15 @@
+import requests
+
+from settings import MARKETPLACE_CHANNEL_USER_URL
 from storage import DatabaseStorage
 
 
+def is_free_call(usage_details_dict):
+    if not usage_details_dict['username'] or len(usage_details_dict['username']):
+        return False
+    return True
+
+
 class UsageService(object):
     storage_service = DatabaseStorage()
 
@@ -18,5 +27,25 @@ def get_free_call_details(self, username, org_id, service_id, group_id=None):
 
     def save_usage_details(self, usage_details_dict):
         # nedd to introduce entities when we enhance  feature to this service right now directly using dicts
+        if is_free_call(usage_details_dict):
+            channel_id = usage_details_dict['channel_id']
+            group_id = usage_details_dict['group_id']
+            username = APIUtilityService().get_user_name(channel_id, group_id)
+            usage_details_dict['username'] = username
         self.storage_service.add_usage_data(usage_details_dict)
         return
+
+
+class APIUtilityService:
+
+    @staticmethod
+    def get_user_name(channel_id, group_id):
+        url = MARKETPLACE_CHANNEL_USER_URL.format(group_id, channel_id)
+        response = requests.get(url)
+        user_data = response.json()
+        try:
+            username = user_data[0]['username']
+        except Exception as e:
+            print(e)
+            raise Exception("Failed to get username from marketplace")
+        return username