openw

package
v2.0.11 Latest Latest
Warning

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

 Go to latest Published: Jun 1, 2022 License: GPL-3.0 Imports: 23 Imported by: 0

README

openw

openw包实现了一个单机版的钱包管理模型。目前用于给实现AssetsAapter协议的区块链资产适配器做功能测试。 后续会做一个可视化的钱包管理系统，专门用于区块链资产适配器的测试。

Documentation

Index

Constants

View Source 
const (
	FilterBalanceKey = "FilterBalance"
	ContractIDKey    = "ContractID"
)

Variables

View Source 
var (
	PeriodOfTask = 5 * time.Second
)

Functions

func GetAssets 

func GetAssets(symbol string) interface{}

GetAssets 根据币种类型获取已注册的管理者

func GetAssetsAdapter 

func GetAssetsAdapter(symbol string) (openwallet.AssetsAdapter, error)

GetAssetsAdapter 获取资产控制器

func GetSymbolInfo 

func GetSymbolInfo(symbol string) (openwallet.SymbolInfo, error)

GetSymbolInfo 获取资产的币种信息

func RegAssets 

func RegAssets(name string, manager interface{}, config ...config.Configer)

RegAssets 注册资产 @param name 资产别名 @param manager 资产适配器或管理器 @param config 加载配置 资产适配器实现了openwallet.AssetsConfig，可以传入配置接口完成预加载配置 usage: RegAssets(cardano.Symbol, &cardano.WalletManager{}, c) RegAssets(bytom.Symbol, &bytom.WalletManager{}, c)

Types

type AppID 

type AppID string

type AppWrapper 

type AppWrapper struct {
	*Wrapper
	// contains filtered or unexported fields
}

AppWrapper 应用装器，扩展应用功能

func NewAppWrapper 

func NewAppWrapper(args ...interface{}) *AppWrapper

func (*AppWrapper) GetWalletInfo 

func (wrapper *AppWrapper) GetWalletInfo(walletID string) (*openwallet.Wallet, error)

GetWalletInfo

func (*AppWrapper) GetWalletList 

func (wrapper *AppWrapper) GetWalletList(offset, limit int) ([]*openwallet.Wallet, error)

GetWalletList

type Config 

type Config struct {
	KeyDir          string   //钥匙备份路径
	DBPath          string   //本地数据库文件路径
	BackupDir       string   //备份路径
	SupportAssets   []string //支持的资产类型
	EnableBlockScan bool
	ConfigDir       string
}

func NewConfig 

func NewConfig() *Config

type NotificationObject 

type NotificationObject interface {

	//BlockScanNotify 新区块扫描完成通知
	BlockScanNotify(header *openwallet.BlockHeader) error

	//BlockTxExtractDataNotify 区块提取结果通知
	BlockTxExtractDataNotify(account *openwallet.AssetsAccount, data *openwallet.TxExtractData) error
}

type StormDB 

type StormDB struct {
	*storm.DB
	FileName string
	Opened   bool
}

func OpenStormDB 

func OpenStormDB(filename string, stormOptions ...func(*storm.Options) error) (*StormDB, error)

OpenStormDB

func (*StormDB) Close 

func (db *StormDB) Close() error

Close closes the database.

type TransactionWrapper 

type TransactionWrapper struct {
	*WalletWrapper
}

TransactionWrapper 交易包装器，扩展钱包交易单相关功能

func NewTransactionWrapper 

func NewTransactionWrapper(args ...interface{}) *TransactionWrapper

func (*TransactionWrapper) DeleteBlockDataByHeight 

func (wrapper *TransactionWrapper) DeleteBlockDataByHeight(height uint64) error

DeleteBlockDataByHeight 删除钱包中指定区块高度相关的交易记录

func (*TransactionWrapper) SaveBlockExtractData 

func (wrapper *TransactionWrapper) SaveBlockExtractData(accountID string, data *openwallet.TxExtractData) error

SaveBlockExtractData 保存区块提取数据

type WalletDBFile 

type WalletDBFile WrapperSourceFile

type WalletKeyFile 

type WalletKeyFile string

type WalletManager 

