add /lifeliners/private/verification-photo return photo from gcs

Author: ifanfairuz

src/lifeliners/lifeliners.controller.ts

@@ -7,10 +7,12 @@ import {
   Patch,
   Post,
   Query,
+  Res,
   UploadedFile,
   UseGuards,
   UseInterceptors,
 } from '@nestjs/common';
+import type { Response } from 'express';
 import { FileInterceptor } from '@nestjs/platform-express';
 import { Role } from '@prisma/client';
 import { CurrentUser } from '../auth/decorators/current-user.decorator';
@@ -116,7 +118,13 @@ export class LifelinersController {
   @Get('private/verification-photo')
   @UseGuards(JwtAuthGuard, RolesGuard)
   @Roles(Role.LIFELINER)
-  async getVerificationPhoto(@CurrentUser() user: AuthUser) {
-    return this.lifelinersService.getVerificationPhotoUrl(user.id);
+  async getVerificationPhoto(
+    @CurrentUser() user: AuthUser,
+    @Res({ passthrough: true }) res: Response,
+  ) {
+    const { stream, contentType } =
+      await this.lifelinersService.getVerificationPhoto(user.id);
+    res.setHeader('Content-Type', contentType);
+    stream.pipe(res);
   }
 }

src/lifeliners/lifeliners.service.ts

@@ -179,7 +179,10 @@ export class LifelinersService {
     });
   }
 
-  async getVerificationPhotoUrl(userId: string): Promise<{ url: string }> {
+  async getVerificationPhoto(userId: string): Promise<{
+    stream: NodeJS.ReadableStream;
+    contentType: string;
+  }> {
     const lifeliner = await this.prisma.lifeliner.findUnique({
       where: { user_id: userId },
       select: { private_picture: true },
@@ -188,8 +191,7 @@ export class LifelinersService {
     if (!lifeliner.private_picture)
       throw new NotFoundException('No verification photo uploaded');
 
-    const url = await this.storage.getSignedUrl(lifeliner.private_picture);
-    return { url };
+    return this.storage.download(lifeliner.private_picture);
   }
 
   private extractGcsPath(url: string): string | null {

src/storage/storage.service.ts

@@ -51,4 +51,16 @@ export class StorageService {
     });
     return url;
   }
+
+  async download(filePath: string): Promise<{
+    stream: NodeJS.ReadableStream;
+    contentType: string;
+  }> {
+    const file = this.bucket.file(this.prefix(filePath));
+    const [metadata] = await file.getMetadata();
+    return {
+      stream: file.createReadStream(),
+      contentType: metadata.contentType ?? 'application/octet-stream',
+    };
+  }
 }