build: update "RxJS" and "jasmine-marbles" version (#1549)

* updated rxjs to 7.4.0

* update jasmine-marbles from 0.6.0 to 0.9.0

* replace docker-compose command with docker compose

* fix test case type error

.github/workflows/test.yml

@@ -94,7 +94,6 @@ jobs:
           name: coverage
           path: coverage/
 
-
   e2etests:
     name: Run E2E Tests
     runs-on: ubuntu-latest

package.json

@@ -44,7 +44,7 @@
     "ngx-json-viewer": "^3",
     "ngx-linky": "^4.0.0",
     "ngx-material-luxon": "^1.1.1",
-    "rxjs": "^6.6.6",
+    "rxjs": "^7.4.0",
     "shortid": "^2.2.16",
     "socket.io-client": "^4.7.2",
     "tslib": "^2.4.0",
@@ -82,7 +82,7 @@
     "eslint-plugin-prettier": "^5.0.0",
     "jasmine": "^5.0.0",
     "jasmine-core": "^5.0.0",
-    "jasmine-marbles": "^0.6.0",
+    "jasmine-marbles": "^0.9.0",
     "jasmine-spec-reporter": "^7.0.0",
     "karma": "~6.4.2",
     "karma-chrome-launcher": "~3.2.0",

src/app/shared/sdk/models/FireLoopRef.ts

@@ -1,5 +1,5 @@
 /* eslint-disable */
-import { merge, Observable, Subject } from "rxjs";
+import { merge, Observable, Subject, throwError } from "rxjs";
 import { catchError } from "rxjs/operators";
 import { LoopBackFilter, StatFilter } from "./index";
 import { SocketConnection } from "../sockets/socket.connections";
@@ -331,15 +331,15 @@ export class FireLoopRef<T> {
       }
     });
     if (event.match("dispose")) {
-      setTimeout(() => subject.next());
+      setTimeout(() => subject.next(null));
     }
     // This event listener will be wiped within socket.connections
     this.socket.sharedObservables.sharedOnDisconnect.subscribe(() =>
       subject.complete(),
     );
     return subject
       .asObservable()
-      .pipe(catchError((error: any) => Observable.throw(error)));
+      .pipe(catchError((error: any) => throwError(() => new Error(error))));
   }
   /**
    * @method buildId

src/app/shared/sdk/sockets/socket.connections.ts

@@ -98,7 +98,7 @@ export class SocketConnection {
       // Listen for authentication
       this.on("authenticated", () => {
         this.authenticated = true;
-        this.subjects.onAuthenticated.next();
+        this.subjects.onAuthenticated.next("authenticated");
         this.heartbeater();
       });
       // Listen for authentication

src/app/state-management/effects/user.effects.spec.ts

@@ -429,7 +429,7 @@ describe("UserEffects", () => {
 
       actions = hot("-a", { a: action });
 
-      expect(effects.logoutNavigate$).toBeObservable(actions);
+      expect(effects.logoutNavigate$).toBeObservable(actions as any);
       expect(router.navigate).toHaveBeenCalledTimes(1);
       expect(router.navigate).toHaveBeenCalledWith(["/login"]);
     });