type WalletManager struct {
	AddressInScanning map[string]string //加入扫描的地址
	// contains filtered or unexported fields
}

WalletManager OpenWallet钱包管理器

func NewWalletManager 

func NewWalletManager(config *Config) *WalletManager

NewWalletManager

func (*WalletManager) AddAddressForBlockScan 

func (wm *WalletManager) AddAddressForBlockScan(address, sourceKey string) error

AddAddressForBlockScan 添加订阅地址

func (*WalletManager) AddObserver 

func (wm *WalletManager) AddObserver(obj NotificationObject)

AddObserver 添加观测者

func (*WalletManager) BlockExtractDataNotify 

func (wm *WalletManager) BlockExtractDataNotify(sourceKey string, data *openwallet.TxExtractData) error

BlockExtractDataNotify 区块提取结果通知

func (*WalletManager) BlockExtractSmartContractDataNotify 

func (wm *WalletManager) BlockExtractSmartContractDataNotify(sourceKey string, data *openwallet.SmartContractReceipt) error

BlockExtractSmartContractDataNotify 区块提取智能合约交易结果通知 @param sourceKey: 为contractID @param data: 合约交易回执 @required

func (*WalletManager) BlockScanNotify 

func (wm *WalletManager) BlockScanNotify(header *openwallet.BlockHeader) error

blockScanNotify 区块扫描结果通知

func (*WalletManager) CallSmartContractABI 

func (wm *WalletManager) CallSmartContractABI(appID, walletID, accountID string, contract *openwallet.SmartContract, abiParam []string) (*openwallet.SmartContractCallResult, error)

CreateSmartContractTransaction

func (*WalletManager) ClearAddressForBlockScan 

func (wm *WalletManager) ClearAddressForBlockScan() error

ClearAddressForBlockScan 清理订阅扫描的内容

func (*WalletManager) CloseDB 

func (wm *WalletManager) CloseDB(appID string) error

CloseDB 关闭应用数据库文件

func (*WalletManager) CreateAddress 

func (wm *WalletManager) CreateAddress(appID, walletID string, accountID string, count uint64) ([]*openwallet.Address, error)

CreateAddress

func (*WalletManager) CreateAssetsAccount 

func (wm *WalletManager) CreateAssetsAccount(appID, walletID, password string, account *openwallet.AssetsAccount, otherOwnerKeys []string) (*openwallet.AssetsAccount, *openwallet.Address, error)

CreateAssetsAccount

func (*WalletManager) CreateBatchTransaction 

func (wm *WalletManager) CreateBatchTransaction(appID, walletID, accountID, feeRate, memo string, to map[string]string, contract *openwallet.SmartContract, extParam map[string]interface{}) (*openwallet.RawTransaction, error)

CreateBatchTransaction

func (*WalletManager) CreateErc20TokenTransaction 

func (wm *WalletManager) CreateErc20TokenTransaction(appID, walletID, accountID, amount, address, feeRate, memo,
	contractAddr, tokenName, tokenSymbol string, tokenDecimal uint64) (*openwallet.RawTransaction, error)

func (*WalletManager) CreateQrc20TokenTransaction 

func (wm *WalletManager) CreateQrc20TokenTransaction(appID, walletID, accountID, sendAmount, toAddress, feeRate, memo,
	contractAddr, tokenName, tokenSymbol string, tokenDecimal uint64) (*openwallet.RawTransaction, error)

func (*WalletManager) CreateSmartContractTransaction 

func (wm *WalletManager) CreateSmartContractTransaction(appID, walletID, accountID, amount, feeRate string, contract *openwallet.SmartContract, abiParam []string, raw string, rawType uint64) (*openwallet.SmartContractRawTransaction, *openwallet.Error)

CreateSmartContractTransaction

func (*WalletManager) CreateSummaryRawTransactionWithError 

func (wm *WalletManager) CreateSummaryRawTransactionWithError(
	appID, walletID, accountID, summaryAddress, minTransfer, retainedBalance, feeRate string,
	start, limit int,
	contract *openwallet.SmartContract,
	feeSupportAccount *openwallet.FeesSupportAccount,
) ([]*openwallet.RawTransactionWithError, error)

