mirror of
https://github.com/d0zingcat/gocryptotrader.git
synced 2026-05-14 07:26:47 +00:00
fd600972ba
* Initial REST managed order updating
* Apply gloriousCode's changes.go patch
* Update internal order ID handling
* Check error
* Replace string with string pointer
* Avoid nil pointers in upsert
* Update test for UpdateOrderFromDetail()
* Add tests for orders.go
* Remove unnecessary newline
* Address comments
* Add missing nil check
* Add tests for new functions in order_manager.go
* Remove empty line
* Change log level for updates from Info to Debug (keep added orders at Info)
* Initialize orders before running the timer
* [TEMP] Add verbosity for debugging
* Nil checking on exchangeManager in GetExchanges()
- exchangeManager.GetExchanges() and iExchangeManager.GetExchanges() return an error on nil
- bot.GetExchanges() wraps exchangeManager.GetExchanges() and returns an empty slice
* Revert b5afe1a46b
* Do not start the order manager runner thread
Instead, mark the order manager as running
* Remove redundant error.Is() and remove print wrapper on msg
* Add atomic blocker and waitgroup on processOrders()
* Disable unnecessary orderManager runner thread for rpcserver_test
* Remove redundant err from orderStore.getActiveOrders()
* [FIX] Populate requiresProcessing using UpsertResponse data instead of REST return data
.. because the data returned by the REST calls do not include the internal user ID's
* [TEST] Verify that processOrders() actually processes queried order data
* Remove leftover warning and add nil check on wg.Done()
* Apply suggestions from code review
Log category changes - as suggested
Co-authored-by: Adrian Gallagher <adrian.gallagher@thrasher.io>
* Return when no exchanges available
Co-authored-by: Adrian Gallagher <adrian.gallagher@thrasher.io>
87 lines
3.2 KiB
Go
87 lines
3.2 KiB
Go
package engine
|
|
|
|
import (
|
|
"context"
|
|
"errors"
|
|
|
|
"github.com/thrasher-corp/gocryptotrader/communications/base"
|
|
"github.com/thrasher-corp/gocryptotrader/currency"
|
|
"github.com/thrasher-corp/gocryptotrader/database"
|
|
exchange "github.com/thrasher-corp/gocryptotrader/exchanges"
|
|
"github.com/thrasher-corp/gocryptotrader/exchanges/asset"
|
|
"github.com/thrasher-corp/gocryptotrader/exchanges/order"
|
|
"github.com/thrasher-corp/gocryptotrader/exchanges/orderbook"
|
|
"github.com/thrasher-corp/gocryptotrader/exchanges/ticker"
|
|
"github.com/thrasher-corp/gocryptotrader/portfolio"
|
|
)
|
|
|
|
const (
|
|
// MsgSubSystemStarting message to return when subsystem is starting up
|
|
MsgSubSystemStarting = "starting..."
|
|
// MsgSubSystemStarted message to return when subsystem has started
|
|
MsgSubSystemStarted = "started."
|
|
// MsgSubSystemShuttingDown message to return when a subsystem is shutting down
|
|
MsgSubSystemShuttingDown = "shutting down..."
|
|
// MsgSubSystemShutdown message to return when a subsystem has shutdown
|
|
MsgSubSystemShutdown = "shutdown."
|
|
)
|
|
|
|
var (
|
|
// ErrSubSystemAlreadyStarted message to return when a subsystem is already started
|
|
ErrSubSystemAlreadyStarted = errors.New("subsystem already started")
|
|
// ErrSubSystemNotStarted message to return when subsystem not started
|
|
ErrSubSystemNotStarted = errors.New("subsystem not started")
|
|
// ErrNilSubsystem is returned when a subsystem hasn't had its Setup() func run
|
|
ErrNilSubsystem = errors.New("subsystem not setup")
|
|
errNilWaitGroup = errors.New("nil wait group received")
|
|
errNilExchangeManager = errors.New("cannot start with nil exchange manager")
|
|
errNilDatabaseConnectionManager = errors.New("cannot start with nil database connection manager")
|
|
errNilConfig = errors.New("received nil config")
|
|
)
|
|
|
|
// iExchangeManager limits exposure of accessible functions to exchange manager
|
|
// so that subsystems can use some functionality
|
|
type iExchangeManager interface {
|
|
GetExchanges() ([]exchange.IBotExchange, error)
|
|
GetExchangeByName(string) (exchange.IBotExchange, error)
|
|
}
|
|
|
|
// iCommsManager limits exposure of accessible functions to communication manager
|
|
type iCommsManager interface {
|
|
PushEvent(evt base.Event)
|
|
}
|
|
|
|
// iOrderManager defines a limited scoped order manager
|
|
type iOrderManager interface {
|
|
Exists(*order.Detail) bool
|
|
Add(*order.Detail) error
|
|
Cancel(context.Context, *order.Cancel) error
|
|
GetByExchangeAndID(string, string) (*order.Detail, error)
|
|
UpdateExistingOrder(*order.Detail) error
|
|
}
|
|
|
|
// iPortfolioManager limits exposure of accessible functions to portfolio manager
|
|
type iPortfolioManager interface {
|
|
GetPortfolioSummary() portfolio.Summary
|
|
IsWhiteListed(string) bool
|
|
IsExchangeSupported(string, string) bool
|
|
}
|
|
|
|
// iBot limits exposure of accessible functions to engine bot
|
|
type iBot interface {
|
|
SetupExchanges() error
|
|
}
|
|
|
|
// iCurrencyPairSyncer defines a limited scoped currency pair syncer
|
|
type iCurrencyPairSyncer interface {
|
|
IsRunning() bool
|
|
PrintTickerSummary(*ticker.Price, string, error)
|
|
PrintOrderbookSummary(*orderbook.Base, string, error)
|
|
Update(string, currency.Pair, asset.Item, int, error) error
|
|
}
|
|
|
|
// iDatabaseConnectionManager defines a limited scoped databaseConnectionManager
|
|
type iDatabaseConnectionManager interface {
|
|
GetInstance() database.IDatabase
|
|
}
|