Merge branch 'develop'

James Moger

2015-11-22 ed552ba47c02779c270ffd62841d6d1048dade70

 src/main/java/com/gitblit/transport/ssh/SshKeyAuthenticator.java

File was renamed from src/main/java/com/gitblit/transport/ssh/CachingPublicKeyAuthenticator.java
@@ -16,15 +16,10 @@
package com.gitblit.transport.ssh;

import java.security.PublicKey;
import java.util.HashMap;
import java.util.List;
import java.util.Locale;
import java.util.Map;
import java.util.concurrent.ConcurrentHashMap;

import org.apache.sshd.common.Session;
import org.apache.sshd.common.SessionListener;
import org.apache.sshd.server.PublickeyAuthenticator;
import org.apache.sshd.server.auth.pubkey.PublickeyAuthenticator;
import org.apache.sshd.server.session.ServerSession;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
@@ -37,7 +32,7 @@
 * Authenticates an SSH session against a public key.
 *
 */
public class CachingPublicKeyAuthenticator implements PublickeyAuthenticator, SessionListener {
public class SshKeyAuthenticator implements PublickeyAuthenticator {

   protected final Logger log = LoggerFactory.getLogger(getClass());

@@ -45,30 +40,13 @@

   protected final IAuthenticationManager authManager;

   private final Map<ServerSession, Map<PublicKey, Boolean>> cache = new ConcurrentHashMap<ServerSession, Map<PublicKey, Boolean>>();

   public CachingPublicKeyAuthenticator(IPublicKeyManager keyManager, IAuthenticationManager authManager) {
   public SshKeyAuthenticator(IPublicKeyManager keyManager, IAuthenticationManager authManager) {
      this.keyManager = keyManager;
      this.authManager = authManager;
   }

   @Override
   public boolean authenticate(String username, PublicKey key, ServerSession session) {
      Map<PublicKey, Boolean> map = cache.get(session);
      if (map == null) {
         map = new HashMap<PublicKey, Boolean>();
         cache.put(session, map);
         session.addListener(this);
      }
      if (map.containsKey(key)) {
         return map.get(key);
      }
      boolean result = doAuthenticate(username, key, session);
      map.put(key, result);
      return result;
   }

   private boolean doAuthenticate(String username, PublicKey suppliedKey, ServerSession session) {
   public boolean authenticate(String username, PublicKey suppliedKey, ServerSession session) {
      SshDaemonClient client = session.getAttribute(SshDaemonClient.KEY);
      Preconditions.checkState(client.getUser() == null);
      username = username.toLowerCase(Locale.US);
@@ -95,18 +73,5 @@

      log.warn("could not authenticate {} for SSH using the supplied public key", username);
      return false;
   }

   @Override
   public void sessionCreated(Session session) {
   }

   @Override
   public void sessionEvent(Session sesssion, Event event) {
   }

   @Override
   public void sessionClosed(Session session) {
      cache.remove(session);
   }
}