public static void main()

in src/main/java/com/uber/rss/tools/StreamReadClientVerify.java [177:206]

• 27 lines of code
• 7 McCabe index (conditional complexity)

    public static void main(String[] args) {
        StreamReadClientVerify tool = new StreamReadClientVerify();
        
        int i = 0;
        while (i < args.length) {
            String argName = args[i++];
            if (argName.equalsIgnoreCase("-rssServers")) {
                String str = args[i++];
                String[] strArray = str.split(":");
                List<ServerDetail> serverDetails = Arrays.asList(strArray).stream().map(t->{
                    ServerHostAndPort hostAndPort = ServerHostAndPort.fromString(t);
                    return TestUtils.getServerDetail(hostAndPort.getHost(), hostAndPort.getPort());
                }).collect(Collectors.toList());
                tool.rssServers.addAll(serverDetails);
            } else if (argName.equalsIgnoreCase("-appId")) {
                tool.appId = args[i++];
            } else if (argName.equalsIgnoreCase("-appAttempt")) {
                tool.appAttempt = args[i++];
            } else if (argName.equalsIgnoreCase("-shuffleId")) {
                tool.shuffleId = Integer.parseInt(args[i++]);
            } else if (argName.equalsIgnoreCase("-expectedTotalRecords")) {
                tool.expectedTotalRecords = Long.parseLong(args[i++]);
            } else {
                throw new IllegalArgumentException("Unsupported argument: " + argName);
            }
        }

        // TODO refine following
        tool.verifyRecords(null, null);
    }