ByteBufferUtil.java

package com.osroyale.fs.util;
 
import java.io.ByteArrayOutputStream;
import java.nio.ByteBuffer;

 
* A static-utility class containing extension or helper methods for {@link
 * ByteBuffer}s.
 *
 * @author Ryley Kimmel <ryley.kimmel@live.com>
 */
public final class ByteBufferUtil {

    public static final char J_STRING_TERMINATOR = '\n';

    public static final char DEFAULT_STRING_TERMINATOR = '\0';

    public static int getMedium(ByteBuffer buffer) {
        return (buffer.getShort() & 0xFFFF) << 8 | buffer.get() & 0xFF;
    }

    public static String getString(ByteBuffer buffer) {
        return getString(buffer, DEFAULT_STRING_TERMINATOR);
    }

    public static String getJString(ByteBuffer buffer) {
        return getString(buffer, J_STRING_TERMINATOR);
    }
 
    public static String readStringCp1252NullTerminated(ByteBuffer buffer) {
        int var1 = buffer.position();
        while (true) {
            buffer.position(buffer.position() + 1);
            byte b = buffer.get(buffer.position() - 1);
            if (b == 0) break;
        }
 
        int var2 =buffer.position() - var1 - 1;
        return var2 == 0 ? "" : decodeStringCp1252(buffer, var1, var2);
    }
 
    public static String decodeStringCp1252(ByteBuffer buffer, int var1, int var2) {
        char[] var3 = new char[var2];
        int var4 = 0;
 
        for(int var5 = 0; var5 < var2; ++var5) {
            int var6 = buffer.get(var5 + var1) & 255;
            if (var6 != 0) {
                if (var6 >= 128 && var6 < 160) {
                    char var7 = cp1252AsciiExtension[var6 - 128];
                    if (var7 == 0) {
                        var7 = '?';
                    }
 
                    var6 = var7;
                }
 
                var3[var4++] = (char)var6;
            }
        }
 
        return new String(var3, 0, var4);
    }
 
    public static final char[] cp1252AsciiExtension = new char[]{'€', '\u0000', '‚', 'ƒ', '„', '…', '†', '‡', 'ˆ', '‰', 'Š', '‹', 'Œ', '\u0000', 'Ž', '\u0000', '\u0000', '‘', '’', '“', '”', '•', '–', '—', '˜', '™', 'š', '›', 'œ', '\u0000', 'ž', 'Ÿ'};
 

    public static byte[] get(ByteBuffer buffer, int length) {
        byte[] data = new byte[length];
        buffer.get(data);
        return data;
    }

    public static String getString(ByteBuffer buffer, char terminator) {
        ByteArrayOutputStream os = new ByteArrayOutputStream();
        for (; ; ) {
            int read = buffer.get() & 0xFF;
            if (read == terminator) {
                break;
            }
            os.write(read);
        }
        return new String(os.toByteArray());
    }

    public static int getSmart(final ByteBuffer buffer) {
        final int position = buffer.position();
        if (position >= buffer.limit()) {
            return 0;
        }
        final int peek = buffer.get(position) & 0xFF;
        if (peek < 128) {
            return buffer.get() & 0xFF;
        }
        return (buffer.getShort() & 0xFFFF) - 32768;
    }

    public static void putSmart(ByteBuffer buffer, int value) {
        if (value < 128) {
            buffer.put((byte) value);
        } else {
            value += 32768;
            buffer.put((byte) (value >> 8));
            buffer.put((byte) value);
        }
    }

    private ByteBufferUtil() {
    }
 
}