feat: use session url

Author: MoeexT

backend/api-gateway/src/main/java/com/datamate/gateway/common/filter/OmsAuthFilter.java

@@ -81,10 +81,9 @@ public Mono<Void> filter(ServerWebExchange exchange, GatewayFilterChain chain) {
                 log.error("Authentication failed: Token is null or invalid.");
                 return exchange.getResponse().setComplete();
             }
-            String userGroupId = this.omsExtensionService.getUserGroupId(userName);
+            log.info("Current oms username is: {}", userName);
             ServerHttpRequest newRequest = request.mutate()
                     .header(USER_NAME_HEADER, userName)
-                    .header(USER_GROUP_ID_HEADER, userGroupId)
                     .build();
 
             return chain.filter(exchange.mutate().request(newRequest).build());

backend/api-gateway/src/main/java/com/datamate/gateway/infrastructure/client/impl/OmsServiceImpl.java

@@ -1,12 +1,15 @@
 package com.datamate.gateway.infrastructure.client.impl;
 
+import com.alibaba.fastjson2.JSON;
+import com.alibaba.fastjson2.JSONException;
+import com.alibaba.fastjson2.JSONObject;
 import com.datamate.gateway.common.config.SslIgnoreHttpClientFactory;
 import com.datamate.gateway.infrastructure.client.OmsService;
 import com.fasterxml.jackson.databind.ObjectMapper;
 
-import lombok.Data;
 import lombok.extern.slf4j.Slf4j;
-import org.apache.hc.client5.http.classic.methods.HttpPost;
+
+import org.apache.hc.client5.http.classic.methods.HttpGet;
 import org.apache.hc.client5.http.impl.classic.CloseableHttpClient;
 import org.apache.hc.client5.http.impl.classic.CloseableHttpResponse;
 import org.apache.hc.core5.http.ParseException;
@@ -15,7 +18,6 @@
 import org.springframework.stereotype.Service;
 
 import java.io.IOException;
-import java.util.List;
 
 /**
  * OmsServiceImpl is a service that interacts with the OMS service.
@@ -56,41 +58,27 @@ public OmsServiceImpl(
     @Override
     public String getUserNameFromOms(String authToken, String csrfToken, String realIp) {
         try {
-            String fullPath = this.omsServiceUrl + "/framework/v1/iam/roles/query-by-token";
-
-            HttpPost httpPost = new HttpPost(fullPath);
-
+            String fullPath = this.omsServiceUrl + "/framework/v1/sessions/current";
+            HttpGet httpPost = new HttpGet(fullPath);
             httpPost.setHeader(AUTH_TOKEN_NEW_HEADER_KEY, authToken);
             httpPost.setHeader(CSRF_TOKEN_NEW_HEADER_KEY, csrfToken);
             httpPost.setHeader(REAL_IP_HEADER_KEY, realIp);
 
             CloseableHttpResponse response = httpClient.execute(httpPost);
             String responseBody = EntityUtils.toString(response.getEntity());
-            log.info("response code: {}, response body: {}", response.getCode(), responseBody);
-
-            ResultVo<List<String>> resultVo = objectMapper.readValue(responseBody, 
-                objectMapper.getTypeFactory().constructParametricType(ResultVo.class, List.class));
-
-            if (resultVo.getData() == null || resultVo.getData().isEmpty()) {
+            log.info("response code: {}", response.getCode());
+
+            try {
+                JSONObject jsonObject = JSON.parseObject(responseBody);
+                JSONObject data = jsonObject.getJSONObject("data");
+                return  data.getString("userName");
+            } catch (JSONException e) {
+                log.error("Failed to parse response body: {}", e.getMessage());
                 return null;
             }
-
-            return resultVo.getData().get(0);
         } catch (IOException | ParseException e) {
             log.error("Failed to get user name from OMS service", e);
             return null;
         }
     }
-
-    /**
-     * ResultVo is a generic result wrapper.
-     * 
-     * @param <T> the type of data
-     */
-    @Data
-    public static class ResultVo<T> {
-        private Integer code;
-        private String msg;
-        private T data;
-    }
 }