test: added tests for utxorpc block functions (#1116)

* test: added tests for utxorpc block functions

Signed-off-by: Jenita <[email protected]>

* test: added tests for utxorpc block functions

Signed-off-by: Jenita <[email protected]>

---------

Signed-off-by: Jenita <[email protected]>
Co-authored-by: Jenita <[email protected]>

Author: jkawan

ledger/allegra/block_test.go

@@ -22,6 +22,7 @@ import (
 
 	"github.com/blinklabs-io/gouroboros/cbor"
 	"github.com/blinklabs-io/gouroboros/ledger/allegra"
+	"github.com/stretchr/testify/assert"
 )
 
 // https://cexplorer.io/block/8115134ab013f6a5fd88fd2a10825177a2eedcde31cb2f1f35e492df469cf9a8
@@ -88,3 +89,50 @@ func TestAllegraBlock_CborRoundTrip_UsingCborEncode(t *testing.T) {
 		}
 	}
 }
+
+func TestAllegraUtxorpcBlock(t *testing.T) {
+	// Decode the block hex to bytes
+	blockCbor, err := hex.DecodeString(allegraBlockHex)
+	assert.NoError(t, err, "Failed to decode block hex")
+
+	// Parse the block
+	block, err := allegra.NewAllegraBlockFromCbor(blockCbor)
+	assert.NoError(t, err, "Failed to parse block")
+	assert.NotNil(t, block, "Parsed block is nil")
+
+	expectedHash := block.Hash().String()
+	expectedHeight := block.BlockNumber()
+	expectedSlot := block.SlotNumber()
+
+	// Convert to UTxO RPC format
+	utxorpcBlock, err := block.Utxorpc()
+	assert.NoError(t, err, "Utxorpc() conversion failed")
+	assert.NotNil(t, utxorpcBlock, "RPC block is nil")
+
+	t.Run("BlockHeader", func(t *testing.T) {
+		assert.Equal(t, expectedHash, hex.EncodeToString(utxorpcBlock.Header.Hash),
+			"Block hash mismatch")
+
+		assert.Equal(t, expectedHeight, utxorpcBlock.Header.Height,
+			"Block height mismatch")
+
+		assert.Equal(t, expectedSlot, utxorpcBlock.Header.Slot,
+			"Block slot mismatch")
+	})
+
+	t.Run("Transactions", func(t *testing.T) {
+		originalTxs := block.Transactions()
+		rpcTxs := utxorpcBlock.Body.Tx
+
+		assert.Equal(t, len(originalTxs), len(rpcTxs),
+			"Transaction count mismatch")
+
+		if len(rpcTxs) > 0 {
+			firstRpcTx := rpcTxs[0]
+			assert.NotEmpty(t, firstRpcTx.Hash, "Transaction hash should not be empty")
+			assert.Greater(t, len(firstRpcTx.Inputs), 0, "Transaction should have inputs")
+			assert.Greater(t, len(firstRpcTx.Outputs), 0, "Transaction should have outputs")
+			assert.Greater(t, firstRpcTx.Fee, uint64(0), "Transaction fee should be positive")
+		}
+	})
+}

ledger/alonzo/alonzo.go

@@ -426,12 +426,18 @@ func (o AlonzoTransactionOutput) Utxorpc() (*utxorpc.TxOutput, error) {
 		return nil, fmt.Errorf("failed to get address bytes: %w", err)
 	}
 
+	// Datum hash handling
+	var datumHash []byte
+	if o.OutputDatumHash != nil {
+		datumHash = o.OutputDatumHash.Bytes()
+	}
+
 	return &utxorpc.TxOutput{
 			Address: addressBytes,
 			Coin:    o.Amount(),
 			Assets:  assets,
 			Datum: &utxorpc.Datum{
-				Hash: o.OutputDatumHash.Bytes(),
+				Hash: datumHash,
 			},
 		},
 		nil

ledger/alonzo/block_test.go

@@ -1,7 +1,54 @@
 package byron_test
 
