Skip to content

Commit 61ec356

Browse files
committed
Small changes
1 parent aeaa405 commit 61ec356

File tree

4 files changed

+28
-27
lines changed

4 files changed

+28
-27
lines changed

services-api/src/main/java/io/scalecube/services/auth/ServicePrincipal.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -15,7 +15,7 @@ public class ServicePrincipal implements Principal {
1515
* @param role service role
1616
* @param permissions service permissions
1717
*/
18-
public ServicePrincipal(String role, Set<String> permissions) {
18+
public ServicePrincipal(String role, Collection<String> permissions) {
1919
this.role = role;
2020
this.permissions = Set.copyOf(permissions);
2121
}

services-api/src/main/java/io/scalecube/services/methods/ServiceRoleDefinition.java

Lines changed: 0 additions & 20 deletions
Original file line numberDiff line numberDiff line change
@@ -1,7 +1,6 @@
11
package io.scalecube.services.methods;
22

33
import java.util.Collection;
4-
import java.util.Objects;
54
import java.util.Set;
65
import java.util.StringJoiner;
76

@@ -29,25 +28,6 @@ public Collection<String> permissions() {
2928
return permissions;
3029
}
3130

32-
@Override
33-
public boolean equals(Object o) {
34-
if (this == o) {
35-
return true;
36-
}
37-
if (o == null || getClass() != o.getClass()) {
38-
return false;
39-
}
40-
final var that = (ServiceRoleDefinition) o;
41-
return Objects.equals(role, that.role) && Objects.equals(permissions, that.permissions);
42-
}
43-
44-
@Override
45-
public int hashCode() {
46-
int result = Objects.hashCode(role);
47-
result = 31 * result + Objects.hashCode(permissions);
48-
return result;
49-
}
50-
5131
@Override
5232
public String toString() {
5333
return new StringJoiner(", ", ServiceRoleDefinition.class.getSimpleName() + "[", "]")

services-api/src/test/java/io/scalecube/services/methods/ReflectTest.java

Lines changed: 14 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -3,10 +3,9 @@
33
import static io.scalecube.services.CommunicationMode.REQUEST_CHANNEL;
44
import static io.scalecube.services.CommunicationMode.REQUEST_RESPONSE;
55
import static io.scalecube.services.CommunicationMode.REQUEST_STREAM;
6-
import static org.hamcrest.MatcherAssert.assertThat;
7-
import static org.hamcrest.Matchers.hasItem;
86
import static org.junit.jupiter.api.Assertions.assertEquals;
97
import static org.junit.jupiter.api.Assertions.assertNotNull;
8+
import static org.junit.jupiter.api.Assertions.assertTrue;
109

1110
import io.scalecube.services.CommunicationMode;
1211
import io.scalecube.services.Reflect;
@@ -17,6 +16,7 @@
1716
import io.scalecube.services.auth.AllowedRoles;
1817
import java.lang.reflect.Method;
1918
import java.util.Arrays;
19+
import java.util.Collection;
2020
import java.util.List;
2121
import java.util.Set;
2222
import java.util.stream.Stream;
@@ -107,11 +107,21 @@ public void testServiceRoles(String test, SuccessArgs args) throws Exception {
107107
final var serviceRoles = Reflect.serviceRoles(method);
108108
assertNotNull(serviceRoles, "serviceRoles");
109109
assertEquals(args.list.size(), serviceRoles.size(), "serviceRoles.size");
110-
for (var expectedServiceRole : args.list) {
111-
assertThat(serviceRoles, hasItem(expectedServiceRole));
110+
for (var role : args.list) {
111+
assertContains(serviceRoles, role);
112112
}
113113
}
114114

115+
private static void assertContains(
116+
Collection<ServiceRoleDefinition> serviceRoles, ServiceRoleDefinition item) {
117+
final var hasItem =
118+
serviceRoles.stream()
119+
.filter(role -> role.role().equals(item.role()))
120+
.filter(role -> role.permissions().equals(item.permissions()))
121+
.findFirst();
122+
assertTrue(hasItem.isPresent(), "serviceRoles: " + serviceRoles + ", item: " + item);
123+
}
124+
115125
private record SuccessArgs(Object serviceInstance, List<ServiceRoleDefinition> list) {}
116126

117127
private static Stream<Arguments> testServiceRolesMethodSource() {

services/src/test/java/io/scalecube/services/auth/ServiceRolesProcessorTest.java

Lines changed: 13 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -1,9 +1,9 @@
11
package io.scalecube.services.auth;
22

3-
import static org.hamcrest.MatcherAssert.assertThat;
43
import static org.hamcrest.Matchers.hasItem;
54
import static org.junit.jupiter.api.Assertions.assertEquals;
65
import static org.junit.jupiter.api.Assertions.assertNotNull;
6+
import static org.junit.jupiter.api.Assertions.assertTrue;
77
import static org.mockito.Mockito.mock;
88
import static org.mockito.Mockito.verify;
99

@@ -12,6 +12,7 @@
1212
import io.scalecube.services.annotations.Service;
1313
import io.scalecube.services.annotations.ServiceMethod;
1414
import io.scalecube.services.methods.ServiceRoleDefinition;
15+
import java.util.Collection;
1516
import java.util.List;
1617
import java.util.Set;
1718
import org.junit.jupiter.api.Test;
@@ -44,13 +45,23 @@ void processSuccessfully() {
4445
assertEquals(
4546
expectedServiceRoles.size(), serviceRoles.size(), "serviceRoles.size");
4647
for (var role : expectedServiceRoles) {
47-
assertThat(serviceRoles, hasItem(role));
48+
assertContains(serviceRoles, role);
4849
}
4950
return true;
5051
}));
5152
}
5253
}
5354

55+
private static void assertContains(
56+
Collection<ServiceRoleDefinition> serviceRoles, ServiceRoleDefinition item) {
57+
final var hasItem =
58+
serviceRoles.stream()
59+
.filter(role -> role.role().equals(item.role()))
60+
.filter(role -> role.permissions().equals(item.permissions()))
61+
.findFirst();
62+
assertTrue(hasItem.isPresent(), "serviceRoles: " + serviceRoles + ", item: " + item);
63+
}
64+
5465
@Service
5566
private interface Service1 {
5667

0 commit comments

Comments
 (0)