aboutsummaryrefslogtreecommitdiff
diff options
context:
space:
mode:
authorOgnjen Cirkovic <ciraboxkg@gmail.com>2022-04-13 13:31:16 +0200
committerOgnjen Cirkovic <ciraboxkg@gmail.com>2022-04-13 13:31:16 +0200
commitbd4a76b61074745735a7c775b0dd24999a4c55fc (patch)
treefb5e354a48c68d98562d2d480554bb256c4b3af2
parent39534c9c3e3ab9c51e34b7641c2871962abfad38 (diff)
Dodata provera da li je korisnik trenutno povezan na websocket pre slanja poruke.
-rw-r--r--backend/api/api/Services/ChatHub.cs6
-rw-r--r--backend/api/api/Services/MlConnectionService.cs3
2 files changed, 8 insertions, 1 deletions
diff --git a/backend/api/api/Services/ChatHub.cs b/backend/api/api/Services/ChatHub.cs
index 3dd6ab3e..efa13a3b 100644
--- a/backend/api/api/Services/ChatHub.cs
+++ b/backend/api/api/Services/ChatHub.cs
@@ -43,6 +43,12 @@ namespace api.Services
{
await Clients.All.SendAsync("Notify",message);
}
+ public static bool CheckUser(string id)
+ {
+ if (Users[id] == null)
+ return false;
+ return true;
+ }
}
diff --git a/backend/api/api/Services/MlConnectionService.cs b/backend/api/api/Services/MlConnectionService.cs
index 2ac977d9..1b001973 100644
--- a/backend/api/api/Services/MlConnectionService.cs
+++ b/backend/api/api/Services/MlConnectionService.cs
@@ -57,7 +57,8 @@ namespace api.Services
Dataset newDataset = JsonConvert.DeserializeObject<Dataset>(result.Content);
newDataset.isPreProcess = true;
_datasetService.Update(newDataset);
- await _ichat.Clients.Client(ChatHub.Users[id]).SendAsync("Notify", "Preprocessed dataset with name "+newDataset.name);
+ if(ChatHub.CheckUser(id))
+ await _ichat.Clients.Client(ChatHub.Users[id]).SendAsync("Notify", "Preprocessed dataset with name "+newDataset.name);
return;
}