mirror of
https://github.com/lensapp/lens.git
synced 2025-05-20 05:10:56 +00:00
Fix lint and resolve conflicts
Signed-off-by: DMYTRO ZHARKOV <dmytrozharkov@DMYTROs-MBP.fritz.box>
This commit is contained in:
parent
3fd2d6121d
commit
57b8f4cc5d
@ -16,11 +16,6 @@ import { ThemeStore } from "../../theme.store";
|
|||||||
export const Terminal = observer(() => {
|
export const Terminal = observer(() => {
|
||||||
const userStore = UserStore.getInstance();
|
const userStore = UserStore.getInstance();
|
||||||
const themeStore = ThemeStore.getInstance();
|
const themeStore = ThemeStore.getInstance();
|
||||||
const [terminalSettings, setTerminalSettings] = React.useState({
|
|
||||||
shell: userStore.shell || "",
|
|
||||||
terminalFontSize: userStore.terminalConfig.fontSize,
|
|
||||||
terminalFontFamily: userStore.terminalConfig.fontFamily,
|
|
||||||
});
|
|
||||||
const defaultShell = process.env.SHELL
|
const defaultShell = process.env.SHELL
|
||||||
|| process.env.PTYSHELL
|
|| process.env.PTYSHELL
|
||||||
|| (
|
|| (
|
||||||
@ -35,12 +30,8 @@ export const Terminal = observer(() => {
|
|||||||
<Input
|
<Input
|
||||||
theme="round-black"
|
theme="round-black"
|
||||||
placeholder={defaultShell}
|
placeholder={defaultShell}
|
||||||
value={terminalSettings.shell}
|
value={userStore.shell}
|
||||||
onChange={(value) => setTerminalSettings({
|
onChange={(value) => userStore.shell = value}
|
||||||
...terminalSettings,
|
|
||||||
shell: value,
|
|
||||||
})}
|
|
||||||
onBlur={() => userStore.shell = terminalSettings.shell}
|
|
||||||
/>
|
/>
|
||||||
</section>
|
</section>
|
||||||
|
|
||||||
@ -74,12 +65,8 @@ export const Terminal = observer(() => {
|
|||||||
type="number"
|
type="number"
|
||||||
min={10}
|
min={10}
|
||||||
validators={InputValidators.isNumber}
|
validators={InputValidators.isNumber}
|
||||||
value={terminalSettings.terminalFontSize.toString()}
|
value={userStore.terminalConfig.fontSize.toString()}
|
||||||
onChange={(value) => setTerminalSettings({
|
onChange={(value) => userStore.terminalConfig.fontSize=Number(value)}
|
||||||
...terminalSettings,
|
|
||||||
terminalFontSize: Number(value),
|
|
||||||
})}
|
|
||||||
onBlur={() => userStore.terminalConfig.fontSize = terminalSettings.terminalFontSize}
|
|
||||||
/>
|
/>
|
||||||
</section>
|
</section>
|
||||||
<section>
|
<section>
|
||||||
@ -87,12 +74,8 @@ export const Terminal = observer(() => {
|
|||||||
<Input
|
<Input
|
||||||
theme="round-black"
|
theme="round-black"
|
||||||
type="text"
|
type="text"
|
||||||
value={terminalSettings.terminalFontFamily}
|
value={userStore.terminalConfig.fontFamily}
|
||||||
onChange={(value) => setTerminalSettings({
|
onChange={(value) => userStore.terminalConfig.fontFamily=value}
|
||||||
...terminalSettings,
|
|
||||||
terminalFontFamily: value.toString(),
|
|
||||||
})}
|
|
||||||
onBlur={() => userStore.terminalConfig.fontFamily = terminalSettings.terminalFontFamily}
|
|
||||||
/>
|
/>
|
||||||
</section>
|
</section>
|
||||||
</div>);
|
</div>);
|
||||||
|
|||||||
@ -1,184 +0,0 @@
|
|||||||
/**
|
|
||||||
* Copyright (c) 2021 OpenLens Authors
|
|
||||||
*
|
|
||||||
* Permission is hereby granted, free of charge, to any person obtaining a copy of
|
|
||||||
* this software and associated documentation files (the "Software"), to deal in
|
|
||||||
* the Software without restriction, including without limitation the rights to
|
|
||||||
* use, copy, modify, merge, publish, distribute, sublicense, and/or sell copies of
|
|
||||||
* the Software, and to permit persons to whom the Software is furnished to do so,
|
|
||||||
* subject to the following conditions:
|
|
||||||
*
|
|
||||||
* The above copyright notice and this permission notice shall be included in all
|
|
||||||
* copies or substantial portions of the Software.
|
|
||||||
*
|
|
||||||
* THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS OR
|
|
||||||
* IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF MERCHANTABILITY, FITNESS
|
|
||||||
* FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT. IN NO EVENT SHALL THE AUTHORS OR
|
|
||||||
* COPYRIGHT HOLDERS BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER LIABILITY, WHETHER
|
|
||||||
* IN AN ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING FROM, OUT OF OR IN
|
|
||||||
* CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN THE SOFTWARE.
|
|
||||||
*/
|
|
||||||
|
|
||||||
import { autorun, observable, when } from "mobx";
|
|
||||||
import { autoBind, noop, Singleton } from "../../utils";
|
|
||||||
import { Terminal } from "./terminal";
|
|
||||||
import { TerminalApi, TerminalChannels } from "../../api/terminal-api";
|
|
||||||
import { dockStore, DockTab, DockTabCreateSpecific, TabId, TabKind } from "./dock.store";
|
|
||||||
import { WebSocketApiState } from "../../api/websocket-api";
|
|
||||||
import { Notifications } from "../notifications";
|
|
||||||
|
|
||||||
export interface ITerminalTab extends DockTab {
|
|
||||||
node?: string; // activate node shell mode
|
|
||||||
}
|
|
||||||
|
|
||||||
export function createTerminalTab(tabParams: DockTabCreateSpecific = {}) {
|
|
||||||
return dockStore.createTab({
|
|
||||||
title: `Terminal`,
|
|
||||||
...tabParams,
|
|
||||||
kind: TabKind.TERMINAL,
|
|
||||||
});
|
|
||||||
}
|
|
||||||
|
|
||||||
export class TerminalStore extends Singleton {
|
|
||||||
protected terminals = new Map<TabId, Terminal>();
|
|
||||||
protected connections = observable.map<TabId, TerminalApi>();
|
|
||||||
|
|
||||||
constructor() {
|
|
||||||
super();
|
|
||||||
autoBind(this);
|
|
||||||
|
|
||||||
// connect active tab
|
|
||||||
autorun(() => {
|
|
||||||
const { selectedTab, isOpen } = dockStore;
|
|
||||||
|
|
||||||
if (selectedTab?.kind === TabKind.TERMINAL && isOpen) {
|
|
||||||
this.connect(selectedTab.id);
|
|
||||||
}
|
|
||||||
});
|
|
||||||
// disconnect closed tabs
|
|
||||||
autorun(() => {
|
|
||||||
const currentTabs = dockStore.tabs.map(tab => tab.id);
|
|
||||||
|
|
||||||
for (const [tabId] of this.connections) {
|
|
||||||
if (!currentTabs.includes(tabId)) this.disconnect(tabId);
|
|
||||||
}
|
|
||||||
});
|
|
||||||
}
|
|
||||||
|
|
||||||
connect(tabId: TabId) {
|
|
||||||
if (this.isConnected(tabId)) {
|
|
||||||
return;
|
|
||||||
}
|
|
||||||
const tab: ITerminalTab = dockStore.getTabById(tabId);
|
|
||||||
const api = new TerminalApi({
|
|
||||||
id: tabId,
|
|
||||||
node: tab.node,
|
|
||||||
});
|
|
||||||
const terminal = new Terminal(tabId, api);
|
|
||||||
|
|
||||||
this.connections.set(tabId, api);
|
|
||||||
this.terminals.set(tabId, terminal);
|
|
||||||
|
|
||||||
api.connect();
|
|
||||||
}
|
|
||||||
|
|
||||||
disconnect(tabId: TabId) {
|
|
||||||
if (!this.isConnected(tabId)) {
|
|
||||||
return;
|
|
||||||
}
|
|
||||||
const terminal = this.terminals.get(tabId);
|
|
||||||
const terminalApi = this.connections.get(tabId);
|
|
||||||
|
|
||||||
terminal.destroy();
|
|
||||||
terminalApi.destroy();
|
|
||||||
this.connections.delete(tabId);
|
|
||||||
this.terminals.delete(tabId);
|
|
||||||
}
|
|
||||||
|
|
||||||
reconnect(tabId: TabId) {
|
|
||||||
this.connections.get(tabId)?.connect();
|
|
||||||
}
|
|
||||||
|
|
||||||
isConnected(tabId: TabId) {
|
|
||||||
return Boolean(this.connections.get(tabId));
|
|
||||||
}
|
|
||||||
|
|
||||||
isDisconnected(tabId: TabId) {
|
|
||||||
return this.connections.get(tabId)?.readyState === WebSocketApiState.CLOSED;
|
|
||||||
}
|
|
||||||
|
|
||||||
async sendCommand(command: string, options: { enter?: boolean; newTab?: boolean; tabId?: TabId } = {}) {
|
|
||||||
const { enter, newTab, tabId } = options;
|
|
||||||
|
|
||||||
if (tabId) {
|
|
||||||
dockStore.selectTab(tabId);
|
|
||||||
}
|
|
||||||
|
|
||||||
if (newTab) {
|
|
||||||
const tab = createTerminalTab();
|
|
||||||
|
|
||||||
await when(() => this.connections.has(tab.id));
|
|
||||||
|
|
||||||
const shellIsReady = when(() => this.connections.get(tab.id).isReady);
|
|
||||||
const notifyVeryLong = setTimeout(() => {
|
|
||||||
shellIsReady.cancel();
|
|
||||||
Notifications.info(
|
|
||||||
"If terminal shell is not ready please check your shell init files, if applicable.",
|
|
||||||
{
|
|
||||||
timeout: 4_000,
|
|
||||||
},
|
|
||||||
);
|
|
||||||
}, 10_000);
|
|
||||||
|
|
||||||
await shellIsReady.catch(noop);
|
|
||||||
clearTimeout(notifyVeryLong);
|
|
||||||
}
|
|
||||||
|
|
||||||
const terminalApi = this.connections.get(dockStore.selectedTabId);
|
|
||||||
|
|
||||||
if (terminalApi) {
|
|
||||||
if (enter) {
|
|
||||||
command += "\r";
|
|
||||||
}
|
|
||||||
|
|
||||||
terminalApi.sendMessage({
|
|
||||||
type: TerminalChannels.STDIN,
|
|
||||||
data: command,
|
|
||||||
});
|
|
||||||
} else {
|
|
||||||
console.warn("The selected tab is does not have a connection. Cannot send command.", { tabId: dockStore.selectedTabId, command });
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
||||||
getTerminal(tabId: TabId) {
|
|
||||||
return this.terminals.get(tabId);
|
|
||||||
}
|
|
||||||
|
|
||||||
reset() {
|
|
||||||
[...this.connections].forEach(([tabId]) => {
|
|
||||||
this.disconnect(tabId);
|
|
||||||
});
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
||||||
/**
|
|
||||||
* @deprecated use `TerminalStore.getInstance()` instead
|
|
||||||
*/
|
|
||||||
export const terminalStore = new Proxy({}, {
|
|
||||||
get(target, p) {
|
|
||||||
if (p === "$$typeof") {
|
|
||||||
return "TerminalStore";
|
|
||||||
}
|
|
||||||
|
|
||||||
const ts = TerminalStore.getInstance();
|
|
||||||
const res = (ts as any)?.[p];
|
|
||||||
|
|
||||||
if (typeof res === "function") {
|
|
||||||
return function (...args: any[]) {
|
|
||||||
return res.apply(ts, args);
|
|
||||||
};
|
|
||||||
}
|
|
||||||
|
|
||||||
return res;
|
|
||||||
},
|
|
||||||
}) as TerminalStore;
|
|
||||||
Loading…
Reference in New Issue
Block a user