HIP-1056 Account BlockItem to RecordItem transformers

hedera-mirror-importer/src/main/java/com/hedera/mirror/importer/downloader/block/transformer/CryptoCreateTransformer.java

@@ -0,0 +1,64 @@
+/*
+ * Copyright (C) 2025 Hedera Hashgraph, LLC
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ *      http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+
+package com.hedera.mirror.importer.downloader.block.transformer;
+
+import com.hedera.mirror.common.domain.transaction.BlockItem;
+import com.hedera.mirror.common.domain.transaction.TransactionType;
+import com.hedera.mirror.common.util.DomainUtils;
+import com.hederahashgraph.api.proto.java.TransactionRecord;
+import jakarta.inject.Named;
+
+import static com.hedera.hapi.block.stream.output.protoc.StateIdentifier.STATE_ID_ALIASES;
+
+@Named
+final class CryptoCreateTransformer extends AbstractBlockItemTransformer {
+
+    @Override
+    protected void updateTransactionRecord(BlockItem blockItem, TransactionRecord.Builder transactionRecordBuilder) {
+        if (!blockItem.successful()) {
+            return;
+        }
+
+        var receiptBuilder = transactionRecordBuilder.getReceiptBuilder();
+        for (var transactionOutput : blockItem.transactionOutput()) {
+            if (transactionOutput.hasAccountCreate()) {
+                var output = transactionOutput.getAccountCreate();
+                if (output.hasCreatedAccountId()) {
+                    receiptBuilder.setAccountID(output.getCreatedAccountId());
+                }
+            }
+        }
+
+            for (var stateChanges : blockItem.stateChanges()) {
+                for (var stateChange : stateChanges.getStateChangesList()) {
+                    if (stateChange.getStateId() == STATE_ID_ALIASES.getNumber() && stateChange.hasMapUpdate()) {
+                        var value = stateChange.getMapUpdate().getValue();
+                        var alias = value.getAccountValue().getAlias();
+                        if (value.hasAccountValue() && alias.toByteArray().length == DomainUtils.EVM_ADDRESS_LENGTH) {
+                            transactionRecordBuilder.setEvmAddress(alias);
+                        }
+                    }
+                }
+            }
+
+    }
+
+    @Override
+    public TransactionType getType() {
+        return TransactionType.CRYPTOCREATEACCOUNT;
+    }
+}

hedera-mirror-importer/src/main/java/com/hedera/mirror/importer/downloader/block/transformer/CryptoUpdateTransformer.java

@@ -0,0 +1,48 @@
+/*
+ * Copyright (C) 2025 Hedera Hashgraph, LLC
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ *      http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+
+package com.hedera.mirror.importer.downloader.block.transformer;
+
+import com.hedera.mirror.common.domain.transaction.BlockItem;
+import com.hedera.mirror.common.domain.transaction.TransactionType;
+import com.hederahashgraph.api.proto.java.TransactionRecord;
+import jakarta.inject.Named;
+
+@Named
+public class CryptoUpdateTransformer extends AbstractBlockItemTransformer {
+
+    @Override
+    protected void updateTransactionRecord(BlockItem blockItem, TransactionRecord.Builder transactionRecordBuilder) {
+        if (!blockItem.successful()) {
+            return;
+        }
+
+        var receiptBuilder = transactionRecordBuilder.getReceiptBuilder();
+        for (var transactionOutput : blockItem.transactionOutput()) {
+            if (transactionOutput.hasAccountCreate()) {
+                var output = transactionOutput.getAccountCreate();
+                if (output.hasCreatedAccountId()) {
+                    receiptBuilder.setAccountID(output.getCreatedAccountId());
+                }
+            }
+        }
+    }
+
+    @Override
+    public TransactionType getType() {
+        return TransactionType.CRYPTOUPDATEACCOUNT;
+    }
+}