X-Git-Url: https://gerrit.o-ran-sc.org/r/gitweb?a=blobdiff_plain;f=policy-agent%2Fsrc%2Ftest%2Fjava%2Forg%2Foransc%2Fpolicyagent%2FMockPolicyAgent.java;h=8adc79a3a4971e25358d052b19cf6aef5ea694a1;hb=636b5946ed5f9475d13cf4c942a2d9d35d1a5cbd;hp=dd57710cd02f37ea1b1f5434989fc02a6c012d82;hpb=637540bc28fbf337e0c4c58c051a6b4f7ceb321d;p=nonrtric.git diff --git a/policy-agent/src/test/java/org/oransc/policyagent/MockPolicyAgent.java b/policy-agent/src/test/java/org/oransc/policyagent/MockPolicyAgent.java index dd57710c..8adc79a3 100644 --- a/policy-agent/src/test/java/org/oransc/policyagent/MockPolicyAgent.java +++ b/policy-agent/src/test/java/org/oransc/policyagent/MockPolicyAgent.java @@ -27,10 +27,6 @@ import java.io.File; import java.io.IOException; import java.net.URL; import java.nio.file.Files; -import java.util.Collection; -import java.util.HashMap; -import java.util.Map; -import java.util.Vector; import org.junit.jupiter.api.Test; import org.junit.jupiter.api.extension.ExtendWith; @@ -41,103 +37,62 @@ import org.oransc.policyagent.repository.Policies; import org.oransc.policyagent.repository.PolicyType; import org.oransc.policyagent.repository.PolicyTypes; import org.oransc.policyagent.repository.Rics; -import org.springframework.beans.factory.annotation.Autowired; +import org.oransc.policyagent.utils.MockA1Client; import org.springframework.boot.test.context.SpringBootTest; import org.springframework.boot.test.context.SpringBootTest.WebEnvironment; import org.springframework.boot.test.context.TestConfiguration; import org.springframework.boot.web.server.LocalServerPort; import org.springframework.context.annotation.Bean; import org.springframework.test.context.junit.jupiter.SpringExtension; -import reactor.core.publisher.Mono; @ExtendWith(SpringExtension.class) @SpringBootTest(webEnvironment = WebEnvironment.DEFINED_PORT) public class MockPolicyAgent { - @Autowired - private Rics rics; - - @Autowired - private Policies policies; - - @Autowired - private PolicyTypes policyTypes; - static class MockApplicationConfig extends ApplicationConfig { - @Override - public void initialize() { + public String getLocalConfigurationFilePath() { URL url = MockApplicationConfig.class.getClassLoader().getResource("test_application_configuration.json"); - loadConfigurationFromFile(url.getFile()); - } - } - - private static class RicPolicyDatabase { - private Map> policies = new HashMap<>(); - - public void putPolicy(String nearRtRicUrl, String policyId, String policyString) { - getPolicies(nearRtRicUrl).put(policyId, policyString); - } - - public Collection getPolicyIdentities(String nearRtRicUrl) { - return getPolicies(nearRtRicUrl).keySet(); - } - - public void deletePolicy(String nearRtRicUrl, String policyId) { - getPolicies(nearRtRicUrl).remove(policyId); - } - - private Map getPolicies(String nearRtRicUrl) { - if (!policies.containsKey(nearRtRicUrl)) { - policies.put(nearRtRicUrl, new HashMap<>()); - } - return policies.get(nearRtRicUrl); + return url.getFile(); } } - static class A1ClientMock implements A1Client { + /** + * overrides the BeanFactory + */ + @TestConfiguration + static class TestBeanFactory { - private final RicPolicyDatabase policies = new RicPolicyDatabase(); + private final Rics rics = new Rics(); + private final Policies policies = new Policies(); private final PolicyTypes policyTypes = new PolicyTypes(); - A1ClientMock() { - loadTypes(this.policyTypes); - } - - @Override - public Mono> getPolicyTypeIdentities(String nearRtRicUrl) { - Vector result = new Vector<>(); - for (PolicyType p : this.policyTypes.getAll()) { - result.add(p.name()); - } - return Mono.just(result); + @Bean + public ApplicationConfig getApplicationConfig() { + return new MockApplicationConfig(); } - @Override - public Mono> getPolicyIdentities(String nearRtRicUrl) { - Collection result = policies.getPolicyIdentities(nearRtRicUrl); - return Mono.just(result); + @Bean + public A1Client getA1Client() { + PolicyTypes ricTypes = new PolicyTypes(); + loadTypes(ricTypes); + A1Client client = new MockA1Client(ricTypes); + return client; } - @Override - public Mono getPolicyType(String nearRtRicUrl, String policyTypeId) { - try { - return Mono.just(this.policyTypes.getType(policyTypeId).schema()); - } catch (Exception e) { - return Mono.error(e); - } + @Bean + public Policies getPolicies() { + return this.policies; } - @Override - public Mono putPolicy(String nearRtRicUrl, String policyId, String policyString) { - policies.putPolicy(nearRtRicUrl, policyId, policyString); - return Mono.just("OK"); + @Bean + public PolicyTypes getPolicyTypes() { + return this.policyTypes; } - @Override - public Mono deletePolicy(String nearRtRicUrl, String policyId) { - policies.deletePolicy(nearRtRicUrl, policyId); - return Mono.just("OK"); + @Bean + public Rics getRics() { + return this.rics; } private static File[] getResourceFolderFiles(String folder) { @@ -164,42 +119,7 @@ public class MockPolicyAgent { } } } - } - - /** - * overrides the BeanFactory - */ - @TestConfiguration - static class TestBeanFactory { - - private final Rics rics = new Rics(); - private final Policies policies = new Policies(); - private final PolicyTypes policyTypes = new PolicyTypes(); - - @Bean - public ApplicationConfig getApplicationConfig() { - return new MockApplicationConfig(); - } - - @Bean - A1Client getA1Client() { - return new A1ClientMock(); - } - - @Bean - public Policies getPolicies() { - return this.policies; - } - @Bean - public PolicyTypes getPolicyTypes() { - return this.policyTypes; - } - - @Bean - public Rics getRics() { - return this.rics; - } } @LocalServerPort