Skip to content

Commit 503e838

Browse files
horadla23lnardai
authored andcommitted
CB-18696 creator field cleanup part 1
- in blueprint, customimage, vmimage entities, creator field is not used - same applies for NetworkCreationRequest
1 parent a7e7f90 commit 503e838

File tree

17 files changed

+31
-112
lines changed

17 files changed

+31
-112
lines changed

cloud-api/src/main/java/com/sequenceiq/cloudbreak/cloud/model/network/NetworkCreationRequest.java

-14
Original file line numberDiff line numberDiff line change
@@ -22,8 +22,6 @@ public class NetworkCreationRequest {
2222

2323
private final String userName;
2424

25-
private final String creatorCrn;
26-
2725
private String accountId;
2826

2927
private final Region region;
@@ -62,7 +60,6 @@ private NetworkCreationRequest(Builder builder) {
6260
privateSubnetEnabled = builder.privateSubnetEnabled;
6361
privateEndpointType = builder.privateEndpointType;
6462
userName = builder.userName;
65-
creatorCrn = builder.creatorCrn;
6663
tags = builder.tags;
6764
accountId = builder.accountId;
6865
}
@@ -127,10 +124,6 @@ public String getUserName() {
127124
return userName;
128125
}
129126

130-
public String getCreatorCrn() {
131-
return creatorCrn;
132-
}
133-
134127
public Map<String, String> getTags() {
135128
return tags;
136129
}
@@ -170,8 +163,6 @@ public static class Builder {
170163

171164
private PrivateEndpointType privateEndpointType;
172165

173-
private String creatorCrn;
174-
175166
private String accountId;
176167

177168
private Map<String, String> tags = new HashMap<>();
@@ -256,11 +247,6 @@ public Builder withAccountId(String accountId) {
256247
return this;
257248
}
258249

259-
public Builder withCreatorCrn(String creatorCrn) {
260-
this.creatorCrn = creatorCrn;
261-
return this;
262-
}
263-
264250
public Builder withTags(Map<String, String> tags) {
265251
this.tags = tags;
266252
return this;

cloud-aws-cloudformation/src/main/java/com/sequenceiq/cloudbreak/cloud/aws/AwsNetworkConnector.java

+2-3
Original file line numberDiff line numberDiff line change
@@ -211,8 +211,7 @@ private CreatedCloudNetwork createNewCfNetworkStack(
211211

212212
cloudFormationRetryClient.createStack(createStackRequest(networkRequest.getStackName(),
213213
cloudFormationTemplate,
214-
networkRequest.getTags(),
215-
networkRequest.getCreatorCrn()));
214+
networkRequest.getTags()));
216215
LOGGER.debug("CloudFormation stack creation request sent with stack name: '{}' ", networkRequest.getStackName());
217216
return getCreatedNetworkWithPolling(networkRequest, credentialView, cloudFormationRetryClient, subnetRequests);
218217
}
@@ -241,7 +240,7 @@ private CreatedCloudNetwork getCreatedCloudNetwork(AmazonCloudFormationClient cl
241240
return new CreatedCloudNetwork(networkRequest.getStackName(), vpcId, subnets);
242241
}
243242

244-
private CreateStackRequest createStackRequest(String stackName, String cloudFormationTemplate, Map<String, String> tags, String creatorUser) {
243+
private CreateStackRequest createStackRequest(String stackName, String cloudFormationTemplate, Map<String, String> tags) {
245244
Collection<Tag> awsTags = awsTaggingService.prepareCloudformationTags(null, tags);
246245
return new CreateStackRequest()
247246
.withStackName(stackName)

cloud-aws-cloudformation/src/test/java/com/sequenceiq/cloudbreak/cloud/aws/AwsNetworkConnectorTest.java

-1
Original file line numberDiff line numberDiff line change
@@ -550,7 +550,6 @@ private NetworkCreationRequest createNetworkRequest(String networkCidr, Set<Netw
550550
.withPublicSubnets(subnets)
551551
.withPrivateSubnetEnabled(true)
552552
.withUserName("[email protected]")
553-
.withCreatorCrn("user-crn")
554553
.build();
555554
}
556555

cloud-gcp/src/test/java/com/sequenceiq/cloudbreak/cloud/gcp/GcpNetworkConnectorTest.java

-8
Original file line numberDiff line numberDiff line change
@@ -101,13 +101,11 @@ public void testCreateNetworkWithSubnetsWhenCreationGoesFine() throws Exception
101101
NetworkCreationRequest networkCreationRequest = new NetworkCreationRequest.Builder()
102102
.withNetworkCidr("16.0.0.0/16")
103103
.withAccountId("account-id")
104-
.withCreatorCrn("creator-crn")
105104
.withVariant("GCP")
106105
.withEnvCrn("env-crn")
107106
.withEnvName("super-env")
108107
.withPrivateSubnetEnabled(true)
109108
.withTags(new HashMap<>())
110-
.withCreatorCrn("creator-crn")
111109
.withRegion(Region.region("us-west-1"))
112110
.withPublicSubnets(new HashSet<>())
113111
.withPrivateSubnets(new HashSet<>())
@@ -176,13 +174,11 @@ public void testCreateNetworkWithSubnetsWhenCreationThrowTokenExceptionShouldThr
176174
NetworkCreationRequest networkCreationRequest = new NetworkCreationRequest.Builder()
177175
.withNetworkCidr("16.0.0.0/16")
178176
.withAccountId("account-id")
179-
.withCreatorCrn("creator-crn")
180177
.withVariant("GCP")
181178
.withEnvCrn("env-crn")
182179
.withEnvName("super-env")
183180
.withPrivateSubnetEnabled(true)
184181
.withTags(new HashMap<>())
185-
.withCreatorCrn("creator-crn")
186182
.withRegion(Region.region("us-west-1"))
187183
.withPublicSubnets(new HashSet<>())
188184
.withPrivateSubnets(new HashSet<>())
@@ -260,13 +256,11 @@ public void testCreateNetworkWithSubnetsWhenCreationThrowGoogleJsonResponseExcep
260256
NetworkCreationRequest networkCreationRequest = new NetworkCreationRequest.Builder()
261257
.withNetworkCidr("16.0.0.0/16")
262258
.withAccountId("account-id")
263-
.withCreatorCrn("creator-crn")
264259
.withVariant("GCP")
265260
.withEnvCrn("env-crn")
266261
.withEnvName("super-env")
267262
.withPrivateSubnetEnabled(true)
268263
.withTags(new HashMap<>())
269-
.withCreatorCrn("creator-crn")
270264
.withRegion(Region.region("us-west-1"))
271265
.withPublicSubnets(new HashSet<>())
272266
.withPrivateSubnets(new HashSet<>())
@@ -347,13 +341,11 @@ public void testCreateNetworkWithSubnetsWhenCreationThrowIoExceptionShouldThrowG
347341
NetworkCreationRequest networkCreationRequest = new NetworkCreationRequest.Builder()
348342
.withNetworkCidr("16.0.0.0/16")
349343
.withAccountId("account-id")
350-
.withCreatorCrn("creator-crn")
351344
.withVariant("GCP")
352345
.withEnvCrn("env-crn")
353346
.withEnvName("super-env")
354347
.withPrivateSubnetEnabled(true)
355348
.withTags(new HashMap<>())
356-
.withCreatorCrn("creator-crn")
357349
.withRegion(Region.region("us-west-1"))
358350
.withPublicSubnets(new HashSet<>())
359351
.withPrivateSubnets(new HashSet<>())

cluster-api/src/test/java/com/sequenceiq/cloudbreak/cluster/common/TestUtil.java

-1
Original file line numberDiff line numberDiff line change
@@ -465,7 +465,6 @@ public static Blueprint blueprint(Long id, String name, String blueprintText) {
465465
blueprint.setStatus(ResourceStatus.DEFAULT);
466466
blueprint.setTags(getEmptyJson());
467467
blueprint.setResourceCrn("someCrn");
468-
blueprint.setCreator("someone");
469468
return blueprint;
470469
}
471470

core-model/src/main/java/com/sequenceiq/cloudbreak/domain/Blueprint.java

-11
Original file line numberDiff line numberDiff line change
@@ -59,8 +59,6 @@ public class Blueprint implements ProvisionEntity, WorkspaceAwareResource {
5959

6060
private String resourceCrn;
6161

62-
private String creator;
63-
6462
private String stackType;
6563

6664
private String stackVersion;
@@ -78,14 +76,6 @@ public void setResourceCrn(String resourceCrn) {
7876
this.resourceCrn = resourceCrn;
7977
}
8078

81-
public String getCreator() {
82-
return creator;
83-
}
84-
85-
public void setCreator(String creator) {
86-
this.creator = creator;
87-
}
88-
8979
public Json getTags() {
9080
return tags;
9181
}
@@ -202,7 +192,6 @@ public String toString() {
202192
", tags=" + tags +
203193
", workspace=" + workspace +
204194
", resourceCrn='" + resourceCrn + '\'' +
205-
", creator='" + creator + '\'' +
206195
", stackType='" + stackType + '\'' +
207196
", stackVersion='" + stackVersion + '\'' +
208197
", created=" + created +

core-model/src/main/java/com/sequenceiq/cloudbreak/domain/CustomImage.java

+4-14
Original file line numberDiff line numberDiff line change
@@ -1,7 +1,7 @@
11
package com.sequenceiq.cloudbreak.domain;
22

3-
import com.sequenceiq.cloudbreak.converter.ImageTypeConverter;
4-
import com.sequenceiq.common.api.type.ImageType;
3+
import java.util.HashSet;
4+
import java.util.Set;
55

66
import javax.persistence.CascadeType;
77
import javax.persistence.Column;
@@ -18,8 +18,8 @@
1818
import javax.persistence.Table;
1919
import javax.persistence.UniqueConstraint;
2020

21-
import java.util.HashSet;
22-
import java.util.Set;
21+
import com.sequenceiq.cloudbreak.converter.ImageTypeConverter;
22+
import com.sequenceiq.common.api.type.ImageType;
2323

2424
@Entity
2525
@Table(uniqueConstraints = {
@@ -49,8 +49,6 @@ public class CustomImage implements ProvisionEntity {
4949
@Column(nullable = false)
5050
private String resourceCrn;
5151

52-
private String creator;
53-
5452
private Long created = System.currentTimeMillis();
5553

5654
@Convert(converter = ImageTypeConverter.class)
@@ -113,14 +111,6 @@ public Long getCreated() {
113111
return created;
114112
}
115113

116-
public String getCreator() {
117-
return creator;
118-
}
119-
120-
public void setCreator(String creator) {
121-
this.creator = creator;
122-
}
123-
124114
public ImageType getImageType() {
125115
return imageType;
126116
}

core-model/src/main/java/com/sequenceiq/cloudbreak/domain/VmImage.java

-10
Original file line numberDiff line numberDiff line change
@@ -20,8 +20,6 @@ public class VmImage implements ProvisionEntity {
2020
@SequenceGenerator(name = "vmimage_generator", sequenceName = "vmimage_id_seq", allocationSize = 1)
2121
private Long id;
2222

23-
private String creator;
24-
2523
private Long created = System.currentTimeMillis();
2624

2725
@ManyToOne
@@ -42,14 +40,6 @@ public void setId(Long id) {
4240
this.id = id;
4341
}
4442

45-
public String getCreator() {
46-
return creator;
47-
}
48-
49-
public void setCreator(String creator) {
50-
this.creator = creator;
51-
}
52-
5343
public Long getCreated() {
5444
return created;
5545
}

core-model/src/test/java/com/sequenceiq/cloudbreak/TestUtil.java

-1
Original file line numberDiff line numberDiff line change
@@ -599,7 +599,6 @@ public static Blueprint blueprint(Long id, String name, String blueprintText) {
599599
blueprint.setStatus(ResourceStatus.DEFAULT);
600600
blueprint.setTags(getEmptyJson());
601601
blueprint.setResourceCrn("someCrn");
602-
blueprint.setCreator("someone");
603602
return blueprint;
604603
}
605604

core/src/main/java/com/sequenceiq/cloudbreak/controller/v4/CustomImageCatalogV4Controller.java

+2-4
Original file line numberDiff line numberDiff line change
@@ -147,10 +147,9 @@ public CustomImageCatalogV4GetImageResponse getCustomImage(@ResourceName String
147147
@CheckPermissionByResourceName(action = AuthorizationResourceAction.EDIT_IMAGE_CATALOG)
148148
public CustomImageCatalogV4CreateImageResponse createCustomImage(@ResourceName String name,
149149
@Valid CustomImageCatalogV4CreateImageRequest request, @AccountId String accountId) {
150-
String creator = ThreadBasedUserCrnProvider.getUserCrn();
151150
CustomImage customImage = customImageCatalogV4CreateImageRequestToCustomImageConverter.convert(request);
152151
CustomImage savedCustomImage = customImageCatalogService
153-
.createCustomImage(restRequestThreadLocalService.getRequestedWorkspaceId(), accountId, creator, name, customImage);
152+
.createCustomImage(restRequestThreadLocalService.getRequestedWorkspaceId(), accountId, name, customImage);
154153

155154
return customImageToCustomImageCatalogV4CreateImageResponseConverter.convert(savedCustomImage);
156155
}
@@ -159,11 +158,10 @@ public CustomImageCatalogV4CreateImageResponse createCustomImage(@ResourceName S
159158
@CheckPermissionByResourceName(action = AuthorizationResourceAction.EDIT_IMAGE_CATALOG)
160159
public CustomImageCatalogV4UpdateImageResponse updateCustomImage(@ResourceName String name, String imageId,
161160
@Valid CustomImageCatalogV4UpdateImageRequest request, @AccountId String accountId) {
162-
String creator = ThreadBasedUserCrnProvider.getUserCrn();
163161
CustomImage customImage = customImageCatalogV4UpdateImageRequestToCustomImageConverter.convert(request);
164162
customImage.setName(imageId);
165163
CustomImage savedCustomImage = customImageCatalogService
166-
.updateCustomImage(restRequestThreadLocalService.getRequestedWorkspaceId(), creator, name, customImage);
164+
.updateCustomImage(restRequestThreadLocalService.getRequestedWorkspaceId(), name, customImage);
167165

168166
return customImageToCustomImageCatalogV4UpdateImageResponseConverter.convert(savedCustomImage);
169167
}

core/src/main/java/com/sequenceiq/cloudbreak/init/blueprint/BlueprintLoaderService.java

+1-2
Original file line numberDiff line numberDiff line change
@@ -123,8 +123,7 @@ private Set<Blueprint> addMissingBlueprints(Collection<Blueprint> blueprintsInDa
123123
bp.setName(diffBlueprint.getValue().getName());
124124
bp = setupBlueprint(bp, workspace);
125125
String accountId = ThreadBasedUserCrnProvider.getAccountId();
126-
String creator = ThreadBasedUserCrnProvider.getUserCrn();
127-
blueprintService.decorateWithCrn(bp, accountId, creator);
126+
blueprintService.decorateWithCrn(bp, accountId);
128127
resultList.add(bp);
129128
}
130129

core/src/main/java/com/sequenceiq/cloudbreak/service/blueprint/BlueprintService.java

+2-3
Original file line numberDiff line numberDiff line change
@@ -145,7 +145,7 @@ public Blueprint get(Long id) {
145145

146146
public Blueprint createForLoggedInUser(Blueprint blueprint, Long workspaceId, String accountId, String creator) {
147147
validate(blueprint, false);
148-
decorateWithCrn(blueprint, accountId, creator);
148+
decorateWithCrn(blueprint, accountId);
149149
try {
150150
return transactionService.required(() -> {
151151
Blueprint created = super.createForLoggedInUser(blueprint, workspaceId);
@@ -201,9 +201,8 @@ public Blueprint getByWorkspace(@NotNull NameOrCrn nameOrCrn, Long workspaceId)
201201
: getByCrnAndWorkspaceIdAndAddToMdc(nameOrCrn.getCrn(), workspaceId);
202202
}
203203

204-
public void decorateWithCrn(Blueprint bp, String accountId, String creator) {
204+
public void decorateWithCrn(Blueprint bp, String accountId) {
205205
bp.setResourceCrn(createCRN(accountId));
206-
bp.setCreator(creator);
207206
}
208207

209208
private Set<String> getHueHostGroups(String blueprintText) {

core/src/main/java/com/sequenceiq/cloudbreak/service/image/CustomImageCatalogService.java

+3-8
Original file line numberDiff line numberDiff line change
@@ -93,21 +93,17 @@ public Image getSourceImage(CustomImage image) {
9393
}
9494
}
9595

96-
public CustomImage createCustomImage(Long workspaceId, String accountId, String creator, String imageCatalogName, CustomImage customImage) {
96+
public CustomImage createCustomImage(Long workspaceId, String accountId, String imageCatalogName, CustomImage customImage) {
9797
String imageName = UUID.randomUUID().toString();
9898
LOGGER.debug(String.format("Create custom image '%s' in catalog '%s' in workspace '%d'", imageName, imageCatalogName, workspaceId));
9999

100100
try {
101101
return transactionService.required(() -> {
102102
ImageCatalog imageCatalog = getImageCatalog(workspaceId, imageCatalogName);
103103
customImage.setName(imageName);
104-
customImage.setCreator(creator);
105104
customImage.setResourceCrn(regionAwareCrnGenerator.generateCrnString(CrnResourceDescriptor.IMAGE_CATALOG, imageName, accountId));
106105
customImage.setImageCatalog(imageCatalog);
107-
customImage.getVmImage().stream().forEach(vmImage -> {
108-
vmImage.setCustomImage(customImage);
109-
vmImage.setCreator(creator);
110-
});
106+
customImage.getVmImage().stream().forEach(vmImage -> vmImage.setCustomImage(customImage));
111107

112108
validateSourceImage(customImage);
113109

@@ -142,7 +138,7 @@ public CustomImage deleteCustomImage(Long workspaceId, String imageCatalogName,
142138
}
143139
}
144140

145-
public CustomImage updateCustomImage(Long workspaceId, String creator, String imageCatalogName, CustomImage customImage) {
141+
public CustomImage updateCustomImage(Long workspaceId, String imageCatalogName, CustomImage customImage) {
146142
LOGGER.debug(String.format("Update custom image '%s' in catalog '%s' in workspace '%d'",
147143
customImage.getName(), imageCatalogName, workspaceId));
148144

@@ -174,7 +170,6 @@ public CustomImage updateCustomImage(Long workspaceId, String creator, String im
174170
}
175171
}
176172
for (VmImage vmImage : vmImagesToSave) {
177-
vmImage.setCreator(creator);
178173
vmImage.setCustomImage(savedCustomImage);
179174
savedCustomImage.getVmImage().add(vmImage);
180175
}

core/src/test/java/com/sequenceiq/cloudbreak/controller/v4/CustomImageCatalogV4ControllerTest.java

+6-10
Original file line numberDiff line numberDiff line change
@@ -194,15 +194,13 @@ public void testCreateCustomImage() {
194194

195195
when(customImageCatalogV4CreateImageRequestToCustomImageConverter.convert(request)).thenReturn(customImage);
196196
when(restRequestThreadLocalService.getRequestedWorkspaceId()).thenReturn(WORKSPACE_ID);
197-
when(customImageCatalogService.createCustomImage(eq(WORKSPACE_ID), anyString(), eq(USER_CRN), eq(IMAGE_CATALOG_NAME), eq(customImage)))
197+
when(customImageCatalogService.createCustomImage(eq(WORKSPACE_ID), anyString(), eq(IMAGE_CATALOG_NAME), eq(customImage)))
198198
.thenReturn(savedCustomImage);
199199
when(customImageToCustomImageCatalogV4CreateImageResponseConverter.convert(savedCustomImage)).thenReturn(expected);
200200

201-
ThreadBasedUserCrnProvider.doAs(USER_CRN, () -> {
202-
CustomImageCatalogV4CreateImageResponse actual = victim.createCustomImage(IMAGE_CATALOG_NAME, request, ACCOUNT_ID);
201+
CustomImageCatalogV4CreateImageResponse actual = victim.createCustomImage(IMAGE_CATALOG_NAME, request, ACCOUNT_ID);
203202

204-
assertEquals(expected, actual);
205-
});
203+
assertEquals(expected, actual);
206204
}
207205

208206
@Test
@@ -214,15 +212,13 @@ public void testUpdateCustomImage() {
214212

215213
when(customImageCatalogV4UpdateImageRequestToCustomImageConverter.convert(request)).thenReturn(customImage);
216214
when(restRequestThreadLocalService.getRequestedWorkspaceId()).thenReturn(WORKSPACE_ID);
217-
when(customImageCatalogService.updateCustomImage(eq(WORKSPACE_ID), eq(USER_CRN), eq(IMAGE_CATALOG_NAME), eq(customImage)))
215+
when(customImageCatalogService.updateCustomImage(eq(WORKSPACE_ID), eq(IMAGE_CATALOG_NAME), eq(customImage)))
218216
.thenReturn(savedCustomImage);
219217
when(customImageToCustomImageCatalogV4UpdateImageResponseConverter.convert(savedCustomImage)).thenReturn(expected);
220218

221-
ThreadBasedUserCrnProvider.doAs(USER_CRN, () -> {
222-
CustomImageCatalogV4UpdateImageResponse actual = victim.updateCustomImage(IMAGE_CATALOG_NAME, IMAGE_ID, request, ACCOUNT_ID);
219+
CustomImageCatalogV4UpdateImageResponse actual = victim.updateCustomImage(IMAGE_CATALOG_NAME, IMAGE_ID, request, ACCOUNT_ID);
223220

224-
assertEquals(expected, actual);
225-
});
221+
assertEquals(expected, actual);
226222
}
227223

228224
@Test

0 commit comments

Comments
 (0)