Files
zeekay 021a8edace fix: resolve proto import paths and test compilation issues
- Fix dag package imports to use vm/proto/pb/dag instead of node/proto
- Fix api/health test to use atomic.Atomic from github.com/luxfi/atomic
- Fix components/message test to use crypto.RandomBytes
- Fix chains/manager to use correct EngineType constant
2026-01-11 20:58:38 -08:00

65 lines
1.6 KiB
Go

// Copyright (C) 2019-2025, Lux Industries, Inc. All rights reserved.
// See the file LICENSE for licensing terms.
package gas
import (
"errors"
"fmt"
"math"
safemath "github.com/luxfi/math"
)
var ErrInsufficientCapacity = errors.New("insufficient capacity")
type State struct {
Capacity Gas `serialize:"true" json:"capacity"`
Excess Gas `serialize:"true" json:"excess"`
}
// AdvanceTime adds maxPerSecond to capacity and subtracts targetPerSecond
// from excess over the provided duration.
//
// Capacity is capped at maxCapacity.
// Excess to be removed is capped at excess.
func (s State) AdvanceTime(
maxCapacity Gas,
maxPerSecond Gas,
targetPerSecond Gas,
duration uint64,
) State {
return State{
Capacity: min(
s.Capacity.AddPerSecond(maxPerSecond, duration),
maxCapacity,
),
Excess: s.Excess.SubPerSecond(targetPerSecond, duration),
}
}
// ConsumeGas removes gas from capacity and adds gas to excess.
//
// If the capacity is insufficient, an error is returned.
// If the excess would overflow, it is capped at MaxUint64.
func (s State) ConsumeGas(gas Gas) (State, error) {
newCapacity, err := safemath.Sub(uint64(s.Capacity), uint64(gas))
if err != nil {
return State{}, fmt.Errorf("%w: capacity (%d) < gas (%d)", ErrInsufficientCapacity, s.Capacity, gas)
}
newExcess, err := safemath.Add(uint64(s.Excess), uint64(gas))
if err != nil {
//nolint:nilerr // excess is capped at MaxUint64
return State{
Capacity: Gas(newCapacity),
Excess: math.MaxUint64,
}, nil
}
return State{
Capacity: Gas(newCapacity),
Excess: Gas(newExcess),
}, nil
}