package org.apache.archiva.redback.users.cached;
   
   /*
    * Licensed to the Apache Software Foundation (ASF) under one
    * or more contributor license agreements.  See the NOTICE file
    * distributed with this work for additional information
    * regarding copyright ownership.  The ASF licenses this file
    * to you under the Apache License, Version 2.0 (the
    * "License"); you may not use this file except in compliance
   * with the License.  You may obtain a copy of the License at
   *
   * http://www.apache.org/licenses/LICENSE-2.0
   *
   * Unless required by applicable law or agreed to in writing,
   * software distributed under the License is distributed on an
   * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
   * KIND, either express or implied.  See the License for the
   * specific language governing permissions and limitations
   * under the License.
   */
  
  import org.apache.archiva.redback.components.cache.Cache;
  import org.apache.archiva.redback.users.User;
  import org.apache.archiva.redback.users.UserManagerException;
  import org.apache.archiva.redback.users.UserManagerListener;
  import org.apache.archiva.redback.users.UserNotFoundException;
  import org.apache.archiva.redback.users.UserQuery;
  import org.apache.archiva.redback.users.UserManager;
  import org.slf4j.Logger;
  import org.slf4j.LoggerFactory;
  import org.springframework.stereotype.Service;
  
  import javax.inject.Inject;
  import javax.inject.Named;
  import java.util.List;
  
  /**
   * CachedUserManager
   *
   * @author <a href="mailto:joakim@erdfelt.com">Joakim Erdfelt</a>
   */
  @Service("userManager#cached")
  public class CachedUserManager
      implements UserManager, UserManagerListener
  {
  
      private Logger log = LoggerFactory.getLogger( getClass() );
  
      @Inject
      @Named(value = "userManager#default")
      private UserManager userImpl;
  
      @Inject
      @Named(value = "cache#users")
      private Cache<String, User> usersCache;
  
      public boolean isReadOnly()
      {
          return userImpl.isReadOnly();
      }
  
      public User createGuestUser()
          throws UserManagerException
      {
          return userImpl.createGuestUser();
      }
  
      public User addUser( User user )
          throws UserManagerException
      {
          if ( user != null )
          {
              usersCache.remove( user.getUsername() );
          }
          return this.userImpl.addUser( user );
      }
  
      public void addUserManagerListener( UserManagerListener listener )
      {
          this.userImpl.addUserManagerListener( listener );
      }
  
      public void addUserUnchecked( User user )
          throws UserManagerException
      {
          if ( user != null )
          {
              usersCache.remove( user.getUsername() );
          }
          this.userImpl.addUserUnchecked( user );
      }
  
      public User createUser( String username, String fullName, String emailAddress )
          throws UserManagerException
      {
          usersCache.remove( username );
          return this.userImpl.createUser( username, fullName, emailAddress );
      }
  
     public void deleteUser( String username )
         throws UserNotFoundException, UserManagerException
     {
         usersCache.remove( username );
         this.userImpl.deleteUser( username );
     }
 
     public void eraseDatabase()
     {
         try
         {
             this.userImpl.eraseDatabase();
         }
         finally
         {
             usersCache.clear();
         }
     }
 
     public User findUser( String username )
         throws UserNotFoundException, UserManagerException
     {
         if ( GUEST_USERNAME.equals( username ) )
         {
             return getGuestUser();
         }
 
         User el = usersCache.get( username );
         if ( el != null )
         {
             return el;
         }
         else
         {
             User user = this.userImpl.findUser( username );
             usersCache.put( username, user );
             return user;
         }
     }
 
     public User getGuestUser()
         throws UserNotFoundException, UserManagerException
     {
         User el = usersCache.get( GUEST_USERNAME );
         if ( el != null )
         {
             return el;
         }
         else
         {
             User user = this.userImpl.getGuestUser();
             usersCache.put( GUEST_USERNAME, user );
             return user;
         }
     }
 
     public UserQuery createUserQuery()
     {
         return userImpl.createUserQuery();
     }
 
 
     public List<User> findUsersByQuery( UserQuery query )
         throws UserManagerException
     {
         log.debug( "NOT CACHED - .findUsersByQuery(UserQuery)" );
         return this.userImpl.findUsersByQuery( query );
     }
 
     public List<User> findUsersByEmailKey( String emailKey, boolean orderAscending )
         throws UserManagerException
     {
         log.debug( "NOT CACHED - .findUsersByEmailKey(String, boolean)" );
         return this.userImpl.findUsersByEmailKey( emailKey, orderAscending );
     }
 
     public List<User> findUsersByFullNameKey( String fullNameKey, boolean orderAscending )
         throws UserManagerException
     {
         log.debug( "NOT CACHED - .findUsersByFullNameKey(String, boolean)" );
         return this.userImpl.findUsersByFullNameKey( fullNameKey, orderAscending );
     }
 
     public List<User> findUsersByUsernameKey( String usernameKey, boolean orderAscending )
         throws UserManagerException
     {
         log.debug( "NOT CACHED - .findUsersByUsernameKey(String, boolean)" );
         return this.userImpl.findUsersByUsernameKey( usernameKey, orderAscending );
     }
 
     public String getId()
     {
         return "cached";
     }
 
     public List<User> getUsers()
         throws UserManagerException
     {
         log.debug( "NOT CACHED - .getUsers()" );
         return this.userImpl.getUsers();
     }
 
     public List<User> getUsers( boolean orderAscending )
         throws UserManagerException
     {
         log.debug( "NOT CACHED - .getUsers(boolean)" );
         return this.userImpl.getUsers( orderAscending );
     }
 
     public void removeUserManagerListener( UserManagerListener listener )
     {
         this.userImpl.removeUserManagerListener( listener );
     }
 
     public User updateUser( User user )
         throws UserNotFoundException, UserManagerException
     {
         return updateUser( user, false );
     }
 
     public User updateUser( User user, boolean passwordChangeRequired )
         throws UserNotFoundException, UserManagerException
     {
         if ( user != null )
         {
             usersCache.remove( user.getUsername() );
         }
         return this.userImpl.updateUser( user, passwordChangeRequired );
     }
 
     public boolean userExists( String userName )
         throws UserManagerException
     {
         if ( usersCache.hasKey( userName ) )
         {
             return true;
         }
 
         return this.userImpl.userExists( userName );
     }
 
     public void userManagerInit( boolean freshDatabase )
     {
         if ( userImpl instanceof UserManager )
         {
             ( (UserManagerListener) this.userImpl ).userManagerInit( freshDatabase );
         }
 
         usersCache.clear();
     }
 
     public void userManagerUserAdded( User user )
     {
         if ( userImpl instanceof UserManager )
         {
             ( (UserManagerListener) this.userImpl ).userManagerUserAdded( user );
         }
 
         if ( user != null )
         {
             usersCache.remove( user.getUsername() );
         }
     }
 
     public void userManagerUserRemoved( User user )
     {
         if ( userImpl instanceof UserManager )
         {
             ( (UserManagerListener) this.userImpl ).userManagerUserRemoved( user );
         }
 
         if ( user != null )
         {
             usersCache.remove( user.getUsername() );
         }
     }
 
     public void userManagerUserUpdated( User user )
     {
         if ( userImpl instanceof UserManager )
         {
             ( (UserManagerListener) this.userImpl ).userManagerUserUpdated( user );
         }
 
         if ( user != null )
         {
             usersCache.remove( user.getUsername() );
         }
     }
 
     public UserManager getUserImpl()
     {
         return userImpl;
     }
 
     public void setUserImpl( UserManager userImpl )
     {
         this.userImpl = userImpl;
     }
 
     public Cache getUsersCache()
     {
         return usersCache;
     }
 
     public void setUsersCache( Cache usersCache )
     {
         this.usersCache = usersCache;
     }
 
     public void initialize()
     {
         // no op configurable impl do the job
     }
 
     public boolean isFinalImplementation()
     {
         return false;
     }
 
     public String getDescriptionKey()
     {
         return "archiva.redback.usermanager.cached";
     }
 }