From bae12bf7d5a92a4d6be22e9ce8c3dc9878c59f36 Mon Sep 17 00:00:00 2001 From: Bogumil Zebek Date: Wed, 10 Mar 2021 12:55:08 +0100 Subject: Package rename Step 2: package rename, fix pom.xml, fix integration tests Issue-ID: INT-1869 Signed-off-by: Zebek Bogumil Change-Id: Ia4c6823e4facc3791583fb39caba3bcc125b3af7 --- .../simulators/nfsimulator/vesclient/Main.java | 59 ++++ .../nfsimulator/vesclient/SwaggerConfig.java | 46 +++ .../simulators/nfsimulator/vesclient/db/Row.java | 39 +++ .../nfsimulator/vesclient/db/Storage.java | 41 +++ .../nfsimulator/vesclient/event/EventData.java | 67 +++++ .../vesclient/event/EventDataRepository.java | 26 ++ .../vesclient/event/EventDataService.java | 65 ++++ .../vesclient/filesystem/WatcherConfig.java | 39 +++ .../filesystem/WatcherEventProcessor.java | 111 +++++++ .../vesclient/filesystem/WatcherService.java | 44 +++ .../vesclient/filesystem/WatcherThread.java | 81 +++++ .../vesclient/logging/MdcVariables.java | 35 +++ .../vesclient/rest/SimulatorController.java | 235 +++++++++++++++ .../vesclient/rest/TemplateController.java | 112 +++++++ .../vesclient/rest/model/FullEvent.java | 48 +++ .../vesclient/rest/model/SearchExp.java | 42 +++ .../vesclient/rest/model/SimulatorParams.java | 46 +++ .../vesclient/rest/model/SimulatorRequest.java | 55 ++++ .../vesclient/rest/model/TemplateRequest.java | 38 +++ .../nfsimulator/vesclient/rest/util/DateUtil.java | 35 +++ .../rest/util/JsonObjectDeserializer.java | 42 +++ .../vesclient/rest/util/ResponseBuilder.java | 62 ++++ .../vesclient/simulator/DbTemplateReader.java | 51 ++++ .../simulator/EventNotFoundException.java | 29 ++ .../simulator/FilesystemTemplateReader.java | 54 ++++ .../vesclient/simulator/IncrementProvider.java | 26 ++ .../vesclient/simulator/IncrementProviderImpl.java | 47 +++ .../vesclient/simulator/JsonTokenProcessor.java | 134 +++++++++ .../vesclient/simulator/KeywordsExtractor.java | 122 ++++++++ .../vesclient/simulator/KeywordsHandler.java | 74 +++++ .../simulator/KeywordsHandlerException.java | 28 ++ .../vesclient/simulator/KeywordsValueProvider.java | 80 +++++ .../vesclient/simulator/SimulatorService.java | 132 +++++++++ .../vesclient/simulator/TemplatePatcher.java | 53 ++++ .../vesclient/simulator/TemplateReader.java | 29 ++ .../simulator/TemplateVariablesReplacer.java | 50 ++++ .../client/HttpApacheResponseAdapterFactory.java | 45 +++ .../simulator/client/HttpClientAdapter.java | 27 ++ .../simulator/client/HttpClientAdapterImpl.java | 119 ++++++++ .../simulator/client/HttpResponseAdapter.java | 41 +++ .../utils/ssl/CertAuthSslContextFactory.java | 53 ++++ .../client/utils/ssl/CertificateReader.java | 46 +++ .../client/utils/ssl/HttpClientFactory.java | 104 +++++++ .../client/utils/ssl/HttpClientFactoryFacade.java | 40 +++ .../client/utils/ssl/PasswordConverter.java | 32 ++ .../client/utils/ssl/SSLContextFactory.java | 48 +++ .../client/utils/ssl/SslAuthenticationHelper.java | 45 +++ .../vesclient/simulator/keywords/Keyword.java | 76 +++++ .../simulator/keywords/NonParameterKeyword.java | 65 ++++ .../simulator/keywords/SingleParameterKeyword.java | 73 +++++ .../simulator/keywords/TwoParameterKeyword.java | 80 +++++ .../vesclient/simulator/scheduler/EventJob.java | 99 +++++++ .../simulator/scheduler/EventScheduler.java | 120 ++++++++ .../simulator/scheduler/QuartzConfiguration.java | 38 +++ .../vesclient/simulatorconfig/SimulatorConfig.java | 49 +++ .../simulatorconfig/SimulatorConfigRepository.java | 26 ++ .../simulatorconfig/SimulatorConfigService.java | 52 ++++ .../template/FsToDbTemplateSynchronizer.java | 74 +++++ .../nfsimulator/vesclient/template/Template.java | 92 ++++++ .../vesclient/template/TemplateRepository.java | 26 ++ .../vesclient/template/TemplateService.java | 81 +++++ .../template/search/IllegalJsonValueException.java | 28 ++ .../vesclient/template/search/JsonUtils.java | 104 +++++++ .../template/search/TemplateSearchHelper.java | 95 ++++++ .../handler/PrimitiveValueCriteriaBuilder.java | 103 +++++++ .../search/viewmodel/FlatTemplateContent.java | 45 +++ .../template/search/viewmodel/KeyValuePair.java | 40 +++ src/main/java/org/onap/pnfsimulator/Main.java | 59 ---- .../java/org/onap/pnfsimulator/SwaggerConfig.java | 46 --- src/main/java/org/onap/pnfsimulator/db/Row.java | 39 --- .../java/org/onap/pnfsimulator/db/Storage.java | 41 --- .../org/onap/pnfsimulator/event/EventData.java | 67 ----- .../pnfsimulator/event/EventDataRepository.java | 26 -- .../onap/pnfsimulator/event/EventDataService.java | 65 ---- .../pnfsimulator/filesystem/WatcherConfig.java | 39 --- .../filesystem/WatcherEventProcessor.java | 111 ------- .../pnfsimulator/filesystem/WatcherService.java | 44 --- .../pnfsimulator/filesystem/WatcherThread.java | 81 ----- .../onap/pnfsimulator/logging/MdcVariables.java | 35 --- .../pnfsimulator/rest/SimulatorController.java | 241 --------------- .../onap/pnfsimulator/rest/TemplateController.java | 112 ------- .../onap/pnfsimulator/rest/model/FullEvent.java | 48 --- .../onap/pnfsimulator/rest/model/SearchExp.java | 42 --- .../pnfsimulator/rest/model/SimulatorParams.java | 46 --- .../pnfsimulator/rest/model/SimulatorRequest.java | 55 ---- .../pnfsimulator/rest/model/TemplateRequest.java | 38 --- .../org/onap/pnfsimulator/rest/util/DateUtil.java | 35 --- .../rest/util/JsonObjectDeserializer.java | 42 --- .../pnfsimulator/rest/util/ResponseBuilder.java | 62 ---- .../pnfsimulator/simulator/DbTemplateReader.java | 51 ---- .../simulator/EventNotFoundException.java | 29 -- .../simulator/FilesystemTemplateReader.java | 54 ---- .../pnfsimulator/simulator/IncrementProvider.java | 26 -- .../simulator/IncrementProviderImpl.java | 47 --- .../pnfsimulator/simulator/JsonTokenProcessor.java | 134 --------- .../pnfsimulator/simulator/KeywordsExtractor.java | 129 -------- .../pnfsimulator/simulator/KeywordsHandler.java | 74 ----- .../simulator/KeywordsHandlerException.java | 28 -- .../simulator/KeywordsValueProvider.java | 80 ----- .../pnfsimulator/simulator/SimulatorService.java | 132 --------- .../pnfsimulator/simulator/TemplatePatcher.java | 53 ---- .../pnfsimulator/simulator/TemplateReader.java | 29 -- .../simulator/TemplateVariablesReplacer.java | 50 ---- .../client/HttpApacheResponseAdapterFactory.java | 45 --- .../simulator/client/HttpClientAdapter.java | 27 -- .../simulator/client/HttpClientAdapterImpl.java | 119 -------- .../simulator/client/HttpResponseAdapter.java | 41 --- .../utils/ssl/CertAuthSslContextFactory.java | 53 ---- .../client/utils/ssl/CertificateReader.java | 46 --- .../client/utils/ssl/HttpClientFactory.java | 104 ------- .../client/utils/ssl/HttpClientFactoryFacade.java | 40 --- .../client/utils/ssl/PasswordConverter.java | 32 -- .../client/utils/ssl/SSLContextFactory.java | 48 --- .../client/utils/ssl/SslAuthenticationHelper.java | 45 --- .../pnfsimulator/simulator/keywords/Keyword.java | 76 ----- .../simulator/keywords/NonParameterKeyword.java | 65 ---- .../simulator/keywords/SingleParameterKeyword.java | 73 ----- .../simulator/keywords/TwoParameterKeyword.java | 80 ----- .../pnfsimulator/simulator/scheduler/EventJob.java | 99 ------- .../simulator/scheduler/EventScheduler.java | 120 -------- .../simulator/scheduler/QuartzConfiguration.java | 38 --- .../simulatorconfig/SimulatorConfig.java | 49 --- .../simulatorconfig/SimulatorConfigRepository.java | 26 -- .../simulatorconfig/SimulatorConfigService.java | 52 ---- .../template/FsToDbTemplateSynchronizer.java | 74 ----- .../org/onap/pnfsimulator/template/Template.java | 92 ------ .../pnfsimulator/template/TemplateRepository.java | 26 -- .../pnfsimulator/template/TemplateService.java | 81 ----- .../template/search/IllegalJsonValueException.java | 28 -- .../pnfsimulator/template/search/JsonUtils.java | 104 ------- .../template/search/TemplateSearchHelper.java | 95 ------ .../handler/PrimitiveValueCriteriaBuilder.java | 103 ------- .../search/viewmodel/FlatTemplateContent.java | 45 --- .../template/search/viewmodel/KeyValuePair.java | 40 --- .../vesclient/event/EventDataServiceTest.java | 133 +++++++++ .../filesystem/InMemoryTemplateStorage.java | 71 +++++ .../filesystem/WatcherEventProcessorTest.java | 125 ++++++++ .../vesclient/rest/SimulatorControllerTest.java | 329 +++++++++++++++++++++ .../vesclient/rest/TemplateControllerTest.java | 256 ++++++++++++++++ .../vesclient/rest/util/DateUtilTest.java | 38 +++ .../vesclient/rest/util/ResponseBuilderTest.java | 66 +++++ .../vesclient/simulator/DbTemplateReaderTest.java | 81 +++++ .../simulator/IncrementProviderImplTest.java | 79 +++++ .../KeywordsExtractorInvalidRandomIntegerTest.java | 67 +++++ .../KeywordsExtractorInvalidRandomStringTest.java | 67 +++++ .../KeywordsExtractorInvalidTimestampTest.java | 65 ++++ .../KeywordsExtractorValidRandomIntegerTest.java | 66 +++++ ...dsExtractorValidRandomPrimitiveIntegerTest.java | 66 +++++ .../KeywordsExtractorValidRandomStringTest.java | 68 +++++ ...ywordsExtractorValidTimestampPrimitiveTest.java | 66 +++++ .../KeywordsExtractorValidTimestampTest.java | 68 +++++ .../vesclient/simulator/KeywordsHandlerTest.java | 305 +++++++++++++++++++ .../simulator/KeywordsValueProviderTest.java | 82 +++++ .../vesclient/simulator/SimulatorServiceTest.java | 309 +++++++++++++++++++ .../vesclient/simulator/TemplatePatcherTest.java | 164 ++++++++++ .../vesclient/simulator/TemplateReaderTest.java | 51 ++++ .../simulator/TemplateVariablesReplacerTest.java | 174 +++++++++++ .../HttpApacheResponseAdapterFactoryTest.java | 98 ++++++ .../client/HttpClientAdapterImplTest.java | 157 ++++++++++ .../vesclient/simulator/client/HttpTestUtils.java | 55 ++++ .../utils/ssl/CertAuthSslContextFactoryTest.java | 141 +++++++++ .../utils/ssl/HttpClientFactoryFacadeTest.java | 35 +++ .../client/utils/ssl/HttpClientFactoryTest.java | 143 +++++++++ .../client/utils/ssl/PasswordConverterTest.java | 44 +++ .../client/utils/ssl/SSLContextFactoryTest.java | 61 ++++ .../keywords/TwoParameterKeywordTest.java | 48 +++ .../simulator/scheduler/EventJobTest.java | 84 ++++++ .../simulator/scheduler/EventSchedulerTest.java | 148 +++++++++ .../SimulatorConfigServiceTest.java | 104 +++++++ .../template/FsToDbTemplateSynchronizerTest.java | 53 ++++ .../vesclient/template/TemplateServiceTest.java | 153 ++++++++++ .../vesclient/template/search/JsonUtilsTest.java | 166 +++++++++++ .../template/search/TemplateSearchHelperTest.java | 159 ++++++++++ .../handler/PrimitiveValueCriteriaBuilderTest.java | 75 +++++ .../pnfsimulator/event/EventDataServiceTest.java | 133 --------- .../filesystem/InMemoryTemplateStorage.java | 71 ----- .../filesystem/WatcherEventProcessorTest.java | 125 -------- .../pnfsimulator/rest/SimulatorControllerTest.java | 329 --------------------- .../pnfsimulator/rest/TemplateControllerTest.java | 256 ---------------- .../onap/pnfsimulator/rest/util/DateUtilTest.java | 38 --- .../rest/util/ResponseBuilderTest.java | 66 ----- .../simulator/DbTemplateReaderTest.java | 81 ----- .../simulator/IncrementProviderImplTest.java | 79 ----- .../KeywordsExtractorInvalidRandomIntegerTest.java | 67 ----- .../KeywordsExtractorInvalidRandomStringTest.java | 67 ----- .../KeywordsExtractorInvalidTimestampTest.java | 65 ---- .../KeywordsExtractorValidRandomIntegerTest.java | 66 ----- ...dsExtractorValidRandomPrimitiveIntegerTest.java | 66 ----- .../KeywordsExtractorValidRandomStringTest.java | 69 ----- ...ywordsExtractorValidTimestampPrimitiveTest.java | 66 ----- .../KeywordsExtractorValidTimestampTest.java | 68 ----- .../simulator/KeywordsHandlerTest.java | 306 ------------------- .../simulator/KeywordsValueProviderTest.java | 82 ----- .../simulator/SimulatorServiceTest.java | 308 ------------------- .../simulator/TemplatePatcherTest.java | 164 ---------- .../pnfsimulator/simulator/TemplateReaderTest.java | 51 ---- .../simulator/TemplateVariablesReplacerTest.java | 174 ----------- .../HttpApacheResponseAdapterFactoryTest.java | 98 ------ .../client/HttpClientAdapterImplTest.java | 157 ---------- .../simulator/client/HttpTestUtils.java | 55 ---- .../utils/ssl/CertAuthSslContextFactoryTest.java | 141 --------- .../utils/ssl/HttpClientFactoryFacadeTest.java | 35 --- .../client/utils/ssl/HttpClientFactoryTest.java | 143 --------- .../client/utils/ssl/PasswordConverterTest.java | 44 --- .../client/utils/ssl/SSLContextFactoryTest.java | 61 ---- .../keywords/TwoParameterKeywordTest.java | 48 --- .../simulator/scheduler/EventJobTest.java | 90 ------ .../simulator/scheduler/EventSchedulerTest.java | 148 --------- .../SimulatorConfigServiceTest.java | 104 ------- .../template/FsToDbTemplateSynchronizerTest.java | 53 ---- .../pnfsimulator/template/TemplateServiceTest.java | 152 ---------- .../template/search/JsonUtilsTest.java | 166 ----------- .../template/search/TemplateSearchHelperTest.java | 160 ---------- .../handler/PrimitiveValueCriteriaBuilderTest.java | 75 ----- .../vesclient/simulator/filesystem/test1.json | 12 + .../simulator/invalidJsonStructureEvent.json | 1 + .../simulator/validExampleMeasurementEvent.json | 86 ++++++ .../pnfsimulator/simulator/filesystem/test1.json | 12 - .../simulator/invalidJsonStructureEvent.json | 1 - .../simulator/validExampleMeasurementEvent.json | 86 ------ 220 files changed, 8862 insertions(+), 8882 deletions(-) create mode 100644 src/main/java/org/onap/integration/simulators/nfsimulator/vesclient/Main.java create mode 100644 src/main/java/org/onap/integration/simulators/nfsimulator/vesclient/SwaggerConfig.java create mode 100644 src/main/java/org/onap/integration/simulators/nfsimulator/vesclient/db/Row.java create mode 100644 src/main/java/org/onap/integration/simulators/nfsimulator/vesclient/db/Storage.java create mode 100644 src/main/java/org/onap/integration/simulators/nfsimulator/vesclient/event/EventData.java create mode 100644 src/main/java/org/onap/integration/simulators/nfsimulator/vesclient/event/EventDataRepository.java create mode 100644 src/main/java/org/onap/integration/simulators/nfsimulator/vesclient/event/EventDataService.java create mode 100644 src/main/java/org/onap/integration/simulators/nfsimulator/vesclient/filesystem/WatcherConfig.java create mode 100644 src/main/java/org/onap/integration/simulators/nfsimulator/vesclient/filesystem/WatcherEventProcessor.java create mode 100644 src/main/java/org/onap/integration/simulators/nfsimulator/vesclient/filesystem/WatcherService.java create mode 100644 src/main/java/org/onap/integration/simulators/nfsimulator/vesclient/filesystem/WatcherThread.java create mode 100644 src/main/java/org/onap/integration/simulators/nfsimulator/vesclient/logging/MdcVariables.java create mode 100644 src/main/java/org/onap/integration/simulators/nfsimulator/vesclient/rest/SimulatorController.java create mode 100644 src/main/java/org/onap/integration/simulators/nfsimulator/vesclient/rest/TemplateController.java create mode 100644 src/main/java/org/onap/integration/simulators/nfsimulator/vesclient/rest/model/FullEvent.java create mode 100644 src/main/java/org/onap/integration/simulators/nfsimulator/vesclient/rest/model/SearchExp.java create mode 100644 src/main/java/org/onap/integration/simulators/nfsimulator/vesclient/rest/model/SimulatorParams.java create mode 100644 src/main/java/org/onap/integration/simulators/nfsimulator/vesclient/rest/model/SimulatorRequest.java create mode 100644 src/main/java/org/onap/integration/simulators/nfsimulator/vesclient/rest/model/TemplateRequest.java create mode 100644 src/main/java/org/onap/integration/simulators/nfsimulator/vesclient/rest/util/DateUtil.java create mode 100644 src/main/java/org/onap/integration/simulators/nfsimulator/vesclient/rest/util/JsonObjectDeserializer.java create mode 100644 src/main/java/org/onap/integration/simulators/nfsimulator/vesclient/rest/util/ResponseBuilder.java create mode 100644 src/main/java/org/onap/integration/simulators/nfsimulator/vesclient/simulator/DbTemplateReader.java create mode 100644 src/main/java/org/onap/integration/simulators/nfsimulator/vesclient/simulator/EventNotFoundException.java create mode 100644 src/main/java/org/onap/integration/simulators/nfsimulator/vesclient/simulator/FilesystemTemplateReader.java create mode 100644 src/main/java/org/onap/integration/simulators/nfsimulator/vesclient/simulator/IncrementProvider.java create mode 100644 src/main/java/org/onap/integration/simulators/nfsimulator/vesclient/simulator/IncrementProviderImpl.java create mode 100644 src/main/java/org/onap/integration/simulators/nfsimulator/vesclient/simulator/JsonTokenProcessor.java create mode 100644 src/main/java/org/onap/integration/simulators/nfsimulator/vesclient/simulator/KeywordsExtractor.java create mode 100644 src/main/java/org/onap/integration/simulators/nfsimulator/vesclient/simulator/KeywordsHandler.java create mode 100644 src/main/java/org/onap/integration/simulators/nfsimulator/vesclient/simulator/KeywordsHandlerException.java create mode 100644 src/main/java/org/onap/integration/simulators/nfsimulator/vesclient/simulator/KeywordsValueProvider.java create mode 100644 src/main/java/org/onap/integration/simulators/nfsimulator/vesclient/simulator/SimulatorService.java create mode 100644 src/main/java/org/onap/integration/simulators/nfsimulator/vesclient/simulator/TemplatePatcher.java create mode 100644 src/main/java/org/onap/integration/simulators/nfsimulator/vesclient/simulator/TemplateReader.java create mode 100644 src/main/java/org/onap/integration/simulators/nfsimulator/vesclient/simulator/TemplateVariablesReplacer.java create mode 100644 src/main/java/org/onap/integration/simulators/nfsimulator/vesclient/simulator/client/HttpApacheResponseAdapterFactory.java create mode 100644 src/main/java/org/onap/integration/simulators/nfsimulator/vesclient/simulator/client/HttpClientAdapter.java create mode 100644 src/main/java/org/onap/integration/simulators/nfsimulator/vesclient/simulator/client/HttpClientAdapterImpl.java create mode 100644 src/main/java/org/onap/integration/simulators/nfsimulator/vesclient/simulator/client/HttpResponseAdapter.java create mode 100644 src/main/java/org/onap/integration/simulators/nfsimulator/vesclient/simulator/client/utils/ssl/CertAuthSslContextFactory.java create mode 100644 src/main/java/org/onap/integration/simulators/nfsimulator/vesclient/simulator/client/utils/ssl/CertificateReader.java create mode 100644 src/main/java/org/onap/integration/simulators/nfsimulator/vesclient/simulator/client/utils/ssl/HttpClientFactory.java create mode 100644 src/main/java/org/onap/integration/simulators/nfsimulator/vesclient/simulator/client/utils/ssl/HttpClientFactoryFacade.java create mode 100644 src/main/java/org/onap/integration/simulators/nfsimulator/vesclient/simulator/client/utils/ssl/PasswordConverter.java create mode 100644 src/main/java/org/onap/integration/simulators/nfsimulator/vesclient/simulator/client/utils/ssl/SSLContextFactory.java create mode 100644 src/main/java/org/onap/integration/simulators/nfsimulator/vesclient/simulator/client/utils/ssl/SslAuthenticationHelper.java create mode 100644 src/main/java/org/onap/integration/simulators/nfsimulator/vesclient/simulator/keywords/Keyword.java create mode 100644 src/main/java/org/onap/integration/simulators/nfsimulator/vesclient/simulator/keywords/NonParameterKeyword.java create mode 100644 src/main/java/org/onap/integration/simulators/nfsimulator/vesclient/simulator/keywords/SingleParameterKeyword.java create mode 100644 src/main/java/org/onap/integration/simulators/nfsimulator/vesclient/simulator/keywords/TwoParameterKeyword.java create mode 100644 src/main/java/org/onap/integration/simulators/nfsimulator/vesclient/simulator/scheduler/EventJob.java create mode 100644 src/main/java/org/onap/integration/simulators/nfsimulator/vesclient/simulator/scheduler/EventScheduler.java create mode 100644 src/main/java/org/onap/integration/simulators/nfsimulator/vesclient/simulator/scheduler/QuartzConfiguration.java create mode 100644 src/main/java/org/onap/integration/simulators/nfsimulator/vesclient/simulatorconfig/SimulatorConfig.java create mode 100644 src/main/java/org/onap/integration/simulators/nfsimulator/vesclient/simulatorconfig/SimulatorConfigRepository.java create mode 100644 src/main/java/org/onap/integration/simulators/nfsimulator/vesclient/simulatorconfig/SimulatorConfigService.java create mode 100644 src/main/java/org/onap/integration/simulators/nfsimulator/vesclient/template/FsToDbTemplateSynchronizer.java create mode 100644 src/main/java/org/onap/integration/simulators/nfsimulator/vesclient/template/Template.java create mode 100644 src/main/java/org/onap/integration/simulators/nfsimulator/vesclient/template/TemplateRepository.java create mode 100644 src/main/java/org/onap/integration/simulators/nfsimulator/vesclient/template/TemplateService.java create mode 100644 src/main/java/org/onap/integration/simulators/nfsimulator/vesclient/template/search/IllegalJsonValueException.java create mode 100644 src/main/java/org/onap/integration/simulators/nfsimulator/vesclient/template/search/JsonUtils.java create mode 100644 src/main/java/org/onap/integration/simulators/nfsimulator/vesclient/template/search/TemplateSearchHelper.java create mode 100644 src/main/java/org/onap/integration/simulators/nfsimulator/vesclient/template/search/handler/PrimitiveValueCriteriaBuilder.java create mode 100644 src/main/java/org/onap/integration/simulators/nfsimulator/vesclient/template/search/viewmodel/FlatTemplateContent.java create mode 100644 src/main/java/org/onap/integration/simulators/nfsimulator/vesclient/template/search/viewmodel/KeyValuePair.java delete mode 100644 src/main/java/org/onap/pnfsimulator/Main.java delete mode 100644 src/main/java/org/onap/pnfsimulator/SwaggerConfig.java delete mode 100644 src/main/java/org/onap/pnfsimulator/db/Row.java delete mode 100644 src/main/java/org/onap/pnfsimulator/db/Storage.java delete mode 100644 src/main/java/org/onap/pnfsimulator/event/EventData.java delete mode 100644 src/main/java/org/onap/pnfsimulator/event/EventDataRepository.java delete mode 100644 src/main/java/org/onap/pnfsimulator/event/EventDataService.java delete mode 100644 src/main/java/org/onap/pnfsimulator/filesystem/WatcherConfig.java delete mode 100644 src/main/java/org/onap/pnfsimulator/filesystem/WatcherEventProcessor.java delete mode 100644 src/main/java/org/onap/pnfsimulator/filesystem/WatcherService.java delete mode 100644 src/main/java/org/onap/pnfsimulator/filesystem/WatcherThread.java delete mode 100644 src/main/java/org/onap/pnfsimulator/logging/MdcVariables.java delete mode 100644 src/main/java/org/onap/pnfsimulator/rest/SimulatorController.java delete mode 100644 src/main/java/org/onap/pnfsimulator/rest/TemplateController.java delete mode 100644 src/main/java/org/onap/pnfsimulator/rest/model/FullEvent.java delete mode 100644 src/main/java/org/onap/pnfsimulator/rest/model/SearchExp.java delete mode 100644 src/main/java/org/onap/pnfsimulator/rest/model/SimulatorParams.java delete mode 100644 src/main/java/org/onap/pnfsimulator/rest/model/SimulatorRequest.java delete mode 100644 src/main/java/org/onap/pnfsimulator/rest/model/TemplateRequest.java delete mode 100644 src/main/java/org/onap/pnfsimulator/rest/util/DateUtil.java delete mode 100644 src/main/java/org/onap/pnfsimulator/rest/util/JsonObjectDeserializer.java delete mode 100644 src/main/java/org/onap/pnfsimulator/rest/util/ResponseBuilder.java delete mode 100644 src/main/java/org/onap/pnfsimulator/simulator/DbTemplateReader.java delete mode 100644 src/main/java/org/onap/pnfsimulator/simulator/EventNotFoundException.java delete mode 100644 src/main/java/org/onap/pnfsimulator/simulator/FilesystemTemplateReader.java delete mode 100644 src/main/java/org/onap/pnfsimulator/simulator/IncrementProvider.java delete mode 100644 src/main/java/org/onap/pnfsimulator/simulator/IncrementProviderImpl.java delete mode 100644 src/main/java/org/onap/pnfsimulator/simulator/JsonTokenProcessor.java delete mode 100644 src/main/java/org/onap/pnfsimulator/simulator/KeywordsExtractor.java delete mode 100644 src/main/java/org/onap/pnfsimulator/simulator/KeywordsHandler.java delete mode 100644 src/main/java/org/onap/pnfsimulator/simulator/KeywordsHandlerException.java delete mode 100644 src/main/java/org/onap/pnfsimulator/simulator/KeywordsValueProvider.java delete mode 100644 src/main/java/org/onap/pnfsimulator/simulator/SimulatorService.java delete mode 100644 src/main/java/org/onap/pnfsimulator/simulator/TemplatePatcher.java delete mode 100644 src/main/java/org/onap/pnfsimulator/simulator/TemplateReader.java delete mode 100644 src/main/java/org/onap/pnfsimulator/simulator/TemplateVariablesReplacer.java delete mode 100644 src/main/java/org/onap/pnfsimulator/simulator/client/HttpApacheResponseAdapterFactory.java delete mode 100644 src/main/java/org/onap/pnfsimulator/simulator/client/HttpClientAdapter.java delete mode 100644 src/main/java/org/onap/pnfsimulator/simulator/client/HttpClientAdapterImpl.java delete mode 100644 src/main/java/org/onap/pnfsimulator/simulator/client/HttpResponseAdapter.java delete mode 100644 src/main/java/org/onap/pnfsimulator/simulator/client/utils/ssl/CertAuthSslContextFactory.java delete mode 100644 src/main/java/org/onap/pnfsimulator/simulator/client/utils/ssl/CertificateReader.java delete mode 100644 src/main/java/org/onap/pnfsimulator/simulator/client/utils/ssl/HttpClientFactory.java delete mode 100644 src/main/java/org/onap/pnfsimulator/simulator/client/utils/ssl/HttpClientFactoryFacade.java delete mode 100644 src/main/java/org/onap/pnfsimulator/simulator/client/utils/ssl/PasswordConverter.java delete mode 100644 src/main/java/org/onap/pnfsimulator/simulator/client/utils/ssl/SSLContextFactory.java delete mode 100644 src/main/java/org/onap/pnfsimulator/simulator/client/utils/ssl/SslAuthenticationHelper.java delete mode 100644 src/main/java/org/onap/pnfsimulator/simulator/keywords/Keyword.java delete mode 100644 src/main/java/org/onap/pnfsimulator/simulator/keywords/NonParameterKeyword.java delete mode 100644 src/main/java/org/onap/pnfsimulator/simulator/keywords/SingleParameterKeyword.java delete mode 100644 src/main/java/org/onap/pnfsimulator/simulator/keywords/TwoParameterKeyword.java delete mode 100644 src/main/java/org/onap/pnfsimulator/simulator/scheduler/EventJob.java delete mode 100644 src/main/java/org/onap/pnfsimulator/simulator/scheduler/EventScheduler.java delete mode 100644 src/main/java/org/onap/pnfsimulator/simulator/scheduler/QuartzConfiguration.java delete mode 100644 src/main/java/org/onap/pnfsimulator/simulatorconfig/SimulatorConfig.java delete mode 100644 src/main/java/org/onap/pnfsimulator/simulatorconfig/SimulatorConfigRepository.java delete mode 100644 src/main/java/org/onap/pnfsimulator/simulatorconfig/SimulatorConfigService.java delete mode 100644 src/main/java/org/onap/pnfsimulator/template/FsToDbTemplateSynchronizer.java delete mode 100644 src/main/java/org/onap/pnfsimulator/template/Template.java delete mode 100644 src/main/java/org/onap/pnfsimulator/template/TemplateRepository.java delete mode 100644 src/main/java/org/onap/pnfsimulator/template/TemplateService.java delete mode 100644 src/main/java/org/onap/pnfsimulator/template/search/IllegalJsonValueException.java delete mode 100644 src/main/java/org/onap/pnfsimulator/template/search/JsonUtils.java delete mode 100644 src/main/java/org/onap/pnfsimulator/template/search/TemplateSearchHelper.java delete mode 100644 src/main/java/org/onap/pnfsimulator/template/search/handler/PrimitiveValueCriteriaBuilder.java delete mode 100644 src/main/java/org/onap/pnfsimulator/template/search/viewmodel/FlatTemplateContent.java delete mode 100644 src/main/java/org/onap/pnfsimulator/template/search/viewmodel/KeyValuePair.java create mode 100644 src/test/java/org/onap/integration/simulators/nfsimulator/vesclient/event/EventDataServiceTest.java create mode 100644 src/test/java/org/onap/integration/simulators/nfsimulator/vesclient/filesystem/InMemoryTemplateStorage.java create mode 100644 src/test/java/org/onap/integration/simulators/nfsimulator/vesclient/filesystem/WatcherEventProcessorTest.java create mode 100644 src/test/java/org/onap/integration/simulators/nfsimulator/vesclient/rest/SimulatorControllerTest.java create mode 100644 src/test/java/org/onap/integration/simulators/nfsimulator/vesclient/rest/TemplateControllerTest.java create mode 100644 src/test/java/org/onap/integration/simulators/nfsimulator/vesclient/rest/util/DateUtilTest.java create mode 100644 src/test/java/org/onap/integration/simulators/nfsimulator/vesclient/rest/util/ResponseBuilderTest.java create mode 100644 src/test/java/org/onap/integration/simulators/nfsimulator/vesclient/simulator/DbTemplateReaderTest.java create mode 100644 src/test/java/org/onap/integration/simulators/nfsimulator/vesclient/simulator/IncrementProviderImplTest.java create mode 100644 src/test/java/org/onap/integration/simulators/nfsimulator/vesclient/simulator/KeywordsExtractorInvalidRandomIntegerTest.java create mode 100644 src/test/java/org/onap/integration/simulators/nfsimulator/vesclient/simulator/KeywordsExtractorInvalidRandomStringTest.java create mode 100644 src/test/java/org/onap/integration/simulators/nfsimulator/vesclient/simulator/KeywordsExtractorInvalidTimestampTest.java create mode 100644 src/test/java/org/onap/integration/simulators/nfsimulator/vesclient/simulator/KeywordsExtractorValidRandomIntegerTest.java create mode 100644 src/test/java/org/onap/integration/simulators/nfsimulator/vesclient/simulator/KeywordsExtractorValidRandomPrimitiveIntegerTest.java create mode 100644 src/test/java/org/onap/integration/simulators/nfsimulator/vesclient/simulator/KeywordsExtractorValidRandomStringTest.java create mode 100644 src/test/java/org/onap/integration/simulators/nfsimulator/vesclient/simulator/KeywordsExtractorValidTimestampPrimitiveTest.java create mode 100644 src/test/java/org/onap/integration/simulators/nfsimulator/vesclient/simulator/KeywordsExtractorValidTimestampTest.java create mode 100644 src/test/java/org/onap/integration/simulators/nfsimulator/vesclient/simulator/KeywordsHandlerTest.java create mode 100644 src/test/java/org/onap/integration/simulators/nfsimulator/vesclient/simulator/KeywordsValueProviderTest.java create mode 100644 src/test/java/org/onap/integration/simulators/nfsimulator/vesclient/simulator/SimulatorServiceTest.java create mode 100644 src/test/java/org/onap/integration/simulators/nfsimulator/vesclient/simulator/TemplatePatcherTest.java create mode 100644 src/test/java/org/onap/integration/simulators/nfsimulator/vesclient/simulator/TemplateReaderTest.java create mode 100644 src/test/java/org/onap/integration/simulators/nfsimulator/vesclient/simulator/TemplateVariablesReplacerTest.java create mode 100644 src/test/java/org/onap/integration/simulators/nfsimulator/vesclient/simulator/client/HttpApacheResponseAdapterFactoryTest.java create mode 100644 src/test/java/org/onap/integration/simulators/nfsimulator/vesclient/simulator/client/HttpClientAdapterImplTest.java create mode 100644 src/test/java/org/onap/integration/simulators/nfsimulator/vesclient/simulator/client/HttpTestUtils.java create mode 100644 src/test/java/org/onap/integration/simulators/nfsimulator/vesclient/simulator/client/utils/ssl/CertAuthSslContextFactoryTest.java create mode 100644 src/test/java/org/onap/integration/simulators/nfsimulator/vesclient/simulator/client/utils/ssl/HttpClientFactoryFacadeTest.java create mode 100644 src/test/java/org/onap/integration/simulators/nfsimulator/vesclient/simulator/client/utils/ssl/HttpClientFactoryTest.java create mode 100644 src/test/java/org/onap/integration/simulators/nfsimulator/vesclient/simulator/client/utils/ssl/PasswordConverterTest.java create mode 100644 src/test/java/org/onap/integration/simulators/nfsimulator/vesclient/simulator/client/utils/ssl/SSLContextFactoryTest.java create mode 100644 src/test/java/org/onap/integration/simulators/nfsimulator/vesclient/simulator/keywords/TwoParameterKeywordTest.java create mode 100644 src/test/java/org/onap/integration/simulators/nfsimulator/vesclient/simulator/scheduler/EventJobTest.java create mode 100644 src/test/java/org/onap/integration/simulators/nfsimulator/vesclient/simulator/scheduler/EventSchedulerTest.java create mode 100644 src/test/java/org/onap/integration/simulators/nfsimulator/vesclient/simulatorconfig/SimulatorConfigServiceTest.java create mode 100644 src/test/java/org/onap/integration/simulators/nfsimulator/vesclient/template/FsToDbTemplateSynchronizerTest.java create mode 100644 src/test/java/org/onap/integration/simulators/nfsimulator/vesclient/template/TemplateServiceTest.java create mode 100644 src/test/java/org/onap/integration/simulators/nfsimulator/vesclient/template/search/JsonUtilsTest.java create mode 100644 src/test/java/org/onap/integration/simulators/nfsimulator/vesclient/template/search/TemplateSearchHelperTest.java create mode 100644 src/test/java/org/onap/integration/simulators/nfsimulator/vesclient/template/search/handler/PrimitiveValueCriteriaBuilderTest.java delete mode 100644 src/test/java/org/onap/pnfsimulator/event/EventDataServiceTest.java delete mode 100644 src/test/java/org/onap/pnfsimulator/filesystem/InMemoryTemplateStorage.java delete mode 100644 src/test/java/org/onap/pnfsimulator/filesystem/WatcherEventProcessorTest.java delete mode 100644 src/test/java/org/onap/pnfsimulator/rest/SimulatorControllerTest.java delete mode 100644 src/test/java/org/onap/pnfsimulator/rest/TemplateControllerTest.java delete mode 100644 src/test/java/org/onap/pnfsimulator/rest/util/DateUtilTest.java delete mode 100644 src/test/java/org/onap/pnfsimulator/rest/util/ResponseBuilderTest.java delete mode 100644 src/test/java/org/onap/pnfsimulator/simulator/DbTemplateReaderTest.java delete mode 100644 src/test/java/org/onap/pnfsimulator/simulator/IncrementProviderImplTest.java delete mode 100644 src/test/java/org/onap/pnfsimulator/simulator/KeywordsExtractorInvalidRandomIntegerTest.java delete mode 100644 src/test/java/org/onap/pnfsimulator/simulator/KeywordsExtractorInvalidRandomStringTest.java delete mode 100644 src/test/java/org/onap/pnfsimulator/simulator/KeywordsExtractorInvalidTimestampTest.java delete mode 100644 src/test/java/org/onap/pnfsimulator/simulator/KeywordsExtractorValidRandomIntegerTest.java delete mode 100644 src/test/java/org/onap/pnfsimulator/simulator/KeywordsExtractorValidRandomPrimitiveIntegerTest.java delete mode 100644 src/test/java/org/onap/pnfsimulator/simulator/KeywordsExtractorValidRandomStringTest.java delete mode 100644 src/test/java/org/onap/pnfsimulator/simulator/KeywordsExtractorValidTimestampPrimitiveTest.java delete mode 100644 src/test/java/org/onap/pnfsimulator/simulator/KeywordsExtractorValidTimestampTest.java delete mode 100644 src/test/java/org/onap/pnfsimulator/simulator/KeywordsHandlerTest.java delete mode 100644 src/test/java/org/onap/pnfsimulator/simulator/KeywordsValueProviderTest.java delete mode 100644 src/test/java/org/onap/pnfsimulator/simulator/SimulatorServiceTest.java delete mode 100644 src/test/java/org/onap/pnfsimulator/simulator/TemplatePatcherTest.java delete mode 100644 src/test/java/org/onap/pnfsimulator/simulator/TemplateReaderTest.java delete mode 100644 src/test/java/org/onap/pnfsimulator/simulator/TemplateVariablesReplacerTest.java delete mode 100644 src/test/java/org/onap/pnfsimulator/simulator/client/HttpApacheResponseAdapterFactoryTest.java delete mode 100644 src/test/java/org/onap/pnfsimulator/simulator/client/HttpClientAdapterImplTest.java delete mode 100644 src/test/java/org/onap/pnfsimulator/simulator/client/HttpTestUtils.java delete mode 100644 src/test/java/org/onap/pnfsimulator/simulator/client/utils/ssl/CertAuthSslContextFactoryTest.java delete mode 100644 src/test/java/org/onap/pnfsimulator/simulator/client/utils/ssl/HttpClientFactoryFacadeTest.java delete mode 100644 src/test/java/org/onap/pnfsimulator/simulator/client/utils/ssl/HttpClientFactoryTest.java delete mode 100644 src/test/java/org/onap/pnfsimulator/simulator/client/utils/ssl/PasswordConverterTest.java delete mode 100644 src/test/java/org/onap/pnfsimulator/simulator/client/utils/ssl/SSLContextFactoryTest.java delete mode 100644 src/test/java/org/onap/pnfsimulator/simulator/keywords/TwoParameterKeywordTest.java delete mode 100644 src/test/java/org/onap/pnfsimulator/simulator/scheduler/EventJobTest.java delete mode 100644 src/test/java/org/onap/pnfsimulator/simulator/scheduler/EventSchedulerTest.java delete mode 100644 src/test/java/org/onap/pnfsimulator/simulatorconfig/SimulatorConfigServiceTest.java delete mode 100644 src/test/java/org/onap/pnfsimulator/template/FsToDbTemplateSynchronizerTest.java delete mode 100644 src/test/java/org/onap/pnfsimulator/template/TemplateServiceTest.java delete mode 100644 src/test/java/org/onap/pnfsimulator/template/search/JsonUtilsTest.java delete mode 100644 src/test/java/org/onap/pnfsimulator/template/search/TemplateSearchHelperTest.java delete mode 100644 src/test/java/org/onap/pnfsimulator/template/search/handler/PrimitiveValueCriteriaBuilderTest.java create mode 100644 src/test/resources/org/onap/integration/simulators/nfsimulator/vesclient/simulator/filesystem/test1.json create mode 100644 src/test/resources/org/onap/integration/simulators/nfsimulator/vesclient/simulator/invalidJsonStructureEvent.json create mode 100644 src/test/resources/org/onap/integration/simulators/nfsimulator/vesclient/simulator/validExampleMeasurementEvent.json delete mode 100644 src/test/resources/org/onap/pnfsimulator/simulator/filesystem/test1.json delete mode 100644 src/test/resources/org/onap/pnfsimulator/simulator/invalidJsonStructureEvent.json delete mode 100644 src/test/resources/org/onap/pnfsimulator/simulator/validExampleMeasurementEvent.json (limited to 'src') diff --git a/src/main/java/org/onap/integration/simulators/nfsimulator/vesclient/Main.java b/src/main/java/org/onap/integration/simulators/nfsimulator/vesclient/Main.java new file mode 100644 index 0000000..17ff65b --- /dev/null +++ b/src/main/java/org/onap/integration/simulators/nfsimulator/vesclient/Main.java @@ -0,0 +1,59 @@ +/* + * ============LICENSE_START======================================================= + * PNF-REGISTRATION-HANDLER + * ================================================================================ + * Copyright (C) 2018 Nokia. All rights reserved. + * ================================================================================ + * Licensed under the Apache License, Version 2.0 (the "License"); + * you may not use this file except in compliance with the License. + * You may obtain a copy of the License at + * + * http://www.apache.org/licenses/LICENSE-2.0 + * + * Unless required by applicable law or agreed to in writing, software + * distributed under the License is distributed on an "AS IS" BASIS, + * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. + * See the License for the specific language governing permissions and + * limitations under the License. + * ============LICENSE_END========================================================= + */ + +package org.onap.integration.simulators.nfsimulator.vesclient; + +import javax.annotation.PostConstruct; + +import org.onap.integration.simulators.nfsimulator.vesclient.template.FsToDbTemplateSynchronizer; +import org.onap.integration.simulators.nfsimulator.vesclient.filesystem.WatcherService; +import org.springframework.beans.factory.annotation.Autowired; +import org.springframework.boot.SpringApplication; +import org.springframework.boot.autoconfigure.SpringBootApplication; +import org.springframework.scheduling.annotation.EnableAsync; + +@SpringBootApplication +@EnableAsync +public class Main { + + private final WatcherService watcherService; + private final FsToDbTemplateSynchronizer fsToDbTemplateSynchronizer; + + @Autowired + public Main(WatcherService watcherService, + FsToDbTemplateSynchronizer fsToDbTemplateSynchronizer) { + this.watcherService = watcherService; + this.fsToDbTemplateSynchronizer = fsToDbTemplateSynchronizer; + } + + // We are excluding this line in Sonar due to fact that + // Spring is handling arguments + public static void main(String[] args) { // NOSONAR + SpringApplication.run(Main.class, args); + } + + @PostConstruct + public void createWatchers() { + fsToDbTemplateSynchronizer.synchronize(); + watcherService.createWatcher(); + } +} + + diff --git a/src/main/java/org/onap/integration/simulators/nfsimulator/vesclient/SwaggerConfig.java b/src/main/java/org/onap/integration/simulators/nfsimulator/vesclient/SwaggerConfig.java new file mode 100644 index 0000000..c709729 --- /dev/null +++ b/src/main/java/org/onap/integration/simulators/nfsimulator/vesclient/SwaggerConfig.java @@ -0,0 +1,46 @@ +/* + * ============LICENSE_START======================================================= + * PNF-REGISTRATION-HANDLER + * ================================================================================ + * Copyright (C) 2018 Nokia. All rights reserved. + * ================================================================================ + * Licensed under the Apache License, Version 2.0 (the "License"); + * you may not use this file except in compliance with the License. + * You may obtain a copy of the License at + * + * http://www.apache.org/licenses/LICENSE-2.0 + * + * Unless required by applicable law or agreed to in writing, software + * distributed under the License is distributed on an "AS IS" BASIS, + * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. + * See the License for the specific language governing permissions and + * limitations under the License. + * ============LICENSE_END========================================================= + */ + +package org.onap.integration.simulators.nfsimulator.vesclient; + +import org.onap.integration.simulators.nfsimulator.vesclient.simulator.client.utils.ssl.SslAuthenticationHelper; +import org.springframework.boot.context.properties.EnableConfigurationProperties; +import org.springframework.context.annotation.Bean; +import org.springframework.context.annotation.Configuration; +import springfox.documentation.builders.PathSelectors; +import springfox.documentation.builders.RequestHandlerSelectors; +import springfox.documentation.spi.DocumentationType; +import springfox.documentation.spring.web.plugins.Docket; +import springfox.documentation.swagger2.annotations.EnableSwagger2; + +@Configuration +@EnableConfigurationProperties(SslAuthenticationHelper.class) +@EnableSwagger2 +public class SwaggerConfig { + + @Bean + public Docket api() { + return new Docket(DocumentationType.SWAGGER_2) + .select() + .apis(RequestHandlerSelectors.basePackage("org.onap.pnfsimulator")) + .paths(PathSelectors.any()) + .build(); + } +} diff --git a/src/main/java/org/onap/integration/simulators/nfsimulator/vesclient/db/Row.java b/src/main/java/org/onap/integration/simulators/nfsimulator/vesclient/db/Row.java new file mode 100644 index 0000000..cd9edff --- /dev/null +++ b/src/main/java/org/onap/integration/simulators/nfsimulator/vesclient/db/Row.java @@ -0,0 +1,39 @@ +/*- + * ============LICENSE_START======================================================= + * Simulator + * ================================================================================ + * Copyright (C) 2019 Nokia. All rights reserved. + * ================================================================================ + * Licensed under the Apache License, Version 2.0 (the "License"); + * you may not use this file except in compliance with the License. + * You may obtain a copy of the License at + * + * http://www.apache.org/licenses/LICENSE-2.0 + * + * Unless required by applicable law or agreed to in writing, software + * distributed under the License is distributed on an "AS IS" BASIS, + * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. + * See the License for the specific language governing permissions and + * limitations under the License. + * ============LICENSE_END========================================================= + */ + +package org.onap.integration.simulators.nfsimulator.vesclient.db; + +import lombok.Getter; +import lombok.Setter; +import org.springframework.data.annotation.Id; +import org.springframework.data.mongodb.core.mapping.Field; + +public abstract class Row { + @Id + @Field("_id") + @Getter + @Setter + private String id; + + + public String getId() { + return id; + } +} diff --git a/src/main/java/org/onap/integration/simulators/nfsimulator/vesclient/db/Storage.java b/src/main/java/org/onap/integration/simulators/nfsimulator/vesclient/db/Storage.java new file mode 100644 index 0000000..7e9a378 --- /dev/null +++ b/src/main/java/org/onap/integration/simulators/nfsimulator/vesclient/db/Storage.java @@ -0,0 +1,41 @@ +/*- + * ============LICENSE_START======================================================= + * Simulator + * ================================================================================ + * Copyright (C) 2019 Nokia. All rights reserved. + * ================================================================================ + * Licensed under the Apache License, Version 2.0 (the "License"); + * you may not use this file except in compliance with the License. + * You may obtain a copy of the License at + * + * http://www.apache.org/licenses/LICENSE-2.0 + * + * Unless required by applicable law or agreed to in writing, software + * distributed under the License is distributed on an "AS IS" BASIS, + * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. + * See the License for the specific language governing permissions and + * limitations under the License. + * ============LICENSE_END========================================================= + */ + +package org.onap.integration.simulators.nfsimulator.vesclient.db; + +import com.google.gson.JsonObject; + +import java.util.List; +import java.util.Optional; + +public interface Storage { + + List getAll(); + + Optional get(String rowId); + + void persist(T row); + + boolean tryPersistOrOverwrite(T row, boolean overwrite); + + void delete(String rowId); + + List getIdsByContentCriteria(JsonObject queryJson); +} diff --git a/src/main/java/org/onap/integration/simulators/nfsimulator/vesclient/event/EventData.java b/src/main/java/org/onap/integration/simulators/nfsimulator/vesclient/event/EventData.java new file mode 100644 index 0000000..7ebdfba --- /dev/null +++ b/src/main/java/org/onap/integration/simulators/nfsimulator/vesclient/event/EventData.java @@ -0,0 +1,67 @@ +/* + * ============LICENSE_START======================================================= + * PNF-REGISTRATION-HANDLER + * ================================================================================ + * Copyright (C) 2018 Nokia. All rights reserved. + * ================================================================================ + * Licensed under the Apache License, Version 2.0 (the "License"); + * you may not use this file except in compliance with the License. + * You may obtain a copy of the License at + * + * http://www.apache.org/licenses/LICENSE-2.0 + * + * Unless required by applicable law or agreed to in writing, software + * distributed under the License is distributed on an "AS IS" BASIS, + * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. + * See the License for the specific language governing permissions and + * limitations under the License. + * ============LICENSE_END========================================================= + */ + +package org.onap.integration.simulators.nfsimulator.vesclient.event; + +import com.fasterxml.jackson.annotation.JsonInclude; +import lombok.Builder; +import lombok.Getter; +import lombok.Setter; +import lombok.ToString; +import org.springframework.data.annotation.Id; +import org.springframework.data.mongodb.core.mapping.Field; + +@Builder +@Getter +@Setter +@ToString(exclude = "incrementValue") +public class EventData { + @Id + private String id; + + @Field("template") + @JsonInclude + private String template; + + @Field("patched") + @JsonInclude + private String patched; + + @Field("input") + @JsonInclude + private String input; + + @Field("keywords") + @JsonInclude + private String keywords; + + @Field("incrementValue") + @JsonInclude + private int incrementValue; + + protected EventData(String id, String template, String patched, String input, String keywords, int incrementValue) { + this.id = id; + this.template = template; + this.patched = patched; + this.input = input; + this.keywords = keywords; + this.incrementValue = incrementValue; + } +} diff --git a/src/main/java/org/onap/integration/simulators/nfsimulator/vesclient/event/EventDataRepository.java b/src/main/java/org/onap/integration/simulators/nfsimulator/vesclient/event/EventDataRepository.java new file mode 100644 index 0000000..67f4e2f --- /dev/null +++ b/src/main/java/org/onap/integration/simulators/nfsimulator/vesclient/event/EventDataRepository.java @@ -0,0 +1,26 @@ +/* + * ============LICENSE_START======================================================= + * PNF-REGISTRATION-HANDLER + * ================================================================================ + * Copyright (C) 2018 Nokia. All rights reserved. + * ================================================================================ + * Licensed under the Apache License, Version 2.0 (the "License"); + * you may not use this file except in compliance with the License. + * You may obtain a copy of the License at + * + * http://www.apache.org/licenses/LICENSE-2.0 + * + * Unless required by applicable law or agreed to in writing, software + * distributed under the License is distributed on an "AS IS" BASIS, + * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. + * See the License for the specific language governing permissions and + * limitations under the License. + * ============LICENSE_END========================================================= + */ + +package org.onap.integration.simulators.nfsimulator.vesclient.event; + +import org.springframework.data.mongodb.repository.MongoRepository; + +public interface EventDataRepository extends MongoRepository { +} diff --git a/src/main/java/org/onap/integration/simulators/nfsimulator/vesclient/event/EventDataService.java b/src/main/java/org/onap/integration/simulators/nfsimulator/vesclient/event/EventDataService.java new file mode 100644 index 0000000..638afee --- /dev/null +++ b/src/main/java/org/onap/integration/simulators/nfsimulator/vesclient/event/EventDataService.java @@ -0,0 +1,65 @@ +/* + * ============LICENSE_START======================================================= + * PNF-REGISTRATION-HANDLER + * ================================================================================ + * Copyright (C) 2018 Nokia. All rights reserved. + * ================================================================================ + * Licensed under the Apache License, Version 2.0 (the "License"); + * you may not use this file except in compliance with the License. + * You may obtain a copy of the License at + * + * http://www.apache.org/licenses/LICENSE-2.0 + * + * Unless required by applicable law or agreed to in writing, software + * distributed under the License is distributed on an "AS IS" BASIS, + * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. + * See the License for the specific language governing permissions and + * limitations under the License. + * ============LICENSE_END========================================================= + */ + +package org.onap.integration.simulators.nfsimulator.vesclient.event; + +import com.google.gson.JsonObject; + +import java.util.List; +import java.util.Optional; + +import org.springframework.beans.factory.annotation.Autowired; +import org.springframework.stereotype.Service; + +@Service +public class EventDataService { + private final EventDataRepository repository; + + @Autowired + public EventDataService(EventDataRepository repository) { + this.repository = repository; + } + + private EventData persistEventData(String templateString, String patchedString, String inputString, String keywordsString) { + EventData eventData = EventData.builder() + .template(templateString) + .patched(patchedString) + .input(inputString) + .keywords(keywordsString) + .build(); + return repository.save(eventData); + } + + public EventData persistEventData(JsonObject templateJson, JsonObject patchedJson, JsonObject inputJson, + JsonObject keywordsJson) { + return persistEventData(templateJson.toString(), + patchedJson.toString(), + inputJson.toString(), + keywordsJson.toString()); + } + + public List getAllEvents() { + return repository.findAll(); + } + + public Optional getById(String id) { + return repository.findById(id); + } +} diff --git a/src/main/java/org/onap/integration/simulators/nfsimulator/vesclient/filesystem/WatcherConfig.java b/src/main/java/org/onap/integration/simulators/nfsimulator/vesclient/filesystem/WatcherConfig.java new file mode 100644 index 0000000..3d99a03 --- /dev/null +++ b/src/main/java/org/onap/integration/simulators/nfsimulator/vesclient/filesystem/WatcherConfig.java @@ -0,0 +1,39 @@ +/*- + * ============LICENSE_START======================================================= + * Simulator + * ================================================================================ + * Copyright (C) 2019 Nokia. All rights reserved. + * ================================================================================ + * Licensed under the Apache License, Version 2.0 (the "License"); + * you may not use this file except in compliance with the License. + * You may obtain a copy of the License at + * + * http://www.apache.org/licenses/LICENSE-2.0 + * + * Unless required by applicable law or agreed to in writing, software + * distributed under the License is distributed on an "AS IS" BASIS, + * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. + * See the License for the specific language governing permissions and + * limitations under the License. + * ============LICENSE_END========================================================= + */ + +package org.onap.integration.simulators.nfsimulator.vesclient.filesystem; + +import org.springframework.context.annotation.Bean; +import org.springframework.context.annotation.Configuration; +import org.springframework.core.task.TaskExecutor; +import org.springframework.scheduling.concurrent.ThreadPoolTaskExecutor; + +@Configuration +public class WatcherConfig { + + @Bean + public TaskExecutor watcherTaskExecutor() { + ThreadPoolTaskExecutor executor = new ThreadPoolTaskExecutor(); + executor.setThreadNamePrefix("pnfsimulator_fs_watcher"); + executor.initialize(); + return executor; + } + +} diff --git a/src/main/java/org/onap/integration/simulators/nfsimulator/vesclient/filesystem/WatcherEventProcessor.java b/src/main/java/org/onap/integration/simulators/nfsimulator/vesclient/filesystem/WatcherEventProcessor.java new file mode 100644 index 0000000..15c5d7b --- /dev/null +++ b/src/main/java/org/onap/integration/simulators/nfsimulator/vesclient/filesystem/WatcherEventProcessor.java @@ -0,0 +1,111 @@ +/*- + * ============LICENSE_START======================================================= + * Simulator + * ================================================================================ + * Copyright (C) 2019 Nokia. All rights reserved. + * ================================================================================ + * Licensed under the Apache License, Version 2.0 (the "License"); + * you may not use this file except in compliance with the License. + * You may obtain a copy of the License at + * + * http://www.apache.org/licenses/LICENSE-2.0 + * + * Unless required by applicable law or agreed to in writing, software + * distributed under the License is distributed on an "AS IS" BASIS, + * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. + * See the License for the specific language governing permissions and + * limitations under the License. + * ============LICENSE_END========================================================= + */ + +package org.onap.integration.simulators.nfsimulator.vesclient.filesystem; + +import java.io.IOException; +import java.nio.charset.StandardCharsets; +import java.nio.file.Files; +import java.nio.file.Path; +import java.nio.file.StandardWatchEventKinds; +import java.nio.file.WatchEvent; +import java.nio.file.WatchEvent.Kind; +import java.time.Instant; +import java.util.Arrays; +import java.util.Optional; +import java.util.stream.Collectors; +import java.util.stream.Stream; + +import lombok.extern.slf4j.Slf4j; +import org.bson.BSONException; +import org.bson.json.JsonParseException; +import org.onap.integration.simulators.nfsimulator.vesclient.db.Storage; +import org.onap.integration.simulators.nfsimulator.vesclient.template.Template; +import org.bson.Document; + +@Slf4j +public enum WatcherEventProcessor { + CREATED(StandardWatchEventKinds.ENTRY_CREATE) { + @Override + public void processEvent(Path path, Storage