fix(dataconverter): align workflow type names

Signed-off-by: “Kevin” <kevlar_ksb@yahoo.com>

Author: Bueller87

src/main/java/com/uber/cadence/samples/dataconverter/CompressionStarter.java

@@ -32,7 +32,7 @@
  * <pre>
  * cadence --domain samples-domain \
  *   workflow start \
- *   --workflow_type CompressionDataConverterWorkflow \
+ *   --workflow_type CompressedDataConverterWorkflow \
  *   --tl data-compression \
  *   --et 60
  * </pre>

src/main/java/com/uber/cadence/samples/dataconverter/DataConverterConstants.java

@@ -22,10 +22,10 @@
 /**
  * Shared identifiers for the DataConverter samples.
  *
- * <p>Each of the three samples runs on its own task list so it can have its own
- * {@code DataConverter}. {@code DataConverter} is bound to a {@code WorkflowClient}, and each task
- * list maps to one worker built from one client; that is why one process needs three clients to
- * host all three samples.
+ * <p>Each of the three samples runs on its own task list so it can have its own {@code
+ * DataConverter}. {@code DataConverter} is bound to a {@code WorkflowClient}, and each task list
+ * maps to one worker built from one client; that is why one process needs three clients to host all
+ * three samples.
  */
 public final class DataConverterConstants {
 
@@ -44,10 +44,10 @@ private DataConverterConstants() {}
   public static final String TASK_LIST_S3 = "data-s3";
 
   /** Registered workflow type for {@code CompressedDataConverterWorkflow}. */
-  public static final String COMPRESSION_WORKFLOW_TYPE = "CompressionDataConverterWorkflow";
+  public static final String COMPRESSION_WORKFLOW_TYPE = "CompressedDataConverterWorkflow";
 
   /** Registered workflow type for {@code EncryptedDataConverterWorkflow}. */
-  public static final String ENCRYPTION_WORKFLOW_TYPE = "EncryptionDataConverterWorkflow";
+  public static final String ENCRYPTION_WORKFLOW_TYPE = "EncryptedDataConverterWorkflow";
 
   /** Registered workflow type for {@code S3OffloadDataConverterWorkflow}. */
   public static final String S3_OFFLOAD_WORKFLOW_TYPE = "S3OffloadDataConverterWorkflow";

src/main/java/com/uber/cadence/samples/dataconverter/DataConverterWorker.java

@@ -24,9 +24,9 @@
 import com.uber.cadence.worker.WorkerFactory;
 
 /**
- * Hosts all three DataConverter sample workers in a single process. Each sample uses its own
- * {@link WorkflowClient} (and therefore its own {@link WorkerFactory}) because the
- * {@code DataConverter} is bound to {@code WorkflowClientOptions}.
+ * Hosts all three DataConverter sample workers in a single process. Each sample uses its own {@link
+ * WorkflowClient} (and therefore its own {@link WorkerFactory}) because the {@code DataConverter}
+ * is bound to {@code WorkflowClientOptions}.
  *
  * <p>On startup the worker prints a stats banner per sample showing the visible benefit of each
  * pattern (compression ratio, ciphertext preview, claim-check size), then begins polling all three
@@ -38,7 +38,8 @@ private DataConverterWorker() {}
 
   public static void main(String[] args) {
     DataConverter compressionConverter = new CompressedJsonDataConverter();
-    DataConverter encryptionConverter = new EncryptedJsonDataConverter(EncryptionKeyLoader.loadEncryptionKey());
+    DataConverter encryptionConverter =
+        new EncryptedJsonDataConverter(EncryptionKeyLoader.loadEncryptionKey());
     LocalFsBlobStore blobStore = new LocalFsBlobStore();
     DataConverter s3Converter =
         new S3OffloadDataConverter(
@@ -119,8 +120,10 @@ private static void printCompressionStats(DataConverter converter) {
 
     System.out.println();
     System.out.println("=== Compression Sample Statistics ===");
-    System.out.printf("Original JSON size:  %d bytes (%.2f KB)%n", originalSize, originalSize / 1024.0);
-    System.out.printf("Compressed size:     %d bytes (%.2f KB)%n", compressedSize, compressedSize / 1024.0);
+    System.out.printf(
+        "Original JSON size:  %d bytes (%.2f KB)%n", originalSize, originalSize / 1024.0);
+    System.out.printf(
+        "Compressed size:     %d bytes (%.2f KB)%n", compressedSize, compressedSize / 1024.0);
     System.out.printf("Compression ratio:   %.2f%% reduction%n", pct);
     System.out.printf(
         "Space saved:         %d bytes (%.2f KB)%n",
@@ -147,7 +150,7 @@ private static void printEncryptionStats(DataConverter converter) {
     System.out.println("=== Encryption Sample Statistics ===");
     System.out.printf("Plaintext JSON size:  %d bytes%n", plaintextSize);
     System.out.printf(
-        "Ciphertext size:      %d bytes (overhead: %d bytes nonce+tag)%n",
+        "Encrypted payload:    %d bytes (growth: %d bytes vs plaintext JSON)%n",
         ciphertextSize, ciphertextSize - plaintextSize);
     System.out.printf("Ciphertext preview:   %s%n", preview);
     System.out.printf(
@@ -164,11 +167,11 @@ private static void printS3OffloadStats(LocalFsBlobStore store) {
         S3OffloadDataConverterWorkflow.createS3LargePayload();
     byte[] jsonBytes = JsonDataConverter.getInstance().toData(payload);
     int jsonSize = jsonBytes == null ? 0 : jsonBytes.length;
-    // History footprint = 1 prefix byte + JSON envelope {"__s3_ref":"<bucket>/<sha256hex>"}.
+    // History footprint = 1 prefix byte + JSON envelope {"s3Ref":"<bucket>/<sha256hex>"}.
     // SHA-256 hex digest is 64 chars; bucket + "/" + 64 hex chars.
     int cadenceBytes =
         1
-            + ("{\"__s3_ref\":\""
+            + ("{\"s3Ref\":\""
                     + DataConverterConstants.S3_BUCKET
                     + "/"
                     + repeatChar('a', 64)
@@ -177,8 +180,10 @@ private static void printS3OffloadStats(LocalFsBlobStore store) {
 
     System.out.println();
     System.out.println("=== S3 Offload Sample Statistics ===");
-    System.out.printf("Full payload JSON size:    %d bytes (%.2f KB)%n", jsonSize, jsonSize / 1024.0);
-    System.out.printf("Stored in BlobStore:       %d bytes (%.2f KB)%n", jsonSize, jsonSize / 1024.0);
+    System.out.printf(
+        "Full payload JSON size:    %d bytes (%.2f KB)%n", jsonSize, jsonSize / 1024.0);
+    System.out.printf(
+        "Stored in BlobStore:       %d bytes (%.2f KB)%n", jsonSize, jsonSize / 1024.0);
     System.out.printf(
         "Stored in Cadence history: %d bytes (claim-check reference only)%n", cadenceBytes);
     System.out.printf(

src/main/java/com/uber/cadence/samples/dataconverter/EncryptionStarter.java

@@ -25,14 +25,14 @@
 /**
  * Starts {@link EncryptedDataConverterWorkflow} (async, fire-and-forget).
  *
- * <p>The workflow takes no inputs and generates its own payload, so this starter does not need
- * the encryption key — the worker owns the key. The same effect can be achieved from the Cadence
- * CLI via:
+ * <p>The workflow takes no inputs and generates its own payload, so this starter does not need the
+ * encryption key — the worker owns the key. The same effect can be achieved from the Cadence CLI
+ * via:
  *
  * <pre>
  * cadence --domain samples-domain \
  *   workflow start \
- *   --workflow_type EncryptionDataConverterWorkflow \
+ *   --workflow_type EncryptedDataConverterWorkflow \
  *   --tl data-encryption \
  *   --et 60
  * </pre>