@@ -40,11 +40,9 @@ import {
4040import * as grpc from "@grpc/grpc-js" ;
4141import { inject , injectable } from "inversify" ;
4242import { BridgeController } from "./bridge-controller" ;
43- import { getSupportedWorkspaceClasses } from "./cluster-sync-service" ;
4443import { Configuration } from "./config" ;
4544import { GRPCError } from "./rpc" ;
4645import { isWorkspaceRegion } from "@gitpod/gitpod-protocol/lib/workspace-cluster" ;
47- import { getExperimentsClientForBackend } from "@gitpod/gitpod-protocol/lib/experiments/configcat-server" ;
4846import { GetWorkspacesRequest , WorkspaceManagerClient } from "@gitpod/ws-manager/lib" ;
4947
5048export interface ClusterServiceServerOptions {
@@ -148,34 +146,25 @@ export class ClusterService implements IClusterServiceServer {
148146 maxScore : 100 ,
149147 govern,
150148 tls,
149+ admissionConstraints,
151150 } ;
152151
153- const enabled = await getExperimentsClientForBackend ( ) . getValueAsync (
154- "workspace_classes_backend" ,
155- false ,
156- { } ,
157- ) ;
158- if ( enabled ) {
159- let classConstraints = await getSupportedWorkspaceClasses ( this . clientProvider , newCluster , false ) ;
160- newCluster . admissionConstraints = admissionConstraints . concat ( classConstraints ) ;
161- } else {
162- // try to connect to validate the config. Throws an exception if it fails.
163- await new Promise < void > ( ( resolve , reject ) => {
164- const c = this . clientProvider . createConnection ( WorkspaceManagerClient , newCluster ) ;
165- c . getWorkspaces ( new GetWorkspacesRequest ( ) , ( err : any ) => {
166- if ( err ) {
167- reject (
168- new GRPCError (
169- grpc . status . FAILED_PRECONDITION ,
170- `cannot reach ${ req . url } : ${ err . message } ` ,
171- ) ,
172- ) ;
173- } else {
174- resolve ( ) ;
175- }
176- } ) ;
152+ // try to connect to validate the config. Throws an exception if it fails.
153+ await new Promise < void > ( ( resolve , reject ) => {
154+ const c = this . clientProvider . createConnection ( WorkspaceManagerClient , newCluster ) ;
155+ c . getWorkspaces ( new GetWorkspacesRequest ( ) , ( err : any ) => {
156+ if ( err ) {
157+ reject (
158+ new GRPCError (
159+ grpc . status . FAILED_PRECONDITION ,
160+ `cannot reach ${ req . url } : ${ err . message } ` ,
161+ ) ,
162+ ) ;
163+ } else {
164+ resolve ( ) ;
165+ }
177166 } ) ;
178- }
167+ } ) ;
179168
180169 await this . clusterDB . save ( newCluster ) ;
181170 log . info ( { } , "cluster registered" , { cluster : req . name } ) ;
0 commit comments