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

fixed dynamic port forward listener not getting cleaned up - fixes #4200

Browse Source
This commit is contained in:
Eugene Pankov
2021-07-13 19:27:02 +02:00
parent 6d7f25870e
commit 5053743b1b
3 changed files with 23 additions and 23 deletions
Download Patch File Download Diff File Expand all files Collapse all files

20
tabby-ssh/src/api.ts
View File

@@ -74,11 +74,11 @@ export class ForwardedPort implements ForwardedPortConfig {
targetAddress: string
targetPort: number
private listener: Server
private listener: Server|null = null
async startLocalListener (callback: (accept: () => Socket, reject: () => void, sourceAddress: string|null, sourcePort: number|null, targetAddress: string, targetPort: number) => void): Promise<void> {
if (this.type === PortForwardType.Local) {
this.listener = createServer(s => callback(
const listener = this.listener = createServer(s => callback(
() => s,
() => s.destroy(),
s.remoteAddress ?? null,
@@ -87,9 +87,9 @@ export class ForwardedPort implements ForwardedPortConfig {
this.targetPort,
))
return new Promise((resolve, reject) => {
this.listener.listen(this.port, this.host)
this.listener.on('error', reject)
this.listener.on('listening', resolve)
listener.listen(this.port, this.host)
listener.on('error', reject)
listener.on('listening', resolve)
})
} else if (this.type === PortForwardType.Dynamic) {
return new Promise((resolve, reject) => {
@@ -102,10 +102,10 @@ export class ForwardedPort implements ForwardedPortConfig {
info.dstAddr,
info.dstPort,
)
})
}) as Server
this.listener.on('error', reject)
this.listener.listen(this.port, this.host, resolve)
;(this.listener as any).useAuth(socksv5.auth.None())
this.listener['useAuth'](socksv5.auth.None())
})
} else {
throw new Error('Invalid forward type for a local listener')
@@ -113,7 +113,7 @@ export class ForwardedPort implements ForwardedPortConfig {
}
stopLocalListener (): void {
this.listener.close()
this.listener?.close()
}
toString (): string {
@@ -290,9 +290,7 @@ export class SSHSession extends BaseSession {
this.destroyed$.subscribe(() => {
for (const port of this.forwardedPorts) {
if (port.type === PortForwardType.Local) {
port.stopLocalListener()
}
port.stopLocalListener()
}
})

10
tabby-ssh/src/components/sshPortForwardingConfig.component.pug
View File

@@ -1,4 +1,4 @@
.list-group-light.mb-3
.list-group.mb-3
.list-group-item.d-flex.align-items-center(*ngFor='let fw of model')
strong(*ngIf='fw.type === PortForwardType.Local') Local
strong(*ngIf='fw.type === PortForwardType.Remote') Remote
@@ -7,15 +7,17 @@
.ml-2 &rarr;
.ml-2(*ngIf='fw.type !== PortForwardType.Dynamic') {{fw.targetAddress}}:{{fw.targetPort}}
.ml-2(*ngIf='fw.type === PortForwardType.Dynamic') SOCKS proxy
button.btn.btn-link.ml-auto((click)='remove(fw)')
i.fas.fa-trash-alt.mr-2
span Remove
button.btn.btn-link.hover-reveal.ml-auto((click)='remove(fw)')
i.fas.fa-trash-alt
.input-group.mb-2(*ngIf='newForward.type === PortForwardType.Dynamic')
input.form-control(type='text', [(ngModel)]='newForward.host')
.input-group-append
.input-group-text :
input.form-control(type='number', [(ngModel)]='newForward.port')
.input-group-append
.input-group-text &rarr;
.input-group-append.input-group-text(style='flex: 3 1 0') SOCKS proxy
.input-group.mb-2(*ngIf='newForward.type !== PortForwardType.Dynamic')
input.form-control(type='text', [(ngModel)]='newForward.host')