docs: unify @author tag to @author <a href="https://github.com/loong10k">Loong Wan</a>

Author: loong10k

src/main/java/io/github/easy4j/hermes/api/HermesHttpClient.java

@@ -9,10 +9,12 @@
 import static io.github.easy4j.hermes.api.HermesApiConstants.*;
 import io.github.easy4j.hermes.api.model.*;
 import io.github.easy4j.hermes.exception.HermesHttpException;
+import lombok.Getter;
 import lombok.extern.slf4j.Slf4j;
 import okhttp3.*;
 
 import java.io.IOException;
+import java.nio.charset.StandardCharsets;
 import java.util.*;
 import java.util.concurrent.atomic.AtomicLong;
 import okio.Buffer;
@@ -22,12 +24,18 @@
  * <p>基于 OkHttp，支持外部传入 {@link OkHttpClient}（复用别的插件实例）。</p>
  */
 @Slf4j
+@SuppressWarnings("unchecked")
 public class HermesHttpClient implements AutoCloseable {
 
     private static final MediaType JSON = MediaType.get("application/json; charset=utf-8");
     private static final AtomicLong REQUEST_SEQUENCE = new AtomicLong();
 
     private final HermesHttpClientConfig config;
+    /**
+     * -- GETTER --
+     *  暴露 ObjectMapper 供外部复用。
+     */
+    @Getter
     private final ObjectMapper objectMapper;
     private final OkHttpClient httpClient;
     private final boolean ownsHttpClient;
@@ -108,11 +116,7 @@ public boolean deleteResponse(String responseId) {
     public ModelsResponse listModels() { return get(PATH_MODELS, ModelsResponse.class); }
 
     private static String encodePathSegment(String value) {
-        try {
-            return java.net.URLEncoder.encode(value, "UTF-8");
-        } catch (java.io.UnsupportedEncodingException e) {
-            throw new IllegalStateException("UTF-8 is not supported", e);
-        }
+        return java.net.URLEncoder.encode(value, StandardCharsets.UTF_8);
     }
 
     public ModelsResponse.ModelData getModel(String modelId) {
@@ -157,7 +161,6 @@ public void stopRun(String runId) {
         }
     }
 
-    @SuppressWarnings("unchecked")
     public Map<String, Object> approveRun(String runId, Map<String, Object> decision) {
         return postMap(PATH_RUNS + "/" + runId + "/approval", decision);
     }
@@ -227,7 +230,6 @@ public Map<String, Object> createJob(Map<String, Object> job) {
         return postMap(PATH_JOBS, job);
     }
 
-    @SuppressWarnings("unchecked")
     public Map<String, Object> getJob(String jobId) {
         Request request = authedRequest(url(PATH_JOBS + "/" + jobId)).get().build();
         try (Response response = httpClient.newCall(request).execute()) {
@@ -241,7 +243,6 @@ public Map<String, Object> getJob(String jobId) {
         }
     }
 
-    @SuppressWarnings("unchecked")
     public Map<String, Object> updateJob(String jobId, Map<String, Object> patch) {
         Request request = authedRequest(url(PATH_JOBS + "/" + jobId))
                 .patch(RequestBody.create(toJson(patch), JSON)).build();
@@ -299,13 +300,6 @@ public OkHttpClient getOkHttpClient() {
         return httpClient;
     }
 
-    /**
-     * 暴露 ObjectMapper 供外部复用。
-     */
-    public ObjectMapper getObjectMapper() {
-        return objectMapper;
-    }
-
     // ============================================================
     // Internal helpers
     // ============================================================

src/main/java/io/github/easy4j/hermes/api/HermesSseClient.java

@@ -170,15 +170,13 @@ private void doSubscribePost(String url,
             sub.callRef.set(call);
             try (Response response = call.execute()) {
                 if (!response.isSuccessful()) {
-                    String body = response.body() != null ? response.body().string() : "";
+                    String body = response.body().string();
                     onError.accept(new HermesHttpException(response.code(), body));
                     return;
                 }
                 log.info("SSE chat connected: url={}, status={}, elapsedMs={}", url, response.code(),
                         (System.nanoTime() - startedAt) / 1_000_000L);
-                if (response.body() != null) {
-                    parseSseSource(response.body().source(), consumer, completeOnce, sub);
-                }
+                parseSseSource(response.body().source(), consumer, completeOnce, sub);
             }
             completeOnce.run();
         } catch (Exception e) {
@@ -201,14 +199,12 @@ private void doSubscribeSessionStream(String sessionId, String input,
                 sub.callRef.set(call);
                 try (Response response = call.execute()) {
                     if (!response.isSuccessful()) {
-                        String body = response.body() != null ? response.body().string() : "";
+                        String body = response.body().string();
                         log.warn("SSE session stream failed status={}, retrying", response.code());
                         Thread.sleep(DEFAULT_CONNECT_TIMEOUT_MS / 3);
                         continue;
                     }
-                    if (response.body() != null) {
-                        parseSseSource(response.body().source(), consumer, () -> {}, sub);
-                    }
+                    parseSseSource(response.body().source(), consumer, () -> {}, sub);
                 }
             } catch (InterruptedException e) {
                 Thread.currentThread().interrupt();
@@ -238,9 +234,8 @@ private void doSubscribeRun(String runId, Consumer<SseEvent> consumer, Subscript
                         continue;
                     }
                     log.info("SSE connected to run events {}", runId);
-                    if (response.body() != null) {
-                        parseSseSource(response.body().source(), consumer, () -> {}, sub);
-                    }
+                    parseSseSource(response.body().source(), consumer, () -> {
+                    }, sub);
                 }
             } catch (InterruptedException e) {
                 Thread.currentThread().interrupt();