Get initial accounts and trades information [show]

Get initial accounts and trades information [hide]

    // Get accounts information
    public static void getAccounts(O2GSession session, ResponseListener responseListener)
    {
        try
        {
            O2GLoginRules loginRules = session.getLoginRules();
            if (loginRules != null && loginRules.isTableLoadedByDefault(O2GTableType.Accounts))
            {
                O2GResponse accountsResponse = loginRules.getTableRefreshResponse(O2GTableType.Accounts);
                O2GResponseReaderFactory responseFactory = session.getResponseReaderFactory();
                O2GAccountsTableResponseReader accountsReader = responseFactory.createAccountsTableReader(accountsResponse);
                useGenericReader(accountsReader);
            }
            else
            {
                O2GRequestFactory requestFactory = session.getRequestFactory();
                if (requestFactory != null)
                {
                    O2GRequest request = requestFactory.createRefreshTableRequest(O2GTableType.Accounts);
                    responseListener.RequestID = request.RequestID;
                    session.sendRequest(request);
                    Thread.Sleep(1000);
                }
            }
        }
        catch (Exception e)
        {
            Console.WriteLine("Exception in getAccounts(). " + e.Message);
        }
    }
    // Get trades information
    public static void getTrades(O2GSession session, ResponseListener responseListener)
    {
        try
        {
            O2GLoginRules loginRules = session.getLoginRules();
            if (loginRules != null && loginRules.isTableLoadedByDefault(O2GTableType.Trades))
            {
                O2GResponse tradesResponse = loginRules.getTableRefreshResponse(O2GTableType.Trades);
                O2GResponseReaderFactory responseFactory = session.getResponseReaderFactory();
                O2GTradesTableResponseReader tradesReader = responseFactory.createTradesTableReader(tradesResponse);
                useGenericReader(tradesReader);
            }
            else
            {
                O2GRequestFactory requestFactory = session.getRequestFactory();
                if (requestFactory != null)
                {
                    O2GRequest request = requestFactory.createRefreshTableRequest(O2GTableType.Trades);
                    responseListener.RequestID = request.RequestID;
                    session.sendRequest(request);
                    Thread.Sleep(1000);
                }
            }
        }
        catch (Exception e)
        {
            Console.WriteLine("Exception in getTrades(). " + e.Message);
        }
    }
 
    // Use generic reader
    public static void useGenericReader(O2GGenericTableResponseReader genericReader)
    {
        int columnsCount = 0;
        Console.WriteLine("This is a response to your " + genericReader.Type + " table refresh request.");
        O2GTableColumnCollection columns = genericReader.Columns;
        columnsCount = columns.Count;
        for (int j = 0; j < columnsCount; j++)
        {
            O2GTableColumn column = columns[j];
            Console.WriteLine("" + column.ID + " " + column.ColumnType);
            for (int i = 0; i < genericReader.Count; i++)
            {
                Object value = genericReader.getCell(i, j);
                Console.WriteLine("Value: " + value);
            }
        }
    }
 
    // Implementation of IO2GResponseListener interface public method onRequestCompleted
    public void onRequestCompleted(String requestID, O2GResponse response)
    {
        int columnsCount = 0;
        O2GGenericTableResponseReader reader = null;
        if (requestID.Equals(mRequestID))
        {
            O2GResponseReaderFactory readerFactory = mSession.getResponseReaderFactory();
            if (readerFactory != null)
            {
                switch (response.Type)
                {
                    case O2GResponseType.GetAccounts:
                        reader = readerFactory.createAccountsTableReader(response);
                        break;
                    case O2GResponseType.GetTrades:
                        reader = readerFactory.createTradesTableReader(response);
                        break;
                }
                Console.WriteLine("This is a response to your " + reader.Type + " request.");
                O2GTableColumnCollection columns = reader.Columns;
                columnsCount = columns.Count;
                for (int j = 0; j < columnsCount; j++)
                {
                    O2GTableColumn column = columns[j];
                    Console.WriteLine("" + column.ID + " " + column.ColumnType);
                    for (int i = 0; i < reader.Count; i++)
                    {
                        Object value = reader.getCell(i, j);
                        Console.WriteLine("Value: " + value);
                    }
                }
            }
        }
    }