adding csv api

Author: KittyJose

lib/connectionConfig.js

@@ -285,6 +285,17 @@ ConnectionConfig.prototype.triplesURL = function(type, gid) {
     return s
 }
 
+/**
+ * Generate URL for add / get csv api endpoint
+*/
+ConnectionConfig.prototype.csvURL = function(type, gid) {
+    var s = this.branchBase('csv')
+    const graphId = gid || 'main'
+    const gType = type || 'instance'
+    s += `/${gType}/${graphId}`
+    return s
+}
+
 /**
  * Generate URL for woql query api endpoint
  */

lib/const.js

@@ -34,4 +34,6 @@ module.exports = Object.freeze({
     REBASE: 'rebase',
     RESET: 'reset',
     BRANCH: 'branch',
+    ADD_CSV: 'add_csv',
+    GET_CSV: 'get_csv'
 })

lib/dispatchRequest.js

@@ -24,7 +24,7 @@ function btoaImplementation(str) {
  * @param {Object} payload data to be transmitted to endpoint
  * @param {String} key optional basic auth string to be passed
  */
-function DispatchRequest(url, action, payload, local_auth, remote_auth = null) {
+function DispatchRequest(url, action, payload, local_auth, remote_auth = null, files) {
     /*
      *CORS is only required when trying to fetch data from a browser,
      *as browsers by default will block requests to different origins
@@ -88,6 +88,22 @@ function DispatchRequest(url, action, payload, local_auth, remote_auth = null) {
                     }
                     throw e
                 })
+        case CONST.ADD_CSV:
+            options.headers = options.headers ? options.headers : {}
+            options.headers['Content-Type'] = 'multipart/form-data'
+            const formData = new FormData();
+            files.map((item)=>{
+                formData.append(item.name, item.file)
+            })
+            formData.append('payload', payload)
+            return axiosInstance
+                .put(url, formData, options)
+                .then(response => response.data)
+                .catch(err => {
+                    const e = new Error(ErrorMessage.getAPIErrorMessage(url, options, err))
+                    if (err.response && err.response.data) e.data = err.response.data
+                    throw e
+                })
         case CONST.INSERT_TRIPLES:
             options.headers = options.headers ? options.headers : {}
             options.headers['Content-Type'] = 'application/json'
@@ -98,7 +114,7 @@ function DispatchRequest(url, action, payload, local_auth, remote_auth = null) {
                     const e = new Error(ErrorMessage.getAPIErrorMessage(url, options, err))
                     if (err.response && err.response.data) e.data = err.response.data
                     throw e
-                })        
+                })
         default:
             options.headers = options.headers ? options.headers : {}
             options.headers['Content-Type'] = 'application/json'

lib/woqlClient.js

@@ -226,7 +226,7 @@ WOQLClient.prototype.resource = function(type, val) {
  * @param {object} config - see constructor for structure
  * @return {Promise}
  * @public
- * 
+ *
  */
 WOQLClient.prototype.connect = function(config) {
     if (config) this.connectionConfig.update(config)
@@ -369,7 +369,7 @@ WOQLClient.prototype.updateTriples = function(gtype, gid, turtle, commit_msg) {
 
 
 /**
- * Appends the passed turtle to the contents of a graph 
+ * Appends the passed turtle to the contents of a graph
  *
  * @param {string} gtype type of graph  |instance|schema|inference|
  * @param {string} gid TerminusDB Graph ID to update, main is the default value
@@ -393,6 +393,33 @@ WOQLClient.prototype.insertTriples = function(gtype, gid, turtle, commit_msg) {
     )
 }
 
+
+/**
+ * Appends the passed turtle to the contents of a graph
+ *
+ * @param {string} gtype type of graph  |instance|schema|inference|
+ * @param {string} gid TerminusDB Graph ID to update, main is the default value
+ * @param {string} csv is an array of csv file names
+ * @param {string} commit_msg Textual message describing the reason for the update
+ * @return {Promise}
+ */
+
+ //DispatchRequest(url, action, payload, local_auth, remote_auth = null, files) {
+WOQLClient.prototype.addCSV = function(gtype, gid, csv, commit_msg) {
+    if (commit_msg && csv) {
+        let commit = this.generateCommitInfo(commit_msg)
+        return this.dispatch(
+            CONST.ADD_CSV,
+            this.connectionConfig.dbURL(),
+            commit,
+            files=csv
+        )
+    }
+}
+
+
+
+
 /**
  * Executes a WOQL query on the specified database and returns the results
  *
@@ -586,7 +613,7 @@ WOQLClient.prototype._load_db_prefixes = function(dbs) {
                         ndb.prefix_pairs = {}
                     }
                     if(row['Prefix_'+j] && row['Prefix_'+j]['@value'] && row['IRI_'+j]["@value"]){
-                        ndb.prefix_pairs[row['Prefix_'+j]["@value"]] = row['IRI_'+j]["@value"] 
+                        ndb.prefix_pairs[row['Prefix_'+j]["@value"]] = row['IRI_'+j]["@value"]
                     }
                 }
             }
@@ -598,8 +625,8 @@ WOQLClient.prototype._load_db_prefixes = function(dbs) {
 /**
  * Not yet released - subject to change in parameters
  * The class frame API endpoint is not yet sufficiently stable for release
- * It should be considered unreliable and subject to change in parameters until 
- * it has been released 
+ * It should be considered unreliable and subject to change in parameters until
+ * it has been released
  */
 
 /**
@@ -621,12 +648,12 @@ WOQLClient.prototype.getClassFrame = function(cls) {
 
 
 /***
- * Server Version API 
+ * Server Version API
  * Note: the below endpoints are not part of the terminusdb desktop package
- * they belong to the server package version of the DB which is under construction. 
+ * they belong to the server package version of the DB which is under construction.
  * Until that package is released all of the below endpoints should be considered
  * as unreliable and subject to change - they are provided complete with the desktop
- * version to show users what is coming and to allow people to use them at their own risk 
+ * version to show users what is coming and to allow people to use them at their own risk
  * Any use of them should be considered unsupported and at your own risk
  */