From fbcbcfe276b12d912ab9857570860410bee943c1 Mon Sep 17 00:00:00 2001
From: Ognjen Cirkovic <ciraboxkg@gmail.com>
Date: Wed, 13 Apr 2022 00:58:06 +0200
Subject: Implementiran SignalR na backendu i frontend.Mogu da komuniciraju.

---
 .../src/app/_services/signal-r.service.spec.ts     | 16 +++++++++
 frontend/src/app/_services/signal-r.service.ts     | 30 +++++++++++++++++
 .../src/app/_services/web-socket.service.spec.ts   | 16 ---------
 frontend/src/app/_services/web-socket.service.ts   | 39 ----------------------
 4 files changed, 46 insertions(+), 55 deletions(-)
 create mode 100644 frontend/src/app/_services/signal-r.service.spec.ts
 create mode 100644 frontend/src/app/_services/signal-r.service.ts
 delete mode 100644 frontend/src/app/_services/web-socket.service.spec.ts
 delete mode 100644 frontend/src/app/_services/web-socket.service.ts

(limited to 'frontend/src/app/_services')

diff --git a/frontend/src/app/_services/signal-r.service.spec.ts b/frontend/src/app/_services/signal-r.service.spec.ts
new file mode 100644
index 00000000..f737fa50
--- /dev/null
+++ b/frontend/src/app/_services/signal-r.service.spec.ts
@@ -0,0 +1,16 @@
+import { TestBed } from '@angular/core/testing';
+
+import { SignalRService } from './signal-r.service';
+
+describe('SignalRService', () => {
+  let service: SignalRService;
+
+  beforeEach(() => {
+    TestBed.configureTestingModule({});
+    service = TestBed.inject(SignalRService);
+  });
+
+  it('should be created', () => {
+    expect(service).toBeTruthy();
+  });
+});
diff --git a/frontend/src/app/_services/signal-r.service.ts b/frontend/src/app/_services/signal-r.service.ts
new file mode 100644
index 00000000..5eca48d3
--- /dev/null
+++ b/frontend/src/app/_services/signal-r.service.ts
@@ -0,0 +1,30 @@
+import { Injectable } from '@angular/core';
+import * as signalR from "@microsoft/signalr";
+import Shared from '../Shared';
+import { CookieService } from 'ngx-cookie-service';
+@Injectable({
+  providedIn: 'root'
+})
+export class SignalRService {
+private hubConnection?:signalR.HubConnection;
+public startConnection=()=>{
+
+  this.hubConnection= new signalR.HubConnectionBuilder()
+            .withUrl('http://localhost:5283/chatHub', {
+                accessTokenFactory: () => this.cookie.get("token"),
+                withCredentials: false
+            }).build();
+
+  this.hubConnection.on("Notify",(message:string) =>{
+    console.log(" "+message);
+  });
+
+
+
+  this.hubConnection
+    .start()
+    .then(()=>console.log("con Started"))
+    .catch(err=>console.log("Error"+err))
+}
+  constructor(private cookie:CookieService) { }
+}
diff --git a/frontend/src/app/_services/web-socket.service.spec.ts b/frontend/src/app/_services/web-socket.service.spec.ts
deleted file mode 100644
index a86aeca7..00000000
--- a/frontend/src/app/_services/web-socket.service.spec.ts
+++ /dev/null
@@ -1,16 +0,0 @@
-import { TestBed } from '@angular/core/testing';
-
-import { WebSocketService } from './web-socket.service';
-
-describe('WebSocketService', () => {
-  let service: WebSocketService;
-
-  beforeEach(() => {
-    TestBed.configureTestingModule({});
-    service = TestBed.inject(WebSocketService);
-  });
-
-  it('should be created', () => {
-    expect(service).toBeTruthy();
-  });
-});
diff --git a/frontend/src/app/_services/web-socket.service.ts b/frontend/src/app/_services/web-socket.service.ts
deleted file mode 100644
index 1a7efa87..00000000
--- a/frontend/src/app/_services/web-socket.service.ts
+++ /dev/null
@@ -1,39 +0,0 @@
-import { Injectable } from '@angular/core';
-import { ConstantBackoff, Websocket, WebsocketBuilder } from 'websocket-ts';
-import { API_SETTINGS } from 'src/config';
-
-@Injectable({
-  providedIn: 'root'
-})
-export class WebSocketService {
-
-  ws?: Websocket;
-
-  private handlers: Function[] = [];
-
-  constructor() {
-    this.ws = new WebsocketBuilder(API_SETTINGS.apiWSUrl)
-      .withBackoff(new ConstantBackoff(120000))
-      .onOpen((i, e) => { /*console.log('WS: Connected to ' + API_SETTINGS.apiWSUrl)*/ })
-      .onMessage((i, e) => {
-        console.log('WS MESSAGE: ', e.data);
-        this.handlers.forEach(handler => {
-          handler(e.data);
-        })
-      })
-      .onClose((i, e) => { /*console.log('WS: Connection closed!')*/ })
-      .build();
-  }
-
-  send(msg: string) {
-    this.ws?.send(msg);
-  }
-
-  addHandler(handler: Function) {
-    this.handlers.push(handler);
-  }
-
-  removeHandler(handler: Function) {
-    this.handlers.splice(this.handlers.indexOf(handler), 1);
-  }
-}
-- 
cgit v1.2.3