refactor: 认证信息支持忽略

Author: zhou-hao

hsweb-authorization/hsweb-authorization-api/src/main/java/org/hswebframework/web/authorization/ReactiveAuthenticationHolder.java

@@ -19,9 +19,9 @@
 package org.hswebframework.web.authorization;
 
 import com.google.common.collect.Lists;
-import org.hswebframework.web.authorization.simple.SimpleAuthentication;
 import reactor.core.publisher.Flux;
 import reactor.core.publisher.Mono;
+import reactor.util.context.Context;
 
 import java.util.List;
 import java.util.concurrent.CopyOnWriteArrayList;
@@ -45,18 +45,27 @@
 public final class ReactiveAuthenticationHolder {
     private static final List<ReactiveAuthenticationSupplier> suppliers = new CopyOnWriteArrayList<>();
 
+    public static final String IGNORE_AUTH_KEY = ".auth.ignore";
+
+    static final Context IGNORE_AUTH_CONTEXT_Y = Context.of(IGNORE_AUTH_KEY, true);
+    static final Context IGNORE_AUTH_CONTEXT_N = Context.of(IGNORE_AUTH_KEY, false);
+
     private static Mono<Authentication> get(Function<ReactiveAuthenticationSupplier, Mono<Authentication>> function) {
         return AuthenticationUtils
-            .merge(Flux.merge(Lists.transform(suppliers, function::apply)))
-            ;
+            .merge(Flux.merge(Lists.transform(suppliers, function::apply)));
     }
 
     /**
      * @return 当前登录的用户权限信息
      */
     public static Mono<Authentication> get() {
 
-        return get(ReactiveAuthenticationSupplier::get);
+        return Mono.deferContextual(ctx -> {
+            if (Boolean.TRUE.equals(ctx.getOrDefault(IGNORE_AUTH_KEY, false))) {
+                return Mono.empty();
+            }
+            return get(ReactiveAuthenticationSupplier::get);
+        });
     }
 
     /**
@@ -83,6 +92,15 @@ public static void setSupplier(ReactiveAuthenticationSupplier supplier) {
         suppliers.add(supplier);
     }
 
+    public static Context ignoreContext(boolean ignore) {
+        return ignore ? IGNORE_AUTH_CONTEXT_Y : IGNORE_AUTH_CONTEXT_N;
+    }
+
+    public static Function<Context, Context> ignoreIfAbsent(boolean ignore) {
+        return ctx -> ctx.hasKey(IGNORE_AUTH_KEY)
+            ? ctx
+            : ctx.put(IGNORE_AUTH_KEY, ignore);
+    }
 
 
 }

hsweb-authorization/hsweb-authorization-api/src/main/java/org/hswebframework/web/authorization/simple/SimpleAuthentication.java

@@ -151,7 +151,7 @@ public void addDimension(Dimension dimension) {
     private transient volatile Map<String, Permission> permissionMapping;
     private transient volatile long accessCount;
 
-    private boolean fastPath() {
+    protected boolean fastPath() {
         // 总共访问超过8次,则进行初始化缓存.
         if (ACCESS_COUNT_UPDATER.incrementAndGet(this) == 8) {
             if (permissionMapping == null) {