cash

package
v0.14.0 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Apr 10, 2019 License: Apache-2.0 Imports: 11 Imported by: 0

Documentation

Overview

Package cash defines a simple implementation of sending coins between multi-signature wallets.

There is no logic in the coins (tokens), except that the balance of any coin may not go below zero. Thus, this implementation is referred to as cash. Simple and safe.

In the future, there should be more implementations that support sending and issuing tokens with much more logic inside.

Index

Constants

View Source
const (
	GconfCollectorAddress = "cash:collector_address"
	GconfMinimalFee       = "cash:minimal_fee"
)
View Source
const BucketName = "cash"

BucketName is where we store the balances

Variables

View Source
var (
	ErrInvalidLengthCodec = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowCodec   = fmt.Errorf("proto: integer overflow")
)

Functions

func Add

func Add(cng Coinage, c coin.Coin) error

Add modifies the coinage to add Coin c

func AsCoins

func AsCoins(obj orm.Object) coin.Coins

AsCoins will extract XCoins from any object

func Concat

func Concat(cng Coinage, coins coin.Coins) error

Concat combines the coins to make sure they are sorted and rounded off, with no duplicates or 0 values.

func NewWallet

func NewWallet(key weave.Address) orm.Object

NewWallet creates an empty wallet with this address serves as an object for the bucket

func RegisterQuery

func RegisterQuery(qr weave.QueryRouter)

RegisterQuery will register this bucket as "/wallets"

func RegisterRoutes

func RegisterRoutes(r weave.Registry, auth x.Authenticator,
	control Controller)

RegisterRoutes will instantiate and register all handlers in this package

func Subtract

func Subtract(cng Coinage, c coin.Coin) error

Subtract modifies the coinage to remove Coin c

func ValidateWalletBucket

func ValidateWalletBucket(bucket WalletBucket)

ValidateWalletBucket makes sure that it supports AsCoinage objects, unfortunately this check is done runtime....

panics on error (meant as a sanity check in init)

func WalletWith

func WalletWith(key weave.Address, coins ...*coin.Coin) (orm.Object, error)

WalletWith creates an wallet with a balance

func XCoins

func XCoins(c Coinage) coin.Coins

XCoins returns the stored coins cast properly

Types

type Balancer added in v0.12.0

type Balancer interface {
	// Balance returns the amount of funds stored under given account address.
	Balance(weave.KVStore, weave.Address) (coin.Coins, error)
}

Balancer is an interface to query the amount of coins.

type BaseController

type BaseController struct {
	// contains filtered or unexported fields
}

BaseController implements Controller interface, using WalletBucket as the storage engine. Wallet must return something that supports AsSet.

func NewController

func NewController(bucket WalletBucket) BaseController

NewController returns a base controller implementation.

func (BaseController) Balance added in v0.12.0

func (c BaseController) Balance(store weave.KVStore, src weave.Address) (coin.Coins, error)

Balance returns the amount of funds stored under given account address.

func (BaseController) CoinMint added in v0.12.0

func (c BaseController) CoinMint(store weave.KVStore,
	dest weave.Address, amount coin.Coin) error

CoinMint attempts to add the given amount of coins to the destination address. Fails if it overflows the wallet.

Note the amount may also be negative: "the lord giveth and the lord taketh away"

func (BaseController) MoveCoins

func (c BaseController) MoveCoins(store weave.KVStore,
	src weave.Address, dest weave.Address, amount coin.Coin) error

MoveCoins moves the given amount from src to dest. If src doesn't exist, or doesn't have sufficient coins, it fails.

type Bucket

type Bucket struct {
	orm.Bucket
}

Bucket is a type-safe wrapper around orm.Bucket

func NewBucket

func NewBucket() Bucket

NewBucket initializes a cash.Bucket with default name

func (Bucket) GetOrCreate

func (b Bucket) GetOrCreate(db weave.KVStore, key weave.Address) (orm.Object, error)

GetOrCreate will return the object if found, or create one if not.

