Websocket management (#53)

* Added a ConnectionManager for better readability.
Added webtoken to our ws route, to utilize the uuid when opening ws-communication.
Added simple reconnecting logic for client-unintended disconnects.
Added a GetSessionAndUser API to solve the null reference problem of Users inside Session when calling the GetStatus API for now.

* minor fix on refreshing the online states of users.Fixed Role.Author to Admin, to match with our Frontned.
Added new MessageType UserRefreshed, to update the online states of currently available users in a session.
Adjusted our Dtos to contain an user online state.

* Fixed Role.Author to Admin, to match with our Frontned.
Added new MessageType UserRefreshed, to update the online states of currently available users in a session.
Adjusted our Dtos to contain an user online state.

* Merged-task-estimation and ws management

Author: vlad961

client/app/Components/Features/Session/Users/Stores/UserStore.ts

@@ -1,12 +1,14 @@
 import produce from "immer";
 import create from "zustand";
 import { IUser } from "../../../../../../app/Interfaces/IUser";
+import { IUpdateDto } from "../../../../../Interfaces/IUpdateDto";
 
 interface ISessionUserState {
   users: IUser[];
   setCurrentUsers(payload: IUser[]): void;
   addUser(payload: IUser): void;
   removeUser(id: String): void;
+  changeOnlineStatus(payload: IUpdateDto): void;
 }
 
 export const useSessionUserStore = create<ISessionUserState>()((set) => ({
@@ -15,6 +17,19 @@ export const useSessionUserStore = create<ISessionUserState>()((set) => ({
     set(
       produce((draft) => {
         draft.users.push(payload);
+        draft.users.forEach((user: IUser) => {
+          if(user.id.trim() === payload.id)
+          {
+            user.online = true;
+            user.role = payload.role;
+            user.token = "";
+          }
+        });
+        draft.users = draft.users.filter((user: IUser) => {
+          if(user.token === null || user.token === "") return true;
+        });
+        draft.users = uniqBy(draft.users, JSON.stringify);
+        console.log("useradd:"+ JSON.stringify(draft.users));
       })
     ),
   setCurrentUsers: (payload: IUser[]) =>
@@ -25,4 +40,41 @@ export const useSessionUserStore = create<ISessionUserState>()((set) => ({
         draft.users.filter((item: IUser) => item.id === id);
       })
     ),
+  changeOnlineStatus: (payload: IUpdateDto) => set(
+    produce((draft) => {
+      if(payload.availableClients != undefined && payload.availableClients.length != 0)
+      {
+        let onlineUsers = payload.availableClients;
+        draft.users.forEach((user: IUser) => {
+          for(var i = 0; i < onlineUsers.length; i++)
+          {
+            let onlineUser = onlineUsers[i];
+            if(user.id.trim() === onlineUser)
+            {
+              user.online = true;
+              break;
+            }
+            else {
+              user.online = false;
+            }
+          }
+        });
+        draft.users = draft.users.filter((user: IUser) => {
+          if(user.online === true)
+          {
+            return true
+          }
+        });
+        console.log("Online Users:"+ JSON.stringify(draft.users));
+      }
+    })
+  ),
 }));
+
+function uniqBy(user: IUser[], key: any) {
+  let seen = new Set();
+  return user.filter(item => {
+      let k = key(item);
+      return seen.has(k) ? false : seen.add(k);
+  });
+}

client/app/Interfaces/IUpdateDto.ts

@@ -0,0 +1,7 @@
+import { IUser } from "./IUser";
+
+export interface IUpdateDto extends Array<String> {
+    user: IUser,
+    availableClients: Array<String>
+  }
+  

client/app/Interfaces/IUser.ts

@@ -1,5 +1,10 @@
+import { Role } from "../Types/Role";
+
 export interface IUser {
   id: String;
   username: String;
   imageUrl?: String;
+  online?: boolean;
+  role: Role;
+  token: string;
 }

client/app/Types/Type.ts

@@ -6,4 +6,5 @@ export enum Type {
   TaskAverageAdded = 4,
   TaskFinalValueAdded = 5,
   UserJoined = 6,
+  UserRefreshed = 7,
 }