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.setRequest(request.getRequestId());
                    session.sendRequest(request);
                    Thread.sleep(1000);
                }
            }
        } catch (Exception e) {
            System.out.println("Exception in getAccounts().\n\t " + e.getMessage());
        }
    }
    // 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.setRequest(request.getRequestId());
                    session.sendRequest(request);
                    Thread.sleep(1000);
                }
            }
        } catch (Exception e) {
            System.out.println("Exception in getTrades().\n\t " + e.getMessage());
        }
    }
 
    // Use generic reader
    public static void useGenericReader(O2GGenericTableResponseReader genericReader) {
        int columnsCount = 0;
        System.out.println("\n\nThis is a response to your " + genericReader.getType() + " table refresh request.\n");
        O2GTableColumnCollection columns = genericReader.getColumns();
        columnsCount = columns.size();
        for (int j = 0; j < columnsCount; j++) {
            O2GTableColumn column = columns.get(j);
            System.out.println("" + column.getId() + " " + column.getType());
            for (int i = 0; i < genericReader.size(); i++) {
                Object value = genericReader.getCell(i, j);
                System.out.println("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.getType()) {
                    case GET_ACCOUNTS: {
                        reader = readerFactory.createAccountsTableReader(response);
                    }
                    case GET_TRADES:  {
                        reader = readerFactory.createTradesTableReader(response);
                    }
                    System.out.println("\n\nThis is a response to your " + reader.getType() + " request.\n");
                    O2GTableColumnCollection columns = reader.getColumns();
                    columnsCount = columns.size();
                    for (int j = 0; j < columnsCount; j++) {
                        O2GTableColumn column = columns.get(j);
                        System.out.println("" + column.getId() + " " + column.getType());
                        for (int i = 0; i < reader.size(); i++) {
                            Object value = reader.getCell(i, j);
                            System.out.println("Value: " + value);
                        }
                    }
 
                }
            }
        }
}