Marmelator/persistence-service
1
0
Fork 0
Code Issues Pull Requests 17 Actions Packages Projects Releases 1.1k Wiki Activity

RED-7094 - extracted liquibase code #43

Merged
timo.bejan.ext merged 1 commits from RED-7094 into master 2023-07-06 15:18:04 +02:00
Conversation 2 Commits 1 Files Changed 2 +10 -6
2 changed files with 10 additions and 6 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
persistence-service-v1/persistence-service-processor-v1/pom.xml
View File

@ -19,7 +19,7 @@
<swagger-commons.version>0.5.0</swagger-commons.version> <swagger-commons.version>0.5.0</swagger-commons.version>
<keycloak-commons.version>0.18.0</keycloak-commons.version> <keycloak-commons.version>0.18.0</keycloak-commons.version>
<jobs-commons.version>0.6.0</jobs-commons.version> <jobs-commons.version>0.6.0</jobs-commons.version>
<database-tenant-commons.version>0.3.0</database-tenant-commons.version> <database-tenant-commons.version>0.4.0</database-tenant-commons.version>
</properties> </properties>
<dependencies> <dependencies>

4
persistence-service-v1/persistence-service-processor-v1/src/main/java/com/iqser/red/service/persistence/management/v1/processor/service/job/SyncUserPermissionsJob.java
View File

@ -1,5 +1,7 @@
package com.iqser.red.service.persistence.management.v1.processor.service.job; package com.iqser.red.service.persistence.management.v1.processor.service.job;
import static com.iqser.red.service.persistence.management.v1.processor.utils.TenantUtils.isTenantReadyForPersistence;
import org.quartz.Job; import org.quartz.Job;
import org.quartz.JobExecutionContext; import org.quartz.JobExecutionContext;
import org.quartz.JobExecutionException; import org.quartz.JobExecutionException;
@ -27,12 +29,14 @@ public class SyncUserPermissionsJob implements Job {
var singleTenant = context.getJobDetail().getJobDataMap() != null ? context.getJobDetail().getJobDataMap().get("tenantId") : null; var singleTenant = context.getJobDetail().getJobDataMap() != null ? context.getJobDetail().getJobDataMap().get("tenantId") : null;
tenantProvider.getTenants().forEach(tenant -> { tenantProvider.getTenants().forEach(tenant -> {
if(isTenantReadyForPersistence(tenant)) {
// if it's for a single tenant run only for that one, else run it for all tenants // if it's for a single tenant run only for that one, else run it for all tenants
if (tenant.getTenantId().equals(singleTenant) || singleTenant == null) { if (tenant.getTenantId().equals(singleTenant) || singleTenant == null) {
TenantContext.setTenantId(tenant.getTenantId()); TenantContext.setTenantId(tenant.getTenantId());
customPermissionService.syncAllCustomPermissions(); customPermissionService.syncAllCustomPermissions();
TenantContext.clear(); TenantContext.clear();
} }
}
}); });
} }