Add NONEwithRSA MessageDigest and incorporate typecast for Buffer methods

Author: samspycher

parsec-client-java/src/main/java/org/parallaxsecond/parsec/client/jna/UnixSocketChannel.java

@@ -5,6 +5,7 @@
 import lombok.NonNull;
 import lombok.extern.slf4j.Slf4j;
 
+import java.nio.Buffer;
 import java.nio.ByteBuffer;
 import java.nio.channels.ByteChannel;
 import java.nio.file.Files;
@@ -36,7 +37,7 @@ public int read(ByteBuffer dst) {
     while (read < toRead) {
       read += (int) UnixSocket.readSocket(this.socket, dst, toRead - read);
       log.debug("expected: {}, read: {}", toRead, read);
-      dst.position(pos + read);
+      ((Buffer)dst).position(pos + read);
     }
     return toRead;
   }
@@ -48,7 +49,7 @@ public int write(ByteBuffer src) {
     int pos = src.position();
     while (written < toWrite) {
       written += (int) UnixSocket.writeSocket(socket, src, toWrite - written);
-      src.position(pos + written);
+      ((Buffer)src).position(pos + written);
     }
     return written;
   }

parsec-interface-java/src/main/java/org/parallaxsecond/parsec/protocol/requests/request/RequestBody.java

@@ -4,6 +4,7 @@
 import lombok.RequiredArgsConstructor;
 
 import java.io.IOException;
+import java.nio.Buffer;
 import java.nio.ByteBuffer;
 import java.nio.ByteOrder;
 import java.nio.channels.ReadableByteChannel;
@@ -21,7 +22,7 @@ public static RequestBody readFromStream(ReadableByteChannel channel, int len)
       throws IOException {
     ByteBuffer buf = ByteBuffer.allocate(len).order(ByteOrder.LITTLE_ENDIAN);
     channel.read(buf);
-    buf.flip();
+    ((Buffer)buf).flip();
     return new RequestBody(buf);
   }
 

parsec-interface-java/src/main/java/org/parallaxsecond/parsec/protocol/requests/request/common/WireHeader_1_0.java

@@ -63,7 +63,7 @@ public static WireHeader_1_0 readFromStream(ReadableByteChannel channel) throws
     ByteBuffer buf = ByteBuffer.allocate(REQUEST_HDR_SIZE + 6).order(ByteOrder.LITTLE_ENDIAN);
 
     channel.read(buf);
-    buf.flip();
+    ((Buffer)buf).flip();
 
     int magicNumber = buf.getInt();
     if (magicNumber != MAGIC_NUMBER) {

parsec-interface-java/src/main/java/org/parallaxsecond/parsec/protocol/requests/response/ResponseBody.java

@@ -5,6 +5,7 @@
 import lombok.extern.slf4j.Slf4j;
 
 import java.io.IOException;
+import java.nio.Buffer;
 import java.nio.ByteBuffer;
 import java.nio.ByteOrder;
 import java.nio.channels.ReadableByteChannel;
@@ -27,8 +28,8 @@ public static ResponseBody readFromStream(ReadableByteChannel channel, int len)
     if (read != len) {
       log.warn("expected to read {} but only got {}", len, read);
     }
-    buf.flip();
-    buf.limit(Math.min(len, read));
+    ((Buffer)buf).flip();
+    ((Buffer)buf).limit(Math.min(len, read));
 
     return new ResponseBody(buf.slice());
   }

parsec-jca-java/src/main/java/org/parallaxsecond/parsec/jce/provider/ParsecRsaSignature.java

@@ -20,20 +20,21 @@ public enum ParsecRsaSignature implements ParsecSignatureInfo {
     NONE_WITH_RSA("NONEwithRSA",
         pkcs1(),
         () -> new MessageDigest("NONE"){
-            byte input0;
-            byte[] input1;
+            byte[] input;
             @Override
             protected void engineUpdate(byte input) {
-                this.input0 = input;
+              throw new UnsupportedOperationException("not implemented");
             }
 
             @Override
             protected void engineUpdate(byte[] input, int offset, int len) {
-                this.input1 = input;
+
+              this.input = input;
             }
 
             @Override
-            protected byte[] engineDigest() {return input1;}
+            protected byte[] engineDigest() {
+              return input;}
 
             @Override
             protected void engineReset() {}