Skip to content

Commit 2cb62fa

Browse files
author
Jenita
committed
feat: added error handling to Utxprpc()
Signed-off-by: Jenita <[email protected]>
1 parent 71fe314 commit 2cb62fa

24 files changed

+417
-196
lines changed

‎ledger/allegra/allegra.go‎

Lines changed: 14 additions & 7 deletions
Original file line numberDiff line numberDiff line change
@@ -112,10 +112,13 @@ func (b *AllegraBlock) Transactions() []common.Transaction {
112112
return ret
113113
}
114114

115-
func (b *AllegraBlock) Utxorpc() *utxorpc.Block {
115+
func (b *AllegraBlock) Utxorpc() (*utxorpc.Block, error) {
116116
txs := []*utxorpc.Tx{}
117117
for _, t := range b.Transactions() {
118-
tx := t.Utxorpc()
118+
tx, err := t.Utxorpc()
119+
if err != nil {
120+
return nil, err
121+
}
119122
txs = append(txs, tx)
120123
}
121124
body := &utxorpc.BlockBody{
@@ -130,7 +133,7 @@ func (b *AllegraBlock) Utxorpc() *utxorpc.Block {
130133
Body: body,
131134
Header: header,
132135
}
133-
return block
136+
return block, nil
134137
}
135138

136139
type AllegraBlockHeader struct {
@@ -221,8 +224,8 @@ func (b *AllegraTransactionBody) AuxDataHash() *common.Blake2b256 {
221224
return b.TxAuxDataHash
222225
}
223226

224-
func (b *AllegraTransactionBody) Utxorpc() *utxorpc.Tx {
225-
return common.TransactionBodyToUtxorpc(b)
227+
func (b *AllegraTransactionBody) Utxorpc() (*utxorpc.Tx, error) {
228+
return common.TransactionBodyToUtxorpc(b), nil
226229
}
227230

228231
type AllegraTransaction struct {
@@ -332,8 +335,12 @@ func (t AllegraTransaction) Metadata() *cbor.LazyValue {
332335
return t.TxMetadata
333336
}
334337

335-
func (t AllegraTransaction) Utxorpc() *utxorpc.Tx {
336-
return t.Body.Utxorpc()
338+
func (t AllegraTransaction) Utxorpc() (*utxorpc.Tx, error) {
339+
tx, err := t.Body.Utxorpc()
340+
if err != nil {
341+
return nil, fmt.Errorf("failed to convert transaction body: %w", err)
342+
}
343+
return tx, nil
337344
}
338345

339346
func (t AllegraTransaction) IsValid() bool {

‎ledger/allegra/pparams_test.go‎

Lines changed: 12 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -120,8 +120,10 @@ func TestAllegraUtxorpc(t *testing.T) {
120120
},
121121
}
122122

123-
result := inputParams.Utxorpc()
124-
123+
result, err := inputParams.Utxorpc()
124+
if err != nil {
125+
t.Fatalf("Utxorpc() conversion failed: %v", err)
126+
}
125127
if !reflect.DeepEqual(result, expectedUtxorpc) {
126128
t.Fatalf(
127129
"Utxorpc() test failed for Allegra:\nExpected: %#v\nGot: %#v",
@@ -160,7 +162,10 @@ func TestAllegraTransactionBody_Utxorpc(t *testing.T) {
160162
}
161163

162164
// Run Utxorpc conversion
163-
actual := txBody.Utxorpc()
165+
actual, err := txBody.Utxorpc()
166+
if err != nil {
167+
t.Errorf("Failed to convert the transaction")
168+
}
164169

165170
// Check that the fee matches
166171
if actual.Fee != txBody.Fee() {
@@ -220,8 +225,10 @@ func TestAllegraTransaction_Utxorpc(t *testing.T) {
220225
}
221226

222227
// Run Utxorpc conversion
223-
actual := tx.Utxorpc()
224-
228+
actual, err := tx.Utxorpc()
229+
if err != nil {
230+
t.Errorf("Failed to convert the transaction")
231+
}
225232
// Assertion checks
226233
if actual.Fee != tx.Fee() {
227234
t.Errorf(

‎ledger/alonzo/alonzo.go‎

Lines changed: 14 additions & 7 deletions
Original file line numberDiff line numberDiff line change
@@ -121,10 +121,13 @@ func (b *AlonzoBlock) Transactions() []common.Transaction {
121121
return ret
122122
}
123123

124-
func (b *AlonzoBlock) Utxorpc() *utxorpc.Block {
124+
func (b *AlonzoBlock) Utxorpc() (*utxorpc.Block, error) {
125125
txs := []*utxorpc.Tx{}
126126
for _, t := range b.Transactions() {
127-
tx := t.Utxorpc()
127+
tx, err := t.Utxorpc()
128+
if err != nil {
129+
return nil, err
130+
}
128131
txs = append(txs, tx)
129132
}
130133
body := &utxorpc.BlockBody{
@@ -139,7 +142,7 @@ func (b *AlonzoBlock) Utxorpc() *utxorpc.Block {
139142
Body: body,
140143
Header: header,
141144
}
142-
return block
145+
return block, nil
143146
}
144147

145148
type AlonzoBlockHeader struct {
@@ -255,8 +258,8 @@ func (b *AlonzoTransactionBody) ScriptDataHash() *common.Blake2b256 {
255258
return b.TxScriptDataHash
256259
}
257260

258-
func (b *AlonzoTransactionBody) Utxorpc() *utxorpc.Tx {
259-
return common.TransactionBodyToUtxorpc(b)
261+
func (b *AlonzoTransactionBody) Utxorpc() (*utxorpc.Tx, error) {
262+
return common.TransactionBodyToUtxorpc(b), nil
260263
}
261264

262265
type AlonzoTransactionOutput struct {
@@ -640,8 +643,12 @@ func (t *AlonzoTransaction) Cbor() []byte {
640643
return cborData
641644
}
642645

643-
func (t *AlonzoTransaction) Utxorpc() *utxorpc.Tx {
644-
return t.Body.Utxorpc()
646+
func (t *AlonzoTransaction) Utxorpc() (*utxorpc.Tx, error) {
647+
tx, err := t.Body.Utxorpc()
648+
if err != nil {
649+
return nil, fmt.Errorf("failed to convert Alonzo transaction: %w", err)
650+
}
651+
return tx, nil
645652
}
646653

647654
func NewAlonzoBlockFromCbor(data []byte) (*AlonzoBlock, error) {

‎ledger/alonzo/pparams.go‎

Lines changed: 7 additions & 7 deletions
Original file line numberDiff line numberDiff line change
@@ -273,32 +273,32 @@ func (u *AlonzoProtocolParameterUpdate) UnmarshalCBOR(cborData []byte) error {
273273
return nil
274274
}
275275

276-
func (p *AlonzoProtocolParameters) Utxorpc() *cardano.PParams {
276+
func (p *AlonzoProtocolParameters) Utxorpc() (*cardano.PParams, error) {
277277
// sanity check
278278
if p.A0.Num().Int64() > math.MaxInt32 ||
279279
p.A0.Denom().Int64() < 0 ||
280280
p.A0.Denom().Int64() > math.MaxUint32 {
281-
return nil
281+
return nil, fmt.Errorf("invalid A0 rational number values")
282282
}
283283
if p.Rho.Num().Int64() > math.MaxInt32 ||
284284
p.Rho.Denom().Int64() < 0 ||
285285
p.Rho.Denom().Int64() > math.MaxUint32 {
286-
return nil
286+
return nil, fmt.Errorf("invalid Rho rational number values")
287287
}
288288
if p.Tau.Num().Int64() > math.MaxInt32 ||
289289
p.Tau.Denom().Int64() < 0 ||
290290
p.Tau.Denom().Int64() > math.MaxUint32 {
291-
return nil
291+
return nil, fmt.Errorf("invalid Tau rational number values")
292292
}
293293
if p.ExecutionCosts.MemPrice.Num().Int64() > math.MaxInt32 ||
294294
p.ExecutionCosts.MemPrice.Denom().Int64() < 0 ||
295295
p.ExecutionCosts.MemPrice.Denom().Int64() > math.MaxUint32 {
296-
return nil
296+
return nil, fmt.Errorf("invalid memory price rational number values")
297297
}
298298
if p.ExecutionCosts.StepPrice.Num().Int64() > math.MaxInt32 ||
299299
p.ExecutionCosts.StepPrice.Denom().Int64() < 0 ||
300300
p.ExecutionCosts.StepPrice.Denom().Int64() > math.MaxUint32 {
301-
return nil
301+
return nil, fmt.Errorf("invalid step price rational number values")
302302
}
303303
// #nosec G115
304304
return &cardano.PParams{
@@ -353,7 +353,7 @@ func (p *AlonzoProtocolParameters) Utxorpc() *cardano.PParams {
353353
Memory: p.MaxBlockExUnits.Memory,
354354
Steps: p.MaxBlockExUnits.Steps,
355355
},
356-
}
356+
}, nil
357357
}
358358

359359
func UpgradePParams(

‎ledger/alonzo/pparams_test.go‎

Lines changed: 12 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -431,7 +431,10 @@ func TestAlonzoUtxorpc(t *testing.T) {
431431
},
432432
}
433433

434-
result := inputParams.Utxorpc()
434+
result, err := inputParams.Utxorpc()
435+
if err != nil {
436+
t.Fatalf("Utxorpc() conversion failed")
437+
}
435438

436439
if !reflect.DeepEqual(result, expectedUtxorpc) {
437440
t.Fatalf(
@@ -512,7 +515,10 @@ func TestAlonzoTransactionBody_Utxorpc(t *testing.T) {
512515
}
513516

514517
// Run Utxorpc conversion
515-
got := body.Utxorpc()
518+
got, err := body.Utxorpc()
519+
if err != nil {
520+
t.Errorf("Failed to convert the transaction")
521+
}
516522

517523
// Assertion checks
518524
if got.Fee != 50 {
@@ -572,7 +578,10 @@ func TestAlonzoTransaction_Utxorpc(t *testing.T) {
572578
}
573579

574580
// Run Utxorpc conversion
575-
got := tx.Utxorpc()
581+
got, err := tx.Utxorpc()
582+
if err != nil {
583+
t.Errorf("Failed to convert the transaction")
584+
}
576585

577586
// Assertion checks
578587
if got.Fee != 75 {

‎ledger/babbage/babbage.go‎

Lines changed: 14 additions & 7 deletions
Original file line numberDiff line numberDiff line change
@@ -123,10 +123,13 @@ func (b *BabbageBlock) Transactions() []common.Transaction {
123123
return ret
124124
}
125125

126-
func (b *BabbageBlock) Utxorpc() *utxorpc.Block {
126+
func (b *BabbageBlock) Utxorpc() (*utxorpc.Block, error) {
127127
txs := []*utxorpc.Tx{}
128128
for _, t := range b.Transactions() {
129-
tx := t.Utxorpc()
129+
tx, err := t.Utxorpc()
130+
if err != nil {
131+
return nil, err
132+
}
130133
txs = append(txs, tx)
131134
}
132135
body := &utxorpc.BlockBody{
@@ -141,7 +144,7 @@ func (b *BabbageBlock) Utxorpc() *utxorpc.Block {
141144
Body: body,
142145
Header: header,
143146
}
144-
return block
147+
return block, nil
145148
}
146149

147150
type BabbageBlockHeader struct {
@@ -353,8 +356,8 @@ func (b *BabbageTransactionBody) TotalCollateral() uint64 {
353356
return b.TxTotalCollateral
354357
}
355358

356-
func (b *BabbageTransactionBody) Utxorpc() *utxorpc.Tx {
357-
return common.TransactionBodyToUtxorpc(b)
359+
func (b *BabbageTransactionBody) Utxorpc() (*utxorpc.Tx, error) {
360+
return common.TransactionBodyToUtxorpc(b), nil
358361
}
359362

360363
const (
@@ -799,8 +802,12 @@ func (t *BabbageTransaction) Cbor() []byte {
799802
return cborData
800803
}
801804

802-
func (t *BabbageTransaction) Utxorpc() *utxorpc.Tx {
803-
return t.Body.Utxorpc()
805+
func (t *BabbageTransaction) Utxorpc() (*utxorpc.Tx, error) {
806+
tx, err := t.Body.Utxorpc()
807+
if err != nil {
808+
return nil, fmt.Errorf("failed to convert Babbage transaction: %w", err)
809+
}
810+
return tx, nil
804811
}
805812

806813
func NewBabbageBlockFromCbor(data []byte) (*BabbageBlock, error) {

‎ledger/babbage/babbage_test.go‎

Lines changed: 4 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -2731,7 +2731,10 @@ func TestBabbageBlock_Utxorpc(t *testing.T) {
27312731
assert.NotNil(t, babbageBlock.TransactionBodies)
27322732
assert.NotNil(t, babbageBlock.TransactionWitnessSets)
27332733

2734-
utxoBlock := babbageBlock.Utxorpc()
2734+
utxoBlock, err := babbageBlock.Utxorpc()
2735+
if err != nil {
2736+
t.Fatalf("Utxorpc() failed: %v", err)
2737+
}
27352738

27362739
// Validate the resulting utxorpc.Block
27372740
assert.NotNil(t, utxoBlock)

‎ledger/babbage/pparams.go‎

Lines changed: 8 additions & 7 deletions
Original file line numberDiff line numberDiff line change
@@ -15,6 +15,7 @@
1515
package babbage
1616

1717
import (
18+
"fmt"
1819
"math"
1920

2021
"github.com/blinklabs-io/gouroboros/cbor"
@@ -162,32 +163,32 @@ func (u *BabbageProtocolParameterUpdate) UnmarshalCBOR(cborData []byte) error {
162163
return nil
163164
}
164165

165-
func (p *BabbageProtocolParameters) Utxorpc() *cardano.PParams {
166+
func (p *BabbageProtocolParameters) Utxorpc() (*cardano.PParams, error) {
166167
// sanity check
167168
if p.A0.Num().Int64() > math.MaxInt32 ||
168169
p.A0.Denom().Int64() < 0 ||
169170
p.A0.Denom().Int64() > math.MaxUint32 {
170-
return nil
171+
return nil, fmt.Errorf("invalid A0 rational number values")
171172
}
172173
if p.Rho.Num().Int64() > math.MaxInt32 ||
173174
p.Rho.Denom().Int64() < 0 ||
174175
p.Rho.Denom().Int64() > math.MaxUint32 {
175-
return nil
176+
return nil, fmt.Errorf("invalid Rho rational number values")
176177
}
177178
if p.Tau.Num().Int64() > math.MaxInt32 ||
178179
p.Tau.Denom().Int64() < 0 ||
179180
p.Tau.Denom().Int64() > math.MaxUint32 {
180-
return nil
181+
return nil, fmt.Errorf("invalid Tau rational number values")
181182
}
182183
if p.ExecutionCosts.MemPrice.Num().Int64() > math.MaxInt32 ||
183184
p.ExecutionCosts.MemPrice.Denom().Int64() < 0 ||
184185
p.ExecutionCosts.MemPrice.Denom().Int64() > math.MaxUint32 {
185-
return nil
186+
return nil, fmt.Errorf("invalid memory price rational number values")
186187
}
187188
if p.ExecutionCosts.StepPrice.Num().Int64() > math.MaxInt32 ||
188189
p.ExecutionCosts.StepPrice.Denom().Int64() < 0 ||
189190
p.ExecutionCosts.StepPrice.Denom().Int64() > math.MaxUint32 {
190-
return nil
191+
return nil, fmt.Errorf("invalid step price rational number values")
191192
}
192193
// #nosec G115
193194
return &cardano.PParams{
@@ -242,7 +243,7 @@ func (p *BabbageProtocolParameters) Utxorpc() *cardano.PParams {
242243
Memory: p.MaxBlockExUnits.Memory,
243244
Steps: p.MaxBlockExUnits.Steps,
244245
},
245-
}
246+
}, nil
246247
}
247248

248249
func UpgradePParams(

‎ledger/babbage/pparams_test.go‎

Lines changed: 16 additions & 6 deletions
Original file line numberDiff line numberDiff line change
@@ -545,7 +545,10 @@ func TestBabbageUtxorpc(t *testing.T) {
545545
}
546546

547547
for _, testDef := range testDefs {
548-
result := testDef.startParams.Utxorpc()
548+
result, err := testDef.startParams.Utxorpc()
549+
if err != nil {
550+
t.Fatalf("Utxorpc() failed: %v", err)
551+
}
549552
if !reflect.DeepEqual(result, testDef.expectedUtxorpc) {
550553
t.Fatalf(
551554
"Utxorpc() test failed:\nExpected: %#v\nGot: %#v",
@@ -563,7 +566,10 @@ func TestBabbageTransactionInput_Utxorpc(t *testing.T) {
563566
2,
564567
)
565568

566-
got := input.Utxorpc()
569+
got, err := input.Utxorpc()
570+
if err != nil {
571+
t.Fatalf("Utxorpc() failed: %v", err)
572+
}
567573
want := &cardano.TxInput{
568574
TxHash: input.Id().Bytes(),
569575
OutputIndex: input.Index(),
@@ -629,8 +635,10 @@ func TestBabbageTransactionBody_Utxorpc(t *testing.T) {
629635
TxFee: 100,
630636
}
631637

632-
got := body.Utxorpc()
633-
638+
got, err := body.Utxorpc()
639+
if err != nil {
640+
t.Fatalf("Utxorpc() conversion failed: %v", err)
641+
}
634642
if got.Fee != 100 {
635643
t.Errorf("Fee mismatch: got %d, want 100", got.Fee)
636644
}
@@ -672,8 +680,10 @@ func TestBabbageTransaction_Utxorpc(t *testing.T) {
672680
TxIsValid: true,
673681
}
674682

675-
got := tx.Utxorpc()
676-
683+
got, err := tx.Utxorpc()
684+
if err != nil {
685+
t.Fatalf("Utxorpc() failed: %v", err)
686+
}
677687
if got.Fee != 150 {
678688
t.Errorf("Fee mismatch: got %d, want 150", got.Fee)
679689
}

0 commit comments

Comments
 (0)