v1.5.2

package.json

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

src/MariaDB.ts

@@ -13,9 +13,12 @@ type Credentials = {
     host: string,
     port: number,
     database: string,
-    node: string
 }
 
+type ExtendedCredentials = {
+    node: string
+} & Credentials
+
 export type MariaOptions = {
     load?: boolean,
     cluster?: PoolClusterConfig,
@@ -86,7 +89,7 @@ class MariaDB
     #load: boolean;
 
     #config: MariaOptions;
-    #credentials: Credentials[];
+    #credentials: ExtendedCredentials[];
     #cluster: boolean;
     #pool: PoolCluster | null;
     #nodes: Node[];

src/MessageBroker.ts

@@ -255,7 +255,7 @@ class MessageBroker
     }
 
     // Subscribe to exchange, ensures messages aren't lost by binding it to a queue
-    async subscribe<T> (name: string, listener: Subscriber<T | Buffer>) 
+    async subscribe<T> (name: string, listener: Subscriber<T>) 
     {
         if (!this.#channel)
             throw new Error('Channel does not exist');
@@ -270,7 +270,7 @@ class MessageBroker
 
     }
 
-    private async _subscribe<T> (name: string, listener: Subscriber<T | Buffer>): Promise<void> 
+    private async _subscribe<T> (name: string, listener: Subscriber<T>): Promise<void> 
     {
         if (!this.#channel) 
             return Promise.reject(new Error('Channel doesn\'t exist'));
@@ -283,8 +283,10 @@ class MessageBroker
         {
             if (msg.content && msg.content.toString().startsWith('{'))
                 await listener(JSON.parse(msg.content.toString()), msg);
-            else 
-                await listener(msg.content, msg);
+            else
+                // TODO: Figure out how to do this and remaing logically consistent
+                throw new Error('Malformed content');
+                // await listener(msg.content, msg);
             this.#channel?.ack(msg);
         });
     }