[#IOPAE-174]add possibility to create service with manage key

CreateService/__tests__/handler.test.ts

@@ -50,7 +50,7 @@ const anOrganizationFiscalCode = "01234567890" as OrganizationFiscalCode;
 const anEmail = "test@example.com" as EmailString;
 
 const aServiceId = "s123" as NonEmptyString;
-
+const aManageSubscriptionId = "MANAGE-123" as NonEmptyString;
 const aTokenName = "TOKEN_NAME" as NonEmptyString;
 
 const someServicesMetadata: ServiceMetadata = {
@@ -111,6 +111,11 @@ const aUserAuthenticationDeveloper: IAzureApiAuthorization = {
   userId: "u123" as NonEmptyString
 };
 
+const aUserAuthenticationDeveloperWithManageKey: IAzureApiAuthorization = {
+  ...aUserAuthenticationDeveloper,
+  subscriptionId: aManageSubscriptionId
+};
+
 const aUserInfo: UserInfo = {
   token_name: aTokenName
 };
@@ -624,4 +629,35 @@ describe("CreateServiceHandler", () => {
       expect(result.value).toHaveLength(2);
     }
   });
+
+  //MANAGE FLOW
+
+  it("should respond with a created service with subscriptionKeys using a Manage Key", async () => {
+    const createServiceHandler = CreateServiceHandler(
+      mockAppinsights as any,
+      apiClientMock as any,
+      mockUlidGenerator as any,
+      productName,
+      sandboxFiscalCode
+    );
+    const result = await createServiceHandler(
+      mockContext,
+      aUserAuthenticationDeveloperWithManageKey,
+      undefined as any, // not used
+      someUserAttributes,
+      aServicePayload
+    );
+
+    expect(apiClientMock.createSubscription).toHaveBeenCalledTimes(1);
+    expect(apiClientMock.createService).toHaveBeenCalledTimes(1);
+    expect(apiClientMock.getUser).toHaveBeenCalledTimes(1);
+    expect(mockAppinsights.trackEvent).toHaveBeenCalledTimes(1);
+    expect(result.kind).toBe("IResponseSuccessJson");
+    if (result.kind === "IResponseSuccessJson") {
+      expect(result.value).toEqual({
+        ...aService,
+        ...someSubscriptionKeys
+      });
+    }
+  });
 });

CreateService/handler.ts

@@ -24,6 +24,7 @@ import {
   IResponseErrorNotFound,
   IResponseErrorTooManyRequests,
   IResponseSuccessJson,
+  ResponseErrorForbiddenNotAuthorized,
   ResponseSuccessJson
 } from "@pagopa/ts-commons/lib/responses";
 
@@ -55,6 +56,11 @@ import { Service } from "@pagopa/io-functions-admin-sdk/Service";
 import { Subscription } from "@pagopa/io-functions-admin-sdk/Subscription";
 import { UserInfo } from "@pagopa/io-functions-admin-sdk/UserInfo";
 import { StandardServiceCategoryEnum } from "@pagopa/io-functions-admin-sdk/StandardServiceCategory";
+import { SequenceMiddleware } from "@pagopa/ts-commons/lib/sequence_middleware";
+import {
+  AzureUserAttributesManageMiddleware,
+  IAzureUserAttributesManage
+} from "@pagopa/io-functions-commons/dist/src/utils/middlewares/azure_user_attributes_manage";
 import { APIClient } from "../clients/admin";
 import { ServicePayload } from "../generated/definitions/ServicePayload";
 import { ServiceWithSubscriptionKeys } from "../generated/definitions/ServiceWithSubscriptionKeys";
@@ -82,7 +88,7 @@ type ICreateServiceHandler = (
   context: Context,
   auth: IAzureApiAuthorization,
   clientIp: ClientIp,
-  attrs: IAzureUserAttributes,
+  attrs: IAzureUserAttributes | IAzureUserAttributesManage,
   servicePayload: ServicePayload
 ) => Promise<ResponseTypes>;
 
@@ -255,7 +261,10 @@ export function CreateService(
     ContextMiddleware(),
     AzureApiAuthMiddleware(new Set([UserGroup.ApiServiceWrite])),
     ClientIpMiddleware,
-    AzureUserAttributesMiddleware(serviceModel),
+    SequenceMiddleware(ResponseErrorForbiddenNotAuthorized)(
+      AzureUserAttributesMiddleware(serviceModel),
+      AzureUserAttributesManageMiddleware()
+    ),
     RequiredBodyPayloadMiddleware(ServicePayload)
   );
   return wrapRequestHandler(