Function TestUpdateAccountBalances

engine/rpcserver_test.go:1242–1266

(t *testing.T)

}

func TestUpdateAccountBalances(t *testing.T) {
	t.Parallel()
	em := NewExchangeManager()
	exch, err := em.NewExchangeByName(testExchange)
	require.NoError(t, err)
	b := exch.GetBase()
	b.Name = fakeExchangeName
	b.Enabled = true
	b.CurrencyPairs.Pairs = make(map[asset.Item]*currency.PairStore)
	b.CurrencyPairs.Pairs[asset.Spot] = &currency.PairStore{AssetEnabled: true}
	fakeExchange := fExchange{IBotExchange: exch}
	err = em.Add(fakeExchange)
	require.NoError(t, err)

	s := RPCServer{Engine: &Engine{ExchangeManager: em}}
	ctx := accounts.DeployCredentialsToContext(t.Context(), &accounts.Credentials{Key: "fakerino", Secret: "supafake", SubAccount: "42"})
	_, err = s.GetAccountBalances(ctx, &gctrpc.GetAccountBalancesRequest{Exchange: fakeExchangeName, AssetType: asset.Spot.String()})
	assert.NoError(t, err)

	_, err = s.UpdateAccountBalances(ctx, &gctrpc.GetAccountBalancesRequest{Exchange: fakeExchangeName, AssetType: asset.Futures.String()})
	assert.ErrorIs(t, err, currency.ErrAssetNotFound)

	_, err = s.UpdateAccountBalances(ctx, &gctrpc.GetAccountBalancesRequest{Exchange: fakeExchangeName, AssetType: asset.Spot.String()})
	assert.NoError(t, err)
}

func TestGetOrders(t *testing.T) {
	t.Parallel()