Skip to content

Commit 05a9797

Browse files
committed
Changes based on reviews from @adutra and @dimas-b
1 parent b64aa69 commit 05a9797

8 files changed

+35
-101
lines changed

runtime/service/src/main/java/org/apache/polaris/service/admin/EventsServiceDelegator.java

Lines changed: 0 additions & 36 deletions
This file was deleted.
Lines changed: 5 additions & 18 deletions
Original file line numberDiff line numberDiff line change
@@ -19,9 +19,10 @@
1919

2020
package org.apache.polaris.service.admin;
2121

22+
import jakarta.annotation.Priority;
2223
import jakarta.decorator.Decorator;
2324
import jakarta.decorator.Delegate;
24-
import jakarta.enterprise.inject.Default;
25+
import jakarta.enterprise.inject.Alternative;
2526
import jakarta.inject.Inject;
2627
import jakarta.ws.rs.core.Response;
2728
import jakarta.ws.rs.core.SecurityContext;
@@ -34,35 +35,31 @@
3435
import org.apache.polaris.core.context.RealmContext;
3536
import org.apache.polaris.service.admin.api.PolarisCatalogsApiService;
3637

37-
@EventsServiceDelegator
38-
@Default
3938
@Decorator
40-
public class PolarisCatalogsServiceDefaultDelegator implements PolarisCatalogsApiService {
39+
@Priority(1000)
40+
@Alternative
41+
public class PolarisCatalogsEventServiceDelegator implements PolarisCatalogsApiService {
4142

4243
@Inject @Delegate PolarisCatalogsApiService delegate;
4344

44-
/** From PolarisCatalogsApiService */
4545
@Override
4646
public Response createCatalog(
4747
CreateCatalogRequest request, RealmContext realmContext, SecurityContext securityContext) {
4848
return delegate.createCatalog(request, realmContext, securityContext);
4949
}
5050

51-
/** From PolarisCatalogsApiService */
5251
@Override
5352
public Response deleteCatalog(
5453
String catalogName, RealmContext realmContext, SecurityContext securityContext) {
5554
return delegate.deleteCatalog(catalogName, realmContext, securityContext);
5655
}
5756

58-
/** From PolarisCatalogsApiService */
5957
@Override
6058
public Response getCatalog(
6159
String catalogName, RealmContext realmContext, SecurityContext securityContext) {
6260
return delegate.getCatalog(catalogName, realmContext, securityContext);
6361
}
6462

65-
/** From PolarisCatalogsApiService */
6663
@Override
6764
public Response updateCatalog(
6865
String catalogName,
@@ -72,13 +69,11 @@ public Response updateCatalog(
7269
return delegate.updateCatalog(catalogName, updateRequest, realmContext, securityContext);
7370
}
7471

75-
/** From PolarisCatalogsApiService */
7672
@Override
7773
public Response listCatalogs(RealmContext realmContext, SecurityContext securityContext) {
7874
return delegate.listCatalogs(realmContext, securityContext);
7975
}
8076

81-
/** From PolarisCatalogsApiService */
8277
@Override
8378
public Response createCatalogRole(
8479
String catalogName,
@@ -88,7 +83,6 @@ public Response createCatalogRole(
8883
return delegate.createCatalogRole(catalogName, request, realmContext, securityContext);
8984
}
9085

91-
/** From PolarisCatalogsApiService */
9286
@Override
9387
public Response deleteCatalogRole(
9488
String catalogName,
@@ -98,7 +92,6 @@ public Response deleteCatalogRole(
9892
return delegate.deleteCatalogRole(catalogName, catalogRoleName, realmContext, securityContext);
9993
}
10094

101-
/** From PolarisCatalogsApiService */
10295
@Override
10396
public Response getCatalogRole(
10497
String catalogName,
@@ -108,7 +101,6 @@ public Response getCatalogRole(
108101
return delegate.getCatalogRole(catalogName, catalogRoleName, realmContext, securityContext);
109102
}
110103

111-
/** From PolarisCatalogsApiService */
112104
@Override
113105
public Response updateCatalogRole(
114106
String catalogName,
@@ -120,14 +112,12 @@ public Response updateCatalogRole(
120112
catalogName, catalogRoleName, updateRequest, realmContext, securityContext);
121113
}
122114

123-
/** From PolarisCatalogsApiService */
124115
@Override
125116
public Response listCatalogRoles(
126117
String catalogName, RealmContext realmContext, SecurityContext securityContext) {
127118
return delegate.listCatalogRoles(catalogName, realmContext, securityContext);
128119
}
129120

130-
/** From PolarisCatalogsApiService */
131121
@Override
132122
public Response addGrantToCatalogRole(
133123
String catalogName,
@@ -139,7 +129,6 @@ public Response addGrantToCatalogRole(
139129
catalogName, catalogRoleName, grantRequest, realmContext, securityContext);
140130
}
141131

142-
/** From PolarisCatalogsApiService */
143132
@Override
144133
public Response revokeGrantFromCatalogRole(
145134
String catalogName,
@@ -152,7 +141,6 @@ public Response revokeGrantFromCatalogRole(
152141
catalogName, catalogRoleName, cascade, grantRequest, realmContext, securityContext);
153142
}
154143

155-
/** From PolarisCatalogsApiService */
156144
@Override
157145
public Response listAssigneePrincipalRolesForCatalogRole(
158146
String catalogName,
@@ -163,7 +151,6 @@ public Response listAssigneePrincipalRolesForCatalogRole(
163151
catalogName, catalogRoleName, realmContext, securityContext);
164152
}
165153

166-
/** From PolarisCatalogsApiService */
167154
@Override
168155
public Response listGrantsForCatalogRole(
169156
String catalogName,
Lines changed: 5 additions & 14 deletions
Original file line numberDiff line numberDiff line change
@@ -19,9 +19,10 @@
1919

2020
package org.apache.polaris.service.admin;
2121

22+
import jakarta.annotation.Priority;
2223
import jakarta.decorator.Decorator;
2324
import jakarta.decorator.Delegate;
24-
import jakarta.enterprise.inject.Default;
25+
import jakarta.enterprise.inject.Alternative;
2526
import jakarta.inject.Inject;
2627
import jakarta.ws.rs.core.Response;
2728
import jakarta.ws.rs.core.SecurityContext;
@@ -31,15 +32,13 @@
3132
import org.apache.polaris.core.context.RealmContext;
3233
import org.apache.polaris.service.admin.api.PolarisPrincipalRolesApiService;
3334

34-
@Default
35-
@EventsServiceDelegator
3635
@Decorator
37-
public class PolarisPrincipalRolesServiceDefaultDelegator
38-
implements PolarisPrincipalRolesApiService {
36+
@Priority(1000)
37+
@Alternative
38+
public class PolarisPrincipalRolesEventServiceDelegator implements PolarisPrincipalRolesApiService {
3939

4040
@Inject @Delegate PolarisPrincipalRolesApiService delegate;
4141

42-
/** From PolarisPrincipalRolesApiService */
4342
@Override
4443
public Response createPrincipalRole(
4544
CreatePrincipalRoleRequest request,
@@ -48,21 +47,18 @@ public Response createPrincipalRole(
4847
return delegate.createPrincipalRole(request, realmContext, securityContext);
4948
}
5049

51-
/** From PolarisPrincipalRolesApiService */
5250
@Override
5351
public Response deletePrincipalRole(
5452
String principalRoleName, RealmContext realmContext, SecurityContext securityContext) {
5553
return delegate.deletePrincipalRole(principalRoleName, realmContext, securityContext);
5654
}
5755

58-
/** From PolarisPrincipalRolesApiService */
5956
@Override
6057
public Response getPrincipalRole(
6158
String principalRoleName, RealmContext realmContext, SecurityContext securityContext) {
6259
return delegate.getPrincipalRole(principalRoleName, realmContext, securityContext);
6360
}
6461

65-
/** From PolarisPrincipalRolesApiService */
6662
@Override
6763
public Response updatePrincipalRole(
6864
String principalRoleName,
@@ -73,13 +69,11 @@ public Response updatePrincipalRole(
7369
principalRoleName, updateRequest, realmContext, securityContext);
7470
}
7571

76-
/** From PolarisPrincipalRolesApiService */
7772
@Override
7873
public Response listPrincipalRoles(RealmContext realmContext, SecurityContext securityContext) {
7974
return delegate.listPrincipalRoles(realmContext, securityContext);
8075
}
8176

82-
/** From PolarisPrincipalRolesApiService */
8377
@Override
8478
public Response assignCatalogRoleToPrincipalRole(
8579
String principalRoleName,
@@ -91,7 +85,6 @@ public Response assignCatalogRoleToPrincipalRole(
9185
principalRoleName, catalogName, request, realmContext, securityContext);
9286
}
9387

94-
/** From PolarisPrincipalRolesApiService */
9588
@Override
9689
public Response revokeCatalogRoleFromPrincipalRole(
9790
String principalRoleName,
@@ -103,15 +96,13 @@ public Response revokeCatalogRoleFromPrincipalRole(
10396
principalRoleName, catalogName, catalogRoleName, realmContext, securityContext);
10497
}
10598

106-
/** From PolarisPrincipalRolesApiService */
10799
@Override
108100
public Response listAssigneePrincipalsForPrincipalRole(
109101
String principalRoleName, RealmContext realmContext, SecurityContext securityContext) {
110102
return delegate.listAssigneePrincipalsForPrincipalRole(
111103
principalRoleName, realmContext, securityContext);
112104
}
113105

114-
/** From PolarisPrincipalRolesApiService */
115106
@Override
116107
public Response listCatalogRolesForPrincipalRole(
117108
String principalRoleName,
Lines changed: 5 additions & 13 deletions
Original file line numberDiff line numberDiff line change
@@ -19,9 +19,10 @@
1919

2020
package org.apache.polaris.service.admin;
2121

22+
import jakarta.annotation.Priority;
2223
import jakarta.decorator.Decorator;
2324
import jakarta.decorator.Delegate;
24-
import jakarta.enterprise.inject.Default;
25+
import jakarta.enterprise.inject.Alternative;
2526
import jakarta.inject.Inject;
2627
import jakarta.ws.rs.core.Response;
2728
import jakarta.ws.rs.core.SecurityContext;
@@ -31,35 +32,31 @@
3132
import org.apache.polaris.core.context.RealmContext;
3233
import org.apache.polaris.service.admin.api.PolarisPrincipalsApiService;
3334

34-
@Default
35-
@EventsServiceDelegator
3635
@Decorator
37-
public class PolarisPrincipalsServiceDefaultDelegator implements PolarisPrincipalsApiService {
36+
@Priority(1000)
37+
@Alternative
38+
public class PolarisPrincipalsEventServiceDelegator implements PolarisPrincipalsApiService {
3839

3940
@Inject @Delegate PolarisPrincipalsApiService delegate;
4041

41-
/** From PolarisPrincipalsApiService */
4242
@Override
4343
public Response createPrincipal(
4444
CreatePrincipalRequest request, RealmContext realmContext, SecurityContext securityContext) {
4545
return delegate.createPrincipal(request, realmContext, securityContext);
4646
}
4747

48-
/** From PolarisPrincipalsApiService */
4948
@Override
5049
public Response deletePrincipal(
5150
String principalName, RealmContext realmContext, SecurityContext securityContext) {
5251
return delegate.deletePrincipal(principalName, realmContext, securityContext);
5352
}
5453

55-
/** From PolarisPrincipalsApiService */
5654
@Override
5755
public Response getPrincipal(
5856
String principalName, RealmContext realmContext, SecurityContext securityContext) {
5957
return delegate.getPrincipal(principalName, realmContext, securityContext);
6058
}
6159

62-
/** From PolarisPrincipalsApiService */
6360
@Override
6461
public Response updatePrincipal(
6562
String principalName,
@@ -69,20 +66,17 @@ public Response updatePrincipal(
6966
return delegate.updatePrincipal(principalName, updateRequest, realmContext, securityContext);
7067
}
7168

72-
/** From PolarisPrincipalsApiService */
7369
@Override
7470
public Response rotateCredentials(
7571
String principalName, RealmContext realmContext, SecurityContext securityContext) {
7672
return delegate.rotateCredentials(principalName, realmContext, securityContext);
7773
}
7874

79-
/** From PolarisPrincipalsApiService */
8075
@Override
8176
public Response listPrincipals(RealmContext realmContext, SecurityContext securityContext) {
8277
return delegate.listPrincipals(realmContext, securityContext);
8378
}
8479

85-
/** From PolarisPrincipalsApiService */
8680
@Override
8781
public Response assignPrincipalRole(
8882
String principalName,
@@ -92,7 +86,6 @@ public Response assignPrincipalRole(
9286
return delegate.assignPrincipalRole(principalName, request, realmContext, securityContext);
9387
}
9488

95-
/** From PolarisPrincipalsApiService */
9689
@Override
9790
public Response revokePrincipalRole(
9891
String principalName,
@@ -103,7 +96,6 @@ public Response revokePrincipalRole(
10396
principalName, principalRoleName, realmContext, securityContext);
10497
}
10598

106-
/** From PolarisPrincipalsApiService */
10799
@Override
108100
public Response listPrincipalRolesAssigned(
109101
String principalName, RealmContext realmContext, SecurityContext securityContext) {
Lines changed: 5 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -19,22 +19,22 @@
1919

2020
package org.apache.polaris.service.catalog.generic;
2121

22+
import jakarta.annotation.Priority;
2223
import jakarta.decorator.Decorator;
2324
import jakarta.decorator.Delegate;
24-
import jakarta.enterprise.inject.Default;
25+
import jakarta.enterprise.inject.Alternative;
2526
import jakarta.inject.Inject;
2627
import jakarta.ws.rs.core.Response;
2728
import jakarta.ws.rs.core.SecurityContext;
2829
import org.apache.polaris.core.context.RealmContext;
29-
import org.apache.polaris.service.admin.EventsServiceDelegator;
3030
import org.apache.polaris.service.catalog.api.PolarisCatalogGenericTableApiService;
3131
import org.apache.polaris.service.catalog.common.CatalogAdapter;
3232
import org.apache.polaris.service.types.CreateGenericTableRequest;
3333

34-
@Default
35-
@EventsServiceDelegator
3634
@Decorator
37-
public class CatalogGenericTableServiceDefaultDelegator
35+
@Priority(1000)
36+
@Alternative
37+
public class CatalogGenericTableEventServiceDelegator
3838
implements PolarisCatalogGenericTableApiService, CatalogAdapter {
3939

4040
@Inject @Delegate GenericTableCatalogAdapter delegate;

0 commit comments

Comments
 (0)