CEC-179 Car download progress (#32)

* Display download progress

* Change default

* Fix

* Fix

* Update readme

* Update readme and defaults
Fix Dockerfile

src/components/Contexts/UpdatesContext.jsx

@@ -10,6 +10,8 @@ export const UpdatesProvider = ({ children }) => {
   const [carUpdates, setCarUpdates] = useState([]);
   const [totalPackages, setTotalPackages] = useState(0);
   const [totalCarUpdates, setTotalCarUpdates] = useState(0);
+  const [delayCount, setDelayCount] = useState(0);
+  let progressTimer = 0;
 
   const getPackages = async (search, token) => {
     let result;
@@ -96,6 +98,86 @@ export const UpdatesProvider = ({ children }) => {
     return result;
   };
 
+  const applyProgressStatus = (item, status) => {
+    if (status.msg === "DONE") {
+      delete item.progress;
+      item.status = "downloaded";
+    } else if (status.msg === "downloading" && status.total > 0) {
+      let progress = Math.floor((100 * status.bytes) / status.total);
+      if (progress > 99) progress = 0;
+      item.progress = progress;
+      item.status = `downloading ${progress}%`;
+    } else if (status.error > 0) {
+      item.status = "download error";
+    } else {
+      item.status = "downloading";
+    }
+  };
+
+  const applyProgressStatuses = (statuses) => {
+    let items = JSON.parse(JSON.stringify(carUpdates));
+
+    statuses.forEach((status) => {
+      let item = items.find((item) => status.id === item.id);
+      if (!item || status.id === 0) return;
+      applyProgressStatus(item, status);
+    });
+
+    setCarUpdates(items);
+  };
+
+  const updateStatusProgress = async (token) => {
+    stopMonitor();
+
+    if (!token || carUpdates.length === 0) return;
+
+    try {
+      setBusy(true);
+      const carupdateids = carUpdates.reduce((accum, update) => {
+        if (update.status !== "downloaded") accum.push(update.id);
+        return accum;
+      }, []);
+      if (carupdateids.length === 0) return;
+
+      const result = await api.getCarUpdateProgress(
+        carupdateids.join(","),
+        token
+      );
+      if (result.error)
+        throw new Error(`Get update progress error. ${result.message}`);
+
+      applyProgressStatuses(result.statuses);
+    } catch (e) {
+    } finally {
+      setBusy(false);
+    }
+  };
+
+  const getDelay = () => {
+    if (delayCount < 3) {
+      setDelayCount(delayCount + 1);
+      return 1000;
+    }
+    for (let i = 0, len = carUpdates.length; i < len; i++) {
+      if (carUpdates[i].status.indexOf("downloading") > -1) return 1000;
+    }
+    return 10000;
+  };
+
+  const startMonitor = async (token) => {
+    const delay = getDelay();
+    stopMonitor();
+    progressTimer = setTimeout(() => {
+      updateStatusProgress(token);
+    }, delay);
+  };
+
+  const stopMonitor = async () => {
+    if (progressTimer === 0) return;
+    clearTimeout(progressTimer);
+    progressTimer = 0;
+  };
+
   return (
     <UpdatesContext.Provider
       value={{
@@ -109,6 +191,8 @@ export const UpdatesProvider = ({ children }) => {
         createCarUpdates,
         getCarUpdates,
         getVINUpdates,
+        startMonitor,
+        stopMonitor,
       }}
     >
       {children}