@@ -13,7 +13,6 @@ import com.intellij.util.application
1313import com.jetbrains.rd.platform.codeWithMe.portForwarding.*
1414import com.jetbrains.rd.util.URI
1515import com.jetbrains.rd.util.lifetime.Lifetime
16- import com.jetbrains.rd.util.threading.coroutines.launch
1716import io.gitpod.supervisor.api.Status
1817import io.gitpod.supervisor.api.Status.PortsStatus
1918import io.gitpod.supervisor.api.StatusServiceGrpc
@@ -101,34 +100,34 @@ abstract class AbstractGitpodPortForwardingService : GitpodPortForwardingService
101100 }
102101
103102 private fun syncPortsListWithClient (response : Status .PortsStatusResponse ) {
104- val ignoredPorts = ignoredPortsForNotificationService.getIgnoredPorts()
105- val portsList = response.portsList.filter { ! ignoredPorts.contains(it.localPort) }
106- val portsNumbersFromPortsList = portsList.map { it.localPort }
107- val servedPorts = portsList.filter { it.served }
108- val exposedPorts = servedPorts.filter { it.exposed?.url?.isNotBlank() ? : false }
109- val portsNumbersFromNonServedPorts = portsList.filter { ! it.served }.map { it.localPort }
110- val servedPortsToStartForwarding = servedPorts.filter {
111- perClientPortForwardingManager.getPorts(it.localPort).none { p -> p.labels.contains(FORWARDED_PORT_LABEL ) }
112- }
113- val exposedPortsToStartExposingOnClient = exposedPorts.filter {
114- perClientPortForwardingManager.getPorts(it.localPort).none { p -> p.labels.contains(EXPOSED_PORT_LABEL ) }
115- }
116- val forwardedPortsToStopForwarding = perClientPortForwardingManager.getPorts(FORWARDED_PORT_LABEL )
117- .map { it.hostPortNumber }
118- .filter { portsNumbersFromNonServedPorts.contains(it) || ! portsNumbersFromPortsList.contains(it) }
119- val exposedPortsToStopExposingOnClient = perClientPortForwardingManager.getPorts(EXPOSED_PORT_LABEL )
120- .map { it.hostPortNumber }
121- .filter { portsNumbersFromNonServedPorts.contains(it) || ! portsNumbersFromPortsList.contains(it) }
122-
123- servedPortsToStartForwarding.forEach { startForwarding(it) }
124-
125- exposedPortsToStartExposingOnClient.forEach { startExposingOnClient(it) }
126-
127- forwardedPortsToStopForwarding.forEach { stopForwarding(it) }
128-
129- exposedPortsToStopExposingOnClient.forEach { stopExposingOnClient(it) }
130-
131- portsList.forEach { updatePortsPresentation(it) }
103+ // val ignoredPorts = ignoredPortsForNotificationService.getIgnoredPorts()
104+ // val portsList = response.portsList.filter { !ignoredPorts.contains(it.localPort) }
105+ // val portsNumbersFromPortsList = portsList.map { it.localPort }
106+ // val servedPorts = portsList.filter { it.served }
107+ // val exposedPorts = servedPorts.filter { it.exposed?.url?.isNotBlank() ?: false }
108+ // val portsNumbersFromNonServedPorts = portsList.filter { !it.served }.map { it.localPort }
109+ // val servedPortsToStartForwarding = servedPorts.filter {
110+ // perClientPortForwardingManager.getPorts(it.localPort).none { p -> p.labels.contains(FORWARDED_PORT_LABEL) }
111+ // }
112+ // val exposedPortsToStartExposingOnClient = exposedPorts.filter {
113+ // perClientPortForwardingManager.getPorts(it.localPort).none { p -> p.labels.contains(EXPOSED_PORT_LABEL) }
114+ // }
115+ // val forwardedPortsToStopForwarding = perClientPortForwardingManager.getPorts(FORWARDED_PORT_LABEL)
116+ // .map { it.hostPortNumber }
117+ // .filter { portsNumbersFromNonServedPorts.contains(it) || !portsNumbersFromPortsList.contains(it) }
118+ // val exposedPortsToStopExposingOnClient = perClientPortForwardingManager.getPorts(EXPOSED_PORT_LABEL)
119+ // .map { it.hostPortNumber }
120+ // .filter { portsNumbersFromNonServedPorts.contains(it) || !portsNumbersFromPortsList.contains(it) }
121+ //
122+ // servedPortsToStartForwarding.forEach { startForwarding(it) }
123+ //
124+ // exposedPortsToStartExposingOnClient.forEach { startExposingOnClient(it) }
125+ //
126+ // forwardedPortsToStopForwarding.forEach { stopForwarding(it) }
127+ //
128+ // exposedPortsToStopExposingOnClient.forEach { stopExposingOnClient(it) }
129+ //
130+ // portsList.forEach { updatePortsPresentation(it) }
132131 }
133132
134133 private fun startForwarding (portStatus : PortsStatus ) {
0 commit comments