wip JSONStream

package.json

@@ -14,6 +14,7 @@
     "author": "sticksdev",
     "license": "MIT",
     "devDependencies": {
+        "@types/eventsource": "^1.1.11",
         "@types/jest": "^29.4.0",
         "@typescript-eslint/eslint-plugin": "^5.51.0",
         "@typescript-eslint/parser": "^5.51.0",
@@ -26,7 +27,8 @@
         "typescript": "^4.9.5"
     },
     "dependencies": {
-        "axios": "^1.3.2"
+        "axios": "^1.3.2",
+        "eventsource": "^2.0.2"
     },
     "scripts": {
         "compile": "tsc -p tsconfig.build.json",

src/classes/JSONStream.ts

@@ -0,0 +1,50 @@
+import { EventEmitter } from 'events';
+import EventSource from 'eventsource';
+import { IAPIJSONStreamResponse } from '../objects/APIStreamResponses';
+
+export class JSONStream {
+    emiiter: EventEmitter;
+    eventSoruce: EventSource;
+
+    constructor(url = 'https://notify.hep.gg', channel: string) {
+        this.emiiter = new EventEmitter();
+        this.eventSoruce = new EventSource(`${url}/${channel}/sse`);
+    }
+
+    /**
+     * A method to get the event emitter for this class
+     * @returns EventEmitter
+     */
+    async getEmitter() {
+        return this.emiiter;
+    }
+
+    /**
+     * Starts collecting the data from the SSE stream for the topic
+     * Use the getEmitter() method to get the event emitter and handle the events (message, error)
+     * @returns void
+     */
+    async start() {
+        this.eventSoruce.onerror = (error) => {
+            this.emiiter.emit('error', error);
+        };
+
+        this.eventSoruce.onmessage = (event) => {
+            this.emiiter.emit('message', JSON.parse(event.data));
+        };
+    }
+
+    /**
+     * Closes the connection to the SSE stream (if open)
+     * This can't be undone, so make sure you call this method when you're done with the stream
+     * @returns void
+     * @throws Error
+     */
+    async destory() {
+        if (this.eventSoruce.readyState === 0) {
+            throw new Error('Event source is already closed');
+        }
+
+        this.eventSoruce.close();
+    }
+}

src/main.ts

@@ -1,3 +1,4 @@
+import { JSONStream } from './classes/JSONStream';
 import { RESTNotifyClient } from './classes/REST';
 
 export class notifer {
@@ -7,3 +8,5 @@ export class notifer {
         this.REST = new RESTNotifyClient(url);
     }
 }
+
+export { JSONStream };