​
find

find = async <U extends T = T>(
  filter: Filter<U>,
  readConfig: ReadConfig & { page?: number; perPage?: number } = {},
  findOptions: FindOptions = {},
): Promise<FindResult<U>>

const { results: users, count: usersCount } = await userService.find(
  { status: 'active' },
);
Fetches documents that matches the filter. Returns an object with the following fields(FindResult):
FieldDescription
resultsdocuments, that matches the filter
counttotal number of documents, that matches the filter
pagesCounttotal number of documents, that matches the filter divided by the number of documents per page
Pass page and perPage params to get a paginated result. Otherwise, all documents will be returned. Parameters Returns Promise<FindResult<U>>.

​
findOne

findOne = async <U extends T = T>(
  filter: Filter<U>,
  readConfig: ReadConfig = {},
  findOptions: FindOptions = {},
): Promise<U | null>

const user = await userService.findOne({ _id: u._id });
Fetches the first document that matches the filter. Returns null if document was not found. Parameters Returns Promise<U | null>.

​
updateOne

updateOne = async <U extends T = T>(
  filter: Filter<U>,
  updateFilterOrFn: (doc: U) => Partial<U> | UpdateFilter<U>,
  updateConfig: UpdateConfig = {},
  updateOptions: UpdateOptions = {},
): Promise<U | null>

const updatedUserWithEvent = await userService.updateOne(
  { _id: u._id },
  (doc) => ({ fullName: 'Updated fullname' }),
);

const updatedUser = await userService.updateOne(
  { _id: u._id },
  (doc) => ({ fullName: 'Updated fullname' }),
  { publishEvents: false }
);

const updatedUserWithUpdateFilter = await userService.updateOne(
  { _id: u._id },
  { $set: { fullName: 'Updated fullname' }},
);
Updates a single document and returns it. Returns null if document was not found. Parameters Returns Promise<U | null>.

​
updateMany

updateMany = async <U extends T = T>(
  filter: Filter<U>,
  updateFilterOrFn: (doc: U) => Partial<U> | UpdateFilter<U>,
  updateConfig: UpdateConfig = {},
  updateOptions: UpdateOptions = {},
): Promise<U[]>

const updatedUsers = await userService.updateMany(
  { status: 'active' },
  (doc) => ({ isEmailVerified: true }),
);

const updatedUsersWithUpdateFilter = await userService.updateMany(
  { status: 'active' },
  { $set: { isEmailVerified: true } },
);
Updates multiple documents that match the query. Returns array with updated documents. Parameters Returns Promise<U[]>.

​
insertOne

insertOne = async <U extends T = T>(
  object: Partial<U>,
  createConfig: CreateConfig = {},
  insertOneOptions: InsertOneOptions = {},
): Promise<U>

const user = await userService.insertOne({
  fullName: 'John',
});
Inserts a single document into a collection and returns it. Parameters Returns Promise<U>.

​
insertMany

insertMany = async <U extends T = T>(
  objects: Partial<U>[],
  createConfig: CreateConfig = {},
  bulkWriteOptions: BulkWriteOptions = {},
): Promise<U[]>

const users = await userService.insertMany([
  { fullName: 'John' },
  { fullName: 'Kobe' },
]);
Inserts multiple documents into a collection and returns them. Parameters Returns Promise<U[]>.

​
deleteSoft

deleteSoft = async <U extends T = T>(
  filter: Filter<U>,
  deleteConfig: DeleteConfig = {},
  deleteOptions: DeleteOptions = {},
): Promise<U[]>

const deletedUsers = await userService.deleteSoft(
  { status: 'deactivated' },
);
Adds deletedOn field to the documents that match the query and returns them. Parameters Returns Promise<U[]>.

​
deleteOne

deleteOne = async <U extends T = T>(
  filter: Filter<U>,
  deleteConfig: DeleteConfig = {},
  deleteOptions: DeleteOptions = {},
): Promise<U | null>

const deletedUser = await userService.deleteOne(
  { _id: u._id },
);
Deletes a single document and returns it. Returns null if document was not found. Parameters Returns Promise<U | null>.

​
deleteMany

deleteMany = async <U extends T = T>(
  filter: Filter<U>,
  deleteConfig: DeleteConfig = {},
  deleteOptions: DeleteOptions = {},
): Promise<U[]>

const deletedUsers = await userService.deleteMany(
  { status: 'deactivated' },
);
Deletes multiple documents that match the query. Returns array with deleted documents. Parameters Returns Promise<U[]>.

​
replaceOne

replaceOne: (
  filter: Filter<T>,
  replacement: Partial<T>,
  readConfig: ReadConfig = {},
  replaceOptions: ReplaceOptions = {},
): Promise<UpdateResult | Document>

