Commit 0bf98838 authored by Vasilis Katopodis's avatar Vasilis Katopodis
Browse files

fix: temp commit

parent a46fb321

src/main/java/org/etsi/osl/hypo/registry/service/RegistryService.java

+1 −0
Original line number Diff line number Diff line
@@ -16,6 +16,7 @@ import java.util.List; 
import java.util.Map;

import java.util.Optional;

import java.util.UUID;

import java.util.concurrent.TimeoutException;

import java.util.concurrent.atomic.AtomicReference;

import org.apache.commons.collections4.map.CaseInsensitiveMap;

import org.apache.commons.lang3.StringUtils;

src/test/java/org/etsi/osl/hypo/registry/service/RegistryServiceTest.java

+6 −2
Original line number Diff line number Diff line
@@ -336,7 +336,8 @@ class RegistryServiceTest { 


    @Test

    void getKubernetesConfigSecretResponseMessage_BlankId_FailsFastWithoutTouchingVault() {

        Message<String> messageWithToken = this.createMessageWithToken("   ", KEYCLOAK_TOKEN_WITH_GROUP);

        Message<String> messageWithToken =

                this.createMessageWithToken("   ", KEYCLOAK_TOKEN_WITH_GROUP);



        assertThrows(

                IllegalArgumentException.class,
@@ -763,7 +764,10 @@ class RegistryServiceTest { 
        Message<String> messageWithToken =

                this.createMessageWithToken(serviceId, KEYCLOAK_TOKEN_WITH_GROUP);



        registryService.retrieveKubernetesConfigFromKafkaMessage(messageWithToken).await().indefinitely();

        registryService

                .retrieveKubernetesConfigFromKafkaMessage(messageWithToken)

                .await()

                .indefinitely();



        ArgumentCaptor<VaultSecretResponseMessage> responseCaptor = ArgumentCaptor.captor();

        await()