Function TestGetManagedOrders

engine/rpcserver_test.go:1784–1872

(t *testing.T)

}

func TestGetManagedOrders(t *testing.T) {
	exchName := "Binance"
	engerino := &Engine{}
	em := NewExchangeManager()
	exch, err := em.NewExchangeByName(exchName)
	if err != nil {
		t.Fatal(err)
	}
	exch.SetDefaults()
	b := exch.GetBase()
	cp := currency.NewBTCUSDT()
	b.CurrencyPairs.Pairs = make(map[asset.Item]*currency.PairStore)
	b.CurrencyPairs.Pairs[asset.Spot] = &currency.PairStore{
		Available:     currency.Pairs{cp},
		Enabled:       currency.Pairs{cp},
		AssetEnabled:  true,
		ConfigFormat:  &currency.PairFormat{Uppercase: true},
		RequestFormat: &currency.PairFormat{Uppercase: true},
	}
	err = em.Add(exch)
	require.NoError(t, err)

	var wg sync.WaitGroup
	om, err := SetupOrderManager(em, engerino.CommunicationsManager, &wg, &config.OrderManager{})
	assert.NoError(t, err)

	om.started = 1
	s := RPCServer{Engine: &Engine{ExchangeManager: em, OrderManager: om}}

	p := &gctrpc.CurrencyPair{
		Delimiter: "-",
		Base:      currency.BTC.String(),
		Quote:     currency.USDT.String(),
	}

	_, err = s.GetManagedOrders(t.Context(), nil)
	assert.ErrorIs(t, err, errInvalidArguments)

	_, err = s.GetManagedOrders(t.Context(), &gctrpc.GetOrdersRequest{
		AssetType: asset.Spot.String(),
		Pair:      p,
	})
	assert.ErrorIs(t, err, common.ErrExchangeNameNotSet)

	_, err = s.GetManagedOrders(t.Context(), &gctrpc.GetOrdersRequest{
		Exchange:  "bruh",
		AssetType: asset.Spot.String(),
		Pair:      p,
	})
	assert.ErrorIs(t, err, ErrExchangeNotFound)

	_, err = s.GetManagedOrders(t.Context(), &gctrpc.GetOrdersRequest{
		Exchange:  exchName,
		AssetType: asset.Spot.String(),
	})
	assert.ErrorIs(t, err, errCurrencyPairUnset)

	_, err = s.GetManagedOrders(t.Context(), &gctrpc.GetOrdersRequest{