rename shared extstore hashing utilities to PayloadHasher.

Author: cconstable

contrib/temporal-payload-storage-s3/src/main/java/io/temporal/payload/storage/s3/CompletableFutures.java

@@ -10,8 +10,8 @@ private CompletableFutures() {}
   /**
    * Returns a future that completes when all of the given futures complete, yielding a list of
    * their results. If any future completes exceptionally, the returned future also completes
-   * exceptionally with the same exception. If the input list is empty, the returned future completes
-   * immediately with an empty list.
+   * exceptionally with the same exception. If the input list is empty, the returned future
+   * completes immediately with an empty list.
    *
    * @param <T>
    * @param futures

contrib/temporal-payload-storage-s3/src/main/java/io/temporal/payload/storage/s3/S3StorageDriver.java

@@ -3,7 +3,7 @@
 import com.google.protobuf.InvalidProtocolBufferException;
 import io.temporal.api.common.v1.Payload;
 import io.temporal.common.Experimental;
-import io.temporal.payload.storage.PayloadStorageHashes;
+import io.temporal.payload.storage.PayloadHasher;
 import io.temporal.payload.storage.StorageDriver;
 import io.temporal.payload.storage.StorageDriverClaim;
 import io.temporal.payload.storage.StorageDriverRetrieveContext;
@@ -86,7 +86,7 @@ public CompletableFuture<List<StorageDriverClaim>> store(
     List<CompletableFuture<StorageDriverClaim>> claimFutures = new ArrayList<>(payloads.size());
     for (Payload payload : payloads) {
       byte[] data = payload.toByteArray();
-      String hexDigest = PayloadStorageHashes.sha256Hex(data);
+      String hexDigest = PayloadHasher.sha256Hex(data);
       String bucket = bucketResolver.resolveBucket(context, payload);
       String key = S3StorageKey.forPayload(target, HASH_ALGORITHM, hexDigest);
       String location = storageLocation(bucket, key, describeSuffix);
@@ -152,7 +152,7 @@ private Payload verifyAndParse(
     if (expectedHash == null) {
       throw missingField(CLAIM_HASH_VALUE);
     }
-    String actualHash = PayloadStorageHashes.sha256Hex(data);
+    String actualHash = PayloadHasher.sha256Hex(data);
     if (!actualHash.equals(expectedHash)) {
       throw new S3StorageException(
           "integrity check failed [bucket="

…ayload/storage/PayloadStorageHashes.java …poral/payload/storage/PayloadHasher.javatemporal-sdk/src/main/java/io/temporal/payload/storage/PayloadStorageHashes.java renamed to temporal-sdk/src/main/java/io/temporal/payload/storage/PayloadHasher.java temporal-sdk/src/main/java/io/temporal/payload/storage/PayloadStorageHashes.java renamed to temporal-sdk/src/main/java/io/temporal/payload/storage/PayloadHasher.java

@@ -5,12 +5,12 @@
 import java.security.NoSuchAlgorithmException;
 import javax.annotation.Nonnull;
 
-/** Hash helpers shared by external storage drivers. */
+/** Computes payload hashes shared by external storage drivers. */
 @Experimental
-public final class PayloadStorageHashes {
+public final class PayloadHasher {
   private static final char[] HEX = "0123456789abcdef".toCharArray();
 
-  private PayloadStorageHashes() {}
+  private PayloadHasher() {}
 
   /** Returns the lower-case SHA-256 hex digest of {@code data}. */
   @Nonnull