Move EventStreamReport into the swirlds-cli module #25188

Signed-off-by: imshubham22apr-gif <imshubham22apr@gmail.com>

Author: imshubham22apr-gif

hedera-node/hapi-utils/src/main/java/com/hedera/node/app/hapi/utils/CommonPbjConverters.java

@@ -282,7 +282,7 @@ private static <T, R extends GeneratedMessage> R explicitPbjToProto(
             final var bytes = requireNonNull(proto).toByteArray();
             final var codecField = requireNonNull(pbjClass).getDeclaredField("PROTOBUF");
             final var codec = (Codec<R>) codecField.get(null);
-            return codec.parse(BufferedData.wrap(bytes));
+            return codec.parseStrict(BufferedData.wrap(bytes));
         } catch (NoSuchFieldException | IllegalAccessException | ParseException e) {
             // Should be impossible, so just propagate an exception
             throw new RuntimeException("Invalid conversion to PBJ for " + pbjClass.getSimpleName(), e);
@@ -417,7 +417,7 @@ public static FileID toPbj(com.hederahashgraph.api.proto.java.FileID fileID) {
         requireNonNull(keyValue);
         try {
             final var bytes = keyValue.toByteArray();
-            return Key.PROTOBUF.parse(BufferedData.wrap(bytes));
+            return Key.PROTOBUF.parseStrict(BufferedData.wrap(bytes));
         } catch (ParseException e) {
             throw new RuntimeException(e);
         }
@@ -442,8 +442,7 @@ public static Timestamp toPbj(@NonNull com.hederahashgraph.api.proto.java.Timest
         requireNonNull(txBody);
         try {
             final var bytes = txBody.toByteArray();
-            return TransactionBody.PROTOBUF.parse(
-                    BufferedData.wrap(bytes), false, false, DEFAULT_MAX_DEPTH, MAX_PBJ_RECORD_SIZE);
+            return TransactionBody.PROTOBUF.parseStrict(BufferedData.wrap(bytes));
         } catch (ParseException e) {
             throw new RuntimeException(e);
         }

hedera-node/hapi-utils/src/main/java/com/hedera/node/app/hapi/utils/blocks/BlockStreamAccess.java

@@ -169,27 +169,21 @@ public static <K, V> Map<K, V> computeMapFromUpdates(
      */
     public static Block blockFrom(@NonNull final Path path) {
         final var fileName = path.getFileName().toString();
+        Block block;
         try {
             if (fileName.endsWith(".gz")) {
                 try (final GZIPInputStream in = new GZIPInputStream(Files.newInputStream(path))) {
-                    return Block.PROTOBUF.parse(
-                            Bytes.wrap(in.readAllBytes()).toReadableSequentialData(),
-                            false,
-                            false,
-                            DEFAULT_MAX_DEPTH,
-                            MAX_PBJ_RECORD_SIZE);
+                    block = Block.PROTOBUF.parseStrict(
+                            Bytes.wrap(in.readAllBytes()).toReadableSequentialData());
                 }
             } else {
-                return Block.PROTOBUF.parse(
-                        Bytes.wrap(Files.readAllBytes(path)).toReadableSequentialData(),
-                        false,
-                        false,
-                        DEFAULT_MAX_DEPTH,
-                        MAX_PBJ_RECORD_SIZE);
+                block = Block.PROTOBUF.parseStrict(
+                        Bytes.wrap(Files.readAllBytes(path)).toReadableSequentialData());
             }
         } catch (IOException | ParseException e) {
             throw new RuntimeException("Failed reading block @ " + path, e);
         }
+        return block;
     }
 
     private static Stream<StateChange> stateChangesForState(@NonNull final List<Block> blocks, final int stateId) {

hedera-node/hapi-utils/src/main/java/com/hedera/node/app/hapi/utils/forensics/TransactionParts.java

@@ -33,7 +33,7 @@ public record TransactionParts(
     public static TransactionParts from(@NonNull final BlockItem item) {
         try {
             final var serializedSignedTx = item.signedTransactionOrThrow();
-            final var signedTx = SignedTransaction.PROTOBUF.parse(serializedSignedTx);
+            final var signedTx = SignedTransaction.PROTOBUF.parseStrict(serializedSignedTx);
             final var body = TransactionBody.parseFrom(signedTx.bodyBytes().toByteArray());
             return new TransactionParts(
                     Transaction.newBuilder()

hedera-node/hedera-app/src/main/java/com/hedera/node/app/blocks/impl/BlockStreamBuilder.java

@@ -1481,7 +1481,7 @@ private BlockItem transactionResultBlockItem() {
 
     private TransactionBody inProgressBody() {
         try {
-            return TransactionBody.PROTOBUF.parse(signedTx.bodyBytes().toReadableSequentialData());
+            return TransactionBody.PROTOBUF.parseStrict(signedTx.bodyBytes().toReadableSequentialData());
         } catch (Exception e) {
             throw new IllegalStateException("Record being built for unparseable transaction", e);
         }

hedera-node/hedera-app/src/main/java/com/hedera/node/app/blocks/impl/streaming/BlockBufferIO.java

@@ -180,8 +180,7 @@ private BufferedBlock readBlockFile(final File file) throws IOException, ParseEx
                 byteBuffer.get(payload);
                 final Bytes bytes = Bytes.wrap(payload);
 
-                return BufferedBlock.PROTOBUF.parse(
-                        bytes.toReadableSequentialData(), false, false, maxReadDepth, length);
+                return BufferedBlock.PROTOBUF.parseStrict(bytes.toReadableSequentialData());
             }
         }
     }

hedera-node/hedera-app/src/main/java/com/hedera/node/app/blocks/impl/streaming/BlockNodeConfigService.java

@@ -183,7 +183,7 @@ private void loadConfiguration() {
             }
 
             final byte[] bytes = Files.readAllBytes(path);
-            connectionInfo = BlockNodeConnectionInfo.JSON.parse(Bytes.wrap(bytes));
+            connectionInfo = BlockNodeConnectionInfo.JSON.parseStrict(Bytes.wrap(bytes));
         } catch (final IOException | ParseException e) {
             logger.warn("Failed to read/parse block node configuration from {}", path, e);
             return;

hedera-node/hedera-app/src/main/java/com/hedera/node/app/blocks/impl/streaming/FileBlockItemWriter.java

@@ -257,7 +257,7 @@ public static List<OnDiskPendingBlock> loadContiguousPendingBlocks(
             final var proofJsonPath = proofJson.toPath();
             final PendingProof pendingProof;
             try {
-                pendingProof = PendingProof.JSON.parse(new ReadableStreamingData(proofJsonPath));
+                pendingProof = PendingProof.JSON.parseStrict(new ReadableStreamingData(proofJsonPath));
             } catch (IOException | ParseException e) {
                 logger.warn(
                         "Error reading pending proof metadata from {} (not considering remaining - {})",
@@ -310,8 +310,8 @@ public static List<OnDiskPendingBlock> loadContiguousPendingBlocks(
 
     private static Block parseBlock(final byte[] bytes, final int maxReadDepth, final int maxReadSize)
             throws ParseException {
-        return Block.PROTOBUF.parse(
-                Bytes.wrap(bytes).toReadableSequentialData(), false, false, maxReadDepth, maxReadSize);
+        return Block.PROTOBUF.parseStrict(
+                Bytes.wrap(bytes).toReadableSequentialData());
     }
 
     /**

hedera-node/hedera-app/src/main/java/com/hedera/node/app/blocks/impl/streaming/RequestResponseMarshaller.java

@@ -42,7 +42,7 @@ public T parse(@NonNull final InputStream inputStream) {
         requireNonNull(inputStream);
 
         try {
-            return codec.parse(Bytes.wrap(inputStream.readAllBytes()));
+            return codec.parseStrict(Bytes.wrap(inputStream.readAllBytes()));
         } catch (final ParseException | IOException e) {
             throw new RuntimeException(e);
         }

hedera-node/hedera-app/src/main/java/com/hedera/node/app/fees/ExchangeRateManager.java

@@ -101,7 +101,7 @@ private void internalUpdate(@NonNull final Bytes bytes, @Nullable AccountID paye
         // Parse the exchange rate file. If we cannot parse it, we just continue with whatever our previous rate was.
         final ExchangeRateSet proposedRates;
         try {
-            proposedRates = ExchangeRateSet.PROTOBUF.parse(bytes.toReadableSequentialData());
+            proposedRates = ExchangeRateSet.PROTOBUF.parseStrict(bytes.toReadableSequentialData());
         } catch (final ParseException e) {
             throw new HandleException(ResponseCodeEnum.INVALID_EXCHANGE_RATE_FILE);
         }
@@ -205,7 +205,7 @@ public ExchangeRateInfo exchangeRateInfo(@NonNull final State state) {
         final var bytes = FileUtilities.getFileContent(state, fileID);
         final ExchangeRateSet exchangeRates;
         try {
-            exchangeRates = ExchangeRateSet.PROTOBUF.parse(bytes.toReadableSequentialData());
+            exchangeRates = ExchangeRateSet.PROTOBUF.parseStrict(bytes.toReadableSequentialData());
         } catch (ParseException e) {
             // This should never happen
             throw new IllegalStateException(e);

hedera-node/hedera-app/src/main/java/com/hedera/node/app/fees/FeeManager.java

@@ -129,7 +129,7 @@ public ResponseCodeEnum update(@NonNull final Bytes bytes) {
         // Parse the current and next fee schedules
         final CurrentAndNextFeeSchedule schedules;
         try {
-            schedules = CurrentAndNextFeeSchedule.PROTOBUF.parse(bytes.toReadableSequentialData());
+            schedules = CurrentAndNextFeeSchedule.PROTOBUF.parseStrict(bytes.toReadableSequentialData());
         } catch (final BufferUnderflowException | ParseException ex) {
             return ResponseCodeEnum.FEE_SCHEDULE_FILE_PART_UPLOADED;
         }
@@ -192,7 +192,7 @@ public synchronized ResponseCodeEnum updateSimpleFees(@NonNull final Bytes bytes
         // Parse the current and next fee schedules
         try {
             final org.hiero.hapi.support.fees.FeeSchedule schedule =
-                    org.hiero.hapi.support.fees.FeeSchedule.PROTOBUF.parse(bytes);
+                    org.hiero.hapi.support.fees.FeeSchedule.PROTOBUF.parseStrict(bytes);
             if (isValid(schedule)) {
                 logger.info("Successfully validated simple fee schedule.");
                 this.simpleFeesSchedule = schedule;