Skip to content

Commit fa4dcaf

Browse files
committed
Added: Findall func to get all documents from collation use FindAll
1 parent e8dd6c8 commit fa4dcaf

1 file changed

Lines changed: 35 additions & 1 deletion

File tree

src/query/queries.ts

Lines changed: 35 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -73,6 +73,11 @@ class MongoDB {
7373
return this.db.collection(name);
7474
}
7575

76+
async getAll(collection: string, limit: number = 100) {
77+
return await this.collection(collection).find().limit(limit).toArray();
78+
}
79+
80+
7681
async findOne(collection: string, query: any) {
7782
return this.collection(collection).findOne(query);
7883
}
@@ -192,7 +197,8 @@ export async function FindOne(
192197
) {
193198
try {
194199
const result = await mongo.findOne(collection, query);
195-
return handleCallbackAndError(formatResult(result), callback);
200+
/* return handleCallbackAndError(formatResult(result), callback); */
201+
return result
196202
} catch (error) {
197203
return handleError(error, callback);
198204
}
@@ -211,6 +217,34 @@ export async function FindMany(
211217
}
212218
}
213219

220+
221+
export async function FindAll(
222+
collection: string,
223+
limit: number,
224+
callback?: Function
225+
) {
226+
try {
227+
228+
const result = await mongo.getAll(collection, limit);
229+
230+
231+
const formatted = result.map(formatResult);
232+
233+
if (callback) {
234+
return callback(null, formatted); // Success via callback
235+
}
236+
237+
return formatted; // Success via return
238+
} catch (error) {
239+
if (callback) {
240+
return callback(error); // Error via callback
241+
}
242+
243+
throw error; // Error via exception
244+
}
245+
}
246+
247+
214248
export async function UpdateOne(
215249
collection: string,
216250
query: string,

0 commit comments

Comments
 (0)