[protocol] Centralize grpc.isConnectionAlive

Tool: gitpod/catfood.gitpod.cloud

Author: geropl

components/gitpod-protocol/src/util/grpc.ts

@@ -179,3 +179,12 @@ export function createDebugLogInterceptor(): grpc.Interceptor {
 export function isGrpcError(err: any): err is grpc.StatusObject {
     return err.code && err.details;
 }
+
+export function isConnectionAlive(client: grpc.Client) {
+    const cs = client.getChannel().getConnectivityState(false);
+    return (
+        cs == grpc.connectivityState.CONNECTING ||
+        cs == grpc.connectivityState.IDLE ||
+        cs == grpc.connectivityState.READY
+    );
+}

components/image-builder-api/typescript/src/sugar.ts

@@ -8,7 +8,7 @@ import { ImageBuilderClient } from "./imgbuilder_grpc_pb";
 import { TraceContext } from "@gitpod/gitpod-protocol/lib/util/tracing";
 import { Deferred } from "@gitpod/gitpod-protocol/lib/util/deferred";
 import { log } from "@gitpod/gitpod-protocol/lib/util/logging";
-import { createClientCallMetricsInterceptor, IClientCallMetrics } from "@gitpod/gitpod-protocol/lib/util/grpc";
+import { createClientCallMetricsInterceptor, IClientCallMetrics, isConnectionAlive } from "@gitpod/gitpod-protocol/lib/util/grpc";
 import * as opentracing from "opentracing";
 import { Metadata } from "@grpc/grpc-js";
 import {
@@ -130,12 +130,7 @@ export class PromisifiedImageBuilderClient {
     ) {}
 
     public isConnectionAlive() {
-        const cs = this.client.getChannel().getConnectivityState(false);
-        return (
-            cs == grpc.connectivityState.CONNECTING ||
-            cs == grpc.connectivityState.IDLE ||
-            cs == grpc.connectivityState.READY
-        );
+        return isConnectionAlive(this.client);
     }
 
     public resolveBaseImage(ctx: TraceContext, request: ResolveBaseImageRequest): Promise<ResolveBaseImageResponse> {

components/server/src/util/content-service-sugar.ts

@@ -6,7 +6,11 @@
 
 import { inject, injectable, interfaces, optional } from "inversify";
 import * as grpc from "@grpc/grpc-js";
-import { createClientCallMetricsInterceptor, IClientCallMetrics } from "@gitpod/gitpod-protocol/lib/util/grpc";
+import {
+    createClientCallMetricsInterceptor,
+    IClientCallMetrics,
+    isConnectionAlive,
+} from "@gitpod/gitpod-protocol/lib/util/grpc";
 import { IDEPluginServiceClient } from "@gitpod/content-service/lib/ideplugin_grpc_pb";
 import { ContentServiceClient } from "@gitpod/content-service/lib/content_grpc_pb";
 import { BlobServiceClient } from "@gitpod/content-service/lib/blobs_grpc_pb";
@@ -142,12 +146,3 @@ export class CachingHeadlessLogServiceClientProvider extends CachingClientProvid
         });
     }
 }
-
-function isConnectionAlive(client: grpc.Client) {
-    const cs = client.getChannel().getConnectivityState(false);
-    return (
-        cs == grpc.connectivityState.CONNECTING ||
-        cs == grpc.connectivityState.IDLE ||
-        cs == grpc.connectivityState.READY
-    );
-}