[#IOPID-1124] backup&delete authentication lock data

CreateDevelopmentProfile/handler.ts

@@ -49,6 +49,7 @@ export function toExtendedProfile(profile: RetrievedProfile): ExtendedProfile {
     accepted_tos_version: profile.acceptedTosVersion,
     blocked_inbox_or_channels: profile.blockedInboxOrChannels,
     email: profile.email,
+    is_email_already_taken: undefined,
     is_email_enabled: profile.isEmailEnabled,
     is_email_validated: profile.isEmailValidated,
     is_inbox_enabled: profile.isInboxEnabled === true,

DeleteUserDataActivity/__tests__/authenticationLockService.test.ts

@@ -0,0 +1,157 @@
+import { RestError } from "@azure/data-tables";
+
+import * as E from "fp-ts/Either";
+import * as ROA from "fp-ts/ReadonlyArray";
+
+import AuthenticationLockService from "../authenticationLockService";
+
+import {
+  aFiscalCode,
+  aNotReleasedData,
+  anUnlockCode,
+  anothernUnlockCode,
+  brokeEntityProfileLockedRecordIterator,
+  errorProfileLockedRecordIterator,
+  getProfileLockedRecordIterator,
+  listLockedProfileEntitiesMock,
+  lockedProfileTableClient,
+  submitTransactionMock
+} from "../../__mocks__/lockedProfileTableClient";
+import { UnlockCode } from "../../generated/definitions/UnlockCode";
+
+// -------------------------------------------
+// Variables
+// -------------------------------------------
+
+const service = new AuthenticationLockService(lockedProfileTableClient);
+
+describe("AuthenticationLockService#getAllUserAuthenticationLockData", () => {
+  it("should return an empty array if query returns no records from table storage", async () => {
+    const result = await service.getAllUserAuthenticationLockData(
+      aFiscalCode
+    )();
+
+    expect(result).toEqual(E.right([]));
+    expect(listLockedProfileEntitiesMock).toHaveBeenCalledWith({
+      queryOptions: {
+        filter: `PartitionKey eq '${aFiscalCode}'`
+      }
+    });
+  });
+
+  it.each`
+    title             | records
+    ${"one record"}   | ${[aNotReleasedData]}
+    ${"more records"} | ${[aNotReleasedData, { ...aNotReleasedData, rowKey: anothernUnlockCode, Released: true }]}
+  `(
+    "should return all the records, if $title are found in table storage",
+    async ({ records }) => {
+      listLockedProfileEntitiesMock.mockImplementationOnce(() =>
+        getProfileLockedRecordIterator(records)
+      );
+
+      const result = await service.getAllUserAuthenticationLockData(
+        aFiscalCode
+      )();
+
+      expect(result).toEqual(E.right(records));
+    }
+  );
+
+  it("should return an error if something went wrong retrieving the records", async () => {
+    listLockedProfileEntitiesMock.mockImplementationOnce(
+      errorProfileLockedRecordIterator
+    );
+
+    const result = await service.getAllUserAuthenticationLockData(
+      aFiscalCode
+    )();
+
+    expect(result).toEqual(E.left(Error("an Error")));
+  });
+
+  it("should return an error if something went wrong decoding a record", async () => {
+    listLockedProfileEntitiesMock.mockImplementationOnce(
+      brokeEntityProfileLockedRecordIterator
+    );
+
+    const result = await service.getAllUserAuthenticationLockData(
+      aFiscalCode
+    )();
+
+    expect(result).toEqual(
+      E.left(
+        Error(
+          'value ["CF"] at [root.0.0.0.partitionKey] is not a valid [string that matches the pattern "^[A-Z]{6}[0-9LMNPQRSTUV]{2}[ABCDEHLMPRST][0-9LMNPQRSTUV]{2}[A-Z][0-9LMNPQRSTUV]{3}[A-Z]$"] / value [undefined] at [root.0.0.1.Released] is not a valid [boolean] / value ["CF"] at [root.0.1.partitionKey] is not a valid [string that matches the pattern "^[A-Z]{6}[0-9LMNPQRSTUV]{2}[ABCDEHLMPRST][0-9LMNPQRSTUV]{2}[A-Z][0-9LMNPQRSTUV]{3}[A-Z]$"]'
+        )
+      )
+    );
+  });
+});
+
+describe("AuthenticationLockService#deleteUserAuthenticationLockData", () => {
+  beforeEach(() => {
+    jest.clearAllMocks();
+  });
+
+  const generateUnlockCodes = (number: number) =>
+    [...Array(number).keys()].map(i => i.toString().padStart(9, "0"));
+  it.each`
+    scenario                      | items
+    ${"with less than 100 items"} | ${generateUnlockCodes(50)}
+    ${"with more than 100 items"} | ${generateUnlockCodes(150)}
+  `(
+    "should return true when records delete transaction succeded $scenario",
+    async ({ items }: { items: UnlockCode[] }) => {
+      const result = await service.deleteUserAuthenticationLockData(
+        aFiscalCode,
+        items
+      )();
+
+      expect(result).toEqual(E.right(true));
+
+      let i = 1;
+      for (const chunk of ROA.chunksOf(100)(items)) {
+        expect(submitTransactionMock).toHaveBeenNthCalledWith(
+          i,
+          chunk.map(unlockCode => [
+            "delete",
+            {
+              partitionKey: aFiscalCode,
+              rowKey: unlockCode
+            }
+          ])
+        );
+
+        i++;
+      }
+    }
+  );
+
+  it("should return an Error when at least one CF-unlock code was not found", async () => {
+    submitTransactionMock.mockRejectedValueOnce(
+      new RestError("Not Found", { statusCode: 404 })
+    );
+    const result = await service.deleteUserAuthenticationLockData(aFiscalCode, [
+      anUnlockCode,
+      anothernUnlockCode
+    ])();
+
+    expect(result).toEqual(
+      E.left(new Error("Something went wrong deleting the records"))
+    );
+  });
+
+  it("should return an Error when an error occurred deleting the records", async () => {
+    submitTransactionMock.mockRejectedValueOnce(
+      new RestError("An Error", { statusCode: 500 })
+    );
+    const result = await service.deleteUserAuthenticationLockData(aFiscalCode, [
+      anUnlockCode
+    ])();
+
+    expect(result).toEqual(
+      E.left(new Error("Something went wrong deleting the records"))
+    );
+  });
+});

DeleteUserDataActivity/__tests__/backupAndDelete.test.ts

@@ -27,6 +27,7 @@ import {
 } from "../../__mocks__/mocks";
 import { backupAndDeleteAllUserData } from "../backupAndDelete";
 import { IBlobServiceInfo } from "../types";
+import { AuthenticationLockServiceMock } from "../../__mocks__/authenticationLockService.mock";
 
 const asyncIteratorOf = <T>(items: T[]): AsyncIterator<T[]> => {
   const data = [...items];
@@ -150,10 +151,13 @@ const userDataBackup = {
   folder: "folder"
 } as IBlobServiceInfo;
 
+const authenticationLockService = AuthenticationLockServiceMock;
+
 describe(`backupAndDeleteAllUserData`, () => {
   beforeEach(() => jest.clearAllMocks());
   it("should work if there are no errors", async () => {
     const result = await backupAndDeleteAllUserData({
+      authenticationLockService,
       messageContentBlobService,
       messageModel,
       messageStatusModel,
@@ -179,6 +183,7 @@ describe(`backupAndDeleteAllUserData`, () => {
   it("should not stop if a content is not found for a message", async () => {
     mockGetContentFromBlob.mockImplementationOnce(() => TE.of(none));
     const result = await backupAndDeleteAllUserData({
+      authenticationLockService,
       messageContentBlobService,
       messageModel,
       messageStatusModel,
@@ -204,6 +209,7 @@ describe(`backupAndDeleteAllUserData`, () => {
   it("should not stop if  there is an error while looking for a message content", async () => {
     mockGetContentFromBlob.mockImplementationOnce(() => TE.left(new Error("")));
     const result = await backupAndDeleteAllUserData({
+      authenticationLockService,
       messageContentBlobService,
       messageModel,
       messageStatusModel,
@@ -222,6 +228,7 @@ describe(`backupAndDeleteAllUserData`, () => {
   it("should not stop if a notification is not found for a message (none)", async () => {
     mockFindNotificationForMessage.mockImplementationOnce(() => TE.of(none));
     const result = await backupAndDeleteAllUserData({
+      authenticationLockService,
       messageContentBlobService,
       messageModel,
       messageStatusModel,
@@ -245,6 +252,7 @@ describe(`backupAndDeleteAllUserData`, () => {
       })
     );
     const result = await backupAndDeleteAllUserData({
+      authenticationLockService,
       messageContentBlobService,
       messageModel,
       messageStatusModel,
@@ -268,6 +276,7 @@ describe(`backupAndDeleteAllUserData`, () => {
       })
     );
     const result = await backupAndDeleteAllUserData({
+      authenticationLockService,
       messageContentBlobService,
       messageModel,
       messageStatusModel,
@@ -289,6 +298,7 @@ describe(`backupAndDeleteAllUserData`, () => {
       asyncIteratorOf([])
     );
     const result = await backupAndDeleteAllUserData({
+      authenticationLockService,
       messageContentBlobService,
       messageModel,
       messageStatusModel,
@@ -316,6 +326,7 @@ describe(`backupAndDeleteAllUserData`, () => {
       asyncIteratorOf([E.left([{} as ValidationError])])
     );
     const result = await backupAndDeleteAllUserData({
+      authenticationLockService,
       messageContentBlobService,
       messageModel,
       messageStatusModel,
@@ -343,6 +354,7 @@ describe(`backupAndDeleteAllUserData`, () => {
       TE.left(toCosmosErrorResponse("") as CosmosErrors)
     );
     const result = await backupAndDeleteAllUserData({
+      authenticationLockService,
       messageContentBlobService,
       messageModel,
       messageStatusModel,