@@ -9,9 +9,7 @@ import com.fasterxml.jackson.databind.DeserializationFeature
9
9
import com.fasterxml.jackson.databind.PropertyNamingStrategies
10
10
import com.fasterxml.jackson.module.kotlin.jacksonObjectMapper
11
11
import com.intellij.ide.BrowserUtil
12
- import com.intellij.openapi.Disposable
13
12
import com.intellij.openapi.components.service
14
- import com.intellij.openapi.diagnostic.Logger
15
13
import com.intellij.openapi.diagnostic.thisLogger
16
14
import com.intellij.remote.RemoteCredentialsHolder
17
15
import com.intellij.ssh.AskAboutHostKey
@@ -22,7 +20,6 @@ import com.intellij.ui.components.JBTextArea
22
20
import com.intellij.ui.dsl.builder.panel
23
21
import com.intellij.ui.dsl.gridLayout.HorizontalAlign
24
22
import com.intellij.ui.dsl.gridLayout.VerticalAlign
25
- import com.intellij.util.EventDispatcher
26
23
import com.intellij.util.application
27
24
import com.intellij.util.io.DigestUtil
28
25
import com.intellij.util.ui.JBFont
@@ -35,8 +32,6 @@ import com.jetbrains.gateway.ssh.ClientOverSshTunnelConnector
35
32
import com.jetbrains.gateway.thinClientLink.ThinClientHandle
36
33
import com.jetbrains.rd.util.URI
37
34
import com.jetbrains.rd.util.lifetime.Lifetime
38
- import com.jetbrains.rd.util.lifetime.isAlive
39
- import com.jetbrains.rd.util.lifetime.onTermination
40
35
import io.gitpod.gitpodprotocol.api.entities.WorkspaceInstance
41
36
import io.gitpod.jetbrains.icons.GitpodIcons
42
37
import kotlinx.coroutines.*
@@ -57,26 +52,6 @@ class GitpodConnectionProvider : GatewayConnectionProvider {
57
52
58
53
private val gitpod = service<GitpodConnectionService >()
59
54
60
- companion object {
61
- var jetbrainsClientMap: MutableMap <String , ThinClientHandle > = mutableMapOf ()
62
-
63
- private val dispatcher = EventDispatcher .create(Listener ::class .java)
64
-
65
- private interface Listener : EventListener {
66
- fun didChange ()
67
- }
68
-
69
- fun addListener (listener : () -> Unit ): Disposable {
70
- val internalListener = object : Listener {
71
- override fun didChange () {
72
- listener()
73
- }
74
- }
75
- dispatcher.addListener(internalListener);
76
- return Disposable { dispatcher.removeListener(internalListener) }
77
- }
78
- }
79
-
80
55
private val httpClient = HttpClient .newBuilder()
81
56
.followRedirects(HttpClient .Redirect .ALWAYS )
82
57
.build()
@@ -259,27 +234,18 @@ class GitpodConnectionProvider : GatewayConnectionProvider {
259
234
)
260
235
val client = connector.connect()
261
236
client.clientClosed.advise(connectionLifetime) {
262
- thisLogger().d(" clientClosed, ${client.prettyPrint()} " )
263
237
application.invokeLater {
264
- connectionLifetime.onTermination {
265
- thisLogger().d(" clientTermination, clientClosed didChange fired, ${client.prettyPrint()} " )
266
- dispatcher.multicaster.didChange()
267
- }
268
238
connectionLifetime.terminate()
269
239
}
270
240
}
271
241
client.onClientPresenceChanged.advise(connectionLifetime) {
272
- thisLogger().d(" presenceChanged, ${client.prettyPrint()} " )
273
242
application.invokeLater {
274
- thisLogger().d(" clientPresenceChanged didChange fired, ${client.prettyPrint()} " )
275
- dispatcher.multicaster.didChange()
276
243
if (client.clientPresent) {
277
244
statusMessage.text = " "
278
245
}
279
246
}
280
247
}
281
248
thinClient = client
282
- jetbrainsClientMap[update.workspaceId] = client
283
249
} catch (t: Throwable ) {
284
250
if (t is CancellationException ) {
285
251
throw t
@@ -478,11 +444,3 @@ class GitpodConnectionProvider : GatewayConnectionProvider {
478
444
private data class SSHHostKey (val type : String , val hostKey : String )
479
445
480
446
}
481
-
482
- fun ThinClientHandle.prettyPrint (): String {
483
- return " uid=${uid} , clientPresent=${clientPresent} , lifeTime={status=${lifetime.status} , alive=${lifetime.isAlive} }"
484
- }
485
-
486
- fun Logger.d (message : String ) {
487
- thisLogger().info(" [jb-gw] $message " )
488
- }
0 commit comments