[websockets] send job progress data directly in WS message

This avoids polling

src/Gargantext/Components/Notifications/Types.purs

@@ -82,7 +82,8 @@ instance JSON.WriteForeign WSRequest where
 data Message =
     -- TODO
     -- MJobProgress GT.AsyncProgress
-    MJobProgress GT.AsyncTaskLog
+    -- MJobProgress GT.AsyncTaskLog
+    MJobProgress GT.AsyncProgress
   | MEmpty
 derive instance Generic Message _
 instance JSON.ReadForeign Message where
@@ -92,8 +93,9 @@ instance JSON.ReadForeign Message where
       "MJobProgress" -> do
         -- TODO
         -- { job_progress } <- JSON.readImpl f :: F.F { job_progress :: GT.AsyncProgress }
-        { job_progress } <- JSON.readImpl f :: F.F { job_progress :: GT.AsyncTaskLog }
-        pure $ MJobProgress job_progress
+        -- { job_progress } <- JSON.readImpl f :: F.F { job_progress :: GT.AsyncTaskLog }
+        { job_status } <- JSON.readImpl f :: F.F { job_status :: GT.AsyncProgress }
+        pure $ MJobProgress job_status
       "MEmpty" -> do
         pure MEmpty
       s -> do F.fail $ F.ErrorAtProperty "type" $ F.ForeignError $ "unknown Message type: " <> s

src/Gargantext/Context/Progress.purs

@@ -119,10 +119,7 @@ asyncProgressCpt = R2.hereComponent here "asyncProgress" hCpt where
       let cb msg = do
             -- here.log2 "callback! for job update" taskId
             case msg of
-              NotificationsT.MJobProgress _jobProgress -> do
-                -- TODO With jobProgress we could avoid polling here
-                -- onJobProgress jobProgress
-                fetchJobProgress
+              NotificationsT.MJobProgress jobProgress -> launchAff_ $ onProgress jobProgress
               NotificationsT.MEmpty -> fetchJobProgress
 
             resetInterval intervalIdRef (Just defaultJobPollInterval) fetchJobProgress