[server] Unimplemented user service on internal port

Author: easyCZ

components/server/src/api/server.ts

@@ -4,16 +4,16 @@
  * See License.AGPL.txt in the project root for license information.
  */
 import { ConnectRouter } from "@bufbuild/connect";
-import { WorkspacesService as WorkspacesServiceDefinition } from "@gitpod/public-api/lib/gitpod/experimental/v1/workspaces_connectweb";
+import { UserService as UserServiceDefinition } from "@gitpod/public-api/lib/gitpod/experimental/v1/workspaces_connectweb";
 import { inject, injectable } from "inversify";
-import { WorkspacesService } from "./workspaces";
+import { UserService } from "./user";
 
 @injectable()
 export class Router {
-    @inject(WorkspacesService)
-    protected workspaces: WorkspacesService;
+    @inject(UserService)
+    protected user: UserService;
 
     public routes(router: ConnectRouter) {
-        router.service(WorkspacesServiceDefinition, this.workspaces);
+        router.service(UserServiceDefinition, this.user);
     }
 }

components/server/src/api/user.ts

@@ -0,0 +1,54 @@
+/**
+ * Copyright (c) 2023 Gitpod GmbH. All rights reserved.
+ * Licensed under the GNU Affero General Public License (AGPL).
+ * See License.AGPL.txt in the project root for license information.
+ */
+
+import { ServiceImpl, ConnectError, Code } from "@bufbuild/connect";
+import { UserService as UserServiceInterface } from "@gitpod/public-api/lib/gitpod/experimental/v1/user_connectweb";
+import {
+    GetAuthenticatedUserRequest,
+    ListSSHKeysRequest,
+    CreateSSHKeyRequest,
+    GetSSHKeyRequest,
+    DeleteSSHKeyRequest,
+    GetGitTokenRequest,
+    BlockUserRequest,
+    GetAuthenticatedUserResponse,
+    ListSSHKeysResponse,
+    CreateSSHKeyResponse,
+    GetSSHKeyResponse,
+    DeleteSSHKeyResponse,
+    GetGitTokenResponse,
+    BlockUserResponse,
+} from "@gitpod/public-api/lib/gitpod/experimental/v1/user_pb";
+
+export class UserService implements ServiceImpl<typeof UserServiceInterface> {
+    getAuthenticatedUser(req: GetAuthenticatedUserRequest): Promise<GetAuthenticatedUserResponse> {
+        throw new ConnectError("unimplemented", Code.Unimplemented);
+    }
+
+    listSSHKeysGetAuthenticatedUserRequest(req: ListSSHKeysRequest): Promise<ListSSHKeysResponse> {
+        throw new ConnectError("unimplemented", Code.Unimplemented);
+    }
+
+    createSSHKeyGetAuthenticatedUserRequest(req: CreateSSHKeyRequest): Promise<CreateSSHKeyResponse> {
+        throw new ConnectError("unimplemented", Code.Unimplemented);
+    }
+
+    getSSHKeyGetAuthenticatedUserRequest(req: GetSSHKeyRequest): Promise<GetSSHKeyResponse> {
+        throw new ConnectError("unimplemented", Code.Unimplemented);
+    }
+
+    deleteSSHKeyGetAuthenticatedUserRequest(req: DeleteSSHKeyRequest): Promise<DeleteSSHKeyResponse> {
+        throw new ConnectError("unimplemented", Code.Unimplemented);
+    }
+
+    getGitTokenGetAuthenticatedUserRequest(req: GetGitTokenRequest): Promise<GetGitTokenResponse> {
+        throw new ConnectError("unimplemented", Code.Unimplemented);
+    }
+
+    blockUserGetAuthenticatedUserRequest(req: BlockUserRequest): Promise<BlockUserResponse> {
+        throw new ConnectError("unimplemented", Code.Unimplemented);
+    }
+}

components/server/src/server.ts

@@ -96,6 +96,7 @@ export class Server<C extends GitpodClient, S extends GitpodServer> {
     protected iamSessionAppServer?: http.Server;
 
     @inject(Router) protected readonly apiRouter: Router;
+    protected apiServer?: http.Server;
 
     protected readonly eventEmitter = new EventEmitter();
     protected app?: express.Application;
@@ -311,6 +312,7 @@ export class Server<C extends GitpodClient, S extends GitpodServer> {
             .catch((err) => log.error("webhook-event-gc: error during startup", err));
 
         this.app = app;
+
         log.info("server initialized.");
     }
 
@@ -392,6 +394,14 @@ export class Server<C extends GitpodClient, S extends GitpodServer> {
             });
         }
 
+        {
+            const apiApp = express();
+            apiApp.use(expressConnectMiddleware(this.apiRouter.routes));
+            this.apiServer = apiApp.listen(9877, () => {
+                log.info(`Connect API server listening on: ${<AddressInfo>this.apiServer!.address()}`);
+            });
+        }
+
         this.debugApp.start();
     }
 
@@ -401,6 +411,7 @@ export class Server<C extends GitpodClient, S extends GitpodServer> {
         await this.stopServer(this.monitoringHttpServer);
         await this.stopServer(this.installationAdminHttpServer);
         await this.stopServer(this.httpServer);
+        await this.stopServer(this.apiServer);
         this.disposables.dispose();
         log.info("server stopped.");
     }