X-Git-Url: http://git.squeep.com/?a=blobdiff_plain;f=src%2Fdb%2Fbase.js;fp=src%2Fdb%2Fbase.js;h=21e26642fad6ab703ef5c0a7a094180b4b3d19bc;hb=28de4364128a4b03918a8cbe868009b5d427220a;hp=8d72d0fb88e2c63fa42e0a09773329147b86382e;hpb=3fae9b64c5c70ad52376558caa71db99778541b0;p=websub-hub diff --git a/src/db/base.js b/src/db/base.js index 8d72d0f..21e2664 100644 --- a/src/db/base.js +++ b/src/db/base.js @@ -76,7 +76,7 @@ class Database { * @param {String} method * @param {arguments} args */ - _notImplemented(method, args) { + _notImplemented(method, args) { this.logger.error(_fileScope(method), 'abstract method called', Array.from(args)); throw new DBErrors.NotImplemented(method); } @@ -89,7 +89,7 @@ class Database { * Some engines will also perform other initializations or async actions which * are easier handled outside the constructor. */ - async initialize() { + async initialize() { const _scope = _fileScope('initialize'); const currentSchema = await this._currentSchema(); @@ -416,7 +416,7 @@ class Database { * @param {String} callback * @param {*} topicId */ - async subscriptionGet(dbCtx, callback, topicId) { + async subscriptionGet(dbCtx, callback, topicId) { this._notImplemented('subscriptionGet', arguments); } @@ -442,7 +442,7 @@ class Database { * @param {String=} data.httpRemoteAddr * @param {String=} data.httpFrom */ - async subscriptionUpsert(dbCtx, data) { + async subscriptionUpsert(dbCtx, data) { this._notImplemented('subscriptionUpsert', arguments); } @@ -520,7 +520,7 @@ class Database { * @param {*} topicId * @returns {Boolean} */ - async topicFetchRequested(dbCtx, topicId) { + async topicFetchRequested(dbCtx, topicId) { this._notImplemented('topicPublish', arguments); } @@ -679,7 +679,7 @@ class Database { * @param {Boolean} claim * @returns {*} verificationId */ - async verificationInsert(dbCtx, verification) { + async verificationInsert(dbCtx, verification) { this._notImplemented('verificationInsert', arguments); } @@ -704,9 +704,9 @@ class Database { * @param {String} data.reason * @param {Boolean} data.isPublisherValidated */ - async verificationUpdate(dbCtx, verificationId, data) { + async verificationUpdate(dbCtx, verificationId, data) { this._notImplemented('verificationUpdate', arguments); - } + } /**