Skip to content

Commit

Permalink
Fix duplicate storage access groups
Browse files Browse the repository at this point in the history
  • Loading branch information
harikrishna-patnala committed Feb 14, 2025
1 parent 55b7e87 commit a3dd0b7
Showing 1 changed file with 13 additions and 4 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -17,6 +17,7 @@
package com.cloud.api.query.dao;

import java.util.ArrayList;
import java.util.Arrays;
import java.util.List;

import javax.inject.Inject;
Expand Down Expand Up @@ -196,16 +197,24 @@ public StoragePoolResponse newStoragePoolResponse(StoragePoolJoinVO pool, boolea
public StoragePoolResponse setStoragePoolResponse(StoragePoolResponse response, StoragePoolJoinVO sp) {
String tag = sp.getTag();
if (tag != null) {
if (response.getTags() != null && response.getTags().length() > 0) {
response.setTags(response.getTags() + "," + tag);
if (response.getTags() != null && !response.getTags().isEmpty()) {
List<String> tagsList = new ArrayList<>(Arrays.asList(response.getTags().split(",")));

Check warning on line 201 in server/src/main/java/com/cloud/api/query/dao/StoragePoolJoinDaoImpl.java

View check run for this annotation

Codecov / codecov/patch

server/src/main/java/com/cloud/api/query/dao/StoragePoolJoinDaoImpl.java#L201

Added line #L201 was not covered by tests
if (!tagsList.contains(tag)) {
tagsList.add(tag);

Check warning on line 203 in server/src/main/java/com/cloud/api/query/dao/StoragePoolJoinDaoImpl.java

View check run for this annotation

Codecov / codecov/patch

server/src/main/java/com/cloud/api/query/dao/StoragePoolJoinDaoImpl.java#L203

Added line #L203 was not covered by tests
}
response.setTags(String.join(",", tagsList));

Check warning on line 205 in server/src/main/java/com/cloud/api/query/dao/StoragePoolJoinDaoImpl.java

View check run for this annotation

Codecov / codecov/patch

server/src/main/java/com/cloud/api/query/dao/StoragePoolJoinDaoImpl.java#L205

Added line #L205 was not covered by tests
} else {
response.setTags(tag);
}
}
String storageAccessGroup = sp.getStorageAccessGroup();

Check warning on line 210 in server/src/main/java/com/cloud/api/query/dao/StoragePoolJoinDaoImpl.java

View check run for this annotation

Codecov / codecov/patch

server/src/main/java/com/cloud/api/query/dao/StoragePoolJoinDaoImpl.java#L210

Added line #L210 was not covered by tests
if (storageAccessGroup != null) {
if (response.getStorageAccessGroups() != null && response.getStorageAccessGroups().length() > 0) {
response.setStorageAccessGroups(response.getStorageAccessGroups() + "," + storageAccessGroup);
if (response.getStorageAccessGroups() != null && !response.getStorageAccessGroups().isEmpty()) {
List<String> groupList = new ArrayList<>(Arrays.asList(response.getStorageAccessGroups().split(",")));

Check warning on line 213 in server/src/main/java/com/cloud/api/query/dao/StoragePoolJoinDaoImpl.java

View check run for this annotation

Codecov / codecov/patch

server/src/main/java/com/cloud/api/query/dao/StoragePoolJoinDaoImpl.java#L213

Added line #L213 was not covered by tests
if (!groupList.contains(storageAccessGroup)) {
groupList.add(storageAccessGroup);

Check warning on line 215 in server/src/main/java/com/cloud/api/query/dao/StoragePoolJoinDaoImpl.java

View check run for this annotation

Codecov / codecov/patch

server/src/main/java/com/cloud/api/query/dao/StoragePoolJoinDaoImpl.java#L215

Added line #L215 was not covered by tests
}
response.setStorageAccessGroups(String.join(",", groupList));
} else {
response.setStorageAccessGroups(storageAccessGroup);

Check warning on line 219 in server/src/main/java/com/cloud/api/query/dao/StoragePoolJoinDaoImpl.java

View check run for this annotation

Codecov / codecov/patch

server/src/main/java/com/cloud/api/query/dao/StoragePoolJoinDaoImpl.java#L217-L219

Added lines #L217 - L219 were not covered by tests
}
Expand Down

0 comments on commit a3dd0b7

Please sign in to comment.