added publishStream & unpublishStream methods

packages/streaming-server/src/managers/SessionsManager/index.js

@@ -1,6 +1,7 @@
 export default class SessionsManager {
     constructor() {
         this.sessions = {}
+        this.publicStreams = []
     }
 
     newSession = (id, session) => {
@@ -16,4 +17,16 @@ export default class SessionsManager {
 
         delete this.sessions[id]
     }
+
+    publishStream = (payload) => {
+        if (typeof payload !== "object") {
+            throw new Error("Payload must be an object")
+        }
+
+        this.publicStreams.push(payload)
+    }
+
+    unpublishStream = (id) => {
+        this.publicStreams = this.publicStreams.filter(stream => stream.id !== id)
+    }
 }