-
Notifications
You must be signed in to change notification settings - Fork 116
Commit
This commit does not belong to any branch on this repository, and may belong to a fork outside of the repository.
- Loading branch information
1 parent
4b39af4
commit 41cbbc5
Showing
1 changed file
with
3 additions
and
115 deletions.
There are no files selected for viewing
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -1,48 +1,21 @@ | ||
| /* | ||
| * Copyright 2014-2021 Simon Edwards <[email protected]> | ||
| * Copyright 2014-2024 Simon Edwards <[email protected]> | ||
| * | ||
| * This source code is licensed under the MIT license which is detailed in the LICENSE.txt file. | ||
| */ | ||
| import { Event, SessionConfiguration, CreateSessionOptions} from "@extraterm/extraterm-extension-api"; | ||
| import { SessionConfiguration, CreateSessionOptions} from "@extraterm/extraterm-extension-api"; | ||
| import { createUuid } from "extraterm-uuid"; | ||
| import { EventEmitter } from "extraterm-event-emitter"; | ||
| import { Logger, getLogger, log } from "extraterm-logging"; | ||
| import { Pty, BufferSizeChange } from "./Pty.js"; | ||
| import { Pty } from "./Pty.js"; | ||
| import { ExtensionManager } from "../extension/ExtensionManager.js"; | ||
|
|
||
|
|
||
| const LOG_FINE = false; | ||
|
|
||
| // interface PtyTuple { | ||
| // ptyTerm: Pty; | ||
| // outputBufferSize: number; // The number of characters we are allowed to send. | ||
| // outputPaused: boolean; // True if the term's output is paused. | ||
| // }; | ||
|
|
||
| // export interface PtyDataEvent { | ||
| // ptyId: number; | ||
| // data: string; | ||
| // } | ||
|
|
||
| // export interface PtyAvailableWriteBufferSizeChangeEvent { | ||
| // ptyId: number; | ||
| // bufferSizeChange: BufferSizeChange; | ||
| // } | ||
|
|
||
| export class PtyManager { | ||
| private _log: Logger; | ||
| // private _ptyCounter = 0; | ||
| // private _ptyMap: Map<number, PtyTuple> = new Map<number, PtyTuple>(); | ||
| // private _onPtyExitEventEmitter = new EventEmitter<number>(); | ||
| // private _onPtyDataEventEmitter = new EventEmitter<PtyDataEvent>(); | ||
| // private _onPtyAvailableWriteBufferSizeChangeEventEmitter = new EventEmitter<PtyAvailableWriteBufferSizeChangeEvent>(); | ||
|
|
||
| constructor(private _extensionManager: ExtensionManager) { | ||
| this._log = getLogger("PtyManager", this); | ||
|
|
||
| // this.onPtyExit = this._onPtyExitEventEmitter.event; | ||
| // this.onPtyData = this._onPtyDataEventEmitter.event; | ||
| // this.onPtyAvailableWriteBufferSizeChange = this._onPtyAvailableWriteBufferSizeChangeEventEmitter.event; | ||
| } | ||
|
|
||
| getDefaultSessions(): SessionConfiguration[] { | ||
|
|
@@ -59,97 +32,12 @@ export class PtyManager { | |
| return results; | ||
| } | ||
|
|
||
| // onPtyExit: Event<number>; | ||
| // onPtyData: Event<PtyDataEvent>; | ||
| // onPtyAvailableWriteBufferSizeChange: Event<PtyAvailableWriteBufferSizeChangeEvent>; | ||
|
|
||
| createPty(sessionConfiguration: SessionConfiguration, sessionOptions: CreateSessionOptions): Pty { | ||
| const backend = this._extensionManager.getSessionBackend(sessionConfiguration.type); | ||
| const ptyTerm = backend.createSession(sessionConfiguration, sessionOptions); | ||
|
|
||
| // this._ptyCounter++; | ||
| // const ptyId = this._ptyCounter; | ||
| // const ptyTup = { ptyTerm: ptyTerm, outputBufferSize: 0, outputPaused: true }; | ||
| // this._ptyMap.set(ptyId, ptyTup); | ||
|
|
||
| // ptyTerm.onData( (data: string) => { | ||
| // if (LOG_FINE) { | ||
| // this._log.debug("pty process got data for ptyID=" + ptyId); | ||
| // this._logJSData(data); | ||
| // } | ||
|
|
||
| // this._onPtyDataEventEmitter.fire({ptyId, data}); | ||
| // }); | ||
|
|
||
| // ptyTerm.onExit( () => { | ||
| // if (LOG_FINE) { | ||
| // this._log.debug("pty process exited."); | ||
| // } | ||
|
|
||
| // this._onPtyExitEventEmitter.fire(ptyId); | ||
|
|
||
| // ptyTerm.destroy(); | ||
| // this._ptyMap.delete(ptyId); | ||
| // }); | ||
|
|
||
| // ptyTerm.onAvailableWriteBufferSizeChange( (bufferSizeChange: BufferSizeChange) => { | ||
| // this._onPtyAvailableWriteBufferSizeChangeEventEmitter.fire({ptyId, bufferSizeChange}); | ||
| // }); | ||
|
|
||
| return ptyTerm; | ||
| } | ||
|
|
||
| // ptyInput(ptyId: number, data: string): void { | ||
| // const ptyTerminalTuple = this._ptyMap.get(ptyId); | ||
| // if (ptyTerminalTuple === undefined) { | ||
| // this._log.debug("handlePtyInput() WARNING: Input arrived for a terminal which doesn't exist."); | ||
| // return; | ||
| // } | ||
|
|
||
| // ptyTerminalTuple.ptyTerm.write(data); | ||
| // } | ||
|
|
||
| // ptyOutputBufferSize(ptyId: number, size: number): void { | ||
| // const ptyTerminalTuple = this._ptyMap.get(ptyId); | ||
| // if (ptyTerminalTuple === undefined) { | ||
| // this._log.debug("handlePtyOutputBufferSize() WARNING: Input arrived for a terminal which doesn't exist."); | ||
| // return; | ||
| // } | ||
|
|
||
| // if (LOG_FINE) { | ||
| // this._log.debug(`Received Output Buffer Size message. id: ${ptyId}, size: ${size}`); | ||
| // } | ||
| // ptyTerminalTuple.ptyTerm.permittedDataSize(size); | ||
| // } | ||
|
|
||
| // ptyResize(ptyId: number, columns: number, rows: number): void { | ||
| // const ptyTerminalTuple = this._ptyMap.get(ptyId); | ||
| // if (ptyTerminalTuple === undefined) { | ||
| // this._log.debug("handlePtyResize() WARNING: Input arrived for a terminal which doesn't exist."); | ||
| // return; | ||
| // } | ||
| // ptyTerminalTuple.ptyTerm.resize(columns, rows); | ||
| // } | ||
|
|
||
| // closePty(ptyId: number): void { | ||
| // const ptyTerminalTuple = this._ptyMap.get(ptyId); | ||
| // if (ptyTerminalTuple === undefined) { | ||
| // this._log.debug("handlePtyCloseRequest() WARNING: Input arrived for a terminal which doesn't exist."); | ||
| // return; | ||
| // } | ||
| // ptyTerminalTuple.ptyTerm.destroy(); | ||
| // this._ptyMap.delete(ptyId); | ||
| // } | ||
|
|
||
| // async ptyGetWorkingDirectory(ptyId: number): Promise<string> { | ||
| // const ptyTerminalTuple = this._ptyMap.get(ptyId); | ||
| // if (ptyTerminalTuple === undefined) { | ||
| // this._log.debug("handlePtyGetWorkingDirectory() WARNING: Request arrived for a terminal which doesn't exist."); | ||
| // return null; | ||
| // } | ||
| // return await ptyTerminalTuple.ptyTerm.getWorkingDirectory(); | ||
| // } | ||
|
|
||
| private _logData(data: string): void { | ||
| this._log.debug(substituteBadChars(data)); | ||
| } | ||
|
|
||