diff --git a/packages/rocketchat-api/server/v1/chat.js b/packages/rocketchat-api/server/v1/chat.js index 2787ec2620e..f6f92ae0244 100644 --- a/packages/rocketchat-api/server/v1/chat.js +++ b/packages/rocketchat-api/server/v1/chat.js @@ -357,9 +357,10 @@ RocketChat.API.v1.addRoute('chat.getDeletedMessages', { authRequired: true }, { } else if (isNaN(Date.parse(since))) { throw new Meteor.Error('The "since" query parameter must be a valid date.'); } - const cursor = RocketChat.models.Messages.trashFindDeleted(new Date(since), { rid: roomId }, { + const cursor = RocketChat.models.Messages.trashFindDeletedAfter(new Date(since), { rid: roomId }, { skip: offset, limit: count, + fields: { _id: 1 }, }); const total = cursor.count(); diff --git a/packages/rocketchat-importer/server/classes/ImporterBase.js b/packages/rocketchat-importer/server/classes/ImporterBase.js index ffd06b45fe6..1db3c092052 100644 --- a/packages/rocketchat-importer/server/classes/ImporterBase.js +++ b/packages/rocketchat-importer/server/classes/ImporterBase.js @@ -99,7 +99,7 @@ export class Base { this.progress = new Progress(this.info.key, this.info.name); this.collection = RawImports; - const userId = Meteor.user()._id; + const userId = Meteor.userId(); const importRecord = Imports.findPendingImport(this.info.key); if (importRecord) { diff --git a/packages/rocketchat-importer/server/methods/downloadPublicImportFile.js b/packages/rocketchat-importer/server/methods/downloadPublicImportFile.js index b64c304609d..acfd35095f1 100644 --- a/packages/rocketchat-importer/server/methods/downloadPublicImportFile.js +++ b/packages/rocketchat-importer/server/methods/downloadPublicImportFile.js @@ -7,7 +7,6 @@ import http from 'http'; Meteor.methods({ downloadPublicImportFile(fileUrl, importerKey) { const userId = Meteor.userId(); - console.log(fileUrl); if (!userId) { throw new Meteor.Error('error-invalid-user', 'Invalid user', { method: 'downloadPublicImportFile' }); diff --git a/packages/rocketchat-importer/server/methods/uploadImportFile.js b/packages/rocketchat-importer/server/methods/uploadImportFile.js index 45d6d52a526..ded0e5c3ab8 100644 --- a/packages/rocketchat-importer/server/methods/uploadImportFile.js +++ b/packages/rocketchat-importer/server/methods/uploadImportFile.js @@ -30,9 +30,6 @@ Meteor.methods({ const readStream = RocketChatFile.bufferToStream(file); const writeStream = RocketChatImportFileInstance.createWriteStream(newFileName, contentType); - writeStream.on('end', Meteor.bindEnvironment(() => { - })); - readStream.pipe(writeStream); }, }); diff --git a/packages/rocketchat-lib/server/models/_Base.js b/packages/rocketchat-lib/server/models/_Base.js index d09b91760b0..5183d1f0e4e 100644 --- a/packages/rocketchat-lib/server/models/_Base.js +++ b/packages/rocketchat-lib/server/models/_Base.js @@ -128,10 +128,6 @@ class ModelsBase { return this._db.trashFindDeletedAfter(...args); } - trashFindDeleted(...args) { - return this._db.trashFindDeleted(...args); - } - processQueryOptionsOnResult(result, options = {}) { if (result === undefined || result === null) { return undefined; diff --git a/packages/rocketchat-lib/server/models/_BaseDb.js b/packages/rocketchat-lib/server/models/_BaseDb.js index 3c97bf1a574..4b739f8a1bf 100644 --- a/packages/rocketchat-lib/server/models/_BaseDb.js +++ b/packages/rocketchat-lib/server/models/_BaseDb.js @@ -376,15 +376,6 @@ class ModelsBaseDb extends EventEmitter { return trash.find(query, options); } - - trashFindDeleted(deletedAt, query = {}, options) { - query.__collection__ = this.name; - query._deletedAt = { - $gte: deletedAt, - }; - - return trash.find(query, options); - } } export default ModelsBaseDb;