Почему мне нужно отправить сообщение дважды, чтобы вызвать событие Indy OnExecute?

Я работаю над приложением, которое работает как «человек посередине» для анализа протокола (ISO 8583), отправленного через TCP/IP.

Основная идея состоит в том, чтобы получить необработанные двоичные данные и преобразовать их в строку для разбора и декодирования протокола.

Для этого я использую компонент TIdMappedPortTCP.

Тестирую с Hercules.

Я работаю с:

Windows 11 Домашняя

Embarcadero® C++Builder 10.4 Версия 27.0.40680.4203

Delphi и C++ Builder 10.4, обновление 2

Инди 10.6.2.0

Больше контекста можно найти в этих вопросах:

Где я могу найти полностью рабочий пример TCP-клиента и сервера для Indy в C++Builder?

Разбор байтов как BCD с помощью Indy C++ Builder

Проблема в том, что мне нужно отправить сообщение дважды, чтобы вызвать событие OnExecute. Я думаю, что это может быть связано с длиной, но я не нашел проблему. В остальном программа делает то, что от нее ожидается.

Если я использую эти данные в Hercules:

00 04 60 02

эквивалентно:

"\x00\x04\x60\x02"

Моя программа обрабатывает все правильно:

Вот код:

void __fastcall TForm1::MITMProxyExecute(TIdContext *AContext)
{
    static int index;
    TIdBytes ucBuffer;
    UnicodeString usTemp1;
    UnicodeString usTemp2;
    int calculated_length;

    // getting the length in Hexa
    calculated_length = ReadMessageLength(AContext);
    // reads data
    AContext->Connection->IOHandler->ReadBytes(ucBuffer, calculated_length);

    // displays string with calculated length and size of the data
    usTemp2 = UnicodeString("calculated length = ");
    usTemp2 += IntToStr(calculated_length);
    usTemp2 += " ucBuffer.Length = ";
    usTemp2 += IntToStr(ucBuffer.Length);
    Display->Lines->Add(usTemp2);
    // converts the binary data into a a Hex String for visualization
    usTemp1 = BytesToHexString(ucBuffer);

    // adds an index to distinguish from previous entries.
    usTemp2 = IntToStr(index);
    usTemp2 += UnicodeString(": ");
    usTemp2 += usTemp1;
    Display->Lines->Add(usTemp2);
    index++;
}

Вот код вызываемых там функций. Кстати, есть ли лучший способ преобразовать байты в шестнадцатеричную строку?

// Convert an array of bytes to a hexadecimal string
UnicodeString BytesToHexString(const TBytes& bytes)
{
    // Create an empty UnicodeString to store the hexadecimal representation of the bytes
    UnicodeString hexString;

    // Iterate through each byte in the array
    for (int i = 0; i < bytes.Length; i++)
    {
        // Convert the byte to a hexadecimal string and append it to the result string
        hexString += IntToHex(bytes[i], 2);
    }

    // Return the hexadecimal string
    return hexString;
}

// Read the first two bytes of an incoming message and interpret them as the length of the message
int ReadMessageLength(TIdContext *AContext)
{
    int calculated_length;

    // Use the 'ReadSmallInt' method to read the length of the message from the first two bytes
    calculated_length = AContext->Connection->IOHandler->ReadSmallInt();
    // converting from hex binary to hex string
    UnicodeString bcdLength = UnicodeString().sprintf(L"%04x", calculated_length);
    // converting from hex string to int
    calculated_length = bcdLength.ToInt();
    // decrease length
    calculated_length -= 2;
    return calculated_length;
}

ОБНОВЛЯТЬ Я создал класс для обновления элемента управления TEditRich. Но проблема сохраняется, мне нужно дважды отправить сообщение для обработки, и приложение зависает при попытке закрыть его. Это мой класс:

class TAddTextToDisplay : public TIdSync {
private:
    UnicodeString textToAdd;

public:
    __fastcall TAddTextToDisplay(UnicodeString str) {
        // Store the input parameters in member variables.
        textToAdd = str;
    }

    virtual void __fastcall DoSynchronize() {
        if (textToAdd != NULL) {
            // Use the input parameters here...
            Form1->Display->Lines->Add(textToAdd);
        }
    }

    void __fastcall setTextToAdd(UnicodeString str) {
        textToAdd = str;
    }
};

А вот так выглядит мое новое событие OnExecute:

void __fastcall TForm1::MITMProxyExecute(TIdContext *AContext) {
    static int index;
    TIdBytes ucBuffer;
    UnicodeString usTemp1;
    UnicodeString usTemp2;
    int calculated_length;
    int bytes_remaining;

    // getting the length in Hexa
    calculated_length = ReadMessageLength(AContext);
    if (!AContext->Connection->IOHandler->InputBufferIsEmpty()) {

        // reads data
        AContext->Connection->IOHandler->ReadBytes(ucBuffer, calculated_length);

        // displays string with calculated length and size of the data
        usTemp2 = UnicodeString("calculated length = ");
        usTemp2 += IntToStr(calculated_length);
        usTemp2 += " ucBuffer.Length = ";
        usTemp2 += IntToStr(ucBuffer.Length);
        TAddTextToDisplay *AddTextToDisplay = new TAddTextToDisplay(usTemp2);
        AddTextToDisplay->Synchronize();

        // converts the binary data into a a Hex String for visualization
        usTemp1 = BytesToHexString(ucBuffer);
        // adds an index to distinguish from previous entries.
        usTemp2 = IntToStr(index);
        usTemp2 += UnicodeString(": ");
        usTemp2 += usTemp1;
        AddTextToDisplay->setTextToAdd(usTemp2);
        AddTextToDisplay->Synchronize();
        delete AddTextToDisplay;
        index++;
    }

}