allow no auth type, choose default DB

apache · Jan 16, 2025 · efcf8b1 · efcf8b1
1 parent 01db82a
commit efcf8b1
Showing 1 changed file with 5 additions and 2 deletions.
diff --git a/...er/seatunnel-app/src/main/java/org/apache/seatunnel/app/service/impl/UserServiceImpl.java b/...er/seatunnel-app/src/main/java/org/apache/seatunnel/app/service/impl/UserServiceImpl.java
@@ -42,6 +42,8 @@
 import org.apache.seatunnel.server.common.SeatunnelErrorEnum;
 import org.apache.seatunnel.server.common.SeatunnelException;
 
+import org.apache.commons.lang3.StringUtils;
+
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.beans.factory.annotation.Value;
 import org.springframework.stereotype.Component;
@@ -159,11 +161,12 @@ public void disable(int id) {
 
     @Override
     public UserSimpleInfoRes login(UserLoginReq req, String authType) {
-        if (!strategies.containsKey(authType)) {
+        if (StringUtils.isNotEmpty(authType) && !strategies.containsKey(authType)) {
             throw new SeatunnelException(
                     SeatunnelErrorEnum.INVALID_AUTHENTICATION_PROVIDER, authType);
         }
-        IAuthenticationStrategy strategy = strategies.get(authType);
+        IAuthenticationStrategy strategy =
+                strategies.getOrDefault(authType, dbAuthenticationStrategy);
         User user = strategy.authenticate(req);
         UserSimpleInfoRes translate = translate(user);
         final String token = jwtUtils.genToken(translate.toMap());