// serflag variables for input types.
const (
- IssuanceInputType uint8 = iota
+ CrossChainInputType uint8 = iota
SpendInputType
CoinbaseInputType
+ VetoInputType
)
type (
}
)
-var errBadAssetID = errors.New("asset ID does not match other issuance parameters")
-
// AssetAmount return the asset id and amount of the txinput.
func (t *TxInput) AssetAmount() bc.AssetAmount {
switch inp := t.TypedInput.(type) {
- case *IssuanceInput:
- assetID := inp.AssetID()
- return bc.AssetAmount{
- AssetId: &assetID,
- Amount: inp.Amount,
- }
case *SpendInput:
return inp.AssetAmount
+
+ case *CrossChainInput:
+ return inp.AssetAmount
+
+ case *VetoInput:
+ return inp.AssetAmount
}
+
return bc.AssetAmount{}
}
// AssetID return the assetID of the txinput
func (t *TxInput) AssetID() bc.AssetID {
switch inp := t.TypedInput.(type) {
- case *IssuanceInput:
- return inp.AssetID()
case *SpendInput:
return *inp.AssetId
+ case *CrossChainInput:
+ return *inp.AssetAmount.AssetId
+
+ case *VetoInput:
+ return *inp.AssetId
+
}
return bc.AssetID{}
}
// Amount return the asset amount of the txinput
func (t *TxInput) Amount() uint64 {
switch inp := t.TypedInput.(type) {
- case *IssuanceInput:
- return inp.Amount
case *SpendInput:
return inp.Amount
+
+ case *CrossChainInput:
+ return inp.AssetAmount.Amount
+
+ case *VetoInput:
+ return inp.Amount
+
}
return 0
}
// ControlProgram return the control program of the spend input
func (t *TxInput) ControlProgram() []byte {
- if si, ok := t.TypedInput.(*SpendInput); ok {
- return si.ControlProgram
- }
- return nil
-}
+ switch inp := t.TypedInput.(type) {
+ case *SpendInput:
+ return inp.ControlProgram
-// IssuanceProgram return the control program of the issuance input
-func (t *TxInput) IssuanceProgram() []byte {
- if ii, ok := t.TypedInput.(*IssuanceInput); ok {
- return ii.IssuanceProgram
- }
- return nil
-}
+ case *CrossChainInput:
+ return inp.ControlProgram
+
+ case *VetoInput:
+ return inp.ControlProgram
-// AssetDefinition return the asset definition of the issuance input
-func (t *TxInput) AssetDefinition() []byte {
- if ii, ok := t.TypedInput.(*IssuanceInput); ok {
- return ii.AssetDefinition
}
+
return nil
}
// Arguments get the args for the input
func (t *TxInput) Arguments() [][]byte {
switch inp := t.TypedInput.(type) {
- case *IssuanceInput:
- return inp.Arguments
case *SpendInput:
return inp.Arguments
+
+ case *CrossChainInput:
+ return inp.Arguments
+
+ case *VetoInput:
+ return inp.Arguments
}
return nil
}
// SetArguments set the args for the input
func (t *TxInput) SetArguments(args [][]byte) {
switch inp := t.TypedInput.(type) {
- case *IssuanceInput:
- inp.Arguments = args
case *SpendInput:
inp.Arguments = args
+
+ case *CrossChainInput:
+ inp.Arguments = args
+
+ case *VetoInput:
+ inp.Arguments = args
}
}
// SpentOutputID calculate the hash of spended output
func (t *TxInput) SpentOutputID() (o bc.Hash, err error) {
- if si, ok := t.TypedInput.(*SpendInput); ok {
- o, err = ComputeOutputID(&si.SpendCommitment)
+ switch inp := t.TypedInput.(type) {
+ case *SpendInput:
+ o, err = ComputeOutputID(&inp.SpendCommitment, SpendInputType, nil)
+
+ case *VetoInput:
+ o, err = ComputeOutputID(&inp.SpendCommitment, VetoInputType, inp.Vote)
+
+ case *CrossChainInput:
+ o, err = ComputeOutputID(&inp.SpendCommitment, SpendInputType, nil)
}
+
return o, err
}
return err
}
- var assetID bc.AssetID
t.CommitmentSuffix, err = blockchain.ReadExtensibleString(r, func(r *blockchain.Reader) error {
if t.AssetVersion != 1 {
return nil
if _, err = io.ReadFull(r, icType[:]); err != nil {
return errors.Wrap(err, "reading input commitment type")
}
- switch icType[0] {
- case IssuanceInputType:
- ii := new(IssuanceInput)
- t.TypedInput = ii
-
- if ii.Nonce, err = blockchain.ReadVarstr31(r); err != nil {
- return err
- }
- if _, err = assetID.ReadFrom(r); err != nil {
- return err
- }
- if ii.Amount, err = blockchain.ReadVarint63(r); err != nil {
- return err
- }
+ switch icType[0] {
case SpendInputType:
si := new(SpendInput)
t.TypedInput = si
return err
}
+ case CrossChainInputType:
+ ci := new(CrossChainInput)
+ t.TypedInput = ci
+ if ci.SpendCommitmentSuffix, err = ci.SpendCommitment.readFrom(r, 1); err != nil {
+ return err
+ }
+
+ if ci.IssuanceVMVersion, err = blockchain.ReadVarint63(r); err != nil {
+ return err
+ }
+
+ if ci.AssetDefinition, err = blockchain.ReadVarstr31(r); err != nil {
+ return err
+ }
+
+ if ci.IssuanceProgram, err = blockchain.ReadVarstr31(r); err != nil {
+ return err
+ }
+
+ case VetoInputType:
+ ui := new(VetoInput)
+ t.TypedInput = ui
+ if ui.VetoCommitmentSuffix, err = ui.SpendCommitment.readFrom(r, 1); err != nil {
+ return err
+ }
+
+ if ui.Vote, err = blockchain.ReadVarstr31(r); err != nil {
+ return err
+ }
+
default:
return fmt.Errorf("unsupported input type %d", icType[0])
}
return nil
}
+ var err error
switch inp := t.TypedInput.(type) {
- case *IssuanceInput:
- if inp.AssetDefinition, err = blockchain.ReadVarstr31(r); err != nil {
- return err
- }
- if inp.VMVersion, err = blockchain.ReadVarint63(r); err != nil {
- return err
- }
- if inp.IssuanceProgram, err = blockchain.ReadVarstr31(r); err != nil {
- return err
- }
- if inp.AssetID() != assetID {
- return errBadAssetID
- }
- if inp.Arguments, err = blockchain.ReadVarstrList(r); err != nil {
- return err
- }
-
case *SpendInput:
- if inp.Arguments, err = blockchain.ReadVarstrList(r); err != nil {
- return err
- }
+ inp.Arguments, err = blockchain.ReadVarstrList(r)
+
+ case *CrossChainInput:
+ inp.Arguments, err = blockchain.ReadVarstrList(r)
+
+ case *VetoInput:
+ inp.Arguments, err = blockchain.ReadVarstrList(r)
}
- return nil
- })
+ return err
+ })
return err
}
return errors.Wrap(err, "writing input commitment")
}
- _, err := blockchain.WriteExtensibleString(w, t.WitnessSuffix, t.writeInputWitness)
- return errors.Wrap(err, "writing input witness")
+ if _, err := blockchain.WriteExtensibleString(w, t.WitnessSuffix, t.writeInputWitness); err != nil {
+ return errors.Wrap(err, "writing input witness")
+ }
+
+ return nil
}
func (t *TxInput) writeInputCommitment(w io.Writer) (err error) {
}
switch inp := t.TypedInput.(type) {
- case *IssuanceInput:
- if _, err = w.Write([]byte{IssuanceInputType}); err != nil {
+ case *SpendInput:
+ if _, err = w.Write([]byte{SpendInputType}); err != nil {
return err
}
- if _, err = blockchain.WriteVarstr31(w, inp.Nonce); err != nil {
+
+ return inp.SpendCommitment.writeExtensibleString(w, inp.SpendCommitmentSuffix, t.AssetVersion)
+
+ case *CrossChainInput:
+ if _, err = w.Write([]byte{CrossChainInputType}); err != nil {
return err
}
- assetID := t.AssetID()
- if _, err = assetID.WriteTo(w); err != nil {
+
+ if err := inp.SpendCommitment.writeExtensibleString(w, inp.SpendCommitmentSuffix, t.AssetVersion); err != nil {
return err
}
- _, err = blockchain.WriteVarint63(w, inp.Amount)
- return err
- case *SpendInput:
- if _, err = w.Write([]byte{SpendInputType}); err != nil {
+ if _, err := blockchain.WriteVarint63(w, inp.IssuanceVMVersion); err != nil {
+ return err
+ }
+
+ if _, err := blockchain.WriteVarstr31(w, inp.AssetDefinition); err != nil {
+ return err
+ }
+
+ if _, err := blockchain.WriteVarstr31(w, inp.IssuanceProgram); err != nil {
return err
}
- return inp.SpendCommitment.writeExtensibleString(w, inp.SpendCommitmentSuffix, t.AssetVersion)
case *CoinbaseInput:
- if _, err = w.Write([]byte{CoinbaseInputType}); err != nil {
+ if _, err := w.Write([]byte{CoinbaseInputType}); err != nil {
return err
}
- if _, err = blockchain.WriteVarstr31(w, inp.Arbitrary); err != nil {
+
+ if _, err := blockchain.WriteVarstr31(w, inp.Arbitrary); err != nil {
return errors.Wrap(err, "writing coinbase arbitrary")
}
+
+ case *VetoInput:
+ if _, err = w.Write([]byte{VetoInputType}); err != nil {
+ return err
+ }
+
+ if err := inp.SpendCommitment.writeExtensibleString(w, inp.VetoCommitmentSuffix, t.AssetVersion); err != nil {
+ return err
+ }
+
+ _, err := blockchain.WriteVarstr31(w, inp.Vote)
+ return err
}
return nil
}
if t.AssetVersion != 1 {
return nil
}
- switch inp := t.TypedInput.(type) {
- case *IssuanceInput:
- if _, err := blockchain.WriteVarstr31(w, inp.AssetDefinition); err != nil {
- return err
- }
- if _, err := blockchain.WriteVarint63(w, inp.VMVersion); err != nil {
- return err
- }
- if _, err := blockchain.WriteVarstr31(w, inp.IssuanceProgram); err != nil {
- return err
- }
- _, err := blockchain.WriteVarstrList(w, inp.Arguments)
- return err
+ var err error
+ switch inp := t.TypedInput.(type) {
case *SpendInput:
- _, err := blockchain.WriteVarstrList(w, inp.Arguments)
- return err
+ _, err = blockchain.WriteVarstrList(w, inp.Arguments)
+
+ case *CrossChainInput:
+ _, err = blockchain.WriteVarstrList(w, inp.Arguments)
+
+ case *VetoInput:
+ _, err = blockchain.WriteVarstrList(w, inp.Arguments)
}
- return nil
+ return err
}
OSDN Git Service