+import (
+	"encoding/hex"
+	"testing"
+
+	"github.com/blinklabs-io/gouroboros/ledger/byron"
+	"github.com/stretchr/testify/assert"
+)
+
 // https://cexplorer.io/block/1451a0dbf16cfeddf4991a838961df1b08a68f43a19c0eb3b36cc4029c77a2d8
 //
 //slot:4471207
 //hash:1451a0dbf16cfeddf4991a838961df1b08a68f43a19c0eb3b36cc4029c77a2d8
 var byronBlockHex = "83851a2d964a09582025df38df102b89ec25a432a2972993d2fa8cc1f597a73e6260b2f07e79501eb084830258200f284bc22f5b96228ee0687b7bb87c56132f77df4235c78a1595729ccfce2001582019fb988d02ec920a6de5ac71c5d5e75f8b73d7ed8e8abea7773e28859983206e82035820d36a2619a672494604e11bb447cbcf5231e9f2ba25c2169177edc941bd50ad6c5820afc0da64183bf2664f3d4eec7238d524ba607faeeab24fc100eb861dba69971b58204e66280cd94d591072349bec0a3090a53aa945562efb6d08d56e53654b0e4098848218cf0758401bc97a2fe02c297880ce8ecfd997fe4c1ec09ee10feeee9f686760166b05281d6283468ffd93becb0c956ccddd642df9b1244c915911185fa49355f6f22bfab9811a004430ed820282840058401bc97a2fe02c297880ce8ecfd997fe4c1ec09ee10feeee9f686760166b05281d6283468ffd93becb0c956ccddd642df9b1244c915911185fa49355f6f22bfab9584061261a95b7613ee6bf2067dad77b70349729b0c50d57bc1cf30de0db4a1e73a885d0054af7c23fc6c37919dba41c602a57e2d0f9329a7954b867338d6fb2c9455840e03e62f083df5576360e60a32e22bbb07b3c8df4fcab8079f1d6f61af3954d242ba8a06516c395939f24096f3df14e103a7d9c2b80a68a9363cf1f27c7a4e3075840325068a2307397703c4eebb1de1ecab0b23c24a5e80c985e0f7546bb6571ee9eb94069708fc25ec67a4a5753a0d49ab5e536131c19c7f9dd4fd32532fd0f71028483010000826a63617264616e6f2d736c01a058204ba92aa320c60acc9ad7b9a64f2eda55c4d2ec28e604faf186708b4f0c4e8edf849f82839f8200d8185824825820b0a7782d21f37e9d98f4cbdc23bf2677d93eca1ac0fb3f79923863a698d53f8f018200d81858248258205bd3e8385d2ecdd17d3b602263e8a5e7aa0edb4dd00221f369c2720f7d85940d008200d81858248258201e4a77f8375548e5bc409a518dbcb4a8437b539682f4e840f4a1056f01cea566008200d81858248258205e83b53253f705c214d904f65fdaaa2f153db59a229a9cee1da6c329b543236100ff9f8282d818584283581ca1932430cb1ad6482a1b67964d778c18b574674fda151cdfa73c63cda101581e581cfc8a0b5477e819a27a34910e6c174b50b871192e95cca1a711bbceb3001abcb52f6d1b000000013446d5718282d818584283581c093916f7e775fba80eaa65cded085d985f7f9e4982cddd2bb7c476aea101581e581c83d3e2df30edf90acf198b85a7327d964f9d92fd739d0c986a914f6c001a27a611b61a000c48cbffa0848200d8185885825840a781c060f2b32d116ef79bb1823d4a25ea36f6c130b3a182713739ea1819e32d261db3dce30b15c29db81d1c284d3fe350d12241e8ccc65cdf08adba90e0ad4558408eb4c9549a6a044d687d6c04fdee2240994f43966ef113ebb3e76a756e39472badb137c3e0268d34ce6042f76c2534220cc1e061a1a29cce065faf486184cf078200d818588582584085dc150754227f68d1640887f8fa57c93e4cad3499f2cb7b5e8258b0b367dcceaa42bf9ea1cfff73fd0fab44d9e0a36ef61bc5d0f294365316a4e0ed12b40a135840f1233519fa85f3ecbb2deaa9dff2d7e943156d49a7a33603381f2c1779b7f65ea0d39a8dcdd227f5d69b9355ab35df0c43c2abb751c6dd24b107a2c7ac51f5088200d81858858258403559467e9b4a4e47af0388e7224358197e5d39c57c71c391db4a7d480f297d8b86b0746de21dc5dfca2bd8b8fa817c1fa1c3bd3eeaddbfd7a6b270564e416d0c5840b0e33544dcb1895b592a612f5be81242a88226d0612da76099b653f89ce7c5641af14fad696ccd44b58744915291240224fd83a26f103c0717752ea256b4af0b8200d8185885825840572c3ea039ded80f19b0d6841e9ad0d0d1b73242ac98538affbec6e7356192f48eba0291ea1b174f9c42e139ba85ce75656a036ba0993dda605d5a62956dba6558406257e3a27a896268cade4d5371537ed606d3004d6269f87ebe6056b6eff737a2a9ef82d27ba1f9b642ffc622ec27b38e69ed41e272d3de0767cad860d50fa10d82839f8200d8185824825820779a319e0d64b80eaff5ed13d08062b8672fc71ac27e7b30574c1c7972764de202ff9f8282d818582183581c2c0dd53d4e6001e006729fc09d74c5a799d5f93c9f4b74748412a823a0001a1abd89081a769cfd808282d818582183581c05b073f36ee030589a31148838cd47e8d8c8f82fec9fe091c7d53cd8a0001a0c5f26b11b00000016bc0c4c47ffa0818200d8185885825840f129f07bbfd87fd1d3ff5fb32e9a5566e02208f89518e9994048add22074f433424e682a392581268c7544e34e9c54378a8820bdcf7dddce30490bbb2d363b4b5840709a2e70d3803554a15d788235bf56c9567407102be375be5071fa81d4c137047743b5f5abefdbab6b2781822474995dff917213c962ecd111619d75b8534f0aff8203d90102809fff82809fff81a0"
