Fix test indentation

Signed-off-by: Dinu John <[email protected]>
dinujoh · May 3, 2024 · 054fd1b · 054fd1b
1 parent e0a6b0c
commit 054fd1b
Showing 1 changed file with 26 additions and 24 deletions.
diff --git a/...ngodb/src/test/java/org/opensearch/dataprepper/plugins/mongo/stream/StreamWorkerTest.java b/...ngodb/src/test/java/org/opensearch/dataprepper/plugins/mongo/stream/StreamWorkerTest.java
@@ -467,7 +467,7 @@ void test_processStream_dataTypeConversionSuccess() {
         when(streamDoc1.getResumeToken()).thenReturn(bsonDoc1);
         when(streamDoc1.getOperationType()).thenReturn(OperationType.INSERT);
         when(cursor.next())
-                .thenReturn(streamDoc1);
+            .thenReturn(streamDoc1);
         when(streamDoc1.getFullDocument()).thenReturn(doc1);
         final String operationType1 = UUID.randomUUID().toString();
         when(streamDoc1.getOperationTypeString()).thenReturn(operationType1);
@@ -491,37 +491,39 @@ void test_processStream_dataTypeConversionSuccess() {
             }
         });
         await()
-                .atMost(Duration.ofSeconds(10))
-                .untilAsserted(() ->  verify(mongoClient).close());
+            .atMost(Duration.ofSeconds(10))
+            .untilAsserted(() ->  verify(mongoClient).close());
         verify(mongoDatabase).getCollection(eq("collection"));
         verify(mockPartitionCheckpoint).getGlobalS3FolderCreationStatus(collection);
         verify(mockRecordConverter).initializePartitions(partitions);
         final String expectedRecord = "{" +
             "\"_id\": \"6634ed693ac62386d57bcaf0\", " +
             "\"name\": \"Hello User\", " +
             "\"doc\": {" +
-                "\"id\": {\"key1\": \"value1\", " +
-                "\"key2\": \"value2\"" +
-            "}, " +
-            "\"nullField\": null, " +
-            "\"numberField\": 123, " +
-            "\"longValue\": 1234567890123456768, " +
-            "\"stringField\": \"Hello, Mongo!\", " +
-            "\"booleanField\": true, " +
-            "\"dateField\": 1714744671155, " +
-            "\"arrayField\": [\"a\", \"b\", \"c\"], " +
-            "\"objectField\": {" +
-                "\"nestedKey\": \"nestedValue\"" +
-            "}, " +
-            "\"binaryField\": \"AQIDBA==\", " +
-            "\"objectIdField\": \"6634ed5f3ac62386d57bcaef\", " +
-            "\"timestampField\": 7364772325884952605, " +
-            "\"regexField\": {" +
-                "\"pattern\": \"pattern\", " +
-                "\"options\": \"i\"" +
+                "\"id\": {" +
+                    "\"key1\": \"value1\", " +
+                    "\"key2\": \"value2\"" +
+                "}, " +
+                "\"nullField\": null, " +
+                "\"numberField\": 123, " +
+                "\"longValue\": 1234567890123456768, " +
+                "\"stringField\": \"Hello, Mongo!\", " +
+                "\"booleanField\": true, " +
+                "\"dateField\": 1714744671155, " +
+                "\"arrayField\": [\"a\", \"b\", \"c\"], " +
+                "\"objectField\": {" +
+                    "\"nestedKey\": \"nestedValue\"" +
+                "}, " +
+                "\"binaryField\": \"AQIDBA==\", " +
+                "\"objectIdField\": \"6634ed5f3ac62386d57bcaef\", " +
+                "\"timestampField\": 7364772325884952605, " +
+                "\"regexField\": {" +
+                    "\"pattern\": \"pattern\", " +
+                    "\"options\": \"i\"" +
+                "}, " +
+                "\"minKeyField\": null, " +
+                "\"maxKeyField\": null" +
             "}, " +
-            "\"minKeyField\": null, " +
-            "\"maxKeyField\": null}, " +
             "\"price128\": \"123.45\"" +
         "}";
         verify(mockRecordConverter).convert(eq(expectedRecord), eq(timeSecond1 * 1000L), eq(timeSecond1 * 1000L), eq(operationType1));