Adding antivirus scanning capabilities with ClamAV via API calls and Add User fucntion

README.md

@@ -149,6 +149,20 @@ Use [conventional commits](https://www.conventionalcommits.org/en/v1.0.0/#summar
   <img src="https://contrib.rocks/image?repo=C4illin/ConvertX" alt="Image with all contributors"/>
 </a>
 
+## Files updated:
+
+src/db/types.ts
+src/db/db.ts
+src/pages/root.tsx
+src/pages/user.tsx
+src/pages/upload.tsx
+src/pages/antivirus.tsx
+src/components/base.tsx
+public/script.js
+public/theme-init.js
+public/theme.css
+src/main.css
+
 ![Alt](https://repobeats.axiom.co/api/embed/dcdabd0564fcdcccbf5680c1bdc2efad54a3d4d9.svg "Repobeats analytics image")
 
 ## Star History

compose.yaml

@@ -16,5 +16,32 @@ services:
       # - HIDE_HISTORY=true # hides the history tab in the web interface, defaults to false
       - TZ=Europe/Stockholm # set your timezone, defaults to UTC
       # - UNAUTHENTICATED_USER_SHARING=true # for use with ALLOW_UNAUTHENTICATED=true to share history with all unauthenticated users / devices
+      - CLAMAV_URL=http://clam_av_api:3000/api/v1/scan
     ports:
-      - 3000:3000
+      - 8080:3000
+
+  clamav-rest-api:
+    image: benzino77/clamav-rest-api:latest
+    container_name: clamav-rest-api
+    restart: unless-stopped
+    environment:
+      - NODE_ENV=production
+      # field name expected in the multipart form
+      - APP_FORM_KEY=FILES
+      # talk to your existing ClamAV daemon
+      - CLAMD_IP=CLAMAV_server_IP
+      - CLAMD_PORT=3310
+      # max allowed file size (here: 250 MB)
+      - APP_MAX_FILE_SIZE=262144000
+    ports:
+      # outside:inside
+      - "3000:3000"
+
+   clamav:
+    image: clamav/clamav:latest
+    container_name: clamav
+    restart: unless-stopped
+    ports:
+      - "3310:3310"
+    environment:
+      - CLAMAV_NO_FRESHCLAMD=false   

public/results.js

@@ -1,38 +1,222 @@
-const webroot = document.querySelector("meta[name='webroot']").content;
-const jobId = window.location.pathname.split("/").pop();
-const main = document.querySelector("main");
-let progressElem = document.querySelector("progress");
-
-const refreshData = () => {
-  // console.log("Refreshing data...", progressElem.value, progressElem.max);
-  if (progressElem.value !== progressElem.max) {
-    fetch(`${webroot}/progress/${jobId}`, {
-      method: "POST",
-    })
-      .then((res) => res.text())
-      .then((html) => {
-        main.innerHTML = html;
-      })
-      .catch((err) => console.log(err));
-
-    setTimeout(refreshData, 1000);
+// public/results.js
+//
+// Handles live progress updates for /results/:jobId and Share via Erugo modal actions.
+// IMPORTANT: /progress/:jobId re-renders the <main> content, so we must not keep stale
+// element references. Use event delegation + (re)query elements when needed.
+
+(function () {
+  const webrootMeta = document.querySelector("meta[name='webroot']");
+  const webroot = webrootMeta ? webrootMeta.content : "";
+  const jobId = window.location.pathname.split("/").pop();
+  const main = document.querySelector("main");
+
+  // -----------------------------
+  // Progress refresh
+  // -----------------------------
+  async function refreshData() {
+    if (!main || !jobId) return;
+
+    const progressElem = main.querySelector("progress");
+    if (!progressElem) return;
+
+    const max = Number(progressElem.getAttribute("max") || "0");
+    const val = Number(progressElem.getAttribute("value") || "0");
+
+    // Only refresh while still processing
+    if (max > 0 && val >= max) return;
+
+    try {
+      const res = await fetch(`${webroot}/progress/${jobId}`, { method: "POST", cache: "no-store" });
+      const html = await res.text();
+      main.innerHTML = html;
+    } catch (err) {
+      console.error("[ConvertX] progress refresh failed", err);
+    }
+  }
+
+  // Poll every second while job is running
+  setInterval(refreshData, 1000);
+  // Run once immediately so the page updates without waiting 1s.
+  refreshData();
+
+  // -----------------------------
+  // Share modal helpers
+  // -----------------------------
+  function getEls() {
+    return {
+      modal: document.getElementById("cxShareModal"),
+      closeBtn: document.getElementById("cxShareClose"),
+      cancelBtn: document.getElementById("cxShareCancel"),
+      submitBtn: document.getElementById("cxShareSubmit"),
+      statusEl: document.getElementById("cxShareStatus"),
+
+      emailEl: document.getElementById("cxShareEmail"),
+      nameEl: document.getElementById("cxShareName"),
+      descEl: document.getElementById("cxShareDescription"),
+
+      linkBlock: document.getElementById("cxShareLinkBlock"),
+      linkEl: document.getElementById("cxShareLink"),
+      copyBtn: document.getElementById("cxShareCopy"),
+    };
+  }
+
+  let currentJobId = null;
+  let currentFileName = null;
+
+  function openModal(jobIdValue, fileNameValue) {
+    const els = getEls();
+    if (!els.modal) return;
+
+    currentJobId = jobIdValue;
+    currentFileName = fileNameValue;
+
+    if (els.nameEl) els.nameEl.value = fileNameValue || "";
+    if (els.emailEl) els.emailEl.value = "";
+    if (els.descEl) els.descEl.value = "";
+
+    if (els.linkBlock) els.linkBlock.classList.add("hidden");
+    if (els.linkEl) els.linkEl.value = "";
+    if (els.statusEl) els.statusEl.textContent = "";
+
+    els.modal.classList.remove("hidden");
+    els.modal.classList.add("flex");
+
+    if (els.emailEl) els.emailEl.focus();
   }
 
-  progressElem = document.querySelector("progress");
-};
+  function closeModal() {
+    const els = getEls();
+    if (!els.modal) return;
 
-refreshData();
+    els.modal.classList.add("hidden");
+    els.modal.classList.remove("flex");
 
-window.downloadAll = function () {
-  // Get all download links
-  const downloadLinks = document.querySelectorAll("tbody a[download]");
+    currentJobId = null;
+    currentFileName = null;
+  }
 
-  // Trigger download for each link
-  downloadLinks.forEach((link, index) => {
-    // We add a delay for each download to prevent them from starting at the same time
-    setTimeout(() => {
-      const event = new MouseEvent("click");
-      link.dispatchEvent(event);
-    }, index * 300);
+  async function shareFile(jobIdValue, fileNameValue) {
+    const els = getEls();
+    if (!els.submitBtn || !els.statusEl) return;
+
+    const recipientEmail = (els.emailEl && els.emailEl.value ? els.emailEl.value.trim() : "") || undefined;
+    const shareName = (els.nameEl && els.nameEl.value ? els.nameEl.value.trim() : "") || undefined;
+    const description = (els.descEl && els.descEl.value ? els.descEl.value.trim() : "") || undefined;
+
+    els.submitBtn.disabled = true;
+    els.submitBtn.setAttribute("aria-busy", "true");
+    els.statusEl.textContent = "Sending...";
+
+    try {
+      const payload = { fileName: fileNameValue, recipientEmail, shareName, description };
+
+      const res = await fetch(`${webroot}/share-to-erugo/${jobIdValue}`, {
+        method: "POST",
+        headers: { "Content-Type": "application/json" },
+        body: JSON.stringify(payload),
+      });
+
+      const text = await res.text();
+      let json = null;
+      try {
+        json = text ? JSON.parse(text) : null;
+      } catch {
+        json = { raw: text };
+      }
+
+      if (!res.ok) {
+        console.error("[ConvertX] share-to-erugo failed", res.status, json);
+        els.statusEl.textContent = "Failed. See logs.";
+        return;
+      }
+
+      const url =
+        (json && (json.share_url || json.share_link)) ||
+        (json && json.data && json.data.url) ||
+        (json && json.data && json.data.share && json.data.share.url) ||
+        null;
+
+      if (url && els.linkEl && els.linkBlock) {
+        els.linkEl.value = url;
+        els.linkBlock.classList.remove("hidden");
+      }
+
+      if (recipientEmail) {
+        els.statusEl.textContent = url ? "Sent. Link also shown below." : "Sent.";
+      } else {
+        els.statusEl.textContent = url ? "Created. Copy the link below." : "Created.";
+      }
+    } catch (err) {
+      console.error(err);
+      els.statusEl.textContent = "Failed. See logs.";
+    } finally {
+      els.submitBtn.disabled = false;
+      els.submitBtn.removeAttribute("aria-busy");
+    }
+  }
+
+  // -----------------------------
+  // Global event handlers (delegated)
+  // -----------------------------
+  document.addEventListener("click", async (event) => {
+    const target = event.target;
+
+    // Share icon buttons inside the table
+    const shareBtn = target && target.closest ? target.closest("button[data-share='true']") : null;
+    if (shareBtn) {
+      const jobIdAttr = shareBtn.getAttribute("data-job-id");
+      const fileNameAttr = shareBtn.getAttribute("data-file-name");
+      if (!jobIdAttr || !fileNameAttr) return;
+      openModal(jobIdAttr, fileNameAttr);
+      return;
+    }
+
+    // Modal close/cancel
+    if (target && target.id === "cxShareClose") {
+      closeModal();
+      return;
+    }
+    if (target && target.id === "cxShareCancel") {
+      closeModal();
+      return;
+    }
+
+    // Click outside modal (on overlay)
+    const els = getEls();
+    if (els.modal && target === els.modal) {
+      closeModal();
+      return;
+    }
+
+    // Submit
+    if (target && target.id === "cxShareSubmit") {
+      if (!currentJobId || !currentFileName) return;
+      await shareFile(currentJobId, currentFileName);
+      return;
+    }
+
+    // Copy
+    if (target && target.id === "cxShareCopy") {
+      const e = getEls();
+      if (!e.linkEl || !e.statusEl) return;
+      try {
+        await navigator.clipboard.writeText(e.linkEl.value);
+        e.statusEl.textContent = "Copied.";
+      } catch {
+        e.linkEl.focus();
+        e.linkEl.select();
+        e.statusEl.textContent = "Select + copy (Ctrl/Cmd+C).";
+      }
+      return;
+    }
+  });
+
+  document.addEventListener("keydown", (event) => {
+    if (event.key !== "Escape") return;
+    const els = getEls();
+    if (els.modal && !els.modal.classList.contains("hidden")) {
+      closeModal();
+    }
   });
-};
+})();
+