From cb299dfaa279e14def8bf3f26816913213a91097 Mon Sep 17 00:00:00 2001 From: Chris Lu Date: Sun, 1 Sep 2019 03:46:51 -0700 Subject: HCFS: use latest grpc versions, separate hadoop2 and hadoop3 --- .../test/java/seaweedfs/client/SeaweedFilerTest.java | 17 +++++++++++++++++ 1 file changed, 17 insertions(+) create mode 100644 other/java/client/src/test/java/seaweedfs/client/SeaweedFilerTest.java (limited to 'other/java/client/src/test') diff --git a/other/java/client/src/test/java/seaweedfs/client/SeaweedFilerTest.java b/other/java/client/src/test/java/seaweedfs/client/SeaweedFilerTest.java new file mode 100644 index 000000000..dde23ee87 --- /dev/null +++ b/other/java/client/src/test/java/seaweedfs/client/SeaweedFilerTest.java @@ -0,0 +1,17 @@ +package seaweedfs.client; + +import java.util.List; + +public class SeaweedFilerTest { + public static void main(String[] args){ + + FilerClient filerClient = new FilerClient("localhost", 18888); + + List entries = filerClient.listEntries("/"); + + for (FilerProto.Entry entry : entries) { + System.out.println(entry.toString()); + } + + } +} -- cgit v1.2.3 From af8b413a9cebea0109ebdf16bd18078da3c551a1 Mon Sep 17 00:00:00 2001 From: Chris Lu Date: Sun, 1 Sep 2019 12:25:06 -0700 Subject: HCFS: fix mkdirs NPE --- .../client/src/test/java/seaweedfs/client/SeaweedFilerTest.java | 6 ++++++ 1 file changed, 6 insertions(+) (limited to 'other/java/client/src/test') diff --git a/other/java/client/src/test/java/seaweedfs/client/SeaweedFilerTest.java b/other/java/client/src/test/java/seaweedfs/client/SeaweedFilerTest.java index dde23ee87..87165af0c 100644 --- a/other/java/client/src/test/java/seaweedfs/client/SeaweedFilerTest.java +++ b/other/java/client/src/test/java/seaweedfs/client/SeaweedFilerTest.java @@ -13,5 +13,11 @@ public class SeaweedFilerTest { System.out.println(entry.toString()); } + filerClient.mkdirs("/new_folder", 0755); + filerClient.touch("/new_folder/new_empty_file", 0755); + filerClient.touch("/new_folder/new_empty_file2", 0755); + filerClient.rm("/new_folder/new_empty_file", false); + filerClient.rm("/new_folder", true); + } } -- cgit v1.2.3 From a999ed94d0abe53ac444c6a12cf0f5f89ea06d33 Mon Sep 17 00:00:00 2001 From: Chris Lu Date: Tue, 8 Oct 2019 22:49:10 -0700 Subject: update hdfs client --- .../java/client/src/test/java/seaweedfs/client/SeaweedFilerTest.java | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) (limited to 'other/java/client/src/test') diff --git a/other/java/client/src/test/java/seaweedfs/client/SeaweedFilerTest.java b/other/java/client/src/test/java/seaweedfs/client/SeaweedFilerTest.java index 87165af0c..eaf17e5c6 100644 --- a/other/java/client/src/test/java/seaweedfs/client/SeaweedFilerTest.java +++ b/other/java/client/src/test/java/seaweedfs/client/SeaweedFilerTest.java @@ -16,8 +16,8 @@ public class SeaweedFilerTest { filerClient.mkdirs("/new_folder", 0755); filerClient.touch("/new_folder/new_empty_file", 0755); filerClient.touch("/new_folder/new_empty_file2", 0755); - filerClient.rm("/new_folder/new_empty_file", false); - filerClient.rm("/new_folder", true); + filerClient.rm("/new_folder/new_empty_file", false, true); + filerClient.rm("/new_folder", true, true); } } -- cgit v1.2.3 From de1ba85346bd2af41ebb98f152bb769e2b630139 Mon Sep 17 00:00:00 2001 From: Chris Lu Date: Sat, 14 Mar 2020 00:27:57 -0700 Subject: HDFS support encrypted data storage --- .../java/seaweedfs/client/SeaweedCipherTest.java | 42 ++++++++++++++++++++++ 1 file changed, 42 insertions(+) create mode 100644 other/java/client/src/test/java/seaweedfs/client/SeaweedCipherTest.java (limited to 'other/java/client/src/test') diff --git a/other/java/client/src/test/java/seaweedfs/client/SeaweedCipherTest.java b/other/java/client/src/test/java/seaweedfs/client/SeaweedCipherTest.java new file mode 100644 index 000000000..7b5e53e19 --- /dev/null +++ b/other/java/client/src/test/java/seaweedfs/client/SeaweedCipherTest.java @@ -0,0 +1,42 @@ +package seaweedfs.client; + +import org.junit.Test; + +import java.util.Base64; + +import static seaweedfs.client.SeaweedCipher.decrypt; +import static seaweedfs.client.SeaweedCipher.encrypt; + +public class SeaweedCipherTest { + + @Test + public void testSameAsGoImplemnetation() throws Exception { + byte[] secretKey = "256-bit key for AES 256 GCM encr".getBytes(); + + String plainText = "Now we need to generate a 256-bit key for AES 256 GCM"; + + System.out.println("Original Text : " + plainText); + + byte[] cipherText = encrypt(plainText.getBytes(), secretKey); + System.out.println("Encrypted Text : " + Base64.getEncoder().encodeToString(cipherText)); + + byte[] decryptedText = decrypt(cipherText, secretKey); + System.out.println("DeCrypted Text : " + new String(decryptedText)); + } + + @Test + public void testEncryptDecrypt() throws Exception { + byte[] secretKey = SeaweedCipher.genCipherKey(); + + String plainText = "Now we need to generate a 256-bit key for AES 256 GCM"; + + System.out.println("Original Text : " + plainText); + + byte[] cipherText = encrypt(plainText.getBytes(), secretKey); + System.out.println("Encrypted Text : " + Base64.getEncoder().encodeToString(cipherText)); + + byte[] decryptedText = decrypt(cipherText, secretKey); + System.out.println("DeCrypted Text : " + new String(decryptedText)); + } + +} -- cgit v1.2.3