feat: handle incomplete response scenarios with appropriate error messages

Author: lakernote

src/main/java/com/laker/postman/service/http/okhttp/OkHttpResponseHandler.java

@@ -293,10 +293,18 @@ private static void handleBinaryResponse(Response okResponse, HttpResponse respo
             return;
         }
         if (is != null) {
-            FileAndSize fs = saveInputStreamToTempFile(is, "easyPostman_download_", null, contentLengthHeader);
-            response.filePath = fs.file.getAbsolutePath();
-            response.body = I18nUtil.getMessage(MessageKeys.BINARY_SAVED_TEMP_FILE);
-            response.bodySize = fs.size;
+            try {
+                FileAndSize fs = saveInputStreamToTempFile(is, "easyPostman_download_", null, contentLengthHeader);
+                response.filePath = fs.file.getAbsolutePath();
+                response.body = I18nUtil.getMessage(MessageKeys.BINARY_SAVED_TEMP_FILE);
+                response.bodySize = fs.size;
+            } catch (EOFException e) {
+                // 处理下载过程中连接中断的情况
+                log.error("Failed to download complete binary response: {}", e.getMessage());
+                response.body = I18nUtil.getMessage(MessageKeys.RESPONSE_INCOMPLETE, e.getMessage());
+                response.bodySize = 0;
+                response.filePath = null;
+            }
         } else {
             response.body = I18nUtil.getMessage(MessageKeys.NO_RESPONSE_BODY);
             response.bodySize = 0;
@@ -335,7 +343,21 @@ private static void handleTextResponse(Response okResponse, HttpResponse respons
             return;
         }
         if (body != null) {
-            byte[] bytes = body.bytes();
+            byte[] bytes;
+            try {
+                bytes = body.bytes();
+            } catch (EOFException e) {
+                // 处理响应体不完整的情况（网络中断、服务器过早关闭连接等）
+                log.error("Failed to read complete response body: {}", e.getMessage());
+                response.body = I18nUtil.getMessage(MessageKeys.RESPONSE_INCOMPLETE, e.getMessage());
+                response.bodySize = 0;
+                response.filePath = null;
+                return;
+            } catch (IOException e) {
+                // 处理其他 IO 异常
+                log.error("Error reading response body: {}", e.getMessage(), e);
+                throw e;
+            }
             response.bodySize = bytes.length;
             if (bytes.length > getMaxBodySize()) { // 如果解压后内容超过设置值，保存为临时文件
                 String extension = ext != null ? ext : ".txt";

src/main/java/com/laker/postman/util/MessageKeys.java

@@ -796,6 +796,7 @@ public final class MessageKeys {
     public static final String TEXT_TOO_LARGE_BODY = "text.too_large.body";
     public static final String BODY_TOO_LARGE_SAVED = "body.too_large.saved";
     public static final String SSE_STREAM_UNSUPPORTED = "sse.stream.unsupported";
+    public static final String RESPONSE_INCOMPLETE = "response.incomplete";
 
     // ============ ResponseAssertion 国际化 ============
     public static final String RESPONSE_ASSERTION_STATUS_FAILED = "response.assertion.status_failed";

src/main/resources/messages_en.properties

@@ -681,6 +681,7 @@ text.too_large=Text content size {0}MB exceeds the max download limit ({1} MB)
 text.too_large.body=[Text content exceeds max download limit, not downloaded. Limit: {0} MB]
 body.too_large.saved=[Body exceeds {0}KB, saved as temp file. Download to view full content]
 sse.stream.unsupported=[SSE stream response, cannot be handled directly]
+response.incomplete=[Incomplete response: connection closed prematurely. Error: {0}]
 # ResponseAssertion i18n
 response.assertion.status_failed=Status code assertion failed: expected={0}, actual={1}
 response.assertion.header_not_found=Response header not found

src/main/resources/messages_zh.properties

@@ -679,6 +679,7 @@ text.too_large=文本内容大小 {0}MB 超出最大下载限制（{1} MB）
 text.too_large.body=[文本内容超出最大下载限制，未下载。限制：{0} MB]
 body.too_large.saved=[响应体内容超过{0}KB，已保存为临时文件，可下载查看完整内容]
 sse.stream.unsupported=[SSE 流响应，无法直接处理]
+response.incomplete=[响应不完整：连接过早关闭。错误：{0}]
 # ResponseAssertion 国际化
 response.assertion.status_failed=响应状态码断言失败: 期望={0}, 实际={1}
 response.assertion.header_not_found=响应头不存在