+
+func TestByronTransactionUtxorpc(t *testing.T) {
+	// Decode the hex string to bytes
+	blockBytes, err := hex.DecodeString(byronBlockHex)
+	assert.NoError(t, err)
+
+	block, err := byron.NewByronMainBlockFromCbor(blockBytes)
+	assert.NoError(t, err)
+	assert.NotNil(t, block)
+
+	txs := block.Transactions()
+	assert.Greater(t, len(txs), 0, "Expected at least one transaction in the block")
+
+	for _, tx := range txs {
+		byronTx, ok := tx.(*byron.ByronTransaction)
+		assert.True(t, ok, "Transaction should be of type *ByronTransaction")
+
+		utxoTx, err := byronTx.Utxorpc()
+		assert.NoError(t, err)
+		assert.NotNil(t, utxoTx, "Utxorpc() should not return nil")
+
+		txHash := byronTx.Hash()
+		assert.NotEmpty(t, txHash.String(), "Transaction hash should not be empty")
+
+		inputs := byronTx.Inputs()
+		assert.Equal(t, len(inputs), len(byronTx.Consumed()), "Consumed inputs should match Inputs() length")
+
+		produced := byronTx.Produced()
+		assert.Equal(t, len(produced), len(byronTx.Outputs()), "Produced should match Outputs() length")
+
+		for _, utxo := range produced {
+			rpcOut, err := utxo.Output.Utxorpc()
+			assert.NoError(t, err)
+			assert.NotNil(t, rpcOut, "Utxorpc output should not be nil")
+			assert.Greater(t, rpcOut.Coin, uint64(0), "Coin amount should be greater than 0")
+			assert.NotEmpty(t, rpcOut.Address, "Address bytes should not be empty")
+		}
+	}
+}

ledger/byron/block_test.go

@@ -88,3 +88,76 @@ func TestConwayBlock_CborRoundTrip_UsingCborEncode(t *testing.T) {
 		}
 	}
 }
+
+func TestConwayBlockUtxorpc(t *testing.T) {
+	blockCbor, err := hex.DecodeString(conwayBlockHex)
+	if err != nil {
+		t.Fatalf("failed to decode test block hex: %v", err)
+	}
+
+	block, err := conway.NewConwayBlockFromCbor(blockCbor)
+	if err != nil {
+		t.Fatalf("failed to parse Conway block: %v", err)
+	}
+
+	utxoBlock, err := block.Utxorpc()
+	if err != nil {
+		t.Fatalf("failed to convert Conway block to utxorpc: %v", err)
+	}
+
+	if utxoBlock.Header == nil {
+		t.Fatal("block header is nil")
+	}
+
+	expectedHash := block.Hash().Bytes()
+	if !compareByteSlices(utxoBlock.Header.Hash, expectedHash) {
+		t.Errorf("block hash mismatch:\nexpected: %x\nactual: %x", expectedHash, utxoBlock.Header.Hash)
+	}
+
+	if utxoBlock.Header.Height != block.BlockNumber() {
+		t.Errorf("block height mismatch: expected %d, got %d", block.BlockNumber(), utxoBlock.Header.Height)
+	}
+
+	if utxoBlock.Header.Slot != block.SlotNumber() {
+		t.Errorf("block slot mismatch: expected %d, got %d", block.SlotNumber(), utxoBlock.Header.Slot)
+	}
+
+	if utxoBlock.Body == nil {
+		t.Fatal("block body is nil")
+	}
+
+	expectedTxCount := len(block.TransactionBodies)
+	if len(utxoBlock.Body.Tx) != expectedTxCount {
+		t.Errorf("transaction count mismatch: expected %d, got %d", expectedTxCount, len(utxoBlock.Body.Tx))
+	}
+
+	if expectedTxCount > 0 {
+		firstTx := block.Transactions()[0]
+		utxoFirstTx := utxoBlock.Body.Tx[0]
+
+		expectedTxHash := firstTx.Hash().Bytes()
+		if !compareByteSlices(utxoFirstTx.Hash, expectedTxHash) {
+			t.Errorf("first tx hash mismatch:\nexpected: %x\nactual: %x", expectedTxHash, utxoFirstTx.Hash)
+		}
+
+		if len(utxoFirstTx.Inputs) != len(firstTx.Inputs()) {
+			t.Errorf("first tx input count mismatch: expected %d, got %d", len(firstTx.Inputs()), len(utxoFirstTx.Inputs))
+		}
+
+		if len(utxoFirstTx.Outputs) != len(firstTx.Outputs()) {
+			t.Errorf("first tx output count mismatch: expected %d, got %d", len(firstTx.Outputs()), len(utxoFirstTx.Outputs))
+		}
+	}
+}
+
+func compareByteSlices(a, b []byte) bool {
+	if len(a) != len(b) {
+		return false
+	}
+	for i := range a {
+		if a[i] != b[i] {
+			return false
+		}
+	}
+	return true
+}