store

package
v0.17.1 Latest Latest
Warning

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

 Go to latest Published: Aug 14, 2024 License: Apache-2.0 Imports: 17 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var SCHEMA string

Functions

This section is empty.

Types

type ActionResult added in v0.16.0 

type ActionResult struct {
	ActionId     string
	Compaction   string
	Transactions []*mtg.Transaction
	RequestId    string
	CreatedAt    time.Time
}

type Asset 

type Asset struct {
	AssetId   string
	MixinId   string
	AssetKey  string
	Symbol    string
	Name      string
	Decimals  uint32
	Chain     byte
	CreatedAt time.Time
}

type Deposit added in v0.11.0 

type Deposit struct {
	TransactionHash string
	OutputIndex     int64
	AssetId         string
	Amount          string
	Receiver        string
	Sender          string
	State           int
	Chain           byte
	Holder          string
	Category        byte
	CreatedAt       time.Time
	UpdatedAt       time.Time
}

type Key 

type Key struct {
	Public    string
	Curve     byte
	RequestId string
	Role      byte
	Extra     string
	Flags     byte
	Holder    sql.NullString
	CreatedAt time.Time
	UpdatedAt time.Time
}

type MigrateAsset added in v0.13.0 

type MigrateAsset struct {
	SafeAssetId string
	Chain       byte
	Address     string
	AssetId     string
}

type NetworkInfo 

type NetworkInfo struct {
	RequestId string
	Chain     byte
	Fee       uint64
	Height    uint64
	Hash      string
	CreatedAt time.Time
}

type OperationParams added in v0.9.15 

type OperationParams struct {
	RequestId            string
	Chain                byte
	OperationPriceAsset  string
	OperationPriceAmount decimal.Decimal
	TransactionMinimum   decimal.Decimal
	CreatedAt            time.Time
}

type SQLite3Store 

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

func OpenSQLite3ReadOnlyStore 

func OpenSQLite3ReadOnlyStore(path string) (*SQLite3Store, error)

func OpenSQLite3Store 

func OpenSQLite3Store(path string) (*SQLite3Store, error)

func (*SQLite3Store) AssignSignerAndObserverToHolder 

func (s *SQLite3Store) AssignSignerAndObserverToHolder(ctx context.Context, req *common.Request, maturity time.Duration, observerPref string) (string, string, error)

func (*SQLite3Store) CheckFullyMigrated added in v0.13.1 

func (s *SQLite3Store) CheckFullyMigrated(ctx context.Context) bool

func (*SQLite3Store) CheckMigrateAsset added in v0.13.0 

func (s *SQLite3Store) CheckMigrateAsset(ctx context.Context, address, asset_id string) (bool, error)

func (*SQLite3Store) Close 

func (s *SQLite3Store) Close() error

func (*SQLite3Store) CloseAccountBySignatureRequestsWithRequest added in v0.8.0 

func (s *SQLite3Store) CloseAccountBySignatureRequestsWithRequest(ctx context.Context, requests []*SignatureRequest, transactionHash, raw string, req *common.Request, txs []*mtg.Transaction) error

func (*SQLite3Store) CloseAccountByTransactionWithRequest added in v0.8.0 

func (s *SQLite3Store) CloseAccountByTransactionWithRequest(ctx context.Context, trx *Transaction, utxos []*TransactionInput, utxoState int, txs []*mtg.Transaction, req *common.Request) error

func (*SQLite3Store) CountSpareKeys 

func (s *SQLite3Store) CountSpareKeys(ctx context.Context, curve, flags byte, role int) (int, error)

func (*SQLite3Store) CountTransactionsByState added in v0.17.1 

func (s *SQLite3Store) CountTransactionsByState(ctx context.Context, state byte) (int, error)

func (*SQLite3Store) CountUnfinishedTransactionsByHolder added in v0.8.0 

func (s *SQLite3Store) CountUnfinishedTransactionsByHolder(ctx context.Context, holder string) (int, error)

func (*SQLite3Store) CreateEthereumBalanceDepositFromRequest added in v0.13.0 

func (s *SQLite3Store) CreateEthereumBalanceDepositFromRequest(ctx context.Context, safe *Safe, sb *SafeBalance, txHash string, index int64, amount *big.Int, sender string, req *common.Request, txs []*mtg.Transaction) error

func (*SQLite3Store) FailAction added in v0.16.0 

func (s *SQLite3Store) FailAction(ctx context.Context, req *common.Request) error

