@@ -42,17 +42,6 @@ class GitpodRemoteProviderEnvironment(
42
42
43
43
private val lastWSEnvState = MutableSharedFlow <WorkspaceEnvState >(1 , 0 , BufferOverflow .DROP_OLDEST )
44
44
private var lastPhase: WorkspaceInstanceStatus .Phase = WorkspaceInstanceStatus .Phase .PHASE_UNSPECIFIED
45
- private var isMarkActive = false
46
- set(value) {
47
- if (field != value) {
48
- field = value
49
- lastWSEnvState.tryEmit(WorkspaceEnvState (lastPhase, value))
50
- }
51
- }
52
-
53
- fun markActive () {
54
- isMarkActive = true
55
- }
56
45
57
46
init {
58
47
Utils .coroutineScope.launch {
@@ -66,19 +55,19 @@ class GitpodRemoteProviderEnvironment(
66
55
}
67
56
68
57
Utils .coroutineScope.launch {
69
- GitpodLogger .info( " connectParams.workspaceId $ connectParams" )
58
+ GitpodLogger .debug( " watching workspace ${ connectParams.workspaceId} " )
70
59
watchWorkspaceJob = publicApi.watchWorkspaceStatus(connectParams.workspaceId) { _, status ->
71
60
lastPhase = status.phase
72
- GitpodLogger .info (" ${connectParams.workspaceId} status updated: $lastPhase " )
73
- lastWSEnvState.tryEmit(WorkspaceEnvState (status.phase, isMarkActive ))
61
+ GitpodLogger .debug (" ${connectParams.workspaceId} status updated: $lastPhase " )
62
+ lastWSEnvState.tryEmit(WorkspaceEnvState (status.phase))
74
63
}
75
64
}
76
65
}
77
66
78
67
override fun addStateListener (consumer : EnvironmentStateConsumer ): Boolean {
79
68
val ok = super .addStateListener(consumer)
80
69
Utils .coroutineScope.launch {
81
- lastWSEnvState.tryEmit(WorkspaceEnvState (lastPhase, isMarkActive ))
70
+ lastWSEnvState.tryEmit(WorkspaceEnvState (lastPhase))
82
71
}
83
72
return ok
84
73
}
@@ -89,9 +78,6 @@ class GitpodRemoteProviderEnvironment(
89
78
override fun getContentsView (): CompletableFuture <EnvironmentContentsView > = contentsViewFuture
90
79
91
80
override fun setVisible (visibilityState : EnvironmentVisibilityState ) {
92
- if (visibilityState.contentsVisible && lastPhase == WorkspaceInstanceStatus .Phase .PHASE_RUNNING ) {
93
- isMarkActive = true
94
- }
95
81
}
96
82
97
83
override fun getActionList (): ObservableList <ActionDescription > = actionList
@@ -102,14 +88,10 @@ class GitpodRemoteProviderEnvironment(
102
88
}
103
89
104
90
105
- private class WorkspaceEnvState (val phase : WorkspaceInstanceStatus .Phase , val isMarkActive : Boolean ) {
91
+ private class WorkspaceEnvState (val phase : WorkspaceInstanceStatus .Phase ) {
106
92
107
93
fun getState () = run {
108
- if (isMarkActive && phase == WorkspaceInstanceStatus .Phase .PHASE_RUNNING ) {
109
- StandardRemoteEnvironmentState .Active
110
- } else {
111
- phaseToStateMap[phase] ? : StandardRemoteEnvironmentState .Unreachable
112
- }
94
+ phaseToStateMap[phase] ? : StandardRemoteEnvironmentState .Unreachable
113
95
}
114
96
115
97
companion object {
@@ -120,7 +102,7 @@ private class WorkspaceEnvState(val phase: WorkspaceInstanceStatus.Phase, val is
120
102
WorkspaceInstanceStatus .Phase .PHASE_PENDING to StandardRemoteEnvironmentState .Initializing ,
121
103
WorkspaceInstanceStatus .Phase .PHASE_CREATING to StandardRemoteEnvironmentState .Initializing ,
122
104
WorkspaceInstanceStatus .Phase .PHASE_INITIALIZING to StandardRemoteEnvironmentState .Initializing ,
123
- WorkspaceInstanceStatus .Phase .PHASE_RUNNING to StandardRemoteEnvironmentState .Inactive ,
105
+ WorkspaceInstanceStatus .Phase .PHASE_RUNNING to StandardRemoteEnvironmentState .Active ,
124
106
WorkspaceInstanceStatus .Phase .PHASE_INTERRUPTED to StandardRemoteEnvironmentState .Error ,
125
107
WorkspaceInstanceStatus .Phase .PHASE_STOPPING to StandardRemoteEnvironmentState .Unreachable ,
126
108
WorkspaceInstanceStatus .Phase .PHASE_STOPPED to StandardRemoteEnvironmentState .Hibernated ,
0 commit comments