Code Review / nonrtric / plt / ranpm.git / commit
? search:
summary | shortlog | log | commit | commitdiff | review | tree
(parent: 54c8fec) | patch
Added support for using oauth token for Kafka 62/10762/1
authorPatrikBuhr <patrik.buhr@est.tech>
Thu, 23 Mar 2023 14:04:00 +0000 (15:04 +0100)
committerPatrikBuhr <patrik.buhr@est.tech>
Thu, 23 Mar 2023 14:06:56 +0000 (15:06 +0100)
commitf0af18429aec79a590835103fedd753ee5ea93a9
tree53be9aa7f7b051c2790290b136a065fca82217f5tree | snapshot
parent54c8fecebbb5e19010e56eddf3aba8e127e0abc3commit | 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
51 files changed:
datafilecollector/config/application.yaml diff | blob | history
datafilecollector/pom.xml diff | blob | history
datafilecollector/src/main/java/org/oran/datafile/MainApp.java [moved from datafilecollector/src/main/java/org/onap/dcaegen2/collectors/datafile/MainApp.java with 85% similarity] diff | blob | history
datafilecollector/src/main/java/org/oran/datafile/commons/FileCollectClient.java [moved from datafilecollector/src/main/java/org/onap/dcaegen2/collectors/datafile/commons/FileCollectClient.java with 80% similarity] diff | blob | history
datafilecollector/src/main/java/org/oran/datafile/commons/FileServerData.java [moved from datafilecollector/src/main/java/org/onap/dcaegen2/collectors/datafile/commons/FileServerData.java with 92% similarity] diff | blob | history
datafilecollector/src/main/java/org/oran/datafile/commons/Scheme.java [moved from datafilecollector/src/main/java/org/onap/dcaegen2/collectors/datafile/commons/Scheme.java with 89% similarity] diff | blob | history
datafilecollector/src/main/java/org/oran/datafile/commons/SecurityUtil.java [moved from datafilecollector/src/main/java/org/onap/dcaegen2/collectors/datafile/commons/SecurityUtil.java with 93% similarity] diff | blob | history
datafilecollector/src/main/java/org/oran/datafile/configuration/AppConfig.java [moved from datafilecollector/src/main/java/org/onap/dcaegen2/collectors/datafile/configuration/AppConfig.java with 56% similarity] diff | blob | history
datafilecollector/src/main/java/org/oran/datafile/configuration/CertificateConfig.java [moved from datafilecollector/src/main/java/org/onap/dcaegen2/collectors/datafile/configuration/CertificateConfig.java with 90% similarity] diff | blob | history
datafilecollector/src/main/java/org/oran/datafile/configuration/SftpConfig.java [moved from datafilecollector/src/main/java/org/onap/dcaegen2/collectors/datafile/configuration/SftpConfig.java with 94% similarity] diff | blob | history
datafilecollector/src/main/java/org/oran/datafile/configuration/SwaggerConfig.java [moved from datafilecollector/src/main/java/org/onap/dcaegen2/collectors/datafile/configuration/SwaggerConfig.java with 88% similarity] diff | blob | history
datafilecollector/src/main/java/org/oran/datafile/controllers/StatusController.java [moved from datafilecollector/src/main/java/org/onap/dcaegen2/collectors/datafile/controllers/StatusController.java with 94% similarity] diff | blob | history
datafilecollector/src/main/java/org/oran/datafile/datastore/DataStore.java [moved from datafilecollector/src/main/java/org/onap/dcaegen2/collectors/datafile/datastore/DataStore.java with 92% similarity] diff | blob | history
datafilecollector/src/main/java/org/oran/datafile/datastore/FileStore.java [moved from datafilecollector/src/main/java/org/onap/dcaegen2/collectors/datafile/datastore/FileStore.java with 88% similarity] diff | blob | history
datafilecollector/src/main/java/org/oran/datafile/datastore/S3ObjectStore.java [moved from datafilecollector/src/main/java/org/onap/dcaegen2/collectors/datafile/datastore/S3ObjectStore.java with 98% similarity] diff | blob | history
datafilecollector/src/main/java/org/oran/datafile/exceptions/DatafileTaskException.java [moved from datafilecollector/src/main/java/org/onap/dcaegen2/collectors/datafile/exceptions/DatafileTaskException.java with 90% similarity] diff | blob | history
datafilecollector/src/main/java/org/oran/datafile/exceptions/EnvironmentLoaderException.java [moved from datafilecollector/src/main/java/org/onap/dcaegen2/collectors/datafile/exceptions/EnvironmentLoaderException.java with 88% similarity] diff | blob | history
datafilecollector/src/main/java/org/oran/datafile/exceptions/NonRetryableDatafileTaskException.java [moved from datafilecollector/src/main/java/org/onap/dcaegen2/collectors/datafile/exceptions/NonRetryableDatafileTaskException.java with 91% similarity] diff | blob | history
datafilecollector/src/main/java/org/oran/datafile/ftp/FtpesClient.java [moved from datafilecollector/src/main/java/org/onap/dcaegen2/collectors/datafile/ftp/FtpesClient.java with 94% similarity] diff | blob | history
datafilecollector/src/main/java/org/oran/datafile/ftp/SftpClient.java [moved from datafilecollector/src/main/java/org/onap/dcaegen2/collectors/datafile/ftp/SftpClient.java with 91% similarity] diff | blob | history
datafilecollector/src/main/java/org/oran/datafile/ftp/SftpClientSettings.java [moved from datafilecollector/src/main/java/org/onap/dcaegen2/collectors/datafile/ftp/SftpClientSettings.java with 95% similarity] diff | blob | history
datafilecollector/src/main/java/org/oran/datafile/http/DfcHttpClient.java [moved from datafilecollector/src/main/java/org/onap/dcaegen2/collectors/datafile/http/DfcHttpClient.java with 93% similarity] diff | blob | history
datafilecollector/src/main/java/org/oran/datafile/http/DfcHttpsClient.java [moved from datafilecollector/src/main/java/org/onap/dcaegen2/collectors/datafile/http/DfcHttpsClient.java with 93% similarity] diff | blob | history
datafilecollector/src/main/java/org/oran/datafile/http/HttpAsyncClientBuilderWrapper.java [moved from datafilecollector/src/main/java/org/onap/dcaegen2/collectors/datafile/http/HttpAsyncClientBuilderWrapper.java with 95% similarity] diff | blob | history
datafilecollector/src/main/java/org/oran/datafile/http/HttpsClientConnectionManagerUtil.java [moved from datafilecollector/src/main/java/org/onap/dcaegen2/collectors/datafile/http/HttpsClientConnectionManagerUtil.java with 95% similarity] diff | blob | history
datafilecollector/src/main/java/org/oran/datafile/model/Counters.java [moved from datafilecollector/src/main/java/org/onap/dcaegen2/collectors/datafile/model/Counters.java with 97% similarity] diff | blob | history
datafilecollector/src/main/java/org/oran/datafile/model/FileData.java [moved from datafilecollector/src/main/java/org/onap/dcaegen2/collectors/datafile/model/FileData.java with 91% similarity] diff | blob | history
datafilecollector/src/main/java/org/oran/datafile/model/FilePublishInformation.java [moved from datafilecollector/src/main/java/org/onap/dcaegen2/collectors/datafile/model/FilePublishInformation.java with 92% similarity] diff | blob | history
datafilecollector/src/main/java/org/oran/datafile/model/FileReadyMessage.java [moved from datafilecollector/src/main/java/org/onap/dcaegen2/collectors/datafile/model/FileReadyMessage.java with 96% similarity] diff | blob | history
datafilecollector/src/main/java/org/oran/datafile/oauth2/OAuthBearerTokenJwt.java [new file with mode: 0644] blob
datafilecollector/src/main/java/org/oran/datafile/oauth2/OAuthKafkaAuthenticateLoginCallbackHandler.java [new file with mode: 0644] blob
datafilecollector/src/main/java/org/oran/datafile/oauth2/SecurityContext.java [new file with mode: 0644] blob
datafilecollector/src/main/java/org/oran/datafile/service/HttpUtils.java [moved from datafilecollector/src/main/java/org/onap/dcaegen2/collectors/datafile/service/HttpUtils.java with 97% similarity] diff | blob | history
datafilecollector/src/main/java/org/oran/datafile/tasks/CollectAndReportFiles.java [moved from datafilecollector/src/main/java/org/onap/dcaegen2/collectors/datafile/tasks/CollectAndReportFiles.java with 90% similarity] diff | blob | history
datafilecollector/src/main/java/org/oran/datafile/tasks/FileCollector.java [moved from datafilecollector/src/main/java/org/onap/dcaegen2/collectors/datafile/tasks/FileCollector.java with 84% similarity] diff | blob | history
datafilecollector/src/main/java/org/oran/datafile/tasks/KafkaTopicListener.java [moved from datafilecollector/src/main/java/org/onap/dcaegen2/collectors/datafile/tasks/KafkaTopicListener.java with 80% similarity] diff | blob | history
datafilecollector/src/test/java/org/oran/datafile/MockDatafile.java [moved from datafilecollector/src/test/java/org/onap/dcaegen2/collectors/datafile/MockDatafile.java with 86% similarity] diff | blob | history
datafilecollector/src/test/java/org/oran/datafile/controllers/StatusControllerTest.java [moved from datafilecollector/src/test/java/org/onap/dcaegen2/collectors/datafile/controllers/StatusControllerTest.java with 90% similarity] diff | blob | history
datafilecollector/src/test/java/org/oran/datafile/ftp/FtpesClientTest.java [moved from datafilecollector/src/test/java/org/onap/dcaegen2/collectors/datafile/ftp/FtpesClientTest.java with 98% similarity] diff | blob | history
datafilecollector/src/test/java/org/oran/datafile/ftp/SftpClientSettingsTest.java [moved from datafilecollector/src/test/java/org/onap/dcaegen2/collectors/datafile/ftp/SftpClientSettingsTest.java with 93% similarity] diff | blob | history
datafilecollector/src/test/java/org/oran/datafile/ftp/SftpClientTest.java [moved from datafilecollector/src/test/java/org/onap/dcaegen2/collectors/datafile/ftp/SftpClientTest.java with 96% similarity] diff | blob | history
datafilecollector/src/test/java/org/oran/datafile/http/DfcHttpClientTest.java [moved from datafilecollector/src/test/java/org/onap/dcaegen2/collectors/datafile/http/DfcHttpClientTest.java with 96% similarity] diff | blob | history
datafilecollector/src/test/java/org/oran/datafile/http/DfcHttpsClientTest.java [moved from datafilecollector/src/test/java/org/onap/dcaegen2/collectors/datafile/http/DfcHttpsClientTest.java with 96% similarity] diff | blob | history
datafilecollector/src/test/java/org/oran/datafile/http/HttpClientResponseHelper.java [moved from datafilecollector/src/test/java/org/onap/dcaegen2/collectors/datafile/http/HttpClientResponseHelper.java with 99% similarity] diff | blob | history
datafilecollector/src/test/java/org/oran/datafile/http/HttpsClientConnectionManagerUtilTest.java [moved from datafilecollector/src/test/java/org/onap/dcaegen2/collectors/datafile/http/HttpsClientConnectionManagerUtilTest.java with 94% similarity] diff | blob | history
datafilecollector/src/test/java/org/oran/datafile/scheme/SchemeTest.java [moved from datafilecollector/src/test/java/org/onap/dcaegen2/collectors/datafile/scheme/SchemeTest.java with 87% similarity] diff | blob | history
datafilecollector/src/test/java/org/oran/datafile/service/HttpUtilsTest.java [moved from datafilecollector/src/test/java/org/onap/dcaegen2/collectors/datafile/service/HttpUtilsTest.java with 97% similarity] diff | blob | history
datafilecollector/src/test/java/org/oran/datafile/tasks/FileCollectorTest.java [moved from datafilecollector/src/test/java/org/onap/dcaegen2/collectors/datafile/tasks/FileCollectorTest.java with 94% similarity] diff | blob | history
datafilecollector/src/test/java/org/oran/datafile/utils/JsonMessage.java [moved from datafilecollector/src/test/java/org/onap/dcaegen2/collectors/datafile/utils/JsonMessage.java with 97% similarity] diff | blob | history
datafilecollector/src/test/java/org/oran/datafile/utils/LoggingUtils.java [moved from datafilecollector/src/test/java/org/onap/dcaegen2/collectors/datafile/utils/LoggingUtils.java with 90% similarity] diff | blob | history
datafilecollector/src/test/resources/jwtToken.b64 [new file with mode: 0644] blob
"nonrtric_plt_ranpm"