mirror of
https://github.com/lensapp/lens.git
synced 2025-05-20 05:10:56 +00:00
Only wait for the connection to be ready
Signed-off-by: Sebastian Malton <sebastian@malton.name>
This commit is contained in:
parent
86d810ea8e
commit
ab03b4153a
@ -58,7 +58,6 @@ export class TerminalApi extends WebSocketApi {
|
|||||||
|
|
||||||
public onReady = new EventEmitter<[]>();
|
public onReady = new EventEmitter<[]>();
|
||||||
@observable public isReady = false;
|
@observable public isReady = false;
|
||||||
@observable public shellRunCommandsFinished = false;
|
|
||||||
public readonly url: string;
|
public readonly url: string;
|
||||||
|
|
||||||
constructor(protected options: TerminalApiQuery) {
|
constructor(protected options: TerminalApiQuery) {
|
||||||
@ -92,7 +91,6 @@ export class TerminalApi extends WebSocketApi {
|
|||||||
connect() {
|
connect() {
|
||||||
this.emitStatus("Connecting ...");
|
this.emitStatus("Connecting ...");
|
||||||
this.onData.addListener(this._onReady, { prepend: true });
|
this.onData.addListener(this._onReady, { prepend: true });
|
||||||
this.onData.addListener(this._onShellRunCommandsFinished);
|
|
||||||
super.connect(this.url);
|
super.connect(this.url);
|
||||||
}
|
}
|
||||||
|
|
||||||
@ -109,24 +107,6 @@ export class TerminalApi extends WebSocketApi {
|
|||||||
this.onReady.removeAllListeners();
|
this.onReady.removeAllListeners();
|
||||||
}
|
}
|
||||||
|
|
||||||
_onShellRunCommandsFinished = (data: string) => {
|
|
||||||
if (!data) {
|
|
||||||
return;
|
|
||||||
}
|
|
||||||
|
|
||||||
/**
|
|
||||||
* This is a heuistic for ditermining when a shell has finished executing
|
|
||||||
* its own rc file (or RunCommands file) such as `.bashrc` or `.zshrc`.
|
|
||||||
*
|
|
||||||
* This heuistic assumes that the prompt line of a terminal is a single line
|
|
||||||
* and ends with a whitespace character or the > character (windows's CMD).
|
|
||||||
*/
|
|
||||||
if (data.match(/\r?\n/) === null && data.match(/(\s|>)$/)) {
|
|
||||||
this.shellRunCommandsFinished = true;
|
|
||||||
this.onData.removeListener(this._onShellRunCommandsFinished);
|
|
||||||
}
|
|
||||||
};
|
|
||||||
|
|
||||||
@boundMethod
|
@boundMethod
|
||||||
protected _onReady(data: string) {
|
protected _onReady(data: string) {
|
||||||
if (!data) return true;
|
if (!data) return true;
|
||||||
|
|||||||
@ -117,9 +117,9 @@ export class TerminalStore extends Singleton {
|
|||||||
|
|
||||||
await when(() => this.connections.has(tab.id));
|
await when(() => this.connections.has(tab.id));
|
||||||
|
|
||||||
const rcIsFinished = when(() => this.connections.get(tab.id).shellRunCommandsFinished);
|
const shellIsReady = when(() => this.connections.get(tab.id).isReady);
|
||||||
const notifyVeryLong = setTimeout(() => {
|
const notifyVeryLong = setTimeout(() => {
|
||||||
rcIsFinished.cancel();
|
shellIsReady.cancel();
|
||||||
Notifications.info(
|
Notifications.info(
|
||||||
"If terminal shell is not ready please check your shell init files, if applicable. You may see this message if you have set a custom shell prompt.",
|
"If terminal shell is not ready please check your shell init files, if applicable. You may see this message if you have set a custom shell prompt.",
|
||||||
{
|
{
|
||||||
@ -128,7 +128,7 @@ export class TerminalStore extends Singleton {
|
|||||||
);
|
);
|
||||||
}, 10_000);
|
}, 10_000);
|
||||||
|
|
||||||
await rcIsFinished.catch(noop);
|
await shellIsReady.catch(noop);
|
||||||
clearTimeout(notifyVeryLong);
|
clearTimeout(notifyVeryLong);
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|||||||
Loading…
Reference in New Issue
Block a user