add check for tls files when enableTLS (#167)

daleiz · web-flow · commit 8c3c5ef1a75a · 2023-01-17T14:29:39.000+08:00
diff --git a/client/src/main/java/io/hstream/impl/HStreamClientBuilderImpl.java b/client/src/main/java/io/hstream/impl/HStreamClientBuilderImpl.java
@@ -77,10 +77,13 @@ public HStreamClient build() {
       throw new HStreamDBClientException("hstreams url schema should enable tls");
     }
     if (enableTls) {
+      checkNotNull(caPath);
       try {
         TlsChannelCredentials.Builder credentialsBuilder =
             TlsChannelCredentials.newBuilder().trustManager(new File(caPath));
         if (enableTlsAuthentication) {
+          checkNotNull(certPath);
+          checkNotNull(keyPath);
           credentialsBuilder = credentialsBuilder.keyManager(new File(certPath), new File(keyPath));
         }
         return new HStreamClientKtImpl(

Original file line number	Diff line number	Diff line change
`@@ -77,10 +77,13 @@ public HStreamClient build() {`
`77`	`77`	`throw new HStreamDBClientException("hstreams url schema should enable tls");`
`78`	`78`	`}`
`79`	`79`	`if (enableTls) {`
	`80`	`+ checkNotNull(caPath);`
`80`	`81`	`try {`
`81`	`82`	`TlsChannelCredentials.Builder credentialsBuilder =`
`82`	`83`	`TlsChannelCredentials.newBuilder().trustManager(new File(caPath));`
`83`	`84`	`if (enableTlsAuthentication) {`
	`85`	`+ checkNotNull(certPath);`
	`86`	`+ checkNotNull(keyPath);`
`84`	`87`	`credentialsBuilder = credentialsBuilder.keyManager(new File(certPath), new File(keyPath));`
`85`	`88`	`}`
`86`	`89`	`return new HStreamClientKtImpl(`