From 7ccced45aa43f540f6124bfb591180947cc85712 Mon Sep 17 00:00:00 2001
From: Richard Shephard <richard.shephard@gmail.com>
Date: Thu, 16 May 2019 13:57:11 +0200
Subject: [PATCH] Add reset endpoint

---
 index.d.ts                            |  1 +
 src/projections/projectionsClient.js  |  4 ++++
 src/projections/projectionsManager.js | 10 ++++++++++
 3 files changed, 15 insertions(+)

diff --git a/index.d.ts b/index.d.ts
index ff4940d..bed7feb 100644
--- a/index.d.ts
+++ b/index.d.ts
@@ -72,6 +72,7 @@ export class ProjectionsManager {
     enable(name: string, userCredentials: UserCredentials): Promise<void>;
     disable(name: string, userCredentials: UserCredentials): Promise<void>;
     abort(name: string, userCredentials: UserCredentials): Promise<void>;
+    reset(name: string, userCredentials: UserCredentials): Promise<void>;
     createOneTime(query: string, userCredentials: UserCredentials): Promise<void>;
     createTransient(name: string, query: string, userCredentials: UserCredentials): Promise<void>;
     createContinuous(name: string, query: string, trackEmittedStreams: boolean, userCredentials: UserCredentials): Promise<void>;
diff --git a/src/projections/projectionsClient.js b/src/projections/projectionsClient.js
index 781694a..4657b88 100644
--- a/src/projections/projectionsClient.js
+++ b/src/projections/projectionsClient.js
@@ -31,6 +31,10 @@ ProjectionsClient.prototype.abort = function(httpEndPoint, name, userCredentials
   return this.sendPost(httpEndPoint + '/projection/' + name + '/command/abort', '', userCredentials, HTTP_OK);
 };
 
+ProjectionsClient.prototype.reset = function(httpEndPoint, name, userCredentials) {
+  return this.sendPost(httpEndPoint + '/projection/' + name + 'command/reset', userCredentials, HTTP_OK);
+};
+
 ProjectionsClient.prototype.createOneTime = function(httpEndPoint, query, userCredentials) {
   return this.sendPost(httpEndPoint + '/projections/onetime?type=JS', query, userCredentials, HTTP_CREATED);
 };
diff --git a/src/projections/projectionsManager.js b/src/projections/projectionsManager.js
index f453d4b..47a8925 100644
--- a/src/projections/projectionsManager.js
+++ b/src/projections/projectionsManager.js
@@ -45,6 +45,16 @@ ProjectionsManager.prototype.abort = function(name, userCredentials) {
   return this._client.abort(this._httpEndPoint, name, userCredentials);
 };
 
+/**
+ * Reset a projection. (This will re-emit events, streams that are written to from the projection will also be soft deleted)
+ * @param name            The name of the projection.
+ * @param userCredentials Credentials for a user with permission to disable a projection.
+ * @returns {Promise<void>}
+ */
+ProjectionsManager.prototype.reset = function(name, userCredentials) {
+  return this._client.abort(this._httpEndPoint, name, userCredentials);
+};
+
 /**
  * Creates a one-time query.
  * @param query           The JavaScript source code for the query.