simplify chain, wip

src/lavinmq/auth/authenticator.cr

@@ -2,23 +2,8 @@ module LavinMQ
   module Auth
     abstract class Authenticator
       Log = LavinMQ::Log.for "auth.handler"
-      @log = Logger.new(Log)
-      property successor : Authenticator?
 
       abstract def authenticate(username : String, password : String)
-
-      def set_successor(service : Authenticator) : Authenticator
-        @successor = service
-        service
-      end
-
-      def try_next(username : String, password : String)
-        if successor = @successor
-          successor.authenticate(username, password)
-        else
-          nil
-        end
-      end
     end
   end
 end

src/lavinmq/auth/authenticators/basic.cr

@@ -3,15 +3,14 @@ require "../../server"
 
 module LavinMQ
   module Auth
-    class BasicAuthenticator < LavinMQ::Auth::Authenticator
+    class BasicAuthenticator < Authenticator
       def initialize(@users : UserStore)
       end
 
       def authenticate(username : String, password : String)
         user = @users[username]
         return user if user && user.password && user.password.not_nil!.verify(password)
-        @log.info { "Basic authentication failed" }
-        try_next(username, password)
+        Log.info { "Basic authentication failed" }
       end
     end
   end

src/lavinmq/auth/chain.cr

@@ -3,40 +3,33 @@ require "./authenticators/basic"
 
 module LavinMQ
   module Auth
-    class Chain
-      @first : Authenticator?
+    class Chain < Authenticator
+      @backends : Array(Authenticator)
 
       def initialize(users : UserStore)
+        @backends = [] of Authenticator
         backends = Config.instance.auth_backends
         if backends.nil? || backends.size == 0
-          add_handler(BasicAuthenticator.new(users))
+          @backends << BasicAuthenticator.new(users)
         else
           backends.each do |backend|
             case backend
             when "basic"
-              add_handler(BasicAuthenticator.new(users))
+              @backends << BasicAuthenticator.new(users)
             else
               raise "Unsupported authentication backend: #{backend}"
             end
           end
         end
       end
 
-      def add_handler(auth : Authenticator)
-        if first = @first
-          current = first
-          while successor = current.@successor
-            current = successor
+      def authenticate(username : String, password : String)
+        @backends.each do |backend|
+          if user = backend.authenticate(username, password)
+            return user
           end
-          current.set_successor(auth)
-        else
-          @first = auth
         end
-        self
-      end
-
-      def authenticate(username : String, password : String)
-        @first.try &.authenticate(username, password)
+        nil
       end
     end
   end