1 files changed, 38 insertions, 0 deletions
diff --git a/workers/npm_worker.py b/workers/npm_worker.py
new file mode 100644
index 0000000..b8c04af
--- /dev/null
+++ b/workers/npm_worker.py
@@ -0,0 +1,38 @@
+from __future__ import annotations
+from PyQt6.QtCore import QObject, QProcess, pyqtSignal
+from pathlib import Path
+
+class NpmWorker(QObject):
+    log_line = pyqtSignal(str)
+    finished = pyqtSignal(bool)  # True = success
+
+    def __init__(self, repo_path: Path, parent=None):
+        super().__init__(parent)
+        self._repo_path = repo_path
+        self._process = QProcess(self)
+        self._process.readyReadStandardOutput.connect(self._on_stdout)
+        self._process.readyReadStandardError.connect(self._on_stderr)
+        self._process.finished.connect(self._on_finished)
+
+    @property
+    def is_running(self) -> bool:
+        return self._process.state() == QProcess.ProcessState.Running
+
+    def run(self):
+        if self.is_running:
+            return
+        self._process.setWorkingDirectory(str(self._repo_path))
+        self._process.start("npm", ["run", "build"])
+
+    def _on_stdout(self):
+        data = self._process.readAllStandardOutput().data().decode("utf-8", errors="replace")
+        for line in data.splitlines():
+            self.log_line.emit(line)
+
+    def _on_stderr(self):
+        data = self._process.readAllStandardError().data().decode("utf-8", errors="replace")
+        for line in data.splitlines():
+            self.log_line.emit(line)
+
+    def _on_finished(self, exit_code: int, _):
+        self.finished.emit(exit_code == 0)