Navy.gif/wrappers
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

Compare commits

base: Navy.gif:17d9d124feb8856b8d27f3cfeb33c3cbed896a8a
Branches Tags
Navy.gif:main
..
compare: Navy.gif:37a54d993289b4b6e20f713ebbd586bb863ef91f
Branches Tags
Navy.gif:main

No commits in common. "17d9d124feb8856b8d27f3cfeb33c3cbed896a8a" and "37a54d993289b4b6e20f713ebbd586bb863ef91f" have entirely different histories.
17d9d124fe ... 37a54d9932

3 changed files with 8 additions and 8 deletions
Show Stats Expand all files Collapse all files

2
package.json
View File

@ -1,6 +1,6 @@
{ {
"name": "@navy.gif/wrappers", "name": "@navy.gif/wrappers",
"version": "1.3.18", "version": "1.3.16",
"description": "Various wrapper classes I use in my projects", "description": "Various wrapper classes I use in my projects",
"repository": "https://git.corgi.wtf/Navy.gif/wrappers.git", "repository": "https://git.corgi.wtf/Navy.gif/wrappers.git",
"author": "Navy.gif", "author": "Navy.gif",

6
src/MessageBroker.ts
View File

@ -300,13 +300,13 @@ class MessageBroker {
} }
} }
assertExchange (exchange: string, props?: ExchangeDef) { assertExchange (exchange: string, props: ExchangeDef) {
if (!this.#channel) if (!this.#channel)
throw new Error('Channel doesn\'t exist'); throw new Error('Channel doesn\'t exist');
return this.#channel.assertExchange(exchange, props?.type ?? 'fanout', props); return this.#channel.assertExchange(exchange, props.type ?? 'fanout', props);
} }
assertQueue (queue: string, opts?: QueueDef) { assertQueue (queue: string, opts: QueueDef) {
if (!this.#channel) if (!this.#channel)
throw new Error('Channel doesn\'t exist'); throw new Error('Channel doesn\'t exist');
return this.#channel.assertQueue(queue, opts); return this.#channel.assertQueue(queue, opts);

8
src/MongoDB.ts
View File

@ -301,7 +301,7 @@ class MongoDB {
* @returns {object} * @returns {object}
* @memberof Database * @memberof Database
*/ */
random<T extends Document> (db: string, filter: Document = {}, amount = 1) { random (db: string, filter: Document = {}, amount = 1) {
if (!this.#db) if (!this.#db)
throw new Error(`MongoDB not connected`); throw new Error(`MongoDB not connected`);
@ -315,7 +315,7 @@ class MongoDB {
if (amount > 100) if (amount > 100)
amount = 100; amount = 100;
const cursor = this.#db.collection(db).aggregate<T>([{ $match: filter }, { $sample: { size: amount } }]); const cursor = this.#db.collection(db).aggregate([{ $match: filter }, { $sample: { size: amount } }]);
return cursor.toArray(); return cursor.toArray();
} }
@ -327,10 +327,10 @@ class MongoDB {
return result; return result;
} }
collection<T extends Document> (coll: string) { collection (coll: string) {
if (!this.#db) if (!this.#db)
throw new Error(`MongoDB not connected`); throw new Error(`MongoDB not connected`);
return this.#db.collection<T>(coll); return this.#db.collection(coll);
} }
count (coll: string, query: Document) { count (coll: string, query: Document) {