adding message api call

Author: KittyJose

lib/connectionConfig.js

@@ -275,6 +275,7 @@ ConnectionConfig.prototype.graphURL = function(type, gid) {
     return this.branchBase('graph') + `/${type}/${gid}`
 }
 
+
 /**
  * Generate URL for get / set schema api endpoint
  */

lib/const.js

@@ -36,5 +36,6 @@ module.exports = Object.freeze({
     BRANCH: 'branch',
     ADD_CSV: 'add_csv',
     GET_CSV: 'get_csv',
-    UPDATE_CSV: 'update_csv'
+    UPDATE_CSV: 'update_csv',
+    MESSAGE: 'message'
 })

lib/dispatchRequest.js

@@ -100,6 +100,21 @@ function DispatchRequest(url, action, payload, local_auth, remote_auth = null) {
                     }
                     throw e
                 })
+        case CONST.MESSAGE:
+            if (payload) {
+                const ext = UTILS.URIEncodePayload(payload)
+                if (ext) url += `?api:message=${ext}`
+            }
+            return axiosInstance
+                .get(url, options)
+                .then(response => response.data)
+                .catch(err => {
+                    let e = new Error(ErrorMessage.getAPIErrorMessage(url, options, err))
+                    if (err.response && err.response.data) {
+                        e.data = err.response.data
+                    }
+                    throw e
+                })
         case CONST.ADD_CSV:
             options.headers = options.headers ? options.headers : {}
             options.headers['Content-Type'] = 'application/form-data'

lib/woqlClient.js

@@ -407,10 +407,10 @@ WOQLClient.prototype.insertCSV = function(csv_path, commitMsg, gtype, gid) {
         let commit = this.generateCommitInfo(commitMsg)
         const formData = new FormData();
         csv_path.map((item)=>{
-            if(typeof(item.name)=="string"){ // file objects 
+            if(typeof(item.name)=="string"){
                 formData.append(item.name, item)
             }
-            else { // string file paths
+            else {
                 let name = new String(item).substring(item.lastIndexOf('/') + 1);
                 var fr = new File([name], item, {type: "csv/text"});
                 formData.append(name, fr)
@@ -456,15 +456,37 @@ WOQLClient.prototype.updateCSV = function(csv, commitMsg, gtype, gid) {
  *
  * @param {string} csvName Name of csv to dump from the specified database to extract
  * @param {string} csvDirectory CSV output directory path. (defaults to current directory).
+ * @param {string} download flag to download csv file
  * @param {string} gtype Type of graph (instance|schema|inference)
  * @param {string} gid identifier.
  * @return {Promise} An API success message
  *
  */
-WOQLClient.prototype.getCSV = function(csvName, csvDirectory, gtype, gid) {
-    let options = {}
+WOQLClient.prototype.getCSV = function(csvName, download, gtype, gid) {
+    let options = {}, filePath
     options.name=csvName;
-    return this.dispatch(CONST.GET_CSV, this.connectionConfig.csvURL(gtype, gid), options)
+    return this.dispatch(CONST.GET_CSV, this.connectionConfig.csvURL(gtype, gid), options).then(results => {
+            if (download) {
+                const url=window.URL.createObjectURL(new Blob([results]));
+                const link=document.createElement('a');
+                link.href = url;
+                link.setAttribute('download', csvName);
+                document.body.appendChild(link);
+                link.click();
+            }
+            return results;
+        })
+}
+
+/**
+ * sends a message  to the server
+ * @param {string} msg - textual string
+ */
+WOQLClient.prototype.message = function(message) {
+    const url = this.api() + 'message'
+    return this.dispatch(CONST.MESSAGE, url, message).then(response => {
+        return response
+    })
 }