CreateSummaryTransaction

func (*WalletManager) CreateSummaryTransaction 

func (wm *WalletManager) CreateSummaryTransaction(
	appID, walletID, accountID, summaryAddress, minTransfer, retainedBalance, feeRate string,
	start, limit int,
	contract *openwallet.SmartContract) ([]*openwallet.RawTransaction, error)

CreateSummaryTransaction

func (*WalletManager) CreateTransaction 

func (wm *WalletManager) CreateTransaction(appID, walletID, accountID, amount, address, feeRate, memo string, contract *openwallet.SmartContract, extParam map[string]interface{}) (*openwallet.RawTransaction, error)

CreateTransaction

func (*WalletManager) CreateWallet 

func (wm *WalletManager) CreateWallet(appID string, wallet *openwallet.Wallet) (*openwallet.Wallet, *hdkeystore.HDKey, error)

CreateWallet 创建钱包

func (*WalletManager) DBFile 

func (wm *WalletManager) DBFile(appID string) string

DBFile 应用数据库文件

func (*WalletManager) DeleteRechargesByHeight 

func (wm *WalletManager) DeleteRechargesByHeight(height uint64) error

DeleteRechargesByHeight 删除某区块高度的充值记录

func (*WalletManager) GetAddress 

func (wm *WalletManager) GetAddress(appID, walletID, accountID, address string) (*openwallet.Address, error)

GetAddress 获取单个地址信息

func (*WalletManager) GetAddressList 

func (wm *WalletManager) GetAddressList(appID, walletID, accountID string, offset, limit int, watchOnly bool) ([]*openwallet.Address, error)

GetAddressList

func (*WalletManager) GetAssetsAccountBalance 

func (wm *WalletManager) GetAssetsAccountBalance(appID, walletID, accountID string) (*openwallet.Balance, error)

GetAssetsAccountBalance 获取账户余额

func (*WalletManager) GetAssetsAccountInfo 

func (wm *WalletManager) GetAssetsAccountInfo(appID, walletID, accountID string) (*openwallet.AssetsAccount, error)

GetAssetsAccountInfo

func (*WalletManager) GetAssetsAccountList 

func (wm *WalletManager) GetAssetsAccountList(appID, walletID string, offset, limit int) ([]*openwallet.AssetsAccount, error)

GetAssetsAccountList

func (*WalletManager) GetAssetsAccountTokenBalance 

func (wm *WalletManager) GetAssetsAccountTokenBalance(appID, walletID, accountID string, contract openwallet.SmartContract) (*openwallet.TokenBalance, error)

GetAssetsAccountTokenBalance 获取账户Token余额

func (*WalletManager) GetEstimateFeeRate 

func (wm *WalletManager) GetEstimateFeeRate(coin openwallet.Coin) (feeRate string, unit string, err error)

GetEstimateFeeRate 获取币种推荐手续费

func (*WalletManager) GetNewBlockHeight 

func (wm *WalletManager) GetNewBlockHeight(symbol string) (uint64, uint64, error)

GetNewBlockHeight 获取区块高度，（最新高度，已扫描高度）

func (*WalletManager) GetSourceKeyByAddressForBlockScan 

func (wm *WalletManager) GetSourceKeyByAddressForBlockScan(address string) (string, bool)

GetSourceKeyByAddressForBlockScan 获取地址对应的数据源标识

func (*WalletManager) GetTransactionByWxID 

func (wm *WalletManager) GetTransactionByWxID(appID, wxID string) (*openwallet.Transaction, error)

GetTransactionByWxID 通过WxID获取交易单

func (*WalletManager) GetTransactions 

func (wm *WalletManager) GetTransactions(appID string, offset, limit int, cols ...interface{}) ([]*openwallet.Transaction, error)

GetTransactions

func (*WalletManager) GetTxSpent 

func (wm *WalletManager) GetTxSpent(appID string, offset, limit int, cols ...interface{}) ([]*openwallet.TxInput, error)

GetTxSpent

func (*WalletManager) GetTxUnspent 

func (wm *WalletManager) GetTxUnspent(appID string, offset, limit int, cols ...interface{}) ([]*openwallet.TxOutPut, error)

