feat: added migrateWalletInstances function

Refs: #598 [SIW-3556]

Author: silvicir

.changeset/whole-dancers-raise.md

@@ -0,0 +1,5 @@
+---
+"io-wallet-user-func": minor
+---
+
+Added function `migrateWalletInstances` to copy wallet instances data to new tenant database collection

apps/io-wallet-user-func/local.settings.json.example

@@ -40,9 +40,7 @@
     "PidIssuerHealthCheckEnabled": "PID_ISSUER_HEALTH_CHECK_ENABLED",
     "PidIssuerApiRequestTimeout": "PID_ISSUER_API_REQUEST_TIMEOUT",
     "HttpRequestTimeout": "HTTP_REQUEST_TIMEOUT",
-    "SkipSignatureValidation": "SKIP_SIGNATURE_VALIDATION",
     "HardwarePublicTestKey": "HARDWARE_PUBLIC_TEST_PEM_BASE64_ENCODED",
-    "SlackStatusChannelWebhook": "SLACK_STATUS_CHANNEL_WEBHOOK",
     "MailupUsername": "MAILUP_USERNAME",
     "MailupSecret": "MAILUP_SECRET",
     "MailSender": "MAIL_SENDER",
@@ -59,6 +57,7 @@
     "FrontDoorProfileName": "FRONT_DOOR_PROFILE_NAME",
     "FrontDoorEndpointName": "FRONT_DOOR_ENDPOINT_NAME",
     "APPLICATIONINSIGHTS_CONNECTION_STRING": "APPLICATIONINSIGHTS_CONNECTION_STRING",
-    "NODE_OPTIONS": "--import @pagopa/azure-tracing"
+    "NODE_OPTIONS": "--import @pagopa/azure-tracing",
+    "PagoPACosmosDbConnectionString": "PAGOPA_COSMOS_DB_CONNECTION_STRING"
   }
 }

apps/io-wallet-user-func/src/app/main.ts

@@ -1,6 +1,6 @@
 import { CdnManagementClient } from "@azure/arm-cdn";
 import { CosmosClient } from "@azure/cosmos";
-import { app } from "@azure/functions";
+import { app, output } from "@azure/functions";
 import { DefaultAzureCredential } from "@azure/identity";
 import { BlobServiceClient } from "@azure/storage-blob";
 import { QueueServiceClient } from "@azure/storage-queue";
@@ -10,6 +10,7 @@ import { Crypto } from "@peculiar/webcrypto";
 import * as E from "fp-ts/Either";
 import { identity, pipe } from "fp-ts/function";
 import * as t from "io-ts";
+import { WalletInstance } from "io-wallet-common/wallet-instance";
 
 import { getCrlFromUrl } from "@/certificates";
 import { CosmosDbCertificateRepository } from "@/infra/azure/cosmos/certificate";
@@ -26,6 +27,7 @@ import { GetCurrentWalletInstanceStatusFunction } from "@/infra/azure/functions/
 import { GetNonceFunction } from "@/infra/azure/functions/get-nonce";
 import { GetWalletInstanceStatusFunction } from "@/infra/azure/functions/get-wallet-instance-status";
 import { HealthFunction } from "@/infra/azure/functions/health";
+import { MigrateWalletInstancesFunction } from "@/infra/azure/functions/migrate-wallet-instances";
 import { SendEmailOnWalletInstanceCreationFunction } from "@/infra/azure/functions/send-email-on-wallet-instance-creation";
 import { SendEmailOnWalletInstanceRevocationFunction } from "@/infra/azure/functions/send-email-on-wallet-instance-revocation";
 import { SetWalletInstanceStatusFunction } from "@/infra/azure/functions/set-wallet-instance-status";
@@ -299,3 +301,22 @@ app.http("generateCertificateChain", {
   methods: ["POST"],
   route: "certificate-chain",
 });
+
+app.cosmosDB("migrateWalletInstances", {
+  connection: "PagoPACosmosDbConnectionString",
+  containerName: "wallet-instances",
+  createLeaseCollectionIfNotExists: true,
+  databaseName: "db",
+  handler: MigrateWalletInstancesFunction({
+    inputDecoder: t.array(WalletInstance),
+  }),
+  leaseContainerName: "leases-migration",
+  maxItemsPerInvocation: 50,
+  return: output.cosmosDB({
+    connection: "CosmosDbEndpoint",
+    containerName: "wallet-instances",
+    createIfNotExists: false,
+    databaseName: "db",
+  }),
+  startFromBeginning: true,
+});

apps/io-wallet-user-func/src/infra/azure/functions/migrate-wallet-instances.ts

@@ -0,0 +1,7 @@
+import { azureFunction } from "@pagopa/handler-kit-azure-func";
+
+import { MigrateWalletInstancesHandler } from "@/infra/handlers/migrate-wallet-instances";
+
+export const MigrateWalletInstancesFunction = azureFunction(
+  MigrateWalletInstancesHandler,
+);

apps/io-wallet-user-func/src/infra/handlers/migrate-wallet-instances.ts

@@ -0,0 +1,22 @@
+import * as H from "@pagopa/handler-kit";
+import { flow, pipe } from "fp-ts/function";
+import * as RTE from "fp-ts/lib/ReaderTaskEither";
+import { WalletInstance } from "io-wallet-common/wallet-instance";
+
+import { sendTelemetryException } from "@/infra/telemetry";
+
+export const MigrateWalletInstancesHandler = H.of(
+  (walletInstances: WalletInstance[]) =>
+    pipe(
+      walletInstances,
+      RTE.right,
+      RTE.orElseFirstW(
+        flow(
+          sendTelemetryException({
+            functionName: "migrateWalletInstances",
+          }),
+          RTE.fromEither,
+        ),
+      ),
+    ),
+);