@@ -30,7 +30,7 @@ type WorkspaceService struct {
30
30
}
31
31
32
32
func (s * WorkspaceService ) GetWorkspace (ctx context.Context , req * connect.Request [v1.GetWorkspaceRequest ]) (* connect.Response [v1.GetWorkspaceResponse ], error ) {
33
- workspaceID , err := validateWorkspaceID (req .Msg .GetWorkspaceId ())
33
+ workspaceID , err := validateWorkspaceID (ctx , req .Msg .GetWorkspaceId ())
34
34
if err != nil {
35
35
return nil , err
36
36
}
@@ -73,7 +73,7 @@ func (s *WorkspaceService) GetWorkspace(ctx context.Context, req *connect.Reques
73
73
}
74
74
75
75
func (s * WorkspaceService ) StreamWorkspaceStatus (ctx context.Context , req * connect.Request [v1.StreamWorkspaceStatusRequest ], stream * connect.ServerStream [v1.StreamWorkspaceStatusResponse ]) error {
76
- workspaceID , err := validateWorkspaceID (req .Msg .GetWorkspaceId ())
76
+ workspaceID , err := validateWorkspaceID (ctx , req .Msg .GetWorkspaceId ())
77
77
if err != nil {
78
78
return err
79
79
}
@@ -121,7 +121,7 @@ func (s *WorkspaceService) StreamWorkspaceStatus(ctx context.Context, req *conne
121
121
}
122
122
123
123
func (s * WorkspaceService ) GetOwnerToken (ctx context.Context , req * connect.Request [v1.GetOwnerTokenRequest ]) (* connect.Response [v1.GetOwnerTokenResponse ], error ) {
124
- workspaceID , err := validateWorkspaceID (req .Msg .GetWorkspaceId ())
124
+ workspaceID , err := validateWorkspaceID (ctx , req .Msg .GetWorkspaceId ())
125
125
if err != nil {
126
126
return nil , err
127
127
}
@@ -177,7 +177,7 @@ func (s *WorkspaceService) ListWorkspaces(ctx context.Context, req *connect.Requ
177
177
}
178
178
179
179
func (s * WorkspaceService ) UpdatePort (ctx context.Context , req * connect.Request [v1.UpdatePortRequest ]) (* connect.Response [v1.UpdatePortResponse ], error ) {
180
- workspaceID , err := validateWorkspaceID (req .Msg .GetWorkspaceId ())
180
+ workspaceID , err := validateWorkspaceID (ctx , req .Msg .GetWorkspaceId ())
181
181
if err != nil {
182
182
return nil , err
183
183
}
@@ -212,7 +212,7 @@ func (s *WorkspaceService) UpdatePort(ctx context.Context, req *connect.Request[
212
212
}
213
213
214
214
func (s * WorkspaceService ) StopWorkspace (ctx context.Context , req * connect.Request [v1.StopWorkspaceRequest ]) (* connect.Response [v1.StopWorkspaceResponse ], error ) {
215
- workspaceID , err := validateWorkspaceID (req .Msg .GetWorkspaceId ())
215
+ workspaceID , err := validateWorkspaceID (ctx , req .Msg .GetWorkspaceId ())
216
216
if err != nil {
217
217
return nil , err
218
218
}
@@ -232,7 +232,7 @@ func (s *WorkspaceService) StopWorkspace(ctx context.Context, req *connect.Reque
232
232
}
233
233
234
234
func (s * WorkspaceService ) DeleteWorkspace (ctx context.Context , req * connect.Request [v1.DeleteWorkspaceRequest ]) (* connect.Response [v1.DeleteWorkspaceResponse ], error ) {
235
- workspaceID , err := validateWorkspaceID (req .Msg .GetWorkspaceId ())
235
+ workspaceID , err := validateWorkspaceID (ctx , req .Msg .GetWorkspaceId ())
236
236
if err != nil {
237
237
return nil , err
238
238
}
0 commit comments