Added http headers in Intent model

Author: alfredfrancis

app/endpoint/controllers.py

@@ -169,7 +169,8 @@ def api():
             if intent.apiTrigger:
                 isJson = False
                 parameters = result_json["extractedParameters"]
-
+                headers = intent.apiDetails.get_headers()
+                app.logger.info("headers %s"%headers)
                 url_template = Template(
                     intent.apiDetails.url, undefined=SilentUndefined)
                 rendered_url = url_template.render(**context)
@@ -181,7 +182,7 @@ def api():
 
                 try:
                     result = call_api(rendered_url,
-                                      intent.apiDetails.requestType,
+                                      intent.apiDetails.requestType,headers,
                                       parameters, isJson)
                 except Exception as e:
                     app.logger.warn("API call failed", e)

app/endpoint/utils.py

@@ -22,7 +22,7 @@ def get_synonyms():
     app.logger.info("loaded synonyms %s",synonyms)
     return synonyms
 
-def call_api(url, type, parameters = {}, is_json=False):
+def call_api(url, type,headers={}, parameters = {}, is_json=False):
     """
     Call external API
     :param url:
@@ -33,19 +33,19 @@ def call_api(url, type, parameters = {}, is_json=False):
     """
     app.logger.info("Initiating API Call with following info: url => {} payload => {}".format(url,parameters))
     if "GET" in type:
-            response = requests.get(url, params=parameters)
+            response = requests.get(url,headers=headers, params=parameters)
     elif "POST" in type:
         if is_json:
-            response = requests.post(url, json=parameters)
+            response = requests.post(url,headers=headers, json=parameters)
         else:
-            response = requests.post(url, params=parameters)
+            response = requests.post(url,headers=headers, params=parameters)
     elif "PUT" in type:
         if is_json:
-            response = requests.put(url, json=parameters)
+            response = requests.put(url,headers=headers, json=parameters)
         else:
-            response = requests.put(url, params=parameters)
+            response = requests.put(url,headers=headers, params=parameters)
     elif "DELETE" in type:
-        response = requests.delete(url, params=parameters)
+        response = requests.delete(url,headers=headers, params=parameters)
     else:
         raise Exception("unsupported request method.")
     result = json.loads(response.text)

app/intents/controllers.py

@@ -36,6 +36,7 @@ def create_intent():
             api_details.jsonData = content.get("apiDetails").get("jsonData")
 
         api_details.url = content.get("apiDetails").get("url")
+        api_details.headers = content.get("apiDetails").get("headers")
         api_details.requestType = content.get("apiDetails").get("requestType")
         intent.apiDetails = api_details
     else:

app/intents/models.py

@@ -30,9 +30,15 @@ class ApiDetails(EmbeddedDocument):
             "DELETE",
             "PUT"],
         required=True)
+    headers = ListField(default=[])
     isJson = BooleanField(default=False)
     jsonData = StringField(default="{}")
 
+    def get_headers(self):
+        headers = {}
+        for header in self.headers:
+            headers[header["headerKey"]]=header["headerValue"]
+        return headers
 
 class Intent(Document):
     name = StringField(max_length=100, required=True, unique=True)