refactoring for codestyle

Signed-off-by: salaboy <[email protected]>
dapr · Dec 12, 2023 · 9c534bb · 9c534bb
1 parent f7727db
commit 9c534bb
Show file tree

Hide file tree

Showing 3 changed files with 33 additions and 20 deletions.
diff --git a/sdk-workflows/src/main/java/io/dapr/workflows/client/DaprWorkflowClient.java b/sdk-workflows/src/main/java/io/dapr/workflows/client/DaprWorkflowClient.java
@@ -21,7 +21,7 @@
 import io.dapr.config.Properties;
 import io.dapr.utils.NetworkUtils;
 import io.dapr.workflows.Workflow;
-import io.dapr.workflows.internal.APITokenClientInterceptor;
+import io.dapr.workflows.internal.ApiTokenClientInterceptor;
 import io.grpc.CallOptions;
 import io.grpc.Channel;
 import io.grpc.ClientCall;
@@ -263,6 +263,6 @@ public void close() throws InterruptedException {
     }
   }
 
-  private static ClientInterceptor WORKFLOW_INTERCEPTOR = new APITokenClientInterceptor();
+  private static ClientInterceptor WORKFLOW_INTERCEPTOR = new ApiTokenClientInterceptor();
 }
 
diff --git a/sdk-workflows/src/main/java/io/dapr/workflows/internal/APITokenClientInterceptor.java b/sdk-workflows/src/main/java/io/dapr/workflows/internal/APITokenClientInterceptor.java
@@ -1,3 +1,16 @@
+/*
+ * Copyright 2023 The Dapr Authors
+ * 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.
+*/
+
 package io.dapr.workflows.internal;
 
 import io.dapr.client.Headers;
@@ -10,23 +23,23 @@
 import io.grpc.Metadata;
 import io.grpc.MethodDescriptor;
 
-public class APITokenClientInterceptor implements ClientInterceptor {
-    @Override
-    public <ReqT, RespT> ClientCall<ReqT, RespT> interceptCall(
-        MethodDescriptor<ReqT, RespT> methodDescriptor,
-        CallOptions options,
-        Channel channel) {
-      // TBD: do we need timeout in workflow client?
-      ClientCall<ReqT, RespT> clientCall = channel.newCall(methodDescriptor, options);
-      return new ForwardingClientCall.SimpleForwardingClientCall<ReqT, RespT>(clientCall) {
+public class ApiTokenClientInterceptor implements ClientInterceptor {
+  @Override
+  public <ReqT, RespT> ClientCall<ReqT, RespT> interceptCall(
+            MethodDescriptor<ReqT, RespT> methodDescriptor,
+            CallOptions options,
+            Channel channel) {
+    // TBD: do we need timeout in workflow client?
+    ClientCall<ReqT, RespT> clientCall = channel.newCall(methodDescriptor, options);
+    return new ForwardingClientCall.SimpleForwardingClientCall<ReqT, RespT>(clientCall) {
         @Override
         public void start(final Listener<RespT> responseListener, final Metadata metadata) {
-          String daprApiToken = Properties.API_TOKEN.get();
-          if (daprApiToken != null) {
-            metadata.put(Metadata.Key.of(Headers.DAPR_API_TOKEN, Metadata.ASCII_STRING_MARSHALLER), daprApiToken);
-          }
-          super.start(responseListener, metadata);
+            String daprApiToken = Properties.API_TOKEN.get();
+            if (daprApiToken != null) {
+              metadata.put(Metadata.Key.of(Headers.DAPR_API_TOKEN, Metadata.ASCII_STRING_MARSHALLER), daprApiToken);
+            }
+            super.start(responseListener, metadata);
         }
-      };
-    }
+    };
+  }
 }
diff --git a/sdk-workflows/src/main/java/io/dapr/workflows/runtime/WorkflowRuntimeBuilder.java b/sdk-workflows/src/main/java/io/dapr/workflows/runtime/WorkflowRuntimeBuilder.java
@@ -16,13 +16,13 @@
 import com.microsoft.durabletask.DurableTaskGrpcWorkerBuilder;
 import io.dapr.utils.NetworkUtils;
 import io.dapr.workflows.Workflow;
-import io.dapr.workflows.internal.APITokenClientInterceptor;
+import io.dapr.workflows.internal.ApiTokenClientInterceptor;
 import io.grpc.ClientInterceptor;
 
 public class WorkflowRuntimeBuilder {
   private static volatile WorkflowRuntime instance;
   private DurableTaskGrpcWorkerBuilder builder;
-  private static ClientInterceptor WORKFLOW_INTERCEPTOR = new APITokenClientInterceptor();
+  private static ClientInterceptor WORKFLOW_INTERCEPTOR = new ApiTokenClientInterceptor();
 
   public WorkflowRuntimeBuilder() {
     this.builder = new DurableTaskGrpcWorkerBuilder().grpcChannel(