add get_job_status method (#223)

thehive4py/api.py

@@ -4,7 +4,6 @@
 import json
 import sys
 
-import magic
 import os
 import warnings
 import json
@@ -1152,6 +1151,28 @@ def run_analyzer(self, cortex_id, artifact_id, analyzer_id):
         except requests.exceptions.RequestException as e:
             raise TheHiveException("Analyzer run error: {}".format(e))
 
+    def get_job_status(self, job_id):
+        """
+        Get the job status previously launched
+
+        Arguments:
+            job_id: Analysis job ID
+            
+            
+        Returns:
+            response (requests.Response): Response object including a JSON representation of the analysis job
+
+        Raises:
+            TheHiveException: An error occured during job fetch
+        """
+
+        req = self.url + "/api/connector/cortex/job/{job_id}?nstats=true".format(job_id = job_id)
+
+        try:
+            return requests.get(req, headers={'Content-Type': 'application/json'}, proxies=self.proxies, auth=self.auth, verify=self.cert)
+        except requests.exceptions.RequestException as e:
+            raise TheHiveException("Analyzer run error: {}".format(e))
+
     def find_tasks(self, **attributes):
         """
         Find case tasks using sort, pagination and a query
@@ -1406,4 +1427,4 @@ def update_alert_artifact(self, artifact_id, alert_artifact, fields=[]):
         try:
             return requests.patch(req, headers={'Content-Type': 'application/json'}, json=data, proxies=self.proxies, auth=self.auth, verify=self.cert)
         except requests.exceptions.RequestException as e:
-            raise CaseObservableException("Case observable update error: {}".format(e))
+            raise CaseObservableException("Case observable update error: {}".format(e))