feat: added getCurrentWalletInstanceStatus endpoint

Refs: #1197 SIW-2079

Author: christianatzeni

api_io_wallet.yaml

@@ -82,6 +82,30 @@ paths:
         "503":
           $ref: "#/components/responses/ServiceUnavailable"
 
+  /wallet-instances/current/status:
+    get:
+      summary: Retrieve the current Wallet Instance status
+      operationId: getCurrentWalletInstanceStatus
+      responses:
+        "200":
+          description: Wallet Instance status successfully retrieved
+          content:
+            application/json:
+              schema:
+                $ref: "#/components/schemas/WalletInstanceData"
+        "400":
+          $ref: "#/components/responses/BadRequest"
+        "403":
+          $ref: "#/components/responses/Forbidden"
+        "404":
+          $ref: "#/components/responses/NotFound"
+        "422":
+          $ref: "#/components/responses/UnprocessableContent"
+        "500":
+          $ref: "#/components/responses/Unexpected"
+        "503":
+          $ref: "#/components/responses/ServiceUnavailable"
+
   /wallet-instances/{id}/status:
     parameters:
     - in: path

src/controllers/ioWalletController.ts

@@ -199,6 +199,23 @@ export default class IoWalletController {
       )()
     );
 
+  /**
+   * Get Current Wallet Instance Status
+   */
+  public readonly getCurrentWalletInstanceStatus = (
+    req: express.Request
+  ): Promise<
+    | IResponseErrorInternal
+    | IResponseSuccessJson<WalletInstanceData>
+    | IResponseErrorNotFound
+    | IResponseErrorServiceUnavailable
+    | IResponseErrorValidation
+    | IResponseErrorForbiddenNotAuthorized
+  > =>
+    withUserFromRequest(req, async (user) =>
+      this.ioWalletService.getCurrentWalletInstanceStatus(user.fiscal_code)
+    );
+
   private readonly ensureUserIsAllowed = (
     userId: NonEmptyString
   ): TE.TaskEither<Error, void> =>

src/routes/ioWalletRoutes.ts

@@ -45,6 +45,15 @@ export const registerIoWalletAPIRoutes = (
     )
   );
 
+  app.get(
+    `${basePath}/wallet-instances/current/status`,
+    bearerSessionTokenAuth,
+    toExpressHandler(
+      ioWalletController.getCurrentWalletInstanceStatus,
+      ioWalletController
+    )
+  );
+
   app.get(
     `${basePath}/wallet-instances/:walletInstanceId/status`,
     bearerSessionTokenAuth,

src/services/__tests__/ioWalletService.test.ts

@@ -50,6 +50,17 @@ mockGetWalletInstanceStatus.mockImplementation(() =>
   })
 );
 
