mirror of
https://github.com/laoxong/nofx.git
synced 2026-06-06 18:58:22 +08:00
tinkle-community
cb31782be4
- Rename experience/ to telemetry/ for clarity - Split 15+ large Go files (800-2200 lines) into focused modules: kernel/engine.go, backtest/runner.go, market/data.go, store/position.go, api/handler_trader.go, trader/auto_trader_grid.go, and 9 exchange traders - Split frontend monoliths: types.ts, api.ts, AITradersPage.tsx, BacktestPage.tsx into domain-specific modules with barrel re-exports - Remove stale files: screenshots, .yml.old, pyproject.toml - Remove unused scripts/ and cmd/ directories - Remove broken/outdated test files (network-dependent, stale expectations)
115 lines
2.8 KiB
Go
115 lines
2.8 KiB
Go
package gate
|
|
|
|
import (
|
|
"context"
|
|
"fmt"
|
|
"nofx/trader/types"
|
|
"strings"
|
|
"sync"
|
|
"time"
|
|
|
|
"github.com/gateio/gateapi-go/v6"
|
|
)
|
|
|
|
// GateTrader implements types.Trader interface for Gate.io Futures
|
|
type GateTrader struct {
|
|
apiKey string
|
|
secretKey string
|
|
client *gateapi.APIClient
|
|
ctx context.Context
|
|
|
|
// Cache fields
|
|
cachedBalance map[string]interface{}
|
|
balanceCacheTime time.Time
|
|
balanceCacheMutex sync.RWMutex
|
|
cachedPositions []map[string]interface{}
|
|
positionsCacheTime time.Time
|
|
positionsCacheMutex sync.RWMutex
|
|
contractsCache map[string]*gateapi.Contract
|
|
contractsCacheMutex sync.RWMutex
|
|
cacheDuration time.Duration
|
|
}
|
|
|
|
// NewGateTrader creates a new Gate trader instance
|
|
func NewGateTrader(apiKey, secretKey string) *GateTrader {
|
|
config := gateapi.NewConfiguration()
|
|
config.AddDefaultHeader("X-Gate-Channel-Id", "nofx")
|
|
client := gateapi.NewAPIClient(config)
|
|
|
|
ctx := context.WithValue(context.Background(),
|
|
gateapi.ContextGateAPIV4,
|
|
gateapi.GateAPIV4{
|
|
Key: apiKey,
|
|
Secret: secretKey,
|
|
},
|
|
)
|
|
|
|
return &GateTrader{
|
|
apiKey: apiKey,
|
|
secretKey: secretKey,
|
|
client: client,
|
|
ctx: ctx,
|
|
contractsCache: make(map[string]*gateapi.Contract),
|
|
cacheDuration: 15 * time.Second,
|
|
}
|
|
}
|
|
|
|
// convertSymbol converts symbol format (e.g., BTCUSDT -> BTC_USDT)
|
|
func (t *GateTrader) convertSymbol(symbol string) string {
|
|
// If already in correct format
|
|
if strings.Contains(symbol, "_") {
|
|
return symbol
|
|
}
|
|
// Convert BTCUSDT to BTC_USDT
|
|
if strings.HasSuffix(symbol, "USDT") {
|
|
base := strings.TrimSuffix(symbol, "USDT")
|
|
return base + "_USDT"
|
|
}
|
|
return symbol
|
|
}
|
|
|
|
// revertSymbol converts symbol back to standard format (e.g., BTC_USDT -> BTCUSDT)
|
|
func (t *GateTrader) revertSymbol(symbol string) string {
|
|
return strings.ReplaceAll(symbol, "_", "")
|
|
}
|
|
|
|
// getContract fetches contract info with caching
|
|
func (t *GateTrader) getContract(symbol string) (*gateapi.Contract, error) {
|
|
symbol = t.convertSymbol(symbol)
|
|
|
|
// Check cache
|
|
t.contractsCacheMutex.RLock()
|
|
if contract, ok := t.contractsCache[symbol]; ok {
|
|
t.contractsCacheMutex.RUnlock()
|
|
return contract, nil
|
|
}
|
|
t.contractsCacheMutex.RUnlock()
|
|
|
|
// Fetch from API
|
|
contract, _, err := t.client.FuturesApi.GetFuturesContract(t.ctx, "usdt", symbol)
|
|
if err != nil {
|
|
return nil, fmt.Errorf("failed to get contract info: %w", err)
|
|
}
|
|
|
|
// Update cache
|
|
t.contractsCacheMutex.Lock()
|
|
t.contractsCache[symbol] = &contract
|
|
t.contractsCacheMutex.Unlock()
|
|
|
|
return &contract, nil
|
|
}
|
|
|
|
// clearCache clears all caches
|
|
func (t *GateTrader) clearCache() {
|
|
t.balanceCacheMutex.Lock()
|
|
t.cachedBalance = nil
|
|
t.balanceCacheMutex.Unlock()
|
|
|
|
t.positionsCacheMutex.Lock()
|
|
t.cachedPositions = nil
|
|
t.positionsCacheMutex.Unlock()
|
|
}
|
|
|
|
// Ensure GateTrader implements Trader interface
|
|
var _ types.Trader = (*GateTrader)(nil)
|