Skip to content
Snippets Groups Projects
Unverified Commit 403cbfe2 authored by Diego Sampaio's avatar Diego Sampaio Committed by GitHub
Browse files

refactor: remove deps from Imports model (#34505)

parent 79cba772
No related branches found
No related tags found
No related merge requests found
...@@ -3,7 +3,6 @@ import type { IImportsModel } from '@rocket.chat/model-typings'; ...@@ -3,7 +3,6 @@ import type { IImportsModel } from '@rocket.chat/model-typings';
import type { Db, Document, FindCursor, FindOptions, UpdateResult, IndexDescription } from 'mongodb'; import type { Db, Document, FindCursor, FindOptions, UpdateResult, IndexDescription } from 'mongodb';
import { BaseRaw } from './BaseRaw'; import { BaseRaw } from './BaseRaw';
import { ensureArray } from '../../../lib/utils/arrayUtils';
export class ImportsModel extends BaseRaw<IImport> implements IImportsModel { export class ImportsModel extends BaseRaw<IImport> implements IImportsModel {
constructor(db: Db) { constructor(db: Db) {
...@@ -40,10 +39,6 @@ export class ImportsModel extends BaseRaw<IImport> implements IImportsModel { ...@@ -40,10 +39,6 @@ export class ImportsModel extends BaseRaw<IImport> implements IImportsModel {
return this.updateMany({ valid: { $ne: false }, _id: { $ne: id } }, { $set: { valid: false } }); return this.updateMany({ valid: { $ne: false }, _id: { $ne: id } }, { $set: { valid: false } });
} }
invalidateOperationsNotInStatus(status: IImport['status'] | IImport['status'][]): Promise<UpdateResult | Document> {
return this.updateMany({ valid: { $ne: false }, status: { $nin: ensureArray(status) } }, { $set: { valid: false } });
}
findAllPendingOperations(options: FindOptions<IImport> = {}): FindCursor<IImport> { findAllPendingOperations(options: FindOptions<IImport> = {}): FindCursor<IImport> {
return this.find({ valid: true }, options); return this.find({ valid: true }, options);
} }
......
...@@ -8,7 +8,6 @@ export interface IImportsModel extends IBaseModel<IImport> { ...@@ -8,7 +8,6 @@ export interface IImportsModel extends IBaseModel<IImport> {
hasValidOperationInStatus(allowedStatus: IImport['status'][]): Promise<boolean>; hasValidOperationInStatus(allowedStatus: IImport['status'][]): Promise<boolean>;
invalidateAllOperations(): Promise<UpdateResult | Document>; invalidateAllOperations(): Promise<UpdateResult | Document>;
invalidateOperationsExceptId(id: string): Promise<UpdateResult | Document>; invalidateOperationsExceptId(id: string): Promise<UpdateResult | Document>;
invalidateOperationsNotInStatus(status: string | string[]): Promise<UpdateResult | Document>;
findAllPendingOperations(options: FindOptions<IImport>): FindCursor<IImport>; findAllPendingOperations(options: FindOptions<IImport>): FindCursor<IImport>;
increaseTotalCount(id: string, recordType: 'users' | 'channels' | 'messages', increaseBy?: number): Promise<UpdateResult>; increaseTotalCount(id: string, recordType: 'users' | 'channels' | 'messages', increaseBy?: number): Promise<UpdateResult>;
setOperationStatus(id: string, status: IImport['status']): Promise<UpdateResult>; setOperationStatus(id: string, status: IImport['status']): Promise<UpdateResult>;
......
0% Loading or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment