Subversion Repositories Integrator Subversion

package br.com.kronus.ibkr.futures;

import java.math.BigDecimal;

import java.util.concurrent.CompletableFuture;

import java.util.concurrent.TimeUnit;

import java.util.concurrent.atomic.AtomicInteger;

import com.ib.client.Contract;

import br.com.kronus.core.trade.ServicoMercadoFuturos;

import br.com.kronus.ibkr.api.IbkrClient;

import br.com.kronus.ibkr.api.IbkrMapper;

/**

 * Implementação de mercado usando IBKR, reutilizando a assinatura do serviço da Binance.

 */

public class ServicoMercadoFuturosIbkr implements ServicoMercadoFuturos {

    private final IbkrClient ibkr;

    private final AtomicInteger nextTickerId = new AtomicInteger(1);

    public ServicoMercadoFuturosIbkr(IbkrClient ibkr) {

        this.ibkr = ibkr;

    }

    /**

     * Obtém o último preço do símbolo usando market data da IBKR.

     */

    @Override

    public BigDecimal obterUltimoPreco(String symbol) throws Exception {

        Contract contract = IbkrMapper.contratoFuturoIndice(symbol);

        int tickerId = nextTickerId.getAndIncrement();

        CompletableFuture<BigDecimal> future = ibkr.registrarFuturePreco(tickerId);

        ibkr.getClient().reqMktData(tickerId, contract, "", false, false, null);

        BigDecimal preco = future.get(5, TimeUnit.SECONDS);

        ibkr.getClient().cancelMktData(tickerId);

        return preco;

    }

}