chore(j-s): Update subpoena status from digital-mailbox

apps/judicial-system/backend/src/app/modules/police/internalPolice.controller.ts

@@ -0,0 +1,34 @@
+import { Controller, Get, Inject, Param, UseGuards } from '@nestjs/common'
+import { ApiOkResponse, ApiTags } from '@nestjs/swagger'
+
+import { type Logger, LOGGER_PROVIDER } from '@island.is/logging'
+
+import { TokenGuard } from '@island.is/judicial-system/auth'
+
+import { Case, CaseExistsGuard, CurrentCase } from '../case'
+import { Subpoena } from '../subpoena'
+import { PoliceService } from './police.service'
+
+@UseGuards(TokenGuard, CaseExistsGuard)
+@Controller('api/internal/case/:caseId')
+@ApiTags('internal police')
+export class InternalPoliceController {
+  constructor(
+    private readonly policeService: PoliceService,
+    @Inject(LOGGER_PROVIDER) private readonly logger: Logger,
+  ) {}
+
+  @Get('subpoenaStatus/:subpoenaId')
+  @ApiOkResponse({
+    type: Subpoena,
+    description: 'Gets subpoena status',
+  })
+  getSubpoenaStatus(
+    @Param('subpoenaId') subpoenaId: string,
+    @CurrentCase() theCase: Case,
+  ): Promise<Subpoena> {
+    this.logger.debug(`Gets subpoena status in case ${theCase.id}`)
+
+    return this.policeService.getSubpoenaStatus(subpoenaId)
+  }
+}

apps/judicial-system/backend/src/app/modules/police/police.module.ts

@@ -1,6 +1,7 @@
 import { forwardRef, Module } from '@nestjs/common'
 
 import { AwsS3Module, CaseModule, EventModule, SubpoenaModule } from '../index'
+import { InternalPoliceController } from './internalPolice.controller'
 import { PoliceController } from './police.controller'
 import { PoliceService } from './police.service'
 
@@ -13,6 +14,6 @@ import { PoliceService } from './police.service'
   ],
   providers: [PoliceService],
   exports: [PoliceService],
-  controllers: [PoliceController],
+  controllers: [PoliceController, InternalPoliceController],
 })
 export class PoliceModule {}

apps/judicial-system/backend/src/app/modules/police/police.service.ts

@@ -336,7 +336,7 @@ export class PoliceService {
       })
   }
 
-  async getSubpoenaStatus(subpoenaId: string, user: User): Promise<Subpoena> {
+  async getSubpoenaStatus(subpoenaId: string, user?: User): Promise<Subpoena> {
     return this.fetchPoliceDocumentApi(
       `${this.xRoadPath}/GetSubpoenaStatus?id=${subpoenaId}`,
     )
@@ -407,8 +407,8 @@ export class PoliceService {
           'Failed to get subpoena',
           {
             subpoenaId,
-            actor: user.name,
-            institution: user.institution?.name,
+            actor: user?.name || 'Digital-mailbox',
+            institution: user?.institution?.name,
           },
           reason,
         )

apps/judicial-system/digital-mailbox-api/src/app/modules/cases/case.service.ts

@@ -86,6 +86,7 @@ export class CaseService {
     lang?: string,
   ): Promise<CasesResponse[]> {
     const response = await this.fetchCases(nationalId)
+
     return CasesResponse.fromInternalCasesResponse(response, lang)
   }
 
@@ -95,6 +96,16 @@ export class CaseService {
     lang?: string,
   ): Promise<CaseResponse> {
     const response = await this.fetchCase(id, nationalId)
+    const defendant = response.defendants[0]
+
+    if (!defendant) {
+      throw new NotFoundException('No defendant found for this case')
+    }
+
+    if (defendant.subpoenas && defendant.subpoenas[0].subpoenaId) {
+      await this.fetchServiceStatus(id, defendant.subpoenas[0].subpoenaId)
+    }
+
     return CaseResponse.fromInternalCaseResponse(response, lang)
   }
 
@@ -230,6 +241,52 @@ export class CaseService {
     }
   }
 
+  private async fetchServiceStatus(
+    caseId: string,
+    subpoenaId: string,
+  ): Promise<InternalCaseResponse> {
+    try {
+      const res = await fetch(
+        `${this.config.backendUrl}/api/internal/case/${caseId}/subpoenaStatus/${subpoenaId}`,
+        {
+          method: 'GET',
+          headers: {
+            'Content-Type': 'application/json',
+            authorization: `Bearer ${this.config.secretToken}`,
+          },
+        },
+      )
+
+      if (!res.ok) {
+        if (res.status === 404) {
+          throw new NotFoundException(`Case ${caseId} not found`)
+        }
+
+        const reason = await res.text()
+
+        throw new BadGatewayException(
+          reason ||
+            'Unexpected error occurred while fetching serviceStatus by subpoenaID',
+        )
+      }
+
+      const caseData = await res.json()
+
+      return caseData
+    } catch (reason) {
+      if (
+        reason instanceof BadGatewayException ||
+        reason instanceof NotFoundException
+      ) {
+        throw reason
+      }
+
+      throw new BadGatewayException(
+        `Failed to fetch serviceStatus by subpoenaId: ${reason.message}`,
+      )
+    }
+  }
+
   private async patchDefenseInfo(
     defendantNationalId: string,
     caseId: string,