fix: added logic on bpdm business logic when byow active

Author: leandro-cavalcante

src/externalsystems/Bpdm.Library/BusinessLogic/BpdmBusinessLogic.cs

@@ -151,17 +151,24 @@ await HandlePullLegalEntityInternal(context, result.CompanyId, result.BpdmData,
             });
 
         var registrationValidationFailed = context.Checklist[ApplicationChecklistEntryTypeId.REGISTRATION_VERIFICATION] == ApplicationChecklistEntryStatusId.FAILED;
+        var createWalletOrTransmitCustomerDidStep = await CreateWalletOrBpnCredentialStepAsync(context.ApplicationId);
 
         return new IApplicationChecklistService.WorkerChecklistProcessStepExecutionResult(
             ProcessStepStatusId.DONE,
             entry => entry.ApplicationChecklistEntryStatusId = ApplicationChecklistEntryStatusId.DONE,
             registrationValidationFailed
                 ? null
-                : new[] { CreateWalletStep() },
+                : new[] { createWalletOrTransmitCustomerDidStep },
             new[] { ProcessStepTypeId.CREATE_BUSINESS_PARTNER_NUMBER_MANUAL },
             true,
             null);
     }
 
     private ProcessStepTypeId CreateWalletStep() => _settings.UseDimWallet ? ProcessStepTypeId.CREATE_DIM_WALLET : ProcessStepTypeId.CREATE_IDENTITY_WALLET;
+
+    private async Task<ProcessStepTypeId> CreateWalletOrBpnCredentialStepAsync(Guid applicationId)
+    {
+        var isWalletCustomerProvider = await portalRepositories.GetInstance<ICompanyRepository>().IsBringYourOwnWallet(applicationId);
+        return isWalletCustomerProvider ? ProcessStepTypeId.TRANSMIT_BPN_DID : CreateWalletStep();
+    }
 }

tests/externalsystems/Bpdm.Library/BpdmBusinessLogicTests.cs

@@ -358,21 +358,10 @@ public async Task HandlePullLegalEntity_WithSharingStateError_ThrowsServiceExcep
     public async Task HandlePullLegalEntity_WithSharingProcessStartedNotSet_ReturnsExpected()
     {
         // Arrange
-        var company = new Company(Guid.NewGuid(), "Test Company", CompanyStatusId.ACTIVE, DateTimeOffset.UtcNow)
-        {
-            BusinessPartnerNumber = "1"
-        };
+        var context = PreparePullLegalEntity();
         var checklistEntry = _fixture.Build<ApplicationChecklistEntry>()
             .With(x => x.ApplicationChecklistEntryStatusId, ApplicationChecklistEntryStatusId.TO_DO)
             .Create();
-        var checklist = new Dictionary<ApplicationChecklistEntryTypeId, ApplicationChecklistEntryStatusId>
-            {
-                { ApplicationChecklistEntryTypeId.REGISTRATION_VERIFICATION, ApplicationChecklistEntryStatusId.DONE },
-                { ApplicationChecklistEntryTypeId.BUSINESS_PARTNER_NUMBER, ApplicationChecklistEntryStatusId.TO_DO }
-            }
-            .ToImmutableDictionary();
-        var context = new IApplicationChecklistService.WorkerChecklistProcessStepData(IdWithoutSharingProcessStarted, default, checklist, Enumerable.Empty<ProcessStepTypeId>());
-        SetupForHandlePullLegalEntity(company);
 
         // Act
         var result = await _logic.HandlePullLegalEntity(context, CancellationToken.None);
@@ -386,6 +375,78 @@ public async Task HandlePullLegalEntity_WithSharingProcessStartedNotSet_ReturnsE
         result.ProcessMessage.Should().Be("SharingProcessStarted was not set");
     }
 
