f0af18429aec79a590835103fedd753ee5ea93a9 - oransc/nonrtric/plt/ranpm

commit	f0af18429aec79a590835103fedd753ee5ea93a9	[log] [tgz]
author	PatrikBuhr <patrik.buhr@est.tech>	Thu Mar 23 15:04:00 2023 +0100
committer	PatrikBuhr <patrik.buhr@est.tech>	Thu Mar 23 15:06:56 2023 +0100
tree	53be9aa7f7b051c2790290b136a065fca82217f5
parent	54c8fecebbb5e19010e56eddf3aba8e127e0abc3 [diff]

Added support for using oauth token for Kafka

in datafile collector

OAUTHBEARER is supported as SASL mechanism.
This can be done over SSL or plain text.

Signed-off-by: PatrikBuhr <patrik.buhr@est.tech>
Issue-ID: NONRTRIC-853
Change-Id: I55760d72f2f8c498bd9d57dbb7a99756843f4606

datafilecollector/config/application.yaml[diff]
datafilecollector/pom.xml[diff]
datafilecollector/src/main/java/org/onap/dcaegen2/collectors/datafile/configuration/AppConfig.java[Deleted - diff]
datafilecollector/src/main/java/org/oran/datafile/MainApp.java[Renamed from datafilecollector/src/main/java/org/onap/dcaegen2/collectors/datafile/MainApp.java - diff]
datafilecollector/src/main/java/org/oran/datafile/commons/FileCollectClient.java[Renamed from datafilecollector/src/main/java/org/onap/dcaegen2/collectors/datafile/commons/FileCollectClient.java - diff]
datafilecollector/src/main/java/org/oran/datafile/commons/FileServerData.java[Renamed from datafilecollector/src/main/java/org/onap/dcaegen2/collectors/datafile/commons/FileServerData.java - diff]
datafilecollector/src/main/java/org/oran/datafile/commons/Scheme.java[Renamed from datafilecollector/src/main/java/org/onap/dcaegen2/collectors/datafile/commons/Scheme.java - diff]
datafilecollector/src/main/java/org/oran/datafile/commons/SecurityUtil.java[Renamed from datafilecollector/src/main/java/org/onap/dcaegen2/collectors/datafile/commons/SecurityUtil.java - diff]
datafilecollector/src/main/java/org/oran/datafile/configuration/AppConfig.java[Added - diff]
datafilecollector/src/main/java/org/oran/datafile/configuration/CertificateConfig.java[Renamed from datafilecollector/src/main/java/org/onap/dcaegen2/collectors/datafile/configuration/CertificateConfig.java - diff]
datafilecollector/src/main/java/org/oran/datafile/configuration/SftpConfig.java[Renamed from datafilecollector/src/main/java/org/onap/dcaegen2/collectors/datafile/configuration/SftpConfig.java - diff]
datafilecollector/src/main/java/org/oran/datafile/configuration/SwaggerConfig.java[Renamed from datafilecollector/src/main/java/org/onap/dcaegen2/collectors/datafile/configuration/SwaggerConfig.java - diff]
datafilecollector/src/main/java/org/oran/datafile/controllers/StatusController.java[Renamed from datafilecollector/src/main/java/org/onap/dcaegen2/collectors/datafile/controllers/StatusController.java - diff]
datafilecollector/src/main/java/org/oran/datafile/datastore/DataStore.java[Renamed from datafilecollector/src/main/java/org/onap/dcaegen2/collectors/datafile/datastore/DataStore.java - diff]
datafilecollector/src/main/java/org/oran/datafile/datastore/FileStore.java[Renamed from datafilecollector/src/main/java/org/onap/dcaegen2/collectors/datafile/datastore/FileStore.java - diff]
datafilecollector/src/main/java/org/oran/datafile/datastore/S3ObjectStore.java[Renamed from datafilecollector/src/main/java/org/onap/dcaegen2/collectors/datafile/datastore/S3ObjectStore.java - diff]
datafilecollector/src/main/java/org/oran/datafile/exceptions/DatafileTaskException.java[Renamed from datafilecollector/src/main/java/org/onap/dcaegen2/collectors/datafile/exceptions/DatafileTaskException.java - diff]
datafilecollector/src/main/java/org/oran/datafile/exceptions/EnvironmentLoaderException.java[Renamed from datafilecollector/src/main/java/org/onap/dcaegen2/collectors/datafile/exceptions/EnvironmentLoaderException.java - diff]
datafilecollector/src/main/java/org/oran/datafile/exceptions/NonRetryableDatafileTaskException.java[Renamed from datafilecollector/src/main/java/org/onap/dcaegen2/collectors/datafile/exceptions/NonRetryableDatafileTaskException.java - diff]
datafilecollector/src/main/java/org/oran/datafile/ftp/FtpesClient.java[Renamed from datafilecollector/src/main/java/org/onap/dcaegen2/collectors/datafile/ftp/FtpesClient.java - diff]
datafilecollector/src/main/java/org/oran/datafile/ftp/SftpClient.java[Renamed from datafilecollector/src/main/java/org/onap/dcaegen2/collectors/datafile/ftp/SftpClient.java - diff]
datafilecollector/src/main/java/org/oran/datafile/ftp/SftpClientSettings.java[Renamed from datafilecollector/src/main/java/org/onap/dcaegen2/collectors/datafile/ftp/SftpClientSettings.java - diff]
datafilecollector/src/main/java/org/oran/datafile/http/DfcHttpClient.java[Renamed from datafilecollector/src/main/java/org/onap/dcaegen2/collectors/datafile/http/DfcHttpClient.java - diff]
datafilecollector/src/main/java/org/oran/datafile/http/DfcHttpsClient.java[Renamed from datafilecollector/src/main/java/org/onap/dcaegen2/collectors/datafile/http/DfcHttpsClient.java - diff]
datafilecollector/src/main/java/org/oran/datafile/http/HttpAsyncClientBuilderWrapper.java[Renamed from datafilecollector/src/main/java/org/onap/dcaegen2/collectors/datafile/http/HttpAsyncClientBuilderWrapper.java - diff]
datafilecollector/src/main/java/org/oran/datafile/http/HttpsClientConnectionManagerUtil.java[Renamed from datafilecollector/src/main/java/org/onap/dcaegen2/collectors/datafile/http/HttpsClientConnectionManagerUtil.java - diff]
datafilecollector/src/main/java/org/oran/datafile/model/Counters.java[Renamed from datafilecollector/src/main/java/org/onap/dcaegen2/collectors/datafile/model/Counters.java - diff]
datafilecollector/src/main/java/org/oran/datafile/model/FileData.java[Renamed from datafilecollector/src/main/java/org/onap/dcaegen2/collectors/datafile/model/FileData.java - diff]
datafilecollector/src/main/java/org/oran/datafile/model/FilePublishInformation.java[Renamed from datafilecollector/src/main/java/org/onap/dcaegen2/collectors/datafile/model/FilePublishInformation.java - diff]
datafilecollector/src/main/java/org/oran/datafile/model/FileReadyMessage.java[Renamed from datafilecollector/src/main/java/org/onap/dcaegen2/collectors/datafile/model/FileReadyMessage.java - diff]
datafilecollector/src/main/java/org/oran/datafile/oauth2/OAuthBearerTokenJwt.java[Added - diff]
datafilecollector/src/main/java/org/oran/datafile/oauth2/OAuthKafkaAuthenticateLoginCallbackHandler.java[Added - diff]
datafilecollector/src/main/java/org/oran/datafile/oauth2/SecurityContext.java[Added - diff]
datafilecollector/src/main/java/org/oran/datafile/service/HttpUtils.java[Renamed from datafilecollector/src/main/java/org/onap/dcaegen2/collectors/datafile/service/HttpUtils.java - diff]
datafilecollector/src/main/java/org/oran/datafile/tasks/CollectAndReportFiles.java[Renamed from datafilecollector/src/main/java/org/onap/dcaegen2/collectors/datafile/tasks/CollectAndReportFiles.java - diff]
datafilecollector/src/main/java/org/oran/datafile/tasks/FileCollector.java[Renamed from datafilecollector/src/main/java/org/onap/dcaegen2/collectors/datafile/tasks/FileCollector.java - diff]
datafilecollector/src/main/java/org/oran/datafile/tasks/KafkaTopicListener.java[Renamed from datafilecollector/src/main/java/org/onap/dcaegen2/collectors/datafile/tasks/KafkaTopicListener.java - diff]
datafilecollector/src/test/java/org/oran/datafile/MockDatafile.java[Renamed from datafilecollector/src/test/java/org/onap/dcaegen2/collectors/datafile/MockDatafile.java - diff]
datafilecollector/src/test/java/org/oran/datafile/controllers/StatusControllerTest.java[Renamed from datafilecollector/src/test/java/org/onap/dcaegen2/collectors/datafile/controllers/StatusControllerTest.java - diff]
datafilecollector/src/test/java/org/oran/datafile/ftp/FtpesClientTest.java[Renamed from datafilecollector/src/test/java/org/onap/dcaegen2/collectors/datafile/ftp/FtpesClientTest.java - diff]
datafilecollector/src/test/java/org/oran/datafile/ftp/SftpClientSettingsTest.java[Renamed from datafilecollector/src/test/java/org/onap/dcaegen2/collectors/datafile/ftp/SftpClientSettingsTest.java - diff]
datafilecollector/src/test/java/org/oran/datafile/ftp/SftpClientTest.java[Renamed from datafilecollector/src/test/java/org/onap/dcaegen2/collectors/datafile/ftp/SftpClientTest.java - diff]
datafilecollector/src/test/java/org/oran/datafile/http/DfcHttpClientTest.java[Renamed from datafilecollector/src/test/java/org/onap/dcaegen2/collectors/datafile/http/DfcHttpClientTest.java - diff]
datafilecollector/src/test/java/org/oran/datafile/http/DfcHttpsClientTest.java[Renamed from datafilecollector/src/test/java/org/onap/dcaegen2/collectors/datafile/http/DfcHttpsClientTest.java - diff]
datafilecollector/src/test/java/org/oran/datafile/http/HttpClientResponseHelper.java[Renamed from datafilecollector/src/test/java/org/onap/dcaegen2/collectors/datafile/http/HttpClientResponseHelper.java - diff]
datafilecollector/src/test/java/org/oran/datafile/http/HttpsClientConnectionManagerUtilTest.java[Renamed from datafilecollector/src/test/java/org/onap/dcaegen2/collectors/datafile/http/HttpsClientConnectionManagerUtilTest.java - diff]
datafilecollector/src/test/java/org/oran/datafile/scheme/SchemeTest.java[Renamed from datafilecollector/src/test/java/org/onap/dcaegen2/collectors/datafile/scheme/SchemeTest.java - diff]
datafilecollector/src/test/java/org/oran/datafile/service/HttpUtilsTest.java[Renamed from datafilecollector/src/test/java/org/onap/dcaegen2/collectors/datafile/service/HttpUtilsTest.java - diff]
datafilecollector/src/test/java/org/oran/datafile/tasks/FileCollectorTest.java[Renamed from datafilecollector/src/test/java/org/onap/dcaegen2/collectors/datafile/tasks/FileCollectorTest.java - diff]
datafilecollector/src/test/java/org/oran/datafile/utils/JsonMessage.java[Renamed from datafilecollector/src/test/java/org/onap/dcaegen2/collectors/datafile/utils/JsonMessage.java - diff]
datafilecollector/src/test/java/org/oran/datafile/utils/LoggingUtils.java[Renamed from datafilecollector/src/test/java/org/onap/dcaegen2/collectors/datafile/utils/LoggingUtils.java - diff]
datafilecollector/src/test/resources/jwtToken.b64[Added - diff]

52 files changed

tree: 53be9aa7f7b051c2790290b136a065fca82217f5