GetTxUnspent

func (*WalletManager) GetWalletInfo 

func (wm *WalletManager) GetWalletInfo(appID string, walletID string) (*openwallet.Wallet, error)

GetWalletInfo

func (*WalletManager) GetWalletList 

func (wm *WalletManager) GetWalletList(appID string, offset, limit int) ([]*openwallet.Wallet, error)

GetWalletList

func (*WalletManager) ImportWatchOnlyAddress 

func (wm *WalletManager) ImportWatchOnlyAddress(appID, walletID, accountID string, addresses []*openwallet.Address) error

ImportWatchOnlyAddress

func (*WalletManager) Init 

func (wm *WalletManager) Init()

Init 初始化

func (*WalletManager) IsExistAddressForBlockScan 

func (wm *WalletManager) IsExistAddressForBlockScan(address string) bool

IsExistAddressForBlockScan 指定地址是否已登记扫描

func (*WalletManager) NewWalletWrapper 

func (wm *WalletManager) NewWalletWrapper(appID, walletID string) (*WalletWrapper, error)

NewWalletWrapper 创建App专用的包装器

func (*WalletManager) OpenDB 

func (wm *WalletManager) OpenDB(appID string) (*StormDB, error)

OpenDB 打开应用数据库文件

func (*WalletManager) RemoveObserver 

func (wm *WalletManager) RemoveObserver(obj NotificationObject)

RemoveObserver 移除观测者

func (*WalletManager) RescanBlockHeight 

func (wm *WalletManager) RescanBlockHeight(symbol string, startHeight uint64, endHeight uint64) error

func (*WalletManager) SetRescanBlockHeight 

func (wm *WalletManager) SetRescanBlockHeight(symbol string, height uint64) error

SetRescanBlockHeight 重置区块高度起扫描

func (*WalletManager) SignSmartContractTransaction 

func (wm *WalletManager) SignSmartContractTransaction(appID, walletID, accountID, password string, rawTx *openwallet.SmartContractRawTransaction) (*openwallet.SmartContractRawTransaction, *openwallet.Error)

SignSmartContractTransaction

func (*WalletManager) SignTransaction 

func (wm *WalletManager) SignTransaction(appID, walletID, accountID, password string, rawTx *openwallet.RawTransaction) (*openwallet.RawTransaction, error)

SignTransaction

func (*WalletManager) SubmitSmartContractTransaction 

func (wm *WalletManager) SubmitSmartContractTransaction(appID, walletID, accountID string, rawTx *openwallet.SmartContractRawTransaction) (*openwallet.SmartContractReceipt, *openwallet.Error)

SubmitSmartContractTransaction

func (*WalletManager) SubmitTransaction 

func (wm *WalletManager) SubmitTransaction(appID, walletID, accountID string, rawTx *openwallet.RawTransaction) (*openwallet.Transaction, error)

SubmitTransaction

func (*WalletManager) VerifyTransaction 

func (wm *WalletManager) VerifyTransaction(appID, walletID, accountID string, rawTx *openwallet.RawTransaction) (*openwallet.RawTransaction, error)

VerifyTransaction

type WalletWrapper 

type WalletWrapper struct {
	*AppWrapper
	// contains filtered or unexported fields
}

WalletWrapper 钱包包装器，扩展钱包功能

func NewWalletWrapper 

func NewWalletWrapper(args ...interface{}) *WalletWrapper

func (*WalletWrapper) CreateAddress 

func (wrapper *WalletWrapper) CreateAddress(accountID string, count uint64, decoder openwallet.AddressDecoder, isChange bool, isTestNet bool) ([]*openwallet.Address, error)

CreateAddress 创建地址 @param accountID 指定账户 @param count 创建数量 @param decoder 地址解释器 @param isChange 是否找零地址 @param isTestNet 是否测试网

func (*WalletWrapper) GetAddress 

func (wrapper *WalletWrapper) GetAddress(address string) (*openwallet.Address, error)

GetAddress 通过地址字符串获取地址对象

func (*WalletWrapper) GetAddressExtParam 

func (wrapper *WalletWrapper) GetAddressExtParam(address string, key string) (interface{}, error)

