Merge pull request #12 from IliyanIlievPH/master

Send KYC notification to PartnerAdmin instead of admin who changed th…
OpenMAVN · Jun 30, 2020 · 76b0ead · 76b0ead
2 parents e543d90 + 4edb4e7
commit 76b0ead
Showing 1 changed file with 9 additions and 9 deletions.
diff --git a/src/MAVN.Service.Kyc.DomainServices/KycService.cs b/src/MAVN.Service.Kyc.DomainServices/KycService.cs
@@ -90,29 +90,29 @@ public async Task<UpdateKycStatusErrorCode> UpdateKycInfoAsync(KycInformation mo
             if (model.KycStatus != KycStatus.Accepted && model.KycStatus != KycStatus.Rejected)
                 return UpdateKycStatusErrorCode.None;
 
-            var admin = await _adminManagementClient.AdminsApi.GetByIdAsync(
-                new GetAdminByIdRequestModel { AdminUserId = model.AdminUserId.ToString() });
+            var partner = await _partnerManagementClient.Partners.GetByIdAsync(model.PartnerId);
 
-            if (admin.Error != AdminUserResponseErrorCodes.None || admin.Profile == null)
+            if (partner == null)
             {
-                _log.Warning("Missing admin when trying to send KYC notification", context: model.AdminUserId);
+                _log.Warning("Missing partner when trying to send KYC notification", context: model.PartnerId);
                 return UpdateKycStatusErrorCode.None;
             }
 
-            var partner = await _partnerManagementClient.Partners.GetByIdAsync(model.PartnerId);
+            var admin = await _adminManagementClient.AdminsApi.GetByIdAsync(
+                new GetAdminByIdRequestModel { AdminUserId = partner.CreatedBy.ToString() });
 
-            if (partner == null)
+            if (admin.Error != AdminUserResponseErrorCodes.None || admin.Profile == null)
             {
-                _log.Warning("Missing partner when trying to send KYC notification", context: model.PartnerId);
+                _log.Warning("Missing admin when trying to send KYC notification", context: new { PartnerAdminId = partner.CreatedBy });
                 return UpdateKycStatusErrorCode.None;
             }
 
             if (model.KycStatus == KycStatus.Accepted)
-                await _notificationsService.NotifyKycApprovedAsync(model.AdminUserId.ToString(),
+                await _notificationsService.NotifyKycApprovedAsync(admin.Profile.AdminUserId,
                     admin.Profile.Email,
                     admin.Profile.FirstName, partner.Name);
             else
-                await _notificationsService.NotifyKycRejectedAsync(model.AdminUserId.ToString(),
+                await _notificationsService.NotifyKycRejectedAsync(admin.Profile.AdminUserId,
                     admin.Profile.Email, admin.Profile.FirstName, partner.Name, model.Comment);
 
             return UpdateKycStatusErrorCode.None;