lychiyu/bbgo_origin
1
0
Fork 0
mirror of https://github.com/c9s/bbgo.git synced 2024-11-26 16:55:15 +00:00
Code Issues Actions Packages Projects Releases Wiki Activity

revise orderbook command options

Browse Source
This commit is contained in:
c9s 2021-03-15 10:23:53 +08:00
parent b24c69729a
commit 7b7811bbc3
1 changed files with 21 additions and 11 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

30
pkg/cmd/orderbook.go
View File

@ -12,26 +12,35 @@ import (
"github.com/c9s/bbgo/pkg/types" "github.com/c9s/bbgo/pkg/types"
) )
// go run ./cmd/bbgo orderbook --session=ftx --symbol=BTC/USDT // go run ./cmd/bbgo orderbook --exchange=ftx --symbol=BTC/USDT
var orderbookCmd = &cobra.Command{ var orderbookCmd = &cobra.Command{
Use: "orderbook", Use: "orderbook",
Short: "connect to the order book market data streaming service of an exchange",
RunE: func(cmd *cobra.Command, args []string) error { RunE: func(cmd *cobra.Command, args []string) error {
ctx := context.Background() ctx := context.Background()
session, err := cmd.Flags().GetString("session")
exName, err := cmd.Flags().GetString("exchange")
if err != nil { if err != nil {
return fmt.Errorf("can't get session from flags: %w", err) return fmt.Errorf("can not get exchange from flags: %w", err)
} }
ex, err := newExchange(session)
exchangeName, err := types.ValidExchangeName(exName)
if err != nil {
return err
}
ex, err := cmdutil.NewExchange(exchangeName)
if err != nil { if err != nil {
return err return err
} }
symbol, err := cmd.Flags().GetString("symbol") symbol, err := cmd.Flags().GetString("symbol")
if err != nil { if err != nil {
return fmt.Errorf("can't get the symbol from flags: %w", err) return fmt.Errorf("can not get the symbol from flags: %w", err)
} }
if symbol == "" { if symbol == "" {
return fmt.Errorf("symbol is not found") return fmt.Errorf("--symbol option is required")
} }
s := ex.NewStream() s := ex.NewStream()
@ -43,8 +52,9 @@ var orderbookCmd = &cobra.Command{
log.Infof("orderbook update: %s", book.String()) log.Infof("orderbook update: %s", book.String())
}) })
log.Infof("connecting...")
if err := s.Connect(ctx); err != nil { if err := s.Connect(ctx); err != nil {
return fmt.Errorf("failed to connect to %s", session) return fmt.Errorf("failed to connect to %s", exchangeName)
} }
cmdutil.WaitForSignal(ctx, syscall.SIGINT, syscall.SIGTERM) cmdutil.WaitForSignal(ctx, syscall.SIGINT, syscall.SIGTERM)
@ -53,8 +63,8 @@ var orderbookCmd = &cobra.Command{
} }
func init() { func init() {
orderbookCmd.Flags().String("session", "", "the exchange session name for sync") // since the public data does not require trading authentication, we use --exchange option here.
orderbookCmd.Flags().String("symbol", "", "the trading pair, like btcusdt") orderbookCmd.Flags().String("exchange", "", "the exchange name for sync")
orderbookCmd.Flags().String("symbol", "", "the trading pair. e.g, BTCUSDT, LTCUSDT...")
RootCmd.AddCommand(orderbookCmd) RootCmd.AddCommand(orderbookCmd)
} }