package.json

@@ -1,6 +1,6 @@
 {
   "name": "@navy.gif/wrappers",
-  "version": "1.5.2",
+  "version": "1.5.0",
   "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,11 +13,8 @@ type Credentials = {
     host: string,
     port: number,
     database: string,
-}
-
-type ExtendedCredentials = {
     node: string
-} & Credentials
+}
 
 export type MariaOptions = {
     load?: boolean,
@@ -89,7 +86,7 @@ class MariaDB
     #load: boolean;
 
     #config: MariaOptions;
-    #credentials: ExtendedCredentials[];
+    #credentials: Credentials[];
     #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>) 
+    async subscribe<T> (name: string, listener: Subscriber<T | Buffer>) 
     {
         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>): Promise<void> 
+    private async _subscribe<T> (name: string, listener: Subscriber<T | Buffer>): Promise<void> 
     {
         if (!this.#channel) 
             return Promise.reject(new Error('Channel doesn\'t exist'));
@@ -283,10 +283,8 @@ class MessageBroker
         {
             if (msg.content && msg.content.toString().startsWith('{'))
                 await listener(JSON.parse(msg.content.toString()), msg);
-            else
+            else 
-                // TODO: Figure out how to do this and remaing logically consistent
+                await listener(msg.content, msg);
-                throw new Error('Malformed content');
-                // await listener(msg.content, msg);
             this.#channel?.ack(msg);
         });
     }