fix: bump proto remove unused function (#298)

bump proto remove unused function

Author: vahidlazio

openfeature-provider-local/src/main/java/com/spotify/confidence/WasmResolveApi.java

@@ -11,8 +11,7 @@
 import com.dylibso.chicory.wasm.types.FunctionType;
 import com.dylibso.chicory.wasm.types.ValType;
 import com.google.protobuf.ByteString;
-import com.google.protobuf.BytesValue;
-import com.google.protobuf.GeneratedMessageV3;
+import com.google.protobuf.GeneratedMessage;
 import com.google.protobuf.InvalidProtocolBufferException;
 import com.google.protobuf.Timestamp;
 import com.spotify.confidence.flags.resolver.v1.LogMessage;
@@ -25,14 +24,9 @@
 import com.spotify.confidence.wasm.Messages;
 import java.io.IOException;
 import java.io.InputStream;
-import java.security.SecureRandom;
 import java.time.Instant;
 import java.util.List;
 import java.util.function.Function;
-import javax.crypto.Cipher;
-import javax.crypto.spec.IvParameterSpec;
-import javax.crypto.spec.SecretKeySpec;
-import rust_guest.Types;
 
 @FunctionalInterface
 interface WasmFlagLogger {
@@ -82,11 +76,6 @@ public WasmResolveApi(WasmFlagLogger flagLogger, RetryStrategy retryStrategy) {
                               "wasm_msg_current_thread_id",
                               FunctionType.of(List.of(), List.of(ValType.I32)),
                               this::currentThreadId))
-                      .addFunction(
-                          createImportFunction(
-                              "encrypt_resolve_token",
-                              Types.EncryptionRequest::parseFrom,
-                              this::encryptResolveToken))
                       .build())
               .withMachineFactory(MachineFactoryCompiler::compile)
               .build();
@@ -101,38 +90,11 @@ public WasmResolveApi(WasmFlagLogger flagLogger, RetryStrategy retryStrategy) {
     }
   }
 
-  private GeneratedMessageV3 log(LogMessage message) {
+  private GeneratedMessage log(LogMessage message) {
     System.out.println(message.getMessage());
     return Messages.Void.getDefaultInstance();
   }
 
-  private GeneratedMessageV3 encryptResolveToken(Types.EncryptionRequest encryptionRequest) {
-    try {
-      final byte[] tokenData = encryptionRequest.getTokenData().toByteArray();
-      final byte[] encryptionKey = encryptionRequest.getEncryptionKey().toByteArray();
-      if (encryptionKey.length != 16) {
-        throw new IllegalArgumentException("Encryption key must be exactly 16 bytes for AES-128");
-      }
-      final byte[] iv = new byte[16];
-      new SecureRandom().nextBytes(iv);
-      final Cipher cipher = Cipher.getInstance("AES/CBC/PKCS5Padding");
-      final SecretKeySpec secretKey = new SecretKeySpec(encryptionKey, "AES");
-      final IvParameterSpec ivSpec = new IvParameterSpec(iv);
-
-      cipher.init(Cipher.ENCRYPT_MODE, secretKey, ivSpec);
-      final byte[] encryptedData = cipher.doFinal(tokenData);
-
-      final byte[] result = new byte[iv.length + encryptedData.length];
-      System.arraycopy(iv, 0, result, 0, iv.length);
-      System.arraycopy(encryptedData, 0, result, iv.length, encryptedData.length);
-
-      return BytesValue.newBuilder().setValue(ByteString.copyFrom(result)).build();
-
-    } catch (Exception e) {
-      throw new RuntimeException("Failed to encrypt resolve token", e);
-    }
-  }
-
   private long[] currentThreadId(Instance instance, long... longs) {
     return new long[] {0};
   }
@@ -185,7 +147,7 @@ public ResolveFlagsResponse resolve(ResolveFlagsRequest request) {
         "resolve");
   }
 
-  private <T extends GeneratedMessageV3> T consumeResponse(int addr, ParserFn<T> codec) {
+  private <T extends GeneratedMessage> T consumeResponse(int addr, ParserFn<T> codec) {
     try {
       final Messages.Response response = Messages.Response.parseFrom(consume(addr));
       if (response.hasError()) {
@@ -198,7 +160,7 @@ private <T extends GeneratedMessageV3> T consumeResponse(int addr, ParserFn<T> c
     }
   }
 
-  private <T extends GeneratedMessageV3> T consumeRequest(int addr, ParserFn<T> codec) {
+  private <T extends GeneratedMessage> T consumeRequest(int addr, ParserFn<T> codec) {
     try {
       final Messages.Request request = Messages.Request.parseFrom(consume(addr));
       return codec.apply(request.getData().toByteArray());
@@ -207,13 +169,13 @@ private <T extends GeneratedMessageV3> T consumeRequest(int addr, ParserFn<T> co
     }
   }
 
-  private int transferRequest(GeneratedMessageV3 message) {
+  private int transferRequest(GeneratedMessage message) {
     final byte[] request =
         Messages.Request.newBuilder().setData(message.toByteString()).build().toByteArray();
     return transfer(request);
   }
 
-  private int transferResponseSuccess(GeneratedMessageV3 response) {
+  private int transferResponseSuccess(GeneratedMessage response) {
     final byte[] wrapperBytes =
         Messages.Response.newBuilder().setData(response.toByteString()).build().toByteArray();
     return transfer(wrapperBytes);
@@ -240,16 +202,16 @@ private int transfer(byte[] data) {
     return addr;
   }
 
-  private <T extends GeneratedMessageV3> ImportFunction createImportFunction(
-      String name, ParserFn<T> reqCodec, Function<T, GeneratedMessageV3> impl) {
+  private <T extends GeneratedMessage> ImportFunction createImportFunction(
+      String name, ParserFn<T> reqCodec, Function<T, GeneratedMessage> impl) {
     return new ImportFunction(
         "wasm_msg",
         "wasm_msg_host_" + name,
         HOST_FN_TYPE,
         (instance1, args) -> {
           try {
             final T message = consumeRequest((int) args[0], reqCodec);
-            final GeneratedMessageV3 response = impl.apply(message);
+            final GeneratedMessage response = impl.apply(message);
             return new long[] {transferResponseSuccess(response)};
           } catch (Exception e) {
             return new long[] {transferResponseError(e.getMessage())};

pom.xml

@@ -37,7 +37,7 @@
     <maven.compiler.target>11</maven.compiler.target>
 
     <grpc.version>1.70.0</grpc.version>
-    <protobuf.version>3.25.5</protobuf.version>
+    <protobuf.version>4.32.1</protobuf.version>
     <common.protos.version>2.54.1</common.protos.version>
     <mockito.version>4.11.0</mockito.version>
     <jupiter.version>5.10.0</jupiter.version>