GuanM/tabby
1
0
Fork 0
mirror of https://github.com/Eugeny/tabby.git synced 2025-10-04 22:14:55 +00:00
Code Issues Packages Projects Releases Wiki Activity

API updates

Browse Source
This commit is contained in:
Eugene Pankov
2017-11-04 19:06:58 +01:00
parent 89dff969b1
commit c73d39026b
16 changed files with 75 additions and 46 deletions
Download Patch File Download Diff File Expand all files Collapse all files

63
terminus-terminal/src/services/sessions.service.ts
View File

@@ -14,7 +14,7 @@ export interface IChildProcess {
command: string
}
export class Session {
export abstract class BaseSession {
open: boolean
name: string
output$ = new Subject<string>()
@@ -22,11 +22,46 @@ export class Session {
destroyed$ = new Subject<void>()
recoveryId: string
truePID: number
private pty: any
private initialDataBuffer = ''
private initialDataBufferReleased = false
emitOutput (data: string) {
if (!this.initialDataBufferReleased) {
this.initialDataBuffer += data
} else {
this.output$.next(data)
}
}
releaseInitialDataBuffer () {
this.initialDataBufferReleased = true
this.output$.next(this.initialDataBuffer)
this.initialDataBuffer = null
}
abstract resize (columns, rows)
abstract write (data)
abstract kill (signal?: string)
abstract async getChildProcesses (): Promise<IChildProcess[]>
abstract async gracefullyKillProcess (): Promise<void>
abstract async getWorkingDirectory (): Promise<string>
async destroy (): Promise<void> {
if (this.open) {
this.open = false
this.closed$.next()
this.destroyed$.next()
this.output$.complete()
await this.gracefullyKillProcess()
}
}
}
export class Session extends BaseSession {
private pty: any
constructor (options: SessionOptions) {
super()
this.name = options.name
this.recoveryId = options.recoveryId
@@ -65,12 +100,8 @@ export class Session {
this.open = true
this.pty.on('data', (data) => {
if (!this.initialDataBufferReleased) {
this.initialDataBuffer += data
} else {
this.output$.next(data)
}
this.pty.on('data', data => {
this.emitOutput(data)
})
this.pty.on('exit', () => {
@@ -86,12 +117,6 @@ export class Session {
})
}
releaseInitialDataBuffer () {
this.initialDataBufferReleased = true
this.output$.next(this.initialDataBuffer)
this.initialDataBuffer = null
}
resize (columns, rows) {
if (this.pty._writable) {
this.pty.resize(columns, rows)
@@ -144,16 +169,6 @@ export class Session {
}
}
async destroy (): Promise<void> {
if (this.open) {
this.open = false
this.closed$.next()
this.destroyed$.next()
this.output$.complete()
await this.gracefullyKillProcess()
}
}
async getWorkingDirectory (): Promise<string> {
if (!this.truePID) {
return null