+mockGetCurrentWalletInstanceStatus.mockImplementation(() =>
+  t.success({
+    status: 200,
+    value: {
+      id: "bar",
+      is_revoked: "false",
+      revocation_reason: "NEW_WALLET_INSTANCE_CREATED"
+    },
+  })
+);
+
 mockSetWalletInstanceStatus.mockImplementation(() =>
   t.success({
     status: 204,
@@ -635,6 +646,132 @@ describe("IoWalletService#getWalletInstanceStatus", () => {
   });
 });
 
+describe("IoWalletService#getCurrentWalletInstanceStatus", () => {
+  beforeEach(() => {
+    jest.clearAllMocks();
+  });
+
+  it("should make the correct api call", async () => {
+    const service = new IoWalletService(api, trialSystemApi);
+
+    await service.getCurrentWalletInstanceStatus(aFiscalCode);
+
+    expect(mockGetCurrentWalletInstanceStatus).toHaveBeenCalledWith({
+      "fiscal-code": aFiscalCode,
+    });
+  });
+
+  it("should handle a success response", async () => {
+    const service = new IoWalletService(api, trialSystemApi);
+
+    const res = await service.getCurrentWalletInstanceStatus(aFiscalCode);
+
+    expect(res).toMatchObject({
+      kind: "IResponseSuccessJson",
+    });
+  });
+
+  it("should handle an internal error when the API client returns 400", async () => {
+    mockGetCurrentWalletInstanceStatus.mockImplementationOnce(() =>
+      t.success({ status: 400 })
+    );
+
+    const service = new IoWalletService(api, trialSystemApi);
+
+    const res = await service.getCurrentWalletInstanceStatus(aFiscalCode);
+
+    expect(res).toMatchObject({
+      kind: "IResponseErrorInternal",
+    });
+  });
+
+  it("should handle a not found error when the API client returns 404", async () => {
+    mockGetCurrentWalletInstanceStatus.mockImplementationOnce(() =>
+      t.success({ status: 404 })
+    );
+
+    const service = new IoWalletService(api, trialSystemApi);
+
+    const res = await service.getCurrentWalletInstanceStatus(aFiscalCode);
+
+    expect(res).toMatchObject({
+      kind: "IResponseErrorNotFound",
+    });
+  });
+
+  it("should handle an internal error when the API client returns 422", async () => {
+    mockGetCurrentWalletInstanceStatus.mockImplementationOnce(() =>
+      t.success({ status: 422 })
+    );
+
+    const service = new IoWalletService(api, trialSystemApi);
+
+    const res = await service.getCurrentWalletInstanceStatus(aFiscalCode);
+
+    expect(res).toMatchObject({
+      kind: "IResponseErrorInternal",
+    });
+  });
+
+  it("should handle an internal error when the API client returns 500", async () => {
+    const aGenericProblem = {};
+    mockGetCurrentWalletInstanceStatus.mockImplementationOnce(() =>
+      t.success({ status: 500, value: aGenericProblem })
+    );
+
+    const service = new IoWalletService(api, trialSystemApi);
+
+    const res = await service.getCurrentWalletInstanceStatus(aFiscalCode);
+
+    expect(res).toMatchObject({
+      kind: "IResponseErrorInternal",
+    });
+  });
+
+  it("should handle a service unavailable error when the API client returns 503", async () => {
+    const aGenericProblem = {};
+    mockGetCurrentWalletInstanceStatus.mockImplementationOnce(() =>
+      t.success({ status: 503, value: aGenericProblem })
+    );
+
+    const service = new IoWalletService(api, trialSystemApi);
+
+    const res = await service.getCurrentWalletInstanceStatus(aFiscalCode);
+
+    expect(res).toMatchObject({
+      kind: "IResponseErrorServiceUnavailable",
+    });
+  });
+
+  it("should handle an internal error when the API client returns a code not specified in spec", async () => {
+    const aGenericProblem = {};
+    mockGetCurrentWalletInstanceStatus.mockImplementationOnce(() =>
+      t.success({ status: 599, value: aGenericProblem })
+    );
+
+    const service = new IoWalletService(api, trialSystemApi);
+
+    const res = await service.getCurrentWalletInstanceStatus(aFiscalCode);
+
+    expect(res).toMatchObject({
+      kind: "IResponseErrorInternal",
+    });
+  });
+
+  it("should return an error if the api call throws an error", async () => {
+    mockGetCurrentWalletInstanceStatus.mockImplementationOnce(() => {
+      throw new Error();
+    });
+    const service = new IoWalletService(api, trialSystemApi);
+
+    const res = await service.getCurrentWalletInstanceStatus(aFiscalCode);
+
+    expect(res).toMatchObject({
+      kind: "IResponseErrorInternal",
+    });
+  });
+});
+
 describe("IoWalletService#getSubscription", () => {
   beforeEach(() => {
     jest.clearAllMocks();

src/services/ioWalletService.ts

@@ -281,6 +281,48 @@ export default class IoWalletService {
       });
     });
 
+  /**
+   * Get Current Wallet Instance Status
+   */
+  public readonly getCurrentWalletInstanceStatus = (
+    fiscal_code: FiscalCode
+  ): Promise<
+    | IResponseSuccessJson<WalletInstanceData>
+    | IResponseErrorNotFound
+    | IResponseErrorInternal
+    | IResponseErrorServiceUnavailable
+  > =>
+    withCatchAsInternalError(async () => {
+      const validated =
+        await this.ioWalletApiClient.getCurrentWalletInstanceStatus({
+          "fiscal-code": fiscal_code
+        });
+      return withValidatedOrInternalError(validated, (response) => {
+        switch (response.status) {
+          case 200:
+            return ResponseSuccessJson(response.value);
+          case 404:
+            return ResponseErrorNotFound(
+              "Not Found",
+              "Wallet instance not found"
+            );
+          case 400:
+          case 422:
+          case 500:
+            return ResponseErrorInternal(
+              `Internal server error | ${response.value}`
+            );
+          case 503:
+            return ResponseErrorServiceTemporarilyUnavailable(
+              serviceUnavailableDetail,
+              "10"
+            );
+          default:
+            return ResponseErrorStatusNotDefinedInSpec(response);
+        }
+      });
+    });
+
   /**
    * Get the subscription given a specific user.
    */