func (*SQLite3Store) FailRequest added in v0.3.0 

func (s *SQLite3Store) FailRequest(ctx context.Context, req *common.Request, compaction string, txs []*mtg.Transaction) error

func (*SQLite3Store) FailTransactionWithRequest added in v0.11.0 

func (s *SQLite3Store) FailTransactionWithRequest(ctx context.Context, trx *Transaction, safe *Safe, req *common.Request, bm map[string]*SafeBalance, txs []*mtg.Transaction) error

func (*SQLite3Store) FinishSafeWithRequest added in v0.11.0 

func (s *SQLite3Store) FinishSafeWithRequest(ctx context.Context, transactionHash, raw string, req *common.Request, safe *Safe, txs []*mtg.Transaction) error

func (*SQLite3Store) FinishSignatureRequest 

func (s *SQLite3Store) FinishSignatureRequest(ctx context.Context, req *common.Request) error

func (*SQLite3Store) FinishTransactionSignaturesWithRequest 

func (s *SQLite3Store) FinishTransactionSignaturesWithRequest(ctx context.Context, transactionHash, psbt string, req *common.Request, num int64, safe *Safe, bm map[string]*SafeBalance, txs []*mtg.Transaction) error

func (*SQLite3Store) ListAllBitcoinUTXOsForHolder 

func (s *SQLite3Store) ListAllBitcoinUTXOsForHolder(ctx context.Context, holder string) ([]*bitcoin.Input, error)

func (*SQLite3Store) ListAllSignaturesForTransaction 

func (s *SQLite3Store) ListAllSignaturesForTransaction(ctx context.Context, transactionHash string, state int) (map[int]*SignatureRequest, error)

func (*SQLite3Store) ListPendingBitcoinUTXOsForHolder added in v0.10.0 

func (s *SQLite3Store) ListPendingBitcoinUTXOsForHolder(ctx context.Context, holder string) ([]*bitcoin.Input, error)

func (*SQLite3Store) ListSafesWithState added in v0.13.0 

func (s *SQLite3Store) ListSafesWithState(ctx context.Context, state int) ([]*Safe, error)

func (*SQLite3Store) ListUnmigratedSafesWithState added in v0.13.0 

func (s *SQLite3Store) ListUnmigratedSafesWithState(ctx context.Context) ([]*Safe, error)

func (*SQLite3Store) Migrate added in v0.11.0 

func (s *SQLite3Store) Migrate(ctx context.Context, ss, es []*MigrateAsset) error

FIXME remove this

func (*SQLite3Store) MigrateDepositCreated added in v0.13.2 

func (s *SQLite3Store) MigrateDepositCreated(ctx context.Context) error

FIXME remove this

func (*SQLite3Store) ReadActionResult added in v0.16.0 

func (s *SQLite3Store) ReadActionResult(ctx context.Context, outputId, requestId string) (*ActionResult, bool, error)

func (*SQLite3Store) ReadAllEthereumTokenBalances added in v0.13.0 

func (s *SQLite3Store) ReadAllEthereumTokenBalances(ctx context.Context, address string) ([]*SafeBalance, error)

func (*SQLite3Store) ReadAllEthereumTokenBalancesMap added in v0.13.0 

func (s *SQLite3Store) ReadAllEthereumTokenBalancesMap(ctx context.Context, address string) (map[string]*SafeBalance, error)

func (*SQLite3Store) ReadAssetMeta 

func (s *SQLite3Store) ReadAssetMeta(ctx context.Context, id string) (*Asset, error)

func (*SQLite3Store) ReadBitcoinUTXO 

func (s *SQLite3Store) ReadBitcoinUTXO(ctx context.Context, transactionHash string, index int) (*bitcoin.Input, string, error)

func (*SQLite3Store) ReadDeposit added in v0.11.0 

func (s *SQLite3Store) ReadDeposit(ctx context.Context, hash string, index int64) (*Deposit, error)

func (*SQLite3Store) ReadEthereumBalance added in v0.11.0 

func (s *SQLite3Store) ReadEthereumBalance(ctx context.Context, address, assetId, safeAssetId string) (*SafeBalance, error)

func (*SQLite3Store) ReadKey 

func (s *SQLite3Store) ReadKey(ctx context.Context, public string) (*Key, error)

func (*SQLite3Store) ReadLatestNetworkInfo 

func (s *SQLite3Store) ReadLatestNetworkInfo(ctx context.Context, chain byte, offset time.Time) (*NetworkInfo, error)

