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

cmd: rewrite sync command

Browse Source
This commit is contained in:
c9s 2022-06-01 15:52:11 +08:00
parent cf19ed6f26
commit 63ad635f62
No known key found for this signature in database
GPG Key ID: 7385E7E464CB0A54
2 changed files with 15 additions and 27 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

36
pkg/cmd/sync.go
View File

@ -6,7 +6,6 @@ import (
"time"
"github.com/pkg/errors"
log "github.com/sirupsen/logrus"
"github.com/spf13/cobra"
"github.com/c9s/bbgo/pkg/bbgo"
@ -88,35 +87,18 @@ var SyncCmd = &cobra.Command{
environ.SetSyncStartTime(syncStartTime)
// syncSymbols is the symbol list to sync
var syncSymbols []string
if userConfig.Sync != nil && len(userConfig.Sync.Symbols) > 0 {
syncSymbols = userConfig.Sync.Symbols
}
if len(symbol) > 0 {
syncSymbols = []string{symbol}
}
var selectedSessions []string
if userConfig.Sync != nil && len(userConfig.Sync.Sessions) > 0 {
selectedSessions = userConfig.Sync.Sessions
}
if len(sessionName) > 0 {
selectedSessions = []string{sessionName}
}
sessions := environ.SelectSessions(selectedSessions...)
for _, session := range sessions {
if err := environ.SyncSession(ctx, session, syncSymbols...); err != nil {
return err
if userConfig.Sync != nil && len(userConfig.Sync.Symbols) > 0 {
userConfig.Sync.Symbols = []string{symbol}
}
log.Infof("exchange session %s synchronization done", session.Name)
}
return nil
if len(sessionName) > 0 {
if userConfig.Sync != nil && len(userConfig.Sync.Sessions) > 0 {
userConfig.Sync.Sessions = []string{sessionName}
}
}
return environ.Sync(ctx, userConfig)
},
}

6
pkg/util/paper_trade.go Normal file
View File

@ -0,0 +1,6 @@
package util
func IsPaperTrade() bool {
v, ok := GetEnvVarBool("PAPER_TRADE")
return ok && v
}