Fix syntax highlighting, process spawning, extensions, terminals (#22)

* Fix syntax highlighting, process spawning, extensions, terminals

* Replace colons in toISOString

* Move pathSets included in task

Author: kylecarbs

packages/ide/src/fill/os.ts

@@ -33,6 +33,16 @@ class OS {
 		this._tmpdir = data.tmpDirectory;
 	}
 
+	public platform(): NodeJS.Platform {
+		if (navigator.appVersion.indexOf("Win") != -1) {
+			return "win32";
+		}
+		if (navigator.appVersion.indexOf("Mac") != -1) {
+			return "darwin";
+		}
+		return "linux";
+	}
+
 }
 
 export = new OS();

packages/protocol/src/browser/client.ts

@@ -161,7 +161,7 @@ export class Client {
 	 * @param options Options to execute for the command
 	 */
 	public spawn(command: string, args: string[] = [], options?: SpawnOptions): ChildProcess {
-		return this.doSpawn(command, args, options, false);
+		return this.doSpawn(command, args, options, false, false);
 	}
 
 	/**
@@ -272,6 +272,7 @@ export class Client {
 				tmpDirectory: init.getTmpDirectory(),
 				workingDirectory: init.getWorkingDirectory(),
 				os: opSys,
+				shell: init.getShell(),
 			};
 			this.initDataEmitter.emit(this._initData);
 		} else if (message.hasEvalDone()) {
@@ -316,7 +317,14 @@ export class Client {
 			if (!s) {
 				return;
 			}
-			s.pid = message.getIdentifySession()!.getPid();
+			const pid = message.getIdentifySession()!.getPid();
+			if (typeof pid !== "undefined") {
+				s.pid = pid;
+			}
+			const title = message.getIdentifySession()!.getTitle();
+			if (typeof title !== "undefined") {
+				s.title = title;
+			}
 		} else if (message.hasConnectionEstablished()) {
 			const c = this.connections.get(message.getConnectionEstablished()!.getId());
 			if (!c) {
@@ -347,6 +355,7 @@ export class Client {
 		} else if (message.hasSharedProcessActive()) {
 			this.sharedProcessActiveEmitter.emit({
 				socketPath: message.getSharedProcessActive()!.getSocketPath(),
+				logPath: message.getSharedProcessActive()!.getLogPath(),
 			});
 		} else if (message.hasServerEstablished()) {
 			const s = this.servers.get(message.getServerEstablished()!.getId());

packages/protocol/src/browser/command.ts

@@ -26,6 +26,7 @@ export interface ChildProcess {
 
 	readonly killed?: boolean;
 	readonly pid: number | undefined;
+	readonly title?: string;
 
 	kill(signal?: string): void;
 
@@ -45,6 +46,7 @@ export class ServerProcess extends events.EventEmitter implements ChildProcess {
 	public readonly stderr = new stream.Readable({ read: (): boolean => true });
 
 	private _pid: number | undefined;
+	private _title: string | undefined;
 	private _killed: boolean = false;
 	private _connected: boolean = false;
 
@@ -69,6 +71,14 @@ export class ServerProcess extends events.EventEmitter implements ChildProcess {
 		this._connected = true;
 	}
 
+	public get title(): string | undefined {
+		return this._title;
+	}
+
+	public set title(title: string | undefined) {
+		this._title = title;
+	}
+
 	public get connected(): boolean {
 		return this._connected;
 	}

packages/protocol/src/browser/modules/fs.ts

@@ -113,7 +113,7 @@ export class FS {
 	}
 
 	public createWriteStream = (): void => {
-		throw new Error("not implemented");
+		throw new Error("createWriteStream not implemented");
 	}
 
 	public exists = (path: fs.PathLike, callback: (exists: boolean) => void): void => {

packages/protocol/src/common/connection.ts

@@ -20,8 +20,10 @@ export interface InitData {
 	readonly workingDirectory: string;
 	readonly homeDirectory: string;
 	readonly tmpDirectory: string;
+	readonly shell: string;
 }
 
 export interface ISharedProcessData {
 	readonly socketPath: string;
+	readonly logPath: string;
 }

packages/protocol/src/node/command.ts

@@ -35,19 +35,39 @@ export const handleNewSession = (connection: SendableConnection, newSession: New
 	]);
 
 	let process: Process;
+	let processTitle: string | undefined;
 
 	const env: { [key: string]: string } = {};
 	newSession.getEnvMap().forEach((value, key) => {
 		env[key] = value;
 	});
 	if (newSession.getTtyDimensions()) {
 		// Spawn with node-pty
-		process = nodePty.spawn(newSession.getCommand(), newSession.getArgsList(), {
+		const ptyProc = nodePty.spawn(newSession.getCommand(), newSession.getArgsList(), {
 			cols: newSession.getTtyDimensions()!.getWidth(),
 			rows: newSession.getTtyDimensions()!.getHeight(),
 			cwd: newSession.getCwd(),
 			env,
 		});
+
+		const timer = setInterval(() => {
+			if (ptyProc.process !== processTitle) {
+				processTitle = ptyProc.process;
+				const id = new IdentifySessionMessage();
+				id.setId(newSession.getId());
+				id.setTitle(processTitle);
+				const sm = new ServerMessage();
+				sm.setIdentifySession(id);
+				connection.send(sm.serializeBinary());
+			}
+		}, 200);
+		
+		ptyProc.on("exit", () => {
+			clearTimeout(timer);
+		});
+
+		process = ptyProc;
+		processTitle = ptyProc.process;
 	} else {
 		const options = {
 			cwd: newSession.getCwd(),
@@ -129,6 +149,9 @@ export const handleNewSession = (connection: SendableConnection, newSession: New
 	const id = new IdentifySessionMessage();
 	id.setId(newSession.getId());
 	id.setPid(process.pid);
+	if (processTitle) {
+		id.setTitle(processTitle);
+	}
 	const sm = new ServerMessage();
 	sm.setIdentifySession(id);
 	connection.send(sm.serializeBinary());

packages/protocol/src/node/server.ts

@@ -86,6 +86,9 @@ export class Server {
 				throw new Error(`unrecognized platform "${platform}"`);
 		}
 		initMsg.setOperatingSystem(operatingSystem);
+		if (process.env.SHELL) {
+			initMsg.setShell(process.env.SHELL);
+		}
 		const srvMsg = new ServerMessage();
 		srvMsg.setInit(initMsg);
 		connection.send(srvMsg.serializeBinary());

packages/protocol/src/proto/client.proto

@@ -60,4 +60,5 @@ message WorkingInitMessage {
 		Mac = 2;
 	}
 	OperatingSystem operating_system = 5;
+	string shell = 6;
 }

packages/protocol/src/proto/client_pb.d.ts

@@ -253,6 +253,9 @@ export class WorkingInitMessage extends jspb.Message {
   getOperatingSystem(): WorkingInitMessage.OperatingSystem;
   setOperatingSystem(value: WorkingInitMessage.OperatingSystem): void;
 
+  getShell(): string;
+  setShell(value: string): void;
+
   serializeBinary(): Uint8Array;
   toObject(includeInstance?: boolean): WorkingInitMessage.AsObject;
   static toObject(includeInstance: boolean, msg: WorkingInitMessage): WorkingInitMessage.AsObject;
@@ -270,6 +273,7 @@ export namespace WorkingInitMessage {
     dataDirectory: string,
     workingDirectory: string,
     operatingSystem: WorkingInitMessage.OperatingSystem,
+    shell: string,
   }
 
   export enum OperatingSystem {

packages/protocol/src/proto/client_pb.js

@@ -35,10 +35,12 @@ message SessionDoneMessage {
 	int64 exit_status = 2;
 }
 
-// Identifies a session with a PID.
+// Identifies a session with a PID and a title.
+// Can be sent multiple times when title changes.
 message IdentifySessionMessage {
 	uint64 id = 1;
 	uint64 pid = 2;
+	string title = 3;
 }
 
 // Writes data to a session.

packages/protocol/src/proto/command.proto

@@ -118,6 +118,9 @@ export class IdentifySessionMessage extends jspb.Message {
   getPid(): number;
   setPid(value: number): void;
 
+  getTitle(): string;
+  setTitle(value: string): void;
+
   serializeBinary(): Uint8Array;
   toObject(includeInstance?: boolean): IdentifySessionMessage.AsObject;
   static toObject(includeInstance: boolean, msg: IdentifySessionMessage): IdentifySessionMessage.AsObject;
@@ -132,6 +135,7 @@ export namespace IdentifySessionMessage {
   export type AsObject = {
     id: number,
     pid: number,
+    title: string,
   }
 }
 

packages/protocol/src/proto/command_pb.d.ts

@@ -3,4 +3,5 @@ syntax = "proto3";
 // Sent when a shared process becomes active
 message SharedProcessActiveMessage {
 	string socket_path = 1;
+	string log_path = 2;
 }

packages/protocol/src/proto/command_pb.js

@@ -7,6 +7,9 @@ export class SharedProcessActiveMessage extends jspb.Message {
   getSocketPath(): string;
   setSocketPath(value: string): void;
 
+  getLogPath(): string;
+  setLogPath(value: string): void;
+
   serializeBinary(): Uint8Array;
   toObject(includeInstance?: boolean): SharedProcessActiveMessage.AsObject;
   static toObject(includeInstance: boolean, msg: SharedProcessActiveMessage): SharedProcessActiveMessage.AsObject;
@@ -20,6 +23,7 @@ export class SharedProcessActiveMessage extends jspb.Message {
 export namespace SharedProcessActiveMessage {
   export type AsObject = {
     socketPath: string,
+    logPath: string,
   }
 }