获取地址的扩展字段

func (*WalletWrapper) GetAddressList 

func (wrapper *WalletWrapper) GetAddressList(offset, limit int, cols ...interface{}) ([]*openwallet.Address, error)

GetAddresses 获取资产账户地址列表

func (*WalletWrapper) GetAssetsAccountByAddress 

func (wrapper *WalletWrapper) GetAssetsAccountByAddress(address string) (*openwallet.AssetsAccount, error)

GetAssetsAccountByAddress 通过地址获取资产账户对象

func (*WalletWrapper) GetAssetsAccountInfo 

func (wrapper *WalletWrapper) GetAssetsAccountInfo(accountID string) (*openwallet.AssetsAccount, error)

GetAssetsAccountInfo 获取指定账户

func (*WalletWrapper) GetAssetsAccountList 

func (wrapper *WalletWrapper) GetAssetsAccountList(offset, limit int, cols ...interface{}) ([]*openwallet.AssetsAccount, error)

GetAssetsAccounts 获取某种区块链的全部资产账户

func (*WalletWrapper) GetImportAddressList 

func (wrapper *WalletWrapper) GetImportAddressList(offset, limit int, cols ...interface{}) ([]*openwallet.ImportAddress, error)

GetImportAddressList 获取待导入

func (*WalletWrapper) GetTransactions 

func (wrapper *WalletWrapper) GetTransactions(offset, limit int, cols ...interface{}) ([]*openwallet.Transaction, error)

GetTransactions 获取钱包的交易记录

func (*WalletWrapper) GetTxInputs 

func (wrapper *WalletWrapper) GetTxInputs(offset, limit int, cols ...interface{}) ([]*openwallet.TxInput, error)

GetTxInputs 获取钱包的出账记录

func (*WalletWrapper) GetTxOutputs 

func (wrapper *WalletWrapper) GetTxOutputs(offset, limit int, cols ...interface{}) ([]*openwallet.TxOutPut, error)

GetTxOutputs 获取钱包的入账记录

func (*WalletWrapper) GetWallet 

func (wrapper *WalletWrapper) GetWallet() *openwallet.Wallet

GetWallet 获取钱包

func (*WalletWrapper) GetWalletByID 

func (wrapper *WalletWrapper) GetWalletByID(walletID string) (*openwallet.Wallet, error)

GetWalletByID 通过钱包ID获取

func (*WalletWrapper) HDKey 

func (wrapper *WalletWrapper) HDKey(password ...string) (*hdkeystore.HDKey, error)

HDKey 获取钱包密钥，需要密码

func (*WalletWrapper) ImportWatchOnlyAddress 

func (wrapper *WalletWrapper) ImportWatchOnlyAddress(address ...*openwallet.Address) error

ImportWatchOnlyAddress 导入观测地址

func (*WalletWrapper) SaveAssetsAccount 

func (wrapper *WalletWrapper) SaveAssetsAccount(account *openwallet.AssetsAccount) error

SaveAssetsAccount 更新账户信息

func (*WalletWrapper) SetAddressExtParam 

func (wrapper *WalletWrapper) SetAddressExtParam(address string, key string, val interface{}) error

设置地址的扩展字段

func (*WalletWrapper) UnlockWallet 

func (wrapper *WalletWrapper) UnlockWallet(password string, time time.Duration) error

type Wrapper 

type Wrapper struct {
	openwallet.WalletDAIBase
	// contains filtered or unexported fields
}

Wrapper 基于OpenWallet钱包体系模型，专门处理钱包的持久化问题，关系数据查询

func NewWrapper 

func NewWrapper(args ...interface{}) *Wrapper

func (*Wrapper) CloseDB 

func (wrapper *Wrapper) CloseDB()

CloseDB 关闭数据库

func (*Wrapper) OpenStormDB 

func (wrapper *Wrapper) OpenStormDB() (*StormDB, error)

OpenStormDB 打开数据库

func (*Wrapper) SetExternalDB 

func (wrapper *Wrapper) SetExternalDB(db *StormDB) error

SetStormDB 设置钱包的应用数据库

type WrapperSourceFile 

type WrapperSourceFile string

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.