Add healthcheck to email service

Author: UZ9

packages/email-service/src/app.module.ts

@@ -3,9 +3,10 @@ import { AppController } from './app.controller';
 import { AppService } from './app.service';
 import { EmailModule } from './modules/email/email.module';
 import { SentryModule } from '@sentry/nestjs/setup';
+import { HealthModule } from './modules/health/health.module';
 
 @Module({
-  imports: [SentryModule.forRoot(), EmailModule],
+  imports: [SentryModule.forRoot(), EmailModule, HealthModule],
   controllers: [AppController],
   providers: [AppService],
 })

packages/email-service/src/main.ts

@@ -4,7 +4,12 @@ import { AppModule } from './app.module';
 import { MicroserviceOptions, Transport } from '@nestjs/microservices';
 import { join } from 'path';
 import { ConfigModule } from '@nestjs/config';
-import { EmailProtoFile, EmailProto } from 'juno-proto';
+import {
+  EmailProtoFile,
+  EmailProto,
+  HealthProto,
+  HealthProtoFile,
+} from 'juno-proto';
 import { SentryFilter } from './sentry.filter';
 
 async function bootstrap() {
@@ -16,8 +21,11 @@ async function bootstrap() {
     {
       transport: Transport.GRPC,
       options: {
-        package: [EmailProto.JUNO_EMAIL_PACKAGE_NAME],
-        protoPath: [EmailProtoFile],
+        package: [
+          EmailProto.JUNO_EMAIL_PACKAGE_NAME,
+          HealthProto.GRPC_HEALTH_V1_PACKAGE_NAME,
+        ],
+        protoPath: [EmailProtoFile, HealthProtoFile],
         url: process.env.EMAIL_SERVICE_ADDR,
       },
     },

packages/email-service/src/modules/health/health.controller.ts

@@ -0,0 +1,24 @@
+import { Controller } from '@nestjs/common';
+import { HealthProto } from 'juno-proto';
+import { Observable } from 'rxjs';
+
+@Controller()
+@HealthProto.HealthControllerMethods()
+export class HealthController implements HealthProto.HealthController {
+  Watch(
+    // eslint-disable-next-line @typescript-eslint/no-unused-vars
+    request: HealthProto.HealthCheckRequest,
+  ): Observable<HealthProto.HealthCheckResponse> {
+    throw new Error('Method not implemented.');
+  }
+  Check(
+    // eslint-disable-next-line @typescript-eslint/no-unused-vars
+    _request: HealthProto.HealthCheckRequest,
+  ):
+    | HealthProto.HealthCheckResponse
+    | Promise<HealthProto.HealthCheckResponse> {
+    return {
+      status: HealthProto.HealthCheckResponse_ServingStatus.SERVING,
+    };
+  }
+}

packages/email-service/src/modules/health/health.module.ts

@@ -0,0 +1,7 @@
+import { Module } from '@nestjs/common';
+import { HealthController } from './health.controller';
+
+@Module({
+  controllers: [HealthController],
+})
+export class HealthModule {}