第16篇_Client 05｜状态行、Header 和响应 Body 怎样完整接收

METHOD PUBLIC M_ParseResponse : BOOL
VAR_INPUT
    sMessage : STRING(GVL_Http.cnMaxMessageSize) := '';    // 诊断或协议文本字段。
END_VAR
VAR_OUTPUT
    stResponse : ST_HttpResponse;    // 结构化协议或测试数据。
END_VAR
VAR
    iFirstLineEnd    : INT;                                     // 计数、长度或状态数值。
    iHeaderEnd       : INT;                                     // 计数、长度或状态数值。
    iSpace1          : INT;                                     // 计数、长度或状态数值。
    iSpace2Relative  : INT;                                     // 计数、长度或状态数值。
    iHeaderStart     : INT;                                     // 计数、长度或状态数值。
    iHeaderLen       : INT;                                     // 计数、长度或状态数值。
    iBodyStart       : INT;                                     // 计数、长度或状态数值。
    iBodyLen         : INT;                                     // 计数、长度或状态数值。
    sStartLine       : STRING(255);                             // 诊断或协议文本字段。
    sAfterVersion    : STRING(255);                             // 诊断或协议文本字段。
    sHeaderText      : STRING(GVL_Http.cnMaxHeaderSize);        // 诊断或协议文本字段。
    sBodyText        : STRING(GVL_Http.cnMaxBodySize);          // 诊断或协议文本字段。
    sHeaderValue     : STRING(GVL_Http.cnMaxHeaderValueLen);    // 诊断或协议文本字段。
    udiContentLength : UDINT;                                   // 计数、长度或状态数值。
    uiHeaderCount    : UINT;                                    // 计数、长度或状态数值。
    bHeaderFound     : BOOL;                                    // 布尔状态或命令标志。
    bHeaderInvalid   : BOOL;                                    // 布尔状态或命令标志。
END_VAR
// === IMPLEMENTATION ===
// 工程说明：本段集中处理状态、边界或诊断，避免跨周期残留。
// 边界说明：执行前后保持输出和错误码可被在线诊断追踪。
// 原因：Client 响应解析必须同时覆盖 Content-Length、chunked 和 close-delimited 三种常见响应边界。
// 约束：TE+CL 响应按协议错误处理，避免 PLC Client 接受代理或服务器生成的歧义报文。
// 风险：超限 body 在拷贝到业务字符串前即失败，保护固定长度 STRING 不被截断后误判为成功。
// 诊断：状态码、Reason、body 和协议错误码全部写入 stResponse/eError，供真机矩阵逐项断言。
M_Reset();
M_ParseResponse := FALSE;
M_ResetResponse(
    stResponse := stResponse
    );

iFirstLineEnd := FIND(sMessage, '$R$N');
iHeaderEnd := FIND(sMessage, '$R$N$R$N');
IF (iFirstLineEnd <= 1) OR (iHeaderEnd <= iFirstLineEnd) THEN
    M_SetError(
        eNewError := E_HttpError.iNeedMoreData,
        sMessage  := 'response header is incomplete'
        );
    RETURN;
END_IF

sStartLine := LEFT(sMessage, iFirstLineEnd - 1);
iSpace1 := FIND(sStartLine, ' ');
IF (iSpace1 <= 1) OR (FIND(sStartLine, 'HTTP/') <> 1) THEN
    M_SetError(
        eNewError := E_HttpError.iInvalidStartLine,
        sMessage  := 'response start-line is invalid'
        );
    RETURN;
END_IF

sAfterVersion := MID(sStartLine, LEN(sStartLine) - iSpace1, iSpace1 + 1);
iSpace2Relative := FIND(sAfterVersion, ' ');
IF iSpace2Relative <= 1 THEN
    M_SetError(
        eNewError := E_HttpError.iInvalidStartLine,
        sMessage  := 'response start-line misses reason'
        );
    RETURN;
END_IF

stResponse.sVersion := LEFT(sStartLine, iSpace1 - 1);
stResponse.uiStatusCode := STRING_TO_UINT(LEFT(sAfterVersion, iSpace2Relative - 1));
stResponse.sReason := MID(sAfterVersion, LEN(sAfterVersion) - iSpace2Relative, iSpace2Relative + 1);
IF stResponse.uiStatusCode = 0 THEN
    M_SetError(
        eNewError := E_HttpError.iInvalidStartLine,

        sMessage  := 'response status code is invalid'
        );
    RETURN;
END_IF

iHeaderStart := iFirstLineEnd + 2;
iHeaderLen := iHeaderEnd - iHeaderStart;
IF iHeaderLen > GVL_Http.cnMaxHeaderSize THEN
    M_SetError(
        eNewError := E_HttpError.iBufferTooSmall,
        sMessage  := 'response header exceeds limit'
        );
    RETURN;
END_IF
IF iHeaderLen > 0 THEN
    sHeaderText := MID(sMessage, iHeaderLen, iHeaderStart);
ELSE
    sHeaderText := '';
END_IF
stResponse.sRawHeaders := sHeaderText;

bHeaderFound := F_HttpFindHeader(
    sHeaders        := sHeaderText,
    sHeaderName     := 'Content-Type',
    sValue          => sHeaderValue,
    uiCount         => uiHeaderCount,
    bInvalidGrammar => bHeaderInvalid
    );
IF bHeaderInvalid THEN
    M_SetError(
        eNewError := E_HttpError.iInvalidHeader,
        sMessage  := 'response header grammar is invalid'
        );
    RETURN;
END_IF
IF bHeaderFound THEN
    stResponse.sContentType := sHeaderValue;
END_IF

stResponse.bTransferChunked := FALSE;
bHeaderFound := F_HttpFindHeader(
    sHeaders        := sHeaderText,
    sHeaderName     := 'Transfer-Encoding',
    sValue          => sHeaderValue,
    uiCount         => uiHeaderCount,
    bInvalidGrammar => bHeaderInvalid
    );
IF uiHeaderCount > 1 THEN
    M_SetError(
        eNewError := E_HttpError.iUnsupportedTransferEncoding,
        sMessage  := 'duplicate response transfer-encoding'
        );
    RETURN;
END_IF
IF bHeaderFound THEN
    IF F_HttpAsciiEqualsIgnoreCase(
        sLeft  := sHeaderValue,
        sRight := 'chunked'
        ) THEN
        stResponse.bTransferChunked := TRUE;
    ELSE
        M_SetError(
            eNewError := E_HttpError.iUnsupportedTransferEncoding,
            sMessage  := 'unsupported response transfer-encoding'
            );
        RETURN;
    END_IF
END_IF

stResponse.bHasContentLength := FALSE;
bHeaderFound := F_HttpFindHeader(
    sHeaders        := sHeaderText,
    sHeaderName     := 'Content-Length',
    sValue          => sHeaderValue,
    uiCount         => uiHeaderCount,