api

type APINotifyFunc func(params []json.RawMessage) error

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

type BitsharesAPI interface {
	OnLogin(fn func())
	OnLogout(fn func())

	DatabaseAPI() (DatabaseAPI, error)
	BroadcastAPI() (BroadcastAPI, error)
	HistoryAPI() (HistoryAPI, error)
	NetworkNodeAPI() (NetworkNodeAPI, error)
	CryptoAPI() (CryptoAPI, error)
}

type BitsharesAPIConnEvent int

type BitsharesAPIConnection interface {
	Connect() error
	Close() error
	OnError(func(error))
	OnNotify(subscriberID int, handler APINotifyFunc)
	Call(apiID interface{}, method string, result interface{}, args ...interface{}) error
	RegisterCallback(fn func(BitsharesAPIConnEvent))
}

type BitsharesWalletAPI interface {
	//wallet API
	Close() error
	Connect() error
	//Transfer(from, to objects.GrapheneObject, amount objects.AssetAmount) (interface{}, error)
	ListAccountBalances(account objects.GrapheneObject) ([]objects.AssetAmount, error)
	WalletLock() error
	WalletUnlock(password string) error
	WalletIsLocked() (bool, error)
	Buy(account objects.GrapheneObject, base, quote objects.GrapheneObject, rate string, amount string, broadcast bool) (*objects.Transaction, error)
	BuyEx(account objects.GrapheneObject, base, quote objects.GrapheneObject, rate float64, amount float64, broadcast bool) (*objects.Transaction, error)
	Sell(account objects.GrapheneObject, base, quote objects.GrapheneObject, rate string, amount string, broadcast bool) (*objects.Transaction, error)
	SellEx(account objects.GrapheneObject, base, quote objects.GrapheneObject, rate float64, amount float64, broadcast bool) (*objects.Transaction, error)
	SellAsset(account objects.GrapheneObject, amountToSell string, symbolToSell objects.GrapheneObject, minToReceive string, symbolToReceive objects.GrapheneObject, timeout uint32, fillOrKill bool, broadcast bool) (*objects.Transaction, error)
}

type BlockAppliedHandler func(objects.BlockID)

type BroadcastAPI interface {
	BroadcastTransaction(tx *objects.Transaction) error
}

type Builder interface {
	Node(endpoint string) Builder
	Credentials(login, password string) Builder
	BlockHandler(handler BlockAppliedHandler) Builder
	LoginHandler(login func()) Builder
	LogoutHandler(close func()) Builder
	Build() (BitsharesAPIConnection, BitsharesAPI)
}

type CryptoAPI interface {
}

type DatabaseAPI interface {
	// Objects
	GetObjects(objectIDs ...objects.GrapheneObject) ([]interface{}, error)
	ListAssets(lowerBoundSymbol string, limit int) ([]objects.Asset, error)
	GetTicker(base, quote string) (*objects.MarketTicker, error)

	// Subscriptions
	SubscribeBlockApplied(BlockAppliedHandler) error
	CancelAllSubscriptions() error

	// Blocks & transactions
	GetBlock(number uint64) (*objects.Block, error)
	GetRecentTransactionByID(tx objects.TxID) (*objects.Transaction, error)

	// Globals
	GetChainID() objects.ChainID
	GetDynamicGlobalProperties() (*objects.DynamicGlobalProperties, error)

	// Accounts
	GetAccountBalances(account objects.GrapheneObject, assets ...objects.GrapheneObject) ([]objects.AssetAmount, error)
	GetAccountByName(name string) (*objects.Account, error)
	GetAccounts(accountIDs ...objects.GrapheneObject) ([]objects.Account, error)
	GetAccountCount() (uint64, error)
	GetFullAccounts(subscribe bool, accountIDs ...objects.GrapheneObject) ([]*objects.FullAccountResult, error)

	// Markets
	CancelOrder(orderID objects.GrapheneObject, broadcast bool) (*objects.Transaction, error)
	GetMarginPositions(accountID objects.GrapheneObject) ([]objects.CallOrder, error)
	GetCallOrders(assetID objects.GrapheneObject, limit int) ([]objects.CallOrder, error)
	GetLimitOrders(base, quote objects.GrapheneObject, limit int) (objects.LimitOrders, error)
	GetSettleOrders(assetID objects.GrapheneObject, limit int) ([]objects.SettleOrder, error)
	GetTradeHistory(base, quote objects.GrapheneObject, toTime, fromTime time.Time, limit int) ([]objects.MarketTrade, error)

	// Autority/Validation
	GetRequiredFees(ops objects.Operations, feeAsset objects.GrapheneObject) ([]objects.AssetAmount, error)
	GetPotentialSignatures(tx *objects.Transaction) ([]objects.PublicKey, error)
	GetRequiredSignatures(tx *objects.Transaction, keys []objects.PublicKey) ([]objects.PublicKey, error)
}

type FullAccountHandler func(acc *objects.FullAccount) error

type HistoryAPI interface {
	GetAccountHistory(account objects.GrapheneObject, stop objects.GrapheneObject, start objects.GrapheneObject, limit int) ([]objects.OperationHistory, error)
	GetChronoRelativeHistory(account objects.GrapheneObject, start uint32, limit int) ([]objects.OperationHistory, error)
}

type NetworkNodeAPI interface {
	GetNetworkNodeInfo() (objects.NetworkNodeInfo, error)
	GetConnectedPeers() ([]objects.PeerStatus, error)
	GetAdvancedNodeParameters() (objects.AdvancedNodeParameters, error)
	GetPotentialPeers() ([]objects.PotentialPeerRecord, error)
}

type Params struct {
	Username string `json:"username"`
	Password string `json:"password"`
}