[public-api] hello service server impl

Author: akosyakov

components/public-api/gitpod/experimental/v1/dummy.proto

@@ -16,8 +16,13 @@ service HelloService {
       returns (stream LotsOfRepliesResponse);
 }
 
-message SayHelloRequest { string greeting = 1; }
+message SayHelloRequest {}
 message SayHelloResponse { string reply = 1; }
 
-message LotsOfRepliesRequest { string greeting = 1; }
-message LotsOfRepliesResponse { string reply = 1; }
+message LotsOfRepliesRequest {
+  int32 previous_count = 1;
+}
+message LotsOfRepliesResponse {
+  string reply = 1;
+  int32 count = 2;
+}

components/public-api/go/experimental/v1/dummy.pb.go

@@ -0,0 +1,47 @@
+/**
+ * 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 { HandlerContext, ServiceImpl } from "@bufbuild/connect";
+import { HelloService } from "@gitpod/public-api/lib/gitpod/experimental/v1/dummy_connectweb";
+import {
+    LotsOfRepliesRequest,
+    LotsOfRepliesResponse,
+    SayHelloRequest,
+    SayHelloResponse,
+} from "@gitpod/public-api/lib/gitpod/experimental/v1/dummy_pb";
+import { injectable } from "inversify";
+
+/**
+ * TODO(ak):
+ * - auth
+ * - server-side observability
+ * - client-side observability
+ * - rate limitting
+ */
+@injectable()
+export class APIHelloService implements ServiceImpl<typeof HelloService> {
+    async sayHello(req: SayHelloRequest, context: HandlerContext): Promise<SayHelloResponse> {
+        const response = new SayHelloResponse();
+        response.reply = "Hello " + this.getSubject();
+        return response;
+    }
+    async *lotsOfReplies(req: LotsOfRepliesRequest, context: HandlerContext): AsyncGenerator<LotsOfRepliesResponse> {
+        let count = req.previousCount || 0;
+        while (true) {
+            const response = new LotsOfRepliesResponse();
+            response.reply = `Hello ${this.getSubject()} ${count}`;
+            response.count = count;
+            yield response;
+            count++;
+            await new Promise((resolve) => setTimeout(resolve, 30000));
+        }
+    }
+
+    private getSubject(): string {
+        // TODO(ak) get identify from JWT
+        return "World";
+    }
+}

components/public-api/typescript/src/gitpod/experimental/v1/dummy_pb.ts

@@ -4,28 +4,31 @@
  * See License.AGPL.txt in the project root for license information.
  */
 
-import * as http from "http";
-import express from "express";
-import { log } from "@gitpod/gitpod-protocol/lib/util/logging";
-import { inject, injectable } from "inversify";
-import { APITeamsService } from "./teams";
-import { APIUserService } from "./user";
 import { ConnectRouter } from "@bufbuild/connect";
 import { expressConnectMiddleware } from "@bufbuild/connect-express";
-import { UserService as UserServiceDefinition } from "@gitpod/public-api/lib/gitpod/experimental/v1/user_connectweb";
+import { log } from "@gitpod/gitpod-protocol/lib/util/logging";
+import { HelloService } from "@gitpod/public-api/lib/gitpod/experimental/v1/dummy_connectweb";
+import { StatsService } from "@gitpod/public-api/lib/gitpod/experimental/v1/stats_connectweb";
 import { TeamsService as TeamsServiceDefinition } from "@gitpod/public-api/lib/gitpod/experimental/v1/teams_connectweb";
+import { UserService as UserServiceDefinition } from "@gitpod/public-api/lib/gitpod/experimental/v1/user_connectweb";
 import { WorkspacesService as WorkspacesServiceDefinition } from "@gitpod/public-api/lib/gitpod/experimental/v1/workspaces_connectweb";
-import { StatsService } from "@gitpod/public-api/lib/gitpod/experimental/v1/stats_connectweb";
+import express from "express";
+import * as http from "http";
+import { inject, injectable } from "inversify";
 import { AddressInfo } from "net";
-import { APIWorkspacesService } from "./workspaces";
+import { APIHelloService } from "./dummy";
 import { APIStatsService } from "./stats";
+import { APITeamsService } from "./teams";
+import { APIUserService } from "./user";
+import { APIWorkspacesService } from "./workspaces";
 
 @injectable()
 export class API {
     @inject(APIUserService) protected readonly apiUserService: APIUserService;
     @inject(APITeamsService) protected readonly apiTeamService: APITeamsService;
     @inject(APIWorkspacesService) protected readonly apiWorkspacesService: APIWorkspacesService;
     @inject(APIStatsService) protected readonly apiStatsService: APIStatsService;
+    @inject(APIHelloService) private readonly apiHelloService: APIHelloService;
 
     public listen(): http.Server {
         const app = express();
@@ -50,4 +53,16 @@ export class API {
             }),
         );
     }
+
+    get apiRouter(): express.Router {
+        const router = express.Router();
+        router.use(
+            expressConnectMiddleware({
+                routes: (router: ConnectRouter) => {
+                    router.service(HelloService, this.apiHelloService);
+                },
+            }),
+        );
+        return router;
+    }
 }

components/server/src/api/dummy.ts

@@ -133,6 +133,7 @@ import { GitpodTokenService } from "./user/gitpod-token-service";
 import { EnvVarService } from "./user/env-var-service";
 import { ScmService } from "./projects/scm-service";
 import { RelationshipUpdateJob } from "./authorization/relationship-updater-job";
+import { APIHelloService } from "./api/dummy";
 
 export const productionContainerModule = new ContainerModule(
     (bind, unbind, isBound, rebind, unbindAsync, onActivation, onDeactivation) => {
@@ -330,6 +331,7 @@ export const productionContainerModule = new ContainerModule(
         bind(RelationshipUpdater).toSelf().inSingletonScope();
 
         // grpc / Connect API
+        bind(APIHelloService).toSelf().inSingletonScope();
         bind(APIUserService).toSelf().inSingletonScope();
         bind(APITeamsService).toSelf().inSingletonScope();
         bind(APIWorkspacesService).toSelf().inSingletonScope();

components/server/src/api/server.ts

@@ -317,6 +317,8 @@ export class Server {
 
         log.info("Registered Bitbucket Server app at " + BitbucketServerApp.path);
         app.use(BitbucketServerApp.path, this.bitbucketServerApp.router);
+
+        app.use(this.api.apiRouter);
     }
 
     public async start(port: number) {