package cn.org.hentai.jtt1078.test;

import cn.org.hentai.jtt1078.server.video.Jtt1078Decoder;
import cn.org.hentai.jtt1078.util.Packet;

import java.io.FileInputStream;
import java.io.FileOutputStream;

public class UnPack
{
    public static void main(String[] args) throws Exception
    {
        FileInputStream input = new FileInputStream("d:\\test\\1078\\d.bin");
        FileOutputStream output = new FileOutputStream("d:\\test\\1078\\fuck.1078.xxx");

        int len = -1;
        byte[] block = new byte[1024];
        Jtt1078Decoder decoder = new Jtt1078Decoder();
        while (true)
        {
            len = input.read(block);
            if (len == -1) break;
            decoder.write(block, 0, len);

            while (true)
            {
                Packet p = decoder.decode();
                if (p == null) break;

                int lengthOffset = 28;
                int dataType = (p.seek(15).nextByte() >> 4) & 0x0f;
                // 透传数据类型：0100，没有后面的时间以及Last I Frame Interval和Last Frame Interval字段
                if (dataType == 0x04) lengthOffset = 28 - 8 - 2 - 2;
                else if (dataType == 0x03) lengthOffset = 28 - 4;

                // FFMpegManager.getInstance().feed(publisherId, packet.seek(lengthOffset + 2).nextBytes());
                if (dataType == 0x00 || dataType == 0x01 || dataType == 0x02)
                {
                    // 视频
                    // p.seek(lengthOffset + 2).nextBytes()
                    // output.write(p.seek(lengthOffset + 2).nextBytes());
                    System.out.println(p.seek(lengthOffset).nextShort());
                }
                else
                {
                    // 音频
                    // p.seek(lengthOffset + 2).nextBytes()
                }
            }
        }
        output.flush();
        output.close();
        input.close();
    }
}