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; disable(name: string, userCredentials: UserCredentials): Promise; abort(name: string, userCredentials: UserCredentials): Promise; + reset(name: string, userCredentials: UserCredentials): Promise; createOneTime(query: string, userCredentials: UserCredentials): Promise; createTransient(name: string, query: string, userCredentials: UserCredentials): Promise; createContinuous(name: string, query: string, trackEmittedStreams: boolean, userCredentials: UserCredentials): Promise; diff --git a/src/projections/projectionsClient.js b/src/projections/projectionsClient.js index 781694a..6b569ee 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..6f33ad6 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 reset a projection. + * @returns {Promise} + */ +ProjectionsManager.prototype.reset = function(name, userCredentials) { + return this._client.reset(this._httpEndPoint, name, userCredentials); +}; + /** * Creates a one-time query. * @param query The JavaScript source code for the query.