type CoinMinter added in v0.12.0

type CoinMinter interface {
	// CoinMint increase the number of funds on given accouunt by a
	// specified amount.
	CoinMint(weave.KVStore, weave.Address, coin.Coin) error
}

CoinMinter is an interface to create new coins.

type CoinMover added in v0.12.0

type CoinMover interface {
	// Moving coins must happen from the source to the destination address.
	// Zero or negative values must result in an error.
	MoveCoins(store weave.KVStore, src weave.Address, dest weave.Address, amount coin.Coin) error
}

CoinsMover is an interface for moving coins between accounts.

type Coinage

type Coinage interface {
	GetCoins() []*coin.Coin
	SetCoins([]*coin.Coin)
}

Coinage is any model that allows getting and setting coins, Below functions work on these models (oh, how I long for default implementations for interface, like rust traits)

func AsCoinage

func AsCoinage(obj orm.Object) Coinage

AsCoinage will safely type-cast any value from Bucket to Coinage

type Controller

type Controller interface {
	CoinMover
	Balancer
}

Controller is the functionality needed by cash.Handler and cash.Decorator. BaseController should work plenty fine, but you can add other logic if so desired

type DynamicFeeDecorator added in v0.12.0

type DynamicFeeDecorator struct {
	// contains filtered or unexported fields
}

func NewDynamicFeeDecorator added in v0.12.0

func NewDynamicFeeDecorator(auth x.Authenticator, ctrl Controller) DynamicFeeDecorator

NewDynamicFeeDecorator returns a DynamicFeeDecorator with the given minimum fee, and all collected fees going to a default address.

func (DynamicFeeDecorator) Check added in v0.12.0

func (d DynamicFeeDecorator) Check(ctx weave.Context, store weave.KVStore, tx weave.Tx, next weave.Checker) (cres weave.CheckResult, cerr error)

Check verifies and deducts fees before calling down the stack

func (DynamicFeeDecorator) Deliver added in v0.12.0

func (d DynamicFeeDecorator) Deliver(ctx weave.Context, store weave.KVStore, tx weave.Tx, next weave.Deliverer) (dres weave.DeliverResult, derr error)

Deliver verifies and deducts fees before calling down the stack

type FeeDecorator

type FeeDecorator struct {
	// contains filtered or unexported fields
}

func NewFeeDecorator

func NewFeeDecorator(auth x.Authenticator, ctrl CoinMover) FeeDecorator

NewFeeDecorator returns a FeeDecorator with the given minimum fee, and all collected fees going to a default address.

func (FeeDecorator) Check

func (d FeeDecorator) Check(ctx weave.Context, store weave.KVStore, tx weave.Tx,
	next weave.Checker) (weave.CheckResult, error)

Check verifies and deducts fees before calling down the stack

func (FeeDecorator) Deliver

func (d FeeDecorator) Deliver(ctx weave.Context, store weave.KVStore, tx weave.Tx,
	next weave.Deliverer) (weave.DeliverResult, error)

Deliver verifies and deducts fees before calling down the stack

type FeeInfo

type FeeInfo struct {
	Payer []byte     `protobuf:"bytes,1,opt,name=payer,proto3" json:"payer,omitempty"`
	Fees  *coin.Coin `protobuf:"bytes,2,opt,name=fees,proto3" json:"fees,omitempty"`
}

FeeInfo records who pays what fees to have this message processed

func (*FeeInfo) DefaultPayer

func (f *FeeInfo) DefaultPayer(addr []byte) *FeeInfo

DefaultPayer makes sure there is a payer. If it was already set, returns f. If none was set, returns a new FeeInfo, with the New address set

func (*FeeInfo) Descriptor

func (*FeeInfo) Descriptor() ([]byte, []int)

func (*FeeInfo) GetFees

func (m *FeeInfo) GetFees() *coin.Coin

func (*FeeInfo) GetPayer

func (m *FeeInfo) GetPayer() []byte

func (*FeeInfo) Marshal

