|
4 | 4 | package software.aws.toolkits.jetbrains.gateway.connection.workflow
|
5 | 5 |
|
6 | 6 | import com.jetbrains.gateway.api.GatewayConnectionHandle
|
7 |
| -import com.jetbrains.gateway.thinClientLink.LinkedClientManager |
8 | 7 | import com.jetbrains.rd.util.lifetime.LifetimeDefinition
|
9 |
| -import com.jetbrains.rd.util.lifetime.onTermination |
10 | 8 | import com.jetbrains.rd.util.reactive.adviseEternal
|
| 9 | +import compat.com.jetbrains.gateway.thinClientLink.startNewClient |
11 | 10 | import kotlinx.coroutines.delay
|
12 | 11 | import kotlinx.coroutines.runBlocking
|
13 | 12 | import software.aws.toolkits.core.utils.getLogger
|
@@ -50,16 +49,15 @@ class StartBackend(
|
50 | 49 | val clientHandle = ThinClientTrackerService.getInstance().associate(envId) {
|
51 | 50 | val start = System.currentTimeMillis()
|
52 | 51 | val thinClientHandle = try {
|
53 |
| - LinkedClientManager.getInstance() |
54 |
| - .startNewClient(lifetime, localLink, URLEncoder.encode(message("caws.workspace.backend.title"), Charsets.UTF_8)) { |
55 |
| - CodecatalystTelemetry.devEnvironmentWorkflowStatistic( |
56 |
| - project = null, |
57 |
| - userId = lazilyGetUserId(), |
58 |
| - result = TelemetryResult.Succeeded, |
59 |
| - duration = System.currentTimeMillis() - start.toDouble(), |
60 |
| - codecatalystDevEnvironmentWorkflowStep = "startThinClient", |
61 |
| - ) |
62 |
| - } |
| 52 | + startNewClient(lifetime, localLink, URLEncoder.encode(message("caws.workspace.backend.title"), Charsets.UTF_8)) { |
| 53 | + CodecatalystTelemetry.devEnvironmentWorkflowStatistic( |
| 54 | + project = null, |
| 55 | + userId = lazilyGetUserId(), |
| 56 | + result = TelemetryResult.Succeeded, |
| 57 | + duration = System.currentTimeMillis() - start.toDouble(), |
| 58 | + codecatalystDevEnvironmentWorkflowStep = "startThinClient", |
| 59 | + ) |
| 60 | + } |
63 | 61 | } catch (e: Throwable) {
|
64 | 62 | CodecatalystTelemetry.devEnvironmentWorkflowStatistic(
|
65 | 63 | project = null,
|
|
0 commit comments