gCubeSystem
/
resource-registry-publisher-connector
16
0
Fork 0
Code Issues Pull Requests Projects Releases Wiki Activity

Fixing code

This commit is contained in:
Luca Frosini 2022-06-29 14:59:18 +02:00
parent 3310eeb5f7
commit fb880b39cf
1 changed files with 22 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

27
src/main/java/org/gcube/smartgears/connector/resourceregistry/FacetBasedPublisher.java
View File

@ -32,7 +32,6 @@ public class FacetBasedPublisher implements Publisher {
AuthorizationProvider authorizationProvider = containerContext.configuration().authorizationProvider();
SortedSet<String> contextToIterate = new TreeSet<>(contexts);
final String context = contextToIterate.first();
try {
AuthorizedTasks.executeSafely( () -> {
for (final String c : contextToIterate) {
@ -131,9 +130,18 @@ public class FacetBasedPublisher implements Publisher {
@Override
public boolean update(ContainerContext containerContext) {
HostingNodeManager hostingNodeManager = (HostingNodeManager) containerContext.properties().lookup(Constants.HOSTING_NODE_MANAGER_PROPERTY).value();
AuthorizationProvider authorizationProvider = containerContext.configuration().authorizationProvider();
SortedSet<String> contextToIterate = new TreeSet<>(authorizationProvider.getContexts());
final String context = contextToIterate.first();
try {
hostingNodeManager.updateFacets();
} catch (ResourceRegistryException e) {
AuthorizedTasks.executeSafely( () -> {
try {
hostingNodeManager.updateFacets();
} catch (ResourceRegistryException e) {
throw new RuntimeException(e);
}
}, authorizationProvider.getSecretForContext(context));
}catch (Throwable e) {
logger.error("Unable to update {} (id='{}')", HostingNode.NAME, containerContext.id(), e);
}
return true;
@ -142,9 +150,18 @@ public class FacetBasedPublisher implements Publisher {
@Override
public boolean update(ApplicationContext applicationContext) {
EServiceManager eServiceManager = (EServiceManager) applicationContext.properties().lookup(Constants.ESERVICE_MANAGER_PROPERTY).value();
AuthorizationProvider authorizationProvider = applicationContext.container().configuration().authorizationProvider();
SortedSet<String> contextToIterate = new TreeSet<>(authorizationProvider.getContexts());
final String context = contextToIterate.first();
try {
eServiceManager.updateFacets();
} catch (ResourceRegistryException e) {
AuthorizedTasks.executeSafely( () -> {
try {
eServiceManager.updateFacets();
} catch (ResourceRegistryException e) {
throw new RuntimeException(e);
}
}, authorizationProvider.getSecretForContext(context));
}catch (Throwable e) {
logger.error("Unable to update {} (name='{}', id='{}') ", EService.NAME, applicationContext.name(), applicationContext.id(), e);
}
return true;