Skip to content

Commit ffd4244

Browse files
authored
fix: [PL-27376]: Resource Group Async Reconciliation Handler (#36498)
* fix: [PL-27376]: Resource Group Async Reconciliation Handler * fix: Bind ResourceGroup Validator
1 parent 17961ad commit ffd4244

4 files changed

Lines changed: 14 additions & 7 deletions

File tree

platform-service/modules/resource-group-service/src/main/java/io/harness/resourcegroup/framework/v2/service/ResourceGroupValidator.java

Lines changed: 2 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -10,9 +10,11 @@
1010
import static io.harness.annotations.dev.HarnessTeam.PL;
1111

1212
import io.harness.annotations.dev.OwnedBy;
13+
import io.harness.resourcegroup.v2.model.ResourceGroup;
1314
import io.harness.resourcegroup.v2.remote.dto.ResourceGroupRequest;
1415

1516
@OwnedBy(PL)
1617
public interface ResourceGroupValidator {
18+
boolean sanitizeResourceSelectors(ResourceGroup resourceGroup);
1719
void validateResourceGroup(ResourceGroupRequest resourceGroupRequest);
1820
}

platform-service/modules/resource-group-service/src/main/java/io/harness/resourcegroup/framework/v2/service/impl/ResourceGroupValidatorImpl.java

Lines changed: 2 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -92,6 +92,7 @@ private boolean isValidDynamicResourceSelector(
9292
: resourceMap.get(resourceType).getSelectorKind().get(scopeLevel).contains(BY_RESOURCE_TYPE));
9393
}
9494

95+
@Override
9596
public boolean sanitizeResourceSelectors(ResourceGroup resourceGroup) {
9697
if (resourceGroup.getResourceFilter() == null) {
9798
return false;
@@ -166,6 +167,7 @@ private void validateResourceFilter(ResourceFilter resourceFilter, boolean inclu
166167
}
167168
}
168169

170+
@Override
169171
public void validateResourceGroup(ResourceGroupRequest resourceGroupRequest) {
170172
if (resourceGroupRequest == null || resourceGroupRequest.getResourceGroup() == null) {
171173
return;

platform-service/modules/resource-group-service/src/main/java/io/harness/resourcegroup/reconciliation/ResourceGroupAsyncReconciliationHandler.java

Lines changed: 7 additions & 7 deletions
Original file line numberDiff line numberDiff line change
@@ -18,11 +18,11 @@
1818
import io.harness.mongo.iterator.MongoPersistenceIterator;
1919
import io.harness.mongo.iterator.filter.SpringFilterExpander;
2020
import io.harness.mongo.iterator.provider.SpringPersistenceProvider;
21-
import io.harness.resourcegroup.framework.v1.service.impl.ResourceGroupValidatorServiceImpl;
2221
import io.harness.resourcegroup.framework.v2.remote.mapper.ResourceGroupMapper;
2322
import io.harness.resourcegroup.framework.v2.service.ResourceGroupService;
24-
import io.harness.resourcegroup.v1.model.ResourceGroup;
25-
import io.harness.resourcegroup.v1.model.ResourceGroup.ResourceGroupKeys;
23+
import io.harness.resourcegroup.framework.v2.service.ResourceGroupValidator;
24+
import io.harness.resourcegroup.v2.model.ResourceGroup;
25+
import io.harness.resourcegroup.v2.model.ResourceGroup.ResourceGroupKeys;
2626

2727
import com.google.inject.Inject;
2828
import lombok.AllArgsConstructor;
@@ -39,14 +39,14 @@ public class ResourceGroupAsyncReconciliationHandler implements MongoPersistence
3939
@Inject private final PersistenceIteratorFactory persistenceIteratorFactory;
4040
@Inject private final MongoTemplate mongoTemplate;
4141
@Inject private final ResourceGroupService resourceGroupService;
42-
@Inject private final ResourceGroupValidatorServiceImpl resourceGroupValidatorService;
42+
@Inject private final ResourceGroupValidator resourceGroupValidator;
4343

4444
@Override
4545
public void handle(ResourceGroup resourceGroup) {
46-
boolean updated = resourceGroupValidatorService.sanitizeResourceSelectors(resourceGroup);
46+
boolean updated = resourceGroupValidator.sanitizeResourceSelectors(resourceGroup);
4747
if (updated) {
48-
resourceGroupService.update(ResourceGroupMapper.toDTO(ResourceGroupMapper.fromV1(resourceGroup)),
49-
Boolean.TRUE.equals(resourceGroup.getHarnessManaged()));
48+
resourceGroupService.update(
49+
ResourceGroupMapper.toDTO(resourceGroup), Boolean.TRUE.equals(resourceGroup.getHarnessManaged()));
5050
}
5151
}
5252

platform-service/service/src/main/java/io/harness/platform/resourcegroup/ResourceGroupServiceModule.java

Lines changed: 3 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -44,6 +44,8 @@
4444
import io.harness.platform.PlatformConfiguration;
4545
import io.harness.redis.RedisConfig;
4646
import io.harness.resourcegroup.ResourceGroupModule;
47+
import io.harness.resourcegroup.framework.v2.service.ResourceGroupValidator;
48+
import io.harness.resourcegroup.framework.v2.service.impl.ResourceGroupValidatorImpl;
4749
import io.harness.serializer.KryoRegistrar;
4850
import io.harness.serializer.PrimaryVersionManagerRegistrars;
4951
import io.harness.serializer.morphia.ResourceGroupSerializer;
@@ -121,6 +123,7 @@ public UserProvider userProvider() {
121123
install(ExecutorModule.getInstance());
122124
bind(PlatformConfiguration.class).toInstance(appConfig);
123125
bind(HPersistence.class).to(MongoPersistence.class);
126+
bind(ResourceGroupValidator.class).to(ResourceGroupValidatorImpl.class);
124127
install(VersionModule.getInstance());
125128
install(PrimaryVersionManagerModule.getInstance());
126129
install(new ValidationModule(getValidatorFactory()));

0 commit comments

Comments
 (0)