func (*SQLite3Store) ReadLatestOperationParams added in v0.9.17 

func (s *SQLite3Store) ReadLatestOperationParams(ctx context.Context, chain byte, offset time.Time) (*OperationParams, error)

func (*SQLite3Store) ReadLatestRequest 

func (s *SQLite3Store) ReadLatestRequest(ctx context.Context) (*common.Request, error)

func (*SQLite3Store) ReadNetworkInfo 

func (s *SQLite3Store) ReadNetworkInfo(ctx context.Context, id string) (*NetworkInfo, error)

func (*SQLite3Store) ReadPendingRequest 

func (s *SQLite3Store) ReadPendingRequest(ctx context.Context) (*common.Request, error)

func (*SQLite3Store) ReadProperty 

func (s *SQLite3Store) ReadProperty(ctx context.Context, k string) (string, error)

func (*SQLite3Store) ReadRequest 

func (s *SQLite3Store) ReadRequest(ctx context.Context, id string) (*common.Request, error)

func (*SQLite3Store) ReadSafe 

func (s *SQLite3Store) ReadSafe(ctx context.Context, holder string) (*Safe, error)

func (*SQLite3Store) ReadSafeByAddress 

func (s *SQLite3Store) ReadSafeByAddress(ctx context.Context, addr string) (*Safe, error)

func (*SQLite3Store) ReadSafeProposal 

func (s *SQLite3Store) ReadSafeProposal(ctx context.Context, requestId string) (*SafeProposal, error)

func (*SQLite3Store) ReadSafeProposalByAddress 

func (s *SQLite3Store) ReadSafeProposalByAddress(ctx context.Context, addr string) (*SafeProposal, error)

func (*SQLite3Store) ReadSignatureRequest 

func (s *SQLite3Store) ReadSignatureRequest(ctx context.Context, id string) (*SignatureRequest, error)

func (*SQLite3Store) ReadSignatureRequestByTransactionIndex 

func (s *SQLite3Store) ReadSignatureRequestByTransactionIndex(ctx context.Context, transactionHash string, index int) (*SignatureRequest, error)

func (*SQLite3Store) ReadTerminate added in v0.8.0 

func (s *SQLite3Store) ReadTerminate(ctx context.Context) (bool, error)

func (*SQLite3Store) ReadTransaction 

func (s *SQLite3Store) ReadTransaction(ctx context.Context, hash string) (*Transaction, error)

func (*SQLite3Store) ReadTransactionByRequestId 

func (s *SQLite3Store) ReadTransactionByRequestId(ctx context.Context, requestId string) (*Transaction, error)

func (*SQLite3Store) ReadUnfinishedTransactionsByHolder added in v0.11.0 

func (s *SQLite3Store) ReadUnfinishedTransactionsByHolder(ctx context.Context, holder string) ([]*Transaction, error)

func (*SQLite3Store) ReadUnmigratedEthereumAllBalance added in v0.13.0 

func (s *SQLite3Store) ReadUnmigratedEthereumAllBalance(ctx context.Context, address string) ([]*SafeBalance, error)

func (*SQLite3Store) ReadUnmigratedLatestRequest added in v0.13.0 

func (s *SQLite3Store) ReadUnmigratedLatestRequest(ctx context.Context) (*common.Request, error)

func (*SQLite3Store) ReadUnspentUtxoCountForSafe added in v0.12.0 

func (s *SQLite3Store) ReadUnspentUtxoCountForSafe(ctx context.Context, address string) (int, error)

func (*SQLite3Store) RevokeTransactionWithRequest 

func (s *SQLite3Store) RevokeTransactionWithRequest(ctx context.Context, trx *Transaction, safe *Safe, req *common.Request, txs []*mtg.Transaction) error

func (*SQLite3Store) WriteAssetMeta 

func (s *SQLite3Store) WriteAssetMeta(ctx context.Context, asset *Asset) error

func (*SQLite3Store) WriteBitcoinOutputFromRequest 

func (s *SQLite3Store) WriteBitcoinOutputFromRequest(ctx context.Context, safe *Safe, utxo *bitcoin.Input, req *common.Request, assetId, sender string, txs []*mtg.Transaction) error

func (*SQLite3Store) WriteEthereumSafeProposalWithRequest added in v0.13.0 

func (s *SQLite3Store) WriteEthereumSafeProposalWithRequest(ctx context.Context, sp *SafeProposal, trx *Transaction, txs []*mtg.Transaction, req *common.Request) error

