Merge pull request #16 from appwrite/feat-workDir-update

chore: add updateWorkDir to individual instance

Author: ChiragAgg5k

package.json

@@ -1,6 +1,6 @@
 {
   "name": "@appwrite.io/synapse",
-  "version": "0.4.4",
+  "version": "0.4.5",
   "description": "Operating system gateway for remote serverless environments",
   "main": "dist/index.js",
   "types": "dist/index.d.ts",

src/services/filesystem.ts

@@ -464,6 +464,17 @@ export class Filesystem {
     }
   }
 
+  /**
+   * Updates the working directory
+   * @param workDir - The new working directory
+   */
+  updateWorkDir(workDir: string): void {
+    if (!fsSync.existsSync(workDir)) {
+      fsSync.mkdirSync(workDir, { recursive: true });
+    }
+    this.workDir = workDir;
+  }
+
   /**
    * Cleans up all folder watchers and releases resources.
    */

src/services/git.ts

@@ -190,4 +190,15 @@ export class Git {
   async push(): Promise<GitOperationResult> {
     return this.execute(["push"]);
   }
+
+  /**
+   * Updates the working directory
+   * @param workDir - The new working directory
+   */
+  updateWorkDir(workDir: string): void {
+    if (!fs.existsSync(workDir)) {
+      fs.mkdirSync(workDir, { recursive: true });
+    }
+    this.workDir = workDir;
+  }
 }

src/services/terminal.ts

@@ -1,3 +1,4 @@
+import fs from "fs";
 import * as pty from "node-pty";
 import * as os from "os";
 import { Synapse } from "../synapse";
@@ -150,6 +151,10 @@ export class Terminal {
    */
   updateWorkDir(workDir: string): void {
     try {
+      if (!fs.existsSync(workDir)) {
+        fs.mkdirSync(workDir, { recursive: true });
+      }
+
       this.checkTerminal();
       this.createCommand(`cd "${workDir}"\n`);
     } catch (error) {

tests/services/terminal.test.ts

@@ -1,3 +1,4 @@
+import fs from "fs";
 import * as pty from "node-pty";
 import { Terminal, TerminalOptions } from "../../src/services/terminal";
 import { Synapse } from "../../src/synapse";
@@ -9,7 +10,6 @@ describe("Terminal", () => {
   let mockSynapse: Synapse;
   let mockPty: jest.Mocked<pty.IPty>;
   let onDataHandler: (data: string) => void;
-  let onExitHandler: () => void;
 
   beforeEach(() => {
     mockSynapse = new Synapse();
@@ -18,8 +18,7 @@ describe("Terminal", () => {
         onDataHandler = callback;
         return mockPty;
       }),
-      onExit: jest.fn((callback) => {
-        onExitHandler = callback;
+      onExit: jest.fn(() => {
         return mockPty;
       }),
       write: jest.fn(),
@@ -35,6 +34,7 @@ describe("Terminal", () => {
   describe("basic terminal functionality", () => {
     beforeEach(() => {
       terminal = new Terminal(mockSynapse);
+      jest.spyOn(fs, "existsSync").mockReturnValue(true);
     });
 
     it("should initialize with correct state", () => {
@@ -60,6 +60,7 @@ describe("Terminal", () => {
   describe("terminal operations", () => {
     beforeEach(() => {
       terminal = new Terminal(mockSynapse);
+      jest.spyOn(fs, "existsSync").mockReturnValue(true);
     });
 
     it("should update working directory", () => {