+    [Fact]
+    public async Task HandlePullLegalEntity_BringYourOwnWallet_True_ReturnsExpected()
+    {
+        // Arrange
+        var context = PreparePullLegalEntity();
+
+        A.CallTo(() => _bpdmService.GetSharingState(A<Guid>._, A<CancellationToken>._))
+            .Returns(Task.FromResult(new BpdmSharingState(
+                Guid.NewGuid(),
+                BpdmSharingStateType.Success,
+                null,
+                null,
+                DateTimeOffset.UtcNow,
+                null
+            )));
+        var bpdmLegalEntityOutputData = _fixture.Build<BpdmLegalEntityOutputData>()
+            .With(x => x.LegalEntity,
+                new BpdmLegelEntityData("CAXSDUMMYCATENAZZ",
+                null,
+                null,
+                null,
+                _fixture.Create<BpdmConfidenceCriteria>(), Enumerable.Empty<BpdmStatus>())
+            ).Create();
+
+        A.CallTo(() => _bpdmService.FetchInputLegalEntity(context.ApplicationId.ToString(), A<CancellationToken>._))
+            .Returns(bpdmLegalEntityOutputData);
+
+        A.CallTo(() => _companyRepository.IsBringYourOwnWallet(A<Guid>._)).Returns(true);
+
+        // Act
+        var result = await _logic.HandlePullLegalEntity(context, CancellationToken.None);
+
+        // Assert
+        result.ScheduleStepTypeIds.Should().ContainSingle(x => x == ProcessStepTypeId.TRANSMIT_BPN_DID);
+    }
+
+    [Fact]
+    public async Task HandlePullLegalEntity_BringYourOwnWallet_False_ReturnsExpected()
+    {
+        // Arrange
+        var context = PreparePullLegalEntity();
+
+        A.CallTo(() => _bpdmService.GetSharingState(A<Guid>._, A<CancellationToken>._))
+            .Returns(Task.FromResult(new BpdmSharingState(
+                Guid.NewGuid(),
+                BpdmSharingStateType.Success,
+                null,
+                null,
+                DateTimeOffset.UtcNow,
+                null
+            )));
+        var bpdmLegalEntityOutputData = _fixture.Build<BpdmLegalEntityOutputData>()
+            .With(x => x.LegalEntity,
+                new BpdmLegelEntityData("CAXSDUMMYCATENAZZ",
+                null,
+                null,
+                null,
+                _fixture.Create<BpdmConfidenceCriteria>(), Enumerable.Empty<BpdmStatus>())
+            ).Create();
+
+        A.CallTo(() => _bpdmService.FetchInputLegalEntity(context.ApplicationId.ToString(), A<CancellationToken>._))
+            .Returns(bpdmLegalEntityOutputData);
+
+        A.CallTo(() => _companyRepository.IsBringYourOwnWallet(A<Guid>._)).Returns(false);
+
+        // Act
+        var result = await _logic.HandlePullLegalEntity(context, CancellationToken.None);
+
+        // Assert
+        result.ScheduleStepTypeIds.Should().ContainSingle(x => x == ProcessStepTypeId.CREATE_IDENTITY_WALLET);
+    }
+
     [Fact]
     public async Task HandlePullLegalEntity_WithSharingTypePending_ReturnsExpected()
     {
@@ -576,4 +637,24 @@ private void SetupForHandlePullLegalEntity(Company? company = null)
     }
 
     #endregion
+
+    private IApplicationChecklistService.WorkerChecklistProcessStepData PreparePullLegalEntity()
+    {
+        var company = new Company(Guid.NewGuid(), "Test Company", CompanyStatusId.ACTIVE, DateTimeOffset.UtcNow)
+        {
+            BusinessPartnerNumber = "1"
+        };
+        var checklistEntry = _fixture.Build<ApplicationChecklistEntry>()
+            .With(x => x.ApplicationChecklistEntryStatusId, ApplicationChecklistEntryStatusId.TO_DO)
+            .Create();
+        var checklist = new Dictionary<ApplicationChecklistEntryTypeId, ApplicationChecklistEntryStatusId>
+            {
+                { ApplicationChecklistEntryTypeId.REGISTRATION_VERIFICATION, ApplicationChecklistEntryStatusId.DONE },
+                { ApplicationChecklistEntryTypeId.BUSINESS_PARTNER_NUMBER, ApplicationChecklistEntryStatusId.TO_DO }
+            }
+            .ToImmutableDictionary();
+        var context = new IApplicationChecklistService.WorkerChecklistProcessStepData(IdWithoutSharingProcessStarted, default, checklist, Enumerable.Empty<ProcessStepTypeId>());
+        SetupForHandlePullLegalEntity(company);
+        return context;
+    }
 }