Add URL for results report

Records the URL returned from testresults db.

Changes the URL ref from localhost to external and reports in
daily job.

Change-Id: I0068ea963671fb183779ac20592ba6933647eea0
JIRA: STORPERF-104
Signed-off-by: mbeierl <mark.beierl@dell.com>

4 files changed, 33 insertions, 18 deletions

diff --git a/storperf/db/job_db.py b/storperf/db/job_db.py
index 3d66be8..05160ec 100644
--- a/storperf/db/job_db.py
+++ b/storperf/db/job_db.py
@@ -7,11 +7,11 @@
 # http://www.apache.org/licenses/LICENSE-2.0
 ##############################################################################
 
-from sqlite3 import OperationalError
-from threading import Lock
 import calendar
 import logging
+from sqlite3 import OperationalError
 import sqlite3
+from threading import Lock
 import time
 import uuid
 
@@ -54,6 +54,14 @@ class JobDB(object):
             except OperationalError:
                 self.logger.debug("Job params table exists")
 
+            try:
+                cursor.execute('''CREATE TABLE job_summary
+                (job_id text,
+                summary text)''')
+                self.logger.debug("Created job table")
+            except OperationalError:
+                self.logger.debug("Job table exists")
+
             cursor.execute('SELECT * FROM jobs')
             cursor.execute('SELECT * FROM job_params')
             db.commit()
diff --git a/storperf/db/test_results_db.py b/storperf/db/test_results_db.py
index 038525f..a2f7038 100644
--- a/storperf/db/test_results_db.py
+++ b/storperf/db/test_results_db.py
@@ -52,10 +52,10 @@ def push_results_to_db(db_url, project, case_name,
             logger.debug(r)
             logger.debug(r.status_code)
             logger.debug(r.content)
-        return True
+        return json.loads(r.content)
     except Exception, e:
         logger.error("Error [push_results_to_db('%s', '%s', '%s', " +
                      "'%s', '%s', '%s', '%s', '%s', '%s')]:" %
                      (db_url, project, case_name, pod_name, version,
                       scenario, criteria, build_tag, details), e)
-        return False
+        return None
diff --git a/storperf/test_executor.py b/storperf/test_executor.py
index e6f0784..d46e0c7 100644
--- a/storperf/test_executor.py
+++ b/storperf/test_executor.py
@@ -43,6 +43,7 @@ class TestExecutor(object):
         self.end_time = None
         self.current_workload = None
         self.workload_status = {}
+        self.result_url = None
         self._queue_depths = [1, 4, 8]
         self._block_sizes = [512, 4096, 16384]
         self.event_listeners = set()
@@ -198,6 +199,7 @@ class TestExecutor(object):
 
         result['Status'] = status
         result['Workloads'] = self.workload_status
+        result['TestResultURL'] = self.result_url
 
         return result
 
@@ -303,6 +305,9 @@ class TestExecutor(object):
             self.logger.info("Completed workload %s" % (workload_name))
         self.logger.info("Completed job %s" % (self.job_db.job_id))
 
+        if self.result_url is not None:
+            self.logger.info("Results can be found at %s" % self.result_url)
+
         self.end_time = time.time()
         self._terminated = True
         self.broadcast_event()
diff --git a/storperf/utilities/data_handler.py b/storperf/utilities/data_handler.py
index 78708b5..b62d37b 100644
--- a/storperf/utilities/data_handler.py
+++ b/storperf/utilities/data_handler.py
@@ -9,14 +9,15 @@
 
 import logging
 import os
+from time import sleep
+import time
+
 from storperf.db import test_results_db
 from storperf.db.graphite_db import GraphiteDB
 from storperf.utilities import data_treatment as DataTreatment
 from storperf.utilities import dictionary
 from storperf.utilities import math as math
 from storperf.utilities import steady_state as SteadyState
-from time import sleep
-import time
 
 
 class DataHandler(object):
@@ -167,17 +168,18 @@ class DataHandler(object):
         if test_db is not None:
             self.logger.info("Pushing results to %s" % (test_db))
             try:
-                test_results_db.push_results_to_db(test_db,
-                                                   "storperf",
-                                                   test_case,
-                                                   start_time,
-                                                   end_time,
-                                                   self.logger,
-                                                   pod_name,
-                                                   version,
-                                                   scenario,
-                                                   criteria,
-                                                   build_tag,
-                                                   payload)
+                response = test_results_db.push_results_to_db(test_db,
+                                                              "storperf",
+                                                              test_case,
+                                                              start_time,
+                                                              end_time,
+                                                              self.logger,
+                                                              pod_name,
+                                                              version,
+                                                              scenario,
+                                                              criteria,
+                                                              build_tag,
+                                                              payload)
+                executor.result_url = response['href']
             except:
                 self.logger.exception("Error pushing results into Database")