await usersService.replaceOne(
  { _id: u._id },
  { fullName: fullNameToUpdate },
);
Replaces a single document within the collection based on the filter. Doesn’t validate schema or publish events. Parameters Returns Promise<UpdateResult | Document>.

​
atomic.updateOne

updateOne: (
  filter: Filter<T>,
  updateFilter: UpdateFilter<T>,
  readConfig: ReadConfig = {},
  updateOptions: UpdateOptions = {},
): Promise<UpdateResult>

await userService.atomic.updateOne(
  { _id: u._id },
  { $set: { fullName: `${u.firstName} ${u.lastName}` } },
);
Updates a single document. Doesn’t validate schema or publish events. Parameters Returns Promise<UpdateResult>.

​
atomic.updateMany

updateMany: (
  filter: Filter<T>,
  updateFilter: UpdateFilter<T>,
  readConfig: ReadConfig = {},
  updateOptions: UpdateOptions = {},
): Promise<Document | UpdateResult>

await userService.atomic.updateMany(
  { firstName: { $exists: true }, lastName: { $exists: true } },
  { $set: { fullName: `${u.firstName} ${u.lastName}` } },
);
Updates all documents that match the specified filter. Doesn’t validate schema or publish events. Parameters Returns Promise<UpdateResult | Document>.

​
exists

exists(
  filter: Filter<T>,
  readConfig: ReadConfig = {},
  findOptions: FindOptions = {},
): Promise<boolean>

const isUserExists = await userService.exists(
  { email: '[email protected]' },
);
Returns true if document exists, otherwise false. Parameters Returns Promise<boolean>.

​
countDocuments

countDocuments(
  filter: Filter<T>,
  readConfig: ReadConfig = {},
  countDocumentOptions: CountDocumentsOptions = {},
): Promise<boolean>

const documentsCount = await userService.countDocuments(
  { status: 'active' },
);
Returns amount of documents that matches the query. Parameters Returns Promise<number>.

​
distinct

distinct(
  key: string,
  filter: Filter<T>,
  readConfig: ReadConfig = {},
  distinctOptions: DistinctOptions = {},
): Promise<any[]>

const statesList = await userService.distinct('states');
Returns distinct values for a specified field across a single collection or view and returns the results in an array. Parameters Returns Promise<any[]>.

​
aggregate

aggregate: (
  pipeline: any[],
  options: AggregateOptions = {},
): Promise<any[]>

const sortedActiveUsers = await userService.aggregate([
  { $match: { status: "active" } },
  { $sort: { firstName: -1, lastName: -1 } }
]);
Executes an aggregation framework pipeline and returns array with aggregation result of documents. Parameters Returns Promise<any[]>.

​
watch

watch: (
  pipeline: Document[] | undefined,
  options: ChangeStreamOptions = {},
): Promise<any>

const watchCursor = userService.watch();
Creates a new Change Stream, watching for new changes and returns a cursor. Parameters Returns Promise<any>.

​
drop

drop: (
  recreate: boolean = false,
): Promise<void>

await userService.drop();
Removes a collection from the database. The method also removes any indexes associated with the dropped collection. Parameters
  • recreate: boolean; Should create collection after deletion.
Returns Promise<void>.

​
indexExists

indexExists: (
  indexes: string | string[],
  indexInformationOptions: IndexInformationOptions = {},
): Promise<boolean>

const isIndexExists = await usersService.indexExists(index);
Checks if one or more indexes exist on the collection, fails on first non-existing index. Parameters Returns Promise<string | void>.

​
createIndex

createIndex: (
  indexSpec: IndexSpecification,
  options: CreateIndexesOptions = {},
): Promise<string | void>

await usersService.createIndex({ fullName: 1 });
Creates collection index. Parameters Returns Promise<string | void>.

​
createIndexes

createIndexes: (
  indexSpecs: IndexDescription[],
  options: CreateIndexesOptions = {},
): Promise<string[] | void>

await usersService.createIndexes([
  { key: { fullName: 1 } },
  { key: { createdOn: 1 } },
]);
Creates one or more indexes on a collection. Parameters Returns Promise<string[] | void>.

​
dropIndex

dropIndex: (
  indexName: string,
  options: DropIndexesOptions = {},
): Promise<void | Document>

await userService.dropIndex({ firstName: 1, lastName: -1 });
Removes the specified index from a collection. Parameters Returns Promise<void | Document>.

​
dropIndexes

dropIndexes: (
  options: DropIndexesOptions = {},
): Promise<void | Document>
Removes all but the _id index from a collection. 
await userService.dropIndexes();
Parameters Returns Promise<void | Document>.