fix typo and paths with dedicated sessions

Author: christianalfoni

src/Sandbox.ts

@@ -103,7 +103,7 @@ export class Sandbox {
     opts: SessionCreateOptions
   ): Promise<SandboxSession> {
     if (opts.id.length > 20) {
-      throw new Error("Session ID must be 32 characters or less");
+      throw new Error("Session ID must be 20 characters or less");
     }
 
     const response = await vmCreateSession({
@@ -151,6 +151,8 @@ export class Sandbox {
       ? await this.createSession(customSession)
       : this.globalSession;
 
+    console.log("SESSION", session);
+
     const pitcherClient = await initPitcherClient(
       {
         appId: "sdk",
@@ -208,6 +210,7 @@ export class Sandbox {
     );
 
     return new WebSocketSession(pitcherClient, {
+      sessionId: customSession?.id,
       env: customSession?.env,
       hostToken: customSession?.hostToken,
     });
@@ -237,6 +240,7 @@ export class Sandbox {
     return {
       id: this.id,
       env: customSession?.env,
+      sessionId: customSession?.id,
       hostToken: customSession?.hostToken,
       bootupType: this.bootupType,
       cluster: this.cluster,

src/sessions/WebSocketSession/filesystem.ts

@@ -42,7 +42,8 @@ export class FileSystem {
   private disposable = new Disposable();
   constructor(
     sessionDisposable: Disposable,
-    private pitcherClient: IPitcherClient
+    private pitcherClient: IPitcherClient,
+    private sessionId?: string
   ) {
     sessionDisposable.onWillDispose(() => {
       this.disposable.dispose();
@@ -212,7 +213,21 @@ export class FileSystem {
     const result = await this.pitcherClient.clients.fs.watch(
       path,
       options,
-      (event) => emitter.fire(event)
+      (event) => {
+        if (this.sessionId) {
+          emitter.fire({
+            ...event,
+            paths: event.paths.map((path) =>
+              path.replace(
+                `home/csb-session-${this.sessionId}/workspace/`,
+                "sandbox/"
+              )
+            ),
+          });
+        } else {
+          emitter.fire(event);
+        }
+      }
     );
 
     if (result.type === "error") {

src/sessions/WebSocketSession/index.ts

@@ -31,7 +31,7 @@ export class WebSocketSession {
   /**
    * Namespace for all filesystem operations on this Sandbox
    */
-  public readonly fs = new FileSystem(this.disposable, this.pitcherClient);
+  public readonly fs: FileSystem;
 
   /**
    * Namespace for hosts
@@ -75,7 +75,15 @@ export class WebSocketSession {
 
   constructor(
     protected pitcherClient: IPitcherClient,
-    { env, hostToken }: { env?: Record<string, string>; hostToken?: HostToken }
+    {
+      env,
+      hostToken,
+      sessionId,
+    }: {
+      env?: Record<string, string>;
+      hostToken?: HostToken;
+      sessionId?: string;
+    }
   ) {
     // TODO: Bring this back once metrics polling does not reset inactivity
     // const metricsDisposable = {
@@ -84,6 +92,7 @@ export class WebSocketSession {
     // };
 
     // this.addDisposable(metricsDisposable);
+    this.fs = new FileSystem(this.disposable, this.pitcherClient, sessionId);
     this.terminals = new Terminals(this.disposable, this.pitcherClient, env);
     this.commands = new Commands(this.disposable, this.pitcherClient, env);
 

src/types.ts

@@ -237,6 +237,7 @@ export type SandboxOpts = {
 
 export type SandboxBrowserSession = PitcherManagerResponse & {
   id: string;
+  sessionId?: string;
   env?: Record<string, string>;
   hostToken?: HostToken;
 };