func (m *FeeInfo) Marshal() (dAtA []byte, err error)

func (*FeeInfo) MarshalTo

func (m *FeeInfo) MarshalTo(dAtA []byte) (int, error)

func (*FeeInfo) ProtoMessage

func (*FeeInfo) ProtoMessage()

func (*FeeInfo) Reset

func (m *FeeInfo) Reset()

func (*FeeInfo) Size

func (m *FeeInfo) Size() (n int)

func (*FeeInfo) String

func (m *FeeInfo) String() string

func (*FeeInfo) Unmarshal

func (m *FeeInfo) Unmarshal(dAtA []byte) error

func (*FeeInfo) Validate

func (f *FeeInfo) Validate() error

Validate makes sure that this is sensible. Note that fee must be present, even if 0

func (*FeeInfo) XXX_DiscardUnknown added in v0.12.0

func (m *FeeInfo) XXX_DiscardUnknown()

func (*FeeInfo) XXX_Marshal added in v0.12.0

func (m *FeeInfo) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*FeeInfo) XXX_Merge added in v0.12.0

func (m *FeeInfo) XXX_Merge(src proto.Message)

func (*FeeInfo) XXX_Size added in v0.12.0

func (m *FeeInfo) XXX_Size() int

func (*FeeInfo) XXX_Unmarshal added in v0.12.0

func (m *FeeInfo) XXX_Unmarshal(b []byte) error

type FeeTx

type FeeTx interface {
	GetFees() *FeeInfo
}

FeeTx exposes information about the fees that should be paid

type GenesisAccount

type GenesisAccount struct {
	Address weave.Address `json:"address"`
	Set
}

GenesisAccount is used to parse the json from genesis file use weave.Address, so address in hex, not base64

type Initializer

type Initializer struct{}

Initializer fulfils the InitStater interface to load data from the genesis file

func (Initializer) FromGenesis

func (Initializer) FromGenesis(opts weave.Options, kv weave.KVStore) error

FromGenesis will parse initial account info from genesis and save it to the database

type SendHandler

type SendHandler struct {
	// contains filtered or unexported fields
}

SendHandler will handle sending coins

func NewSendHandler

func NewSendHandler(auth x.Authenticator, control Controller) SendHandler

NewSendHandler creates a handler for SendMsg

func (SendHandler) Check

func (h SendHandler) Check(ctx weave.Context, store weave.KVStore, tx weave.Tx) (weave.CheckResult, error)

Check just verifies it is properly formed and returns the cost of executing it

func (SendHandler) Deliver

func (h SendHandler) Deliver(ctx weave.Context, store weave.KVStore, tx weave.Tx) (weave.DeliverResult, error)

Deliver moves the tokens from sender to receiver if all preconditions are met

type SendMsg

type SendMsg struct {
	Src    []byte     `protobuf:"bytes,1,opt,name=src,proto3" json:"src,omitempty"`
	Dest   []byte     `protobuf:"bytes,2,opt,name=dest,proto3" json:"dest,omitempty"`
	Amount *coin.Coin `protobuf:"bytes,3,opt,name=amount,proto3" json:"amount,omitempty"`
	// max length 128 character
	Memo string `protobuf:"bytes,4,opt,name=memo,proto3" json:"memo,omitempty"`
	// max length 64 bytes
	Ref []byte `protobuf:"bytes,5,opt,name=ref,proto3" json:"ref,omitempty"`
}

SendMsg is a request to move these coins from the given source to the given destination address. memo is an optional human-readable message ref is optional binary data, that can refer to another eg. tx hash

func (*SendMsg) DefaultSource

func (s *SendMsg) DefaultSource(addr []byte) *SendMsg

DefaultSource makes sure there is a payer. If it was already set, returns s. If none was set, returns a new SendMsg with the source set

func (*SendMsg) Descriptor

func (*SendMsg) Descriptor() ([]byte, []int)

func (*SendMsg) GetAmount

func (m *SendMsg) GetAmount() *coin.Coin