func (*SQLite3Store) WriteKeyFromRequest 

func (s *SQLite3Store) WriteKeyFromRequest(ctx context.Context, req *common.Request, role int, extra []byte, flags byte) error

func (*SQLite3Store) WriteNetworkInfoFromRequest 

func (s *SQLite3Store) WriteNetworkInfoFromRequest(ctx context.Context, info *NetworkInfo, req *common.Request) error

func (*SQLite3Store) WriteOperationParamsFromRequest added in v0.9.15 

func (s *SQLite3Store) WriteOperationParamsFromRequest(ctx context.Context, params *OperationParams, req *common.Request) error

func (*SQLite3Store) WriteProperty 

func (s *SQLite3Store) WriteProperty(ctx context.Context, k, v string) error

func (*SQLite3Store) WriteRequestIfNotExist 

func (s *SQLite3Store) WriteRequestIfNotExist(ctx context.Context, req *common.Request) error

func (*SQLite3Store) WriteSafeProposalWithRequest 

func (s *SQLite3Store) WriteSafeProposalWithRequest(ctx context.Context, sp *SafeProposal, txs []*mtg.Transaction, req *common.Request) error

func (*SQLite3Store) WriteSafeWithRequest 

func (s *SQLite3Store) WriteSafeWithRequest(ctx context.Context, safe *Safe, txs []*mtg.Transaction, req *common.Request) error

func (*SQLite3Store) WriteSignatureRequestsWithRequest 

func (s *SQLite3Store) WriteSignatureRequestsWithRequest(ctx context.Context, requests []*SignatureRequest, transactionHash, raw string, req *common.Request, txs []*mtg.Transaction) error

func (*SQLite3Store) WriteTerminate added in v0.8.0 

func (s *SQLite3Store) WriteTerminate(ctx context.Context) error

func (*SQLite3Store) WriteTransactionWithRequest 

func (s *SQLite3Store) WriteTransactionWithRequest(ctx context.Context, trx *Transaction, utxos []*TransactionInput, txs []*mtg.Transaction, req *common.Request) error

func (*SQLite3Store) WriteUnfinishedSafe added in v0.11.0 

func (s *SQLite3Store) WriteUnfinishedSafe(ctx context.Context, safe *Safe) error

type Safe 

type Safe struct {
	Holder      string
	Chain       byte
	Signer      string
	Observer    string
	Timelock    time.Duration
	Path        string
	Address     string
	Extra       []byte
	Receivers   []string
	Threshold   byte
	RequestId   string
	Nonce       int64
	State       byte
	SafeAssetId string
	CreatedAt   time.Time
	UpdatedAt   time.Time
}

type SafeBalance added in v0.11.0 

type SafeBalance struct {
	Address      string
	AssetId      string
	AssetAddress string
	SafeAssetId  string

	LatestTxHash string
	UpdatedAt    time.Time
	// contains filtered or unexported fields
}

func (*SafeBalance) BigBalance added in v0.13.0 

func (sb *SafeBalance) BigBalance() *big.Int

func (*SafeBalance) UpdateBalance added in v0.13.0 

func (sb *SafeBalance) UpdateBalance(change *big.Int)

type SafeProposal 

type SafeProposal struct {
	RequestId string
	Chain     byte
	Holder    string
	Signer    string
	Observer  string
	Timelock  time.Duration
	Path      string
	Address   string
	Extra     []byte
	Receivers []string
	Threshold byte
	CreatedAt time.Time
	UpdatedAt time.Time
}

type SignatureRequest 

type SignatureRequest struct {
	RequestId       string
	TransactionHash string
	InputIndex      int
	Signer          string
	Curve           byte
	Message         string
	Signature       sql.NullString
	State           int
	CreatedAt       time.Time
	UpdatedAt       time.Time
}

type Transaction 

type Transaction struct {
	TransactionHash string
	RawTransaction  string
	Holder          string
	Chain           byte
	AssetId         string
	State           int
	Data            string
	RequestId       string
	CreatedAt       time.Time
	UpdatedAt       time.Time
}

type TransactionInput added in v0.11.0 

type TransactionInput struct {
	Hash  string
	Index uint32
}

func TransactionInputsFromBitcoin added in v0.11.0 

func TransactionInputsFromBitcoin(mainInputs []*bitcoin.Input) []*TransactionInput

func TransactionInputsFromRawTransaction added in v0.11.0 

func TransactionInputsFromRawTransaction(trx *Transaction) []*TransactionInput

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.