import org.agrona.DirectBuffer;
import org.agrona.concurrent.UnsafeBuffer;
import org.junit.Test;
import sbeir.bug.ExecutionReportEncoder;
import sbeir.bug.MessageHeaderEncoder;
import uk.co.real_logic.sbe.ir.Ir;
import uk.co.real_logic.sbe.ir.IrDecoder;
import uk.co.real_logic.sbe.ir.Token;
import uk.co.real_logic.sbe.otf.AbstractTokenListener;
import uk.co.real_logic.sbe.otf.OtfHeaderDecoder;
import uk.co.real_logic.sbe.otf.OtfMessageDecoder;
import java.io.File;
import java.io.IOException;
import java.nio.ByteBuffer;
import java.nio.channels.FileChannel;
import java.nio.file.StandardOpenOption;
import java.util.ArrayDeque;
import java.util.Deque;
import java.util.List;
import static java.util.stream.Collectors.joining;
public class Bug
{
    @Test
    public void test() throws IOException
    {
        UnsafeBuffer buffer = new UnsafeBuffer(new byte[4096]);
        MessageHeaderEncoder headerEncoder = new MessageHeaderEncoder();
        ExecutionReportEncoder executionReportEncoder = new ExecutionReportEncoder();
        executionReportEncoder.wrapAndApplyHeader(buffer, 0, headerEncoder);
        executionReportEncoder.instructionId("abcdef");
        executionReportEncoder.orderState().otherInstructionId("ghijk");
        final ByteBuffer byteBuffer = readOrderBookEventsIr("/bug.sbeir");
        Ir orderBookEventsIr = new IrDecoder(byteBuffer).decode();
        OtfHeaderDecoder headerDecoder = new OtfHeaderDecoder(orderBookEventsIr.headerStructure());
        final int blockLength = headerDecoder.getBlockLength(buffer, 0);
        final int templateId = headerDecoder.getTemplateId(buffer, 0);
        OtfMessageDecoder.decode(
            buffer,
            headerDecoder.encodedLength(),
            209,
            blockLength,
            orderBookEventsIr.getMessage(templateId),
            new AbstractTokenListener()
            {
                private final Deque<String> path = new ArrayDeque<>();
                private int compositeDepth = 0;
                @Override
                public void onBeginComposite(final Token fieldToken, final List<Token> tokens, final int fromIndex, final int toIndex)
                {
                    if (compositeDepth > 0)
                    {
                        path.addLast(tokens.get(fromIndex).name());
                    }
                    else
                    {
                        path.addLast(fieldToken.name());
                    }
                    compositeDepth++;
                }
                @Override
                public void onEndComposite(final Token fieldToken, final List<Token> tokens, final int fromIndex, final int toIndex)
                {
                    path.removeLast();
                    compositeDepth--;
                }
                @Override
                public void onEncoding(final Token fieldToken, final DirectBuffer buffer, final int bufferIndex, final Token typeToken, final int actingVersion)
                {
                    path.addLast(fieldToken.name());
                    System.out.printf("%s%n", path.stream().collect(joining(".")));
                    System.out.printf("fieldToken: %s%n", fieldToken);
                    System.out.printf("typeToken : %s%n", typeToken);
                    path.removeLast();
                }
            });
    }
    private ByteBuffer readOrderBookEventsIr(String s) throws IOException
    {
        FileChannel open = FileChannel.open(new File("bug.sbeir").toPath(), StandardOpenOption.READ);
        return open.map(FileChannel.MapMode.READ_ONLY, 0, open.size());
    }
}