func (*SendMsg) GetDest

func (m *SendMsg) GetDest() []byte

func (*SendMsg) GetMemo

func (m *SendMsg) GetMemo() string

func (*SendMsg) GetRef

func (m *SendMsg) GetRef() []byte

func (*SendMsg) GetSrc

func (m *SendMsg) GetSrc() []byte

func (*SendMsg) Marshal

func (m *SendMsg) Marshal() (dAtA []byte, err error)

func (*SendMsg) MarshalTo

func (m *SendMsg) MarshalTo(dAtA []byte) (int, error)

func (SendMsg) Path

func (SendMsg) Path() string

Path returns the routing path for this message

func (*SendMsg) ProtoMessage

func (*SendMsg) ProtoMessage()

func (*SendMsg) Reset

func (m *SendMsg) Reset()

func (*SendMsg) Size

func (m *SendMsg) Size() (n int)

func (*SendMsg) String

func (m *SendMsg) String() string

func (*SendMsg) Unmarshal

func (m *SendMsg) Unmarshal(dAtA []byte) error

func (*SendMsg) Validate

func (s *SendMsg) Validate() error

Validate makes sure that this is sensible

func (*SendMsg) XXX_DiscardUnknown added in v0.12.0

func (m *SendMsg) XXX_DiscardUnknown()

func (*SendMsg) XXX_Marshal added in v0.12.0

func (m *SendMsg) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*SendMsg) XXX_Merge added in v0.12.0

func (m *SendMsg) XXX_Merge(src proto.Message)

func (*SendMsg) XXX_Size added in v0.12.0

func (m *SendMsg) XXX_Size() int

func (*SendMsg) XXX_Unmarshal added in v0.12.0

func (m *SendMsg) XXX_Unmarshal(b []byte) error

type Set

type Set struct {
	Coins []*coin.Coin `protobuf:"bytes,1,rep,name=coins,proto3" json:"coins,omitempty"`
}

Set may contain Coin of many different currencies. It handles adding and subtracting sets of currencies.

func (*Set) Copy

func (s *Set) Copy() orm.CloneableData

Copy makes a new set with the same coins

func (*Set) Descriptor

func (*Set) Descriptor() ([]byte, []int)

func (*Set) GetCoins

func (m *Set) GetCoins() []*coin.Coin

func (*Set) Marshal

func (m *Set) Marshal() (dAtA []byte, err error)

func (*Set) MarshalTo

func (m *Set) MarshalTo(dAtA []byte) (int, error)

func (*Set) ProtoMessage

func (*Set) ProtoMessage()

func (*Set) Reset

func (m *Set) Reset()

func (*Set) SetCoins

func (s *Set) SetCoins(coins []*coin.Coin)

SetCoins allows us to modify the Set

func (*Set) Size

func (m *Set) Size() (n int)

func (*Set) String

func (m *Set) String() string

func (*Set) Unmarshal

func (m *Set) Unmarshal(dAtA []byte) error

func (*Set) Validate

func (s *Set) Validate() error

Validate requires that all coins are in alphabetical

func (*Set) XXX_DiscardUnknown added in v0.12.0

func (m *Set) XXX_DiscardUnknown()

func (*Set) XXX_Marshal added in v0.12.0

func (m *Set) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Set) XXX_Merge added in v0.12.0

func (m *Set) XXX_Merge(src proto.Message)

func (*Set) XXX_Size added in v0.12.0

func (m *Set) XXX_Size() int

func (*Set) XXX_Unmarshal added in v0.12.0

func (m *Set) XXX_Unmarshal(b []byte) error

type WalletBucket

type WalletBucket interface {
	GetOrCreate(db weave.KVStore, key weave.Address) (orm.Object, error)
	Get(db weave.ReadOnlyKVStore, key []byte) (orm.Object, error)
	Save(db weave.KVStore, obj orm.Object) error
}

WalletBucket is what we expect to be able to do with wallets The object it returns must support AsSet (only checked runtime :()

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL