add stored query update (PUT) method

README.md

@@ -210,6 +210,24 @@ Expects the following parameters:
 
 Returns [`Promise<HTTP.Body>`](#body)
 
+#### <a name="version">`server.version(version, conn)`</a>
+
+Returns a promise that resolves to `version`, or, the version of the server at
+`conn`. Returns `null` if neither parameter is provided.
+
+Used by other methods in this library to handle Stardog API breaking changes
+while avoiding an extra request when the caller knows the server's current
+version.
+
+Expects the following paramters:
+
+- version (`string`)
+
+- conn ([`Connection`](#connection))
+
+Returns [`Promise<string>`]
+
+
 ## <a name="db">db</a>
 
 #### <a name="create">`db.create(conn, database, databaseOptions, options, params)`</a>

lib/query/stored.js

@@ -1,6 +1,7 @@
 const { fetch } = require('../fetch');
 const lodashPick = require('lodash/pick');
-
+const server = require('../server');
+const semver = require('semver');
 const { httpBody } = require('../response-transforms');
 
 /*
@@ -45,8 +46,40 @@ const deleteStoredQuery = (conn, storedQuery, params) => {
   }).then(httpBody);
 };
 
+const updateStoredQuery = (conn, storedQuery, params, stardogVersion) => {
+  const headers = conn.headers();
+  headers.set('Content-Type', 'application/json');
+  headers.set('Accept', 'application/json');
+
+  const body = lodashPick(storedQuery, ['name', 'database', 'query', 'shared']);
+  body.creator = conn.username;
+  body.shared = typeof body.shared === 'boolean' ? body.shared : false;
+
+  return server.version(stardogVersion, conn).then(version => {
+    if (!version) {
+      return null;
+    } else if (semver.gte(version, '6.2.0')) {
+      return fetch(conn.request('admin', 'queries', 'stored'), {
+        headers,
+        method: 'PUT',
+        body: JSON.stringify(body),
+      }).then(httpBody);
+    }
+    return deleteStoredQuery(conn, storedQuery.name)
+      .then(() => create(conn, storedQuery, params))
+      .catch(deleteResponse => {
+        //  Update creates when the query did not already exist
+        if (deleteResponse.status === 404) {
+          return create(conn, storedQuery, params);
+        }
+        return deleteResponse;
+      });
+  });
+};
+
 module.exports = {
   create,
   list,
+  update: updateStoredQuery,
   remove: deleteStoredQuery,
 };

lib/server.js

@@ -25,7 +25,22 @@ const status = (conn, params = {}) => {
   ).then(httpBody);
 };
 
+const versionPromise = (version, conn) => {
+  if (version) {
+    return Promise.resolve(version);
+  } else if (conn) {
+    return status(conn, { databases: false }).then(
+      statusResponse =>
+        statusResponse.status === 200
+          ? statusResponse.body['dbms.version'].value
+          : null
+    );
+  }
+  return null;
+};
+
 module.exports = {
   shutdown,
   status,
+  version: versionPromise,
 };