package cn.org.hentai.jtt1078.test;

import cn.org.hentai.jtt1078.util.ByteHolder;
import cn.org.hentai.jtt1078.util.ByteUtils;

import java.io.ByteArrayOutputStream;
import java.io.IOException;
import java.nio.ByteBuffer;
import java.nio.channels.ByteChannel;

/**
 * Created by matrixy on 2020/1/9.
 */
public class ChannelTest implements ByteChannel
{
    byte[] temp = new byte[4];
    ByteHolder buffer = new ByteHolder(1024);

    // 读出，存入dst
    @Override
    public int read(ByteBuffer dst) throws IOException
    {
        dst.flip();
        int len = Math.min(4, buffer.size());
        if (dst.remaining() > len)
        {
            buffer.sliceInto(temp, len);
            dst.put(temp, 0, len);
        }
        else
        {
            // 丢掉？？？
        }
        dst.flip();
        return len;
    }

    // 从src读出，写入进来
    @Override
    public int write(ByteBuffer src) throws IOException
    {
        int len = -1;
        // src.flip();
        len = Math.min(4, src.limit());
        src.get(temp, 0, len);
        buffer.write(temp, 0, len);
        // src.flip();
        System.out.println("write: " + len);
        return len;
    }

    @Override
    public boolean isOpen()
    {
        return true;
    }

    @Override
    public void close() throws IOException
    {

    }

    public byte[] array()
    {
        return buffer.array();
    }

    public static void main(String[] args) throws Exception
    {
        ChannelTest chl = new ChannelTest();
        ByteBuffer buffer = ByteBuffer.allocate(4);
        java.nio.ByteBuffer xx;
        System.out.println(buffer.getClass().getName());
        for (int i = 0; i < 4096; i++)
            buffer.put((byte)'f');
        /*
        buffer.putLong(0x1122334455667788L);
        buffer.flip();
        // flip太迷惑了
        buffer.isReadOnly();
        int len = chl.write(buffer);
        len = chl.write(buffer);
        ByteUtils.dump(chl.array());
        */
    }

    static final class ByteBufferWrapper
    {
        boolean writeMode;
        ByteBuffer buffer;

        private ByteBufferWrapper(int size)
        {
            this.buffer = ByteBuffer.allocate(size);
        }

        // 控制写入，代理过来
        public void write()
        {

        }

        // 写出就无所谓了

        public static ByteBufferWrapper create(int size)
        {
            return new ByteBufferWrapper(size);
        }
    }
}