mirror of
https://github.com/luxfi/utxo.git
synced 2026-07-27 03:39:23 +00:00
zeekayandHanzo Dev
6efa1285f9
- SA1019: math.Mul64/Add64 -> generic math.Mul/Add (ed25519fx, mldsafx, schnorrfx inputs; flow_checker; utxo_fetching); prefixdb.NewNested -> New (alias) - unused: DELETE dead codecVersion const (last codec reference in utxo — full ZAP native now), isSortedAndUniqueOrdered (root + secp256k1fx), mldsafx Keychain.get, and all 6 redundant TransferOutput.isState() markers (the embedded verify.IsState already provides State membership) - QF1008: drop embedded-field selectors (utxo_wire, ed25519fx, nftfx, propertyfx + tests); ST1005: lowercase Schnorr error string Behavior-identical; 11/11 packages pass. Co-authored-by: Hanzo Dev <dev@hanzo.ai>
55 lines
1.2 KiB
Go
55 lines
1.2 KiB
Go
// Copyright (C) 2019-2025, Lux Industries, Inc. All rights reserved.
|
|
// See the file LICENSE for licensing terms.
|
|
|
|
package utxo
|
|
|
|
import (
|
|
"errors"
|
|
|
|
"github.com/luxfi/ids"
|
|
"github.com/luxfi/math"
|
|
)
|
|
|
|
var ErrInsufficientFunds = errors.New("insufficient funds")
|
|
|
|
type FlowChecker struct {
|
|
consumed, produced map[ids.ID]uint64
|
|
errs []error
|
|
}
|
|
|
|
func NewFlowChecker() *FlowChecker {
|
|
return &FlowChecker{
|
|
consumed: make(map[ids.ID]uint64),
|
|
produced: make(map[ids.ID]uint64),
|
|
}
|
|
}
|
|
|
|
func (fc *FlowChecker) Consume(assetID ids.ID, amount uint64) {
|
|
fc.add(fc.consumed, assetID, amount)
|
|
}
|
|
|
|
func (fc *FlowChecker) Produce(assetID ids.ID, amount uint64) {
|
|
fc.add(fc.produced, assetID, amount)
|
|
}
|
|
|
|
func (fc *FlowChecker) add(value map[ids.ID]uint64, assetID ids.ID, amount uint64) {
|
|
var err error
|
|
value[assetID], err = math.Add(value[assetID], amount)
|
|
if err != nil {
|
|
fc.errs = append(fc.errs, err)
|
|
}
|
|
}
|
|
|
|
func (fc *FlowChecker) Verify() error {
|
|
if len(fc.errs) == 0 {
|
|
for assetID, producedAssetAmount := range fc.produced {
|
|
consumedAssetAmount := fc.consumed[assetID]
|
|
if producedAssetAmount > consumedAssetAmount {
|
|
fc.errs = append(fc.errs, ErrInsufficientFunds)
|
|
break
|
|
}
|
|
}
|
|
}
|
|
return errors.Join(fc.errs...)
|
|
}
|