Skip to content

Commit 67b17ac

Browse files
authored
Merge pull request #196 from amosproj/sprint-11
Sprint 11
2 parents 3e1b6b4 + 49dd0c8 commit 67b17ac

Some content is hidden

Large Commits have some content hidden by default. Use the searchbox below for content that may be hidden.

41 files changed

+978
-475
lines changed

.gitattributes

Lines changed: 3 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -2,3 +2,6 @@
22
demodata/setup-topology/setup-topology.sh eol=lf
33
demodata/setup-topology/setup-topology-local.sh eol=lf
44
demodata/setup-topology/setup-topology-aws.sh eol=lf
5+
/frontend/** eol=lf
6+
*.png eol=auto
7+
*.jpg eol=auto

backend/src/main/java/de/amos/apachepulsarui/controller/TenantController.java

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -6,7 +6,7 @@
66

77
package de.amos.apachepulsarui.controller;
88

9-
import de.amos.apachepulsarui.dto.TenantDetailsDto;
9+
import de.amos.apachepulsarui.dto.TenantDetailDto;
1010
import de.amos.apachepulsarui.dto.TenantsDto;
1111
import de.amos.apachepulsarui.service.TenantService;
1212
import lombok.RequiredArgsConstructor;
@@ -27,7 +27,7 @@ public class TenantController {
2727
private final TenantService tenantService;
2828

2929
@GetMapping()
30-
public ResponseEntity<TenantDetailsDto> getTenantDetails(@RequestParam String tenantName) {
30+
public ResponseEntity<TenantDetailDto> getTenantDetails(@RequestParam String tenantName) {
3131
return new ResponseEntity<>(tenantService.getTenantDetails(tenantName), HttpStatus.OK);
3232
}
3333

backend/src/main/java/de/amos/apachepulsarui/dto/ClusterDetailDto.java

Lines changed: 0 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -22,9 +22,6 @@ public class ClusterDetailDto {
2222

2323
private List<String> brokers;
2424

25-
@Setter(AccessLevel.PRIVATE)
26-
private int amountOfTenants;
27-
2825
@Setter(AccessLevel.PRIVATE)
2926
private int amountOfBrokers;
3027

backend/src/main/java/de/amos/apachepulsarui/dto/ClusterDto.java

Lines changed: 2 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -16,7 +16,8 @@ public class ClusterDto {
1616

1717
private long numberOfTenants;
1818

19-
private long numberOfNamespces;
19+
private long numberOfNamespaces;
20+
2021
public static ClusterDto create(String name) {
2122
return ClusterDto.builder().name(name).build();
2223
}

backend/src/main/java/de/amos/apachepulsarui/dto/NamespaceDetailDto.java

Lines changed: 0 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -8,7 +8,6 @@
88
import lombok.AccessLevel;
99
import lombok.Data;
1010
import lombok.NoArgsConstructor;
11-
import lombok.Setter;
1211
import org.apache.pulsar.common.policies.data.BundlesData;
1312
import org.apache.pulsar.common.policies.data.RetentionPolicies;
1413

@@ -24,9 +23,6 @@ public class NamespaceDetailDto {
2423

2524
private String tenant;
2625

27-
@Setter(AccessLevel.PRIVATE)
28-
private int amountOfTopics = 0;
29-
3026
private BundlesData bundlesData;
3127

3228
private Integer messagesTTL;
@@ -41,7 +37,6 @@ public static NamespaceDetailDto fromString(String namespaceId) {
4137

4238
public void setTopics(List<String> topics) {
4339
this.topics = topics;
44-
this.amountOfTopics = topics.size();
4540
}
4641

4742
/**

backend/src/main/java/de/amos/apachepulsarui/dto/TenantDetailsDto.java renamed to backend/src/main/java/de/amos/apachepulsarui/dto/TenantDetailDto.java

Lines changed: 1 addition & 6 deletions
Original file line numberDiff line numberDiff line change
@@ -5,25 +5,20 @@
55

66
package de.amos.apachepulsarui.dto;
77

8-
import lombok.AccessLevel;
98
import lombok.Builder;
109
import lombok.Data;
11-
import lombok.Setter;
1210
import org.apache.pulsar.common.policies.data.TenantInfo;
1311

1412
import java.util.List;
1513

1614
@Data
1715
@Builder
18-
public class TenantDetailsDto {
16+
public class TenantDetailDto {
1917

2018
private String name;
2119

2220
private List<String> namespaces;
2321

24-
@Setter(AccessLevel.PRIVATE)
25-
private int amountOfNamespaces;
26-
2722
private TenantInfo tenantInfo;
2823

2924
/**

backend/src/main/java/de/amos/apachepulsarui/service/ClusterService.java

Lines changed: 1 addition & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -49,7 +49,6 @@ public ClusterDetailDto getClusterDetails(String clusterName) {
4949
.brokers(activeBrokers)
5050
.amountOfBrokers(activeBrokers.size())
5151
.tenants(tenantsAllowedForCluster)
52-
.amountOfTenants(tenantsAllowedForCluster.size())
5352
.build();
5453
}
5554

@@ -94,7 +93,7 @@ private ClusterDto enrichWithCardDetails(ClusterDto clusterDto) {
9493
List<String> tenats = getTenantsAllowedForCluster(clusterDto.getName());
9594
long numberOfNamespaces = tenats.stream().mapToLong(t -> namespaceService.getAllOfTenant(t).size()).sum();
9695
clusterDto.setNumberOfTenants(tenats.size());
97-
clusterDto.setNumberOfNamespces(numberOfNamespaces);
96+
clusterDto.setNumberOfNamespaces(numberOfNamespaces);
9897
return clusterDto;
9998
}
10099

backend/src/main/java/de/amos/apachepulsarui/service/TenantService.java

Lines changed: 3 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -1,6 +1,6 @@
11
package de.amos.apachepulsarui.service;
22

3-
import de.amos.apachepulsarui.dto.TenantDetailsDto;
3+
import de.amos.apachepulsarui.dto.TenantDetailDto;
44
import de.amos.apachepulsarui.dto.TenantDto;
55
import de.amos.apachepulsarui.exception.PulsarApiException;
66
import lombok.RequiredArgsConstructor;
@@ -54,13 +54,12 @@ public List<TenantDto> getAllFiltered(List<String> tenants) throws PulsarApiExce
5454
}
5555

5656
@Cacheable("tenant.detail")
57-
public TenantDetailsDto getTenantDetails(String tenantName) {
57+
public TenantDetailDto getTenantDetails(String tenantName) {
5858
List<String> namespacesOfTenant = namespaceService.getAllOfTenant(tenantName);
59-
return TenantDetailsDto.builder()
59+
return TenantDetailDto.builder()
6060
.name(tenantName)
6161
.tenantInfo(getTenantInfo(tenantName))
6262
.namespaces(namespacesOfTenant)
63-
.amountOfNamespaces(namespacesOfTenant.size())
6463
.build();
6564
}
6665

backend/src/test/java/de/amos/apachepulsarui/controller/NamespaceControllerTest.java

Lines changed: 0 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -102,7 +102,6 @@ void getNamespaceDetails_returnsNamespace() throws Exception {
102102
mockMvc.perform(get("/namespace?name=tenantX/namespace1"))
103103
.andExpect(status().isOk())
104104
.andExpect(jsonPath("$.id", equalTo(namespace.getId())))
105-
.andExpect(jsonPath("$.amountOfTopics", equalTo(namespace.getAmountOfTopics())))
106105
.andExpect(jsonPath("$.topics", equalTo(namespace.getTopics())));
107106
}
108107

backend/src/test/java/de/amos/apachepulsarui/service/NamespaceServiceIntegrationTest.java

Lines changed: 0 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -78,7 +78,6 @@ void getNamespaceDetails_returnsNamespaces() throws PulsarAdminException {
7878

7979
Assertions.assertThat(namespace.getId()).isEqualTo("tenant1/namespace1");
8080
Assertions.assertThat(namespace.getTopics()).contains("persistent://tenant1/namespace1/testTopic");
81-
Assertions.assertThat(namespace.getAmountOfTopics()).isEqualTo(1);
8281
}
8382

8483
private void createTenant(String tenant) throws PulsarAdminException {

0 commit comments

Comments
 (0)