Search code examples
javaudpbittorrent

Correctly Parse a BitTorrent UDP Announce Response in Java


I am trying to parse the response from an Announce request I send to a BitTorrent server over UDP. I get data back, but I don't think I am handling the IP addresses and Ports of the peers correct, as I am unable to establish a connection with any of them:

        Map<String, String> info = new Hashtable<String, String>();
        if (goodResponse) {
        try {
            int resAction = Utils.toInt(Utils.subArray(responseData, 0, 4));
            int resTrans = Utils.toInt(Utils.subArray(responseData, 4, 4));
            int interval = Utils.toInt(Utils.subArray(responseData, 8, 4));
            int leechers = Utils.toInt(Utils.subArray(responseData, 12, 4));
            int seeders = Utils.toInt(Utils.subArray(responseData, 16, 4));

            if (resAction != ERROR && resTrans == transactionID && resAction == ANNOUNCE) {

                info.put("udp", "tracker");
                info.put("seeders", String.valueOf(seeders));
                info.put("leechers", String.valueOf(leechers));
                info.put("interval", String.valueOf(interval));
                try {
                    for (int peer = 0; peer < leechers + seeders; peer++) {
                        InetAddress ip = Inet4Address.getByAddress(Utils.subArray(responseData, (20 + (6 * peer)), 4));
                        int port =  (int)Utils.toChar(Utils.subArray(responseData, (24 + (6 * peer)), 2));

                        if (port != 0) {
                            info.put(ip.getHostAddress(), String.valueOf(port));
                        }
                    }
                } catch (ArrayIndexOutOfBoundsException e) {
                    Log.w(TAG, "Too many peers returned, some were dropped");
                }
            } else if (resAction == ERROR) {
                error(responseData);
                info = null;
            } else {
                torrent.setErrorMessage("Unable to announce, invalid request");
                Log.i(TAG, "ANNOUNCE-E: A:" + resAction + " T: " + resTrans + " (" + transactionID + ") I: " + interval + " P: " + seeders + "/" + leechers);
                info = null;
            }
        } catch (Exception e) {
            torrent.setErrorMessage("Unable to announce with tracker " + host);
            Log.e(TAG, "ANNOUCE-EX: " + e.getClass().getSimpleName() + " - " + e.getMessage());
            info = null;
        }
    }

Here are the helper functions:

public static int toInt(final byte[] input) {
    return ByteBuffer.wrap(input).getInt();
}

public static char toChar(final byte[] input) {
    return ByteBuffer.wrap(input).getChar();
}

public static long toLong(byte[] input) {
    return ByteBuffer.wrap(input).getLong();
}

public static short toShort(byte[] input) {
    return ByteBuffer.wrap(input).getShort();
}

This code does spit out hosts like 79.31.92.101:49378 and 79.168.1.215:65535, so it LOOKS right, but none will allow a connection. Am I off on my parsing of the peer data?

The documentation states:

        Response:
        0           32-bit integer  action          1 // announce
        4           32-bit integer  transactionID
        8           32-bit integer  interval
        12          32-bit integer  leechers
        16          32-bit integer  seeders
        20 + 6 * n  32-bit integer  IP address
        24 + 6 * n  16-bit integer  TCP port (unsigned int)
        20 + 6 * N

Doc links: http://xbtt.sourceforge.net/udp_tracker_protocol.html

http://www.rasterbar.com/products/libtorrent/udp_tracker_protocol.html


Solution

  • Sweet, some tweaking and I got it figured out. The Port part was right, the IP address was off. Use this line instead of the InetAddress line;

    String ip = Utils.intToIp(Utils.toInt(Utils.subArray(responseData, (20 + (6 * peer)), 4)));
    

    intToIP is:

    public static String intToIp(int i) {
        return ((i >> 24) & 0xFF) + "." + ((i >> 16) & 0xFF) + "." + ((i >> 8) & 0xFF) + "." + (i & 0xFF);
    }