Skip to content

Commit 02a47b2

Browse files
authored
fix(chainsync): Made the changes to emit an input event when Kupo lookups fail (#555)
Signed-off-by: Akhil Repala <arepala@blinklabs.io>
1 parent 22f50b0 commit 02a47b2

File tree

1 file changed

+12
-2
lines changed

1 file changed

+12
-2
lines changed

input/chainsync/chainsync.go

Lines changed: 12 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -409,7 +409,12 @@ func (c *ChainSync) handleRollForward(
409409
for t, transaction := range block.Transactions() {
410410
resolvedInputs, err := resolveTransactionInputs(transaction, c)
411411
if err != nil {
412-
return err
412+
slog.Error(
413+
"failed to resolve transaction inputs via Kupo, emitting without resolved inputs",
414+
"err",
415+
err,
416+
)
417+
resolvedInputs = nil
413418
}
414419
if t < 0 || t > math.MaxUint32 {
415420
return errors.New("invalid number of transactions")
@@ -491,7 +496,12 @@ func (c *ChainSync) handleBlockFetchBlock(
491496
for t, transaction := range block.Transactions() {
492497
resolvedInputs, err := resolveTransactionInputs(transaction, c)
493498
if err != nil {
494-
return err
499+
slog.Error(
500+
"failed to resolve transaction inputs via Kupo, emitting without resolved inputs",
501+
"err",
502+
err,
503+
)
504+
resolvedInputs = nil
495505
}
496506
if t < 0 || t > math.MaxUint32 {
497507
return errors.New("invalid number of transactions")

0 commit comments

Comments
 (0)