Prevent excessive api calls

daemon/src/main/java/bisq/daemon/grpc/GrpcServer.java

@@ -31,6 +31,8 @@
 
 import lombok.extern.slf4j.Slf4j;
 
+import static io.grpc.ServerInterceptors.interceptForward;
+
 
 
 import bisq.daemon.grpc.interceptor.PasswordAuthInterceptor;
@@ -60,7 +62,7 @@ public GrpcServer(Config config,
                 .addService(priceService)
                 .addService(tradeStatisticsService)
                 .addService(tradesService)
-                .addService(versionService)
+                .addService(interceptForward(versionService, versionService.interceptors()))
                 .addService(walletsService)
                 .intercept(passwordAuthInterceptor)
                 .build();

daemon/src/main/java/bisq/daemon/grpc/GrpcVersionService.java

@@ -1,3 +1,20 @@
+/*
+ * This file is part of Bisq.
+ *
+ * Bisq is free software: you can redistribute it and/or modify it
+ * under the terms of the GNU Affero General Public License as published by
+ * the Free Software Foundation, either version 3 of the License, or (at
+ * your option) any later version.
+ *
+ * Bisq is distributed in the hope that it will be useful, but WITHOUT
+ * ANY WARRANTY; without even the implied warranty of MERCHANTABILITY or
+ * FITNESS FOR A PARTICULAR PURPOSE. See the GNU Affero General Public
+ * License for more details.
+ *
+ * You should have received a copy of the GNU Affero General Public License
+ * along with Bisq. If not, see <http://www.gnu.org/licenses/>.
+ */
+
 package bisq.daemon.grpc;
 
 import bisq.core.api.CoreApi;
@@ -6,11 +23,29 @@
 import bisq.proto.grpc.GetVersionReply;
 import bisq.proto.grpc.GetVersionRequest;
 
+import io.grpc.ServerInterceptor;
 import io.grpc.stub.StreamObserver;
 
 import javax.inject.Inject;
 
-class GrpcVersionService extends GetVersionGrpc.GetVersionImplBase {
+import com.google.common.annotations.VisibleForTesting;
+
+import java.util.HashMap;
+import java.util.Optional;
+
+import lombok.extern.slf4j.Slf4j;
+
+import static bisq.daemon.grpc.interceptor.GrpcServiceRateMeteringConfig.getCustomRateMeteringInterceptor;
+import static java.util.concurrent.TimeUnit.SECONDS;
+
+
+
+import bisq.daemon.grpc.interceptor.CallRateMeteringInterceptor;
+import bisq.daemon.grpc.interceptor.GrpcCallRateMeter;
+
+@VisibleForTesting
+@Slf4j
+public class GrpcVersionService extends GetVersionGrpc.GetVersionImplBase {
 
     private final CoreApi coreApi;
     private final GrpcExceptionHandler exceptionHandler;
@@ -31,4 +66,21 @@ public void getVersion(GetVersionRequest req, StreamObserver<GetVersionReply> re
             exceptionHandler.handleException(cause, responseObserver);
         }
     }
+
+    final ServerInterceptor[] interceptors() {
+        Optional<ServerInterceptor> rateMeteringInterceptor = rateMeteringInterceptor();
+        return rateMeteringInterceptor.map(serverInterceptor ->
+                new ServerInterceptor[]{serverInterceptor}).orElseGet(() -> new ServerInterceptor[0]);
+    }
+
+    final Optional<ServerInterceptor> rateMeteringInterceptor() {
+        @SuppressWarnings("unused")  // Defined as a usage example.
+        CallRateMeteringInterceptor defaultCallRateMeteringInterceptor =
+                new CallRateMeteringInterceptor(new HashMap<>() {{
+                    put("getVersion", new GrpcCallRateMeter(100, SECONDS));
+                }});
+
+        return getCustomRateMeteringInterceptor(coreApi.getConfig().appDataDir, this.getClass())
+                .or(Optional::empty /* Optional.of(defaultCallRateMeteringInterceptor) */);
+    }
 }