/*

 Copyright 2010 James Pether Sörling Licensed 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. 

         $Id

 */

 package org.directdemocracyportal.democracy.service;

 import java.util.Date;

 import java.util.List;

 import org.directdemocracyportal.democracy.model.application.Action;

 import org.directdemocracyportal.democracy.model.application.Authority;

 import org.directdemocracyportal.democracy.model.application.Event;

 import org.directdemocracyportal.democracy.model.application.Portal;

 import org.directdemocracyportal.democracy.model.application.SecurityRoleType;

 import org.directdemocracyportal.democracy.model.application.User;

 import org.directdemocracyportal.democracy.model.application.UserSession;

 import org.directdemocracyportal.democracy.model.world.Person;

 import org.directdemocracyportal.democracy.model.world.Region;

 import org.directdemocracyportal.democracy.model.world.RegionType;

 import org.directdemocracyportal.democracy.service.command.RegisterCommand;

 import org.directdemocracyportal.democracy.service.dao.PersonDAO;

 import org.directdemocracyportal.democracy.service.dao.PortalDAO;

 import org.directdemocracyportal.democracy.service.dao.UserDAO;

 import org.directdemocracyportal.democracy.service.dao.UserSessionDAO;

 import org.springframework.mail.MailException;

 import org.springframework.mail.SimpleMailMessage;

 import org.springframework.mail.javamail.JavaMailSenderImpl;

 import org.springframework.security.authentication.encoding.Md5PasswordEncoder;

 import org.springframework.security.authentication.encoding.PasswordEncoder;

 import org.springframework.transaction.annotation.Propagation;

 import org.springframework.transaction.annotation.Transactional;

 /**

  * The Class UserServiceImpl.

  */

 @Transactional(propagation = Propagation.REQUIRED)

 public class UserServiceImpl implements UserService

 {

     /** The java mail sender impl. */

     final private JavaMailSenderImpl javaMailSenderImpl;

     /** The simple mail message. */

     final private SimpleMailMessage simpleMailMessage;

     /** The user dao. */

     final private UserDAO userDAO;

     /** The portal dao. */

     final private PortalDAO portalDAO;

     /** The person dao. */

     final private PersonDAO personDAO;

     /** The user session dao. */

     final private UserSessionDAO userSessionDAO;

     /** The password encoder. */

     private final PasswordEncoder passwordEncoder;

     /**

      * Instantiates a new user service impl.

      *

      * @param userDAO the user dao

      * @param portalDAO the portal dao

      * @param personDAO the person dao

      * @param userSessionDAO the user session dao

      * @param javaMailSenderImpl the java mail sender impl

      * @param simpleMailMessage the simple mail message

      */

     public UserServiceImpl(UserDAO userDAO, PortalDAO portalDAO,

             PersonDAO personDAO, UserSessionDAO userSessionDAO,

             JavaMailSenderImpl javaMailSenderImpl,

             SimpleMailMessage simpleMailMessage) {

         this.userDAO = userDAO;

         this.portalDAO = portalDAO;

         this.personDAO = personDAO;

         this.userSessionDAO = userSessionDAO;

         this.javaMailSenderImpl = javaMailSenderImpl;

         this.simpleMailMessage = simpleMailMessage;

         this.passwordEncoder = new Md5PasswordEncoder();

     }

     /**

      * Adds the member.

      *

      * @param portal the portal

      * @param person the person

      */

     private void addMember(Portal portal, Person person) {

         portal.addMember(person);

         personDAO.save(person);

         portalDAO.save(portal);

     }

     /*

      * (non-Javadoc)

      *

      * @see org.directdemocracyportal.democracy.service.UserService#register(org.directdemocracyportal.democracy.service.command.RegisterCommand,

      *      java.lang.String)

      */

     public User register(RegisterCommand command, String sessionId)

             throws UserAlreadyExistException {

         if (this.userDAO.findByUsername(command.getUsername()) == null) {

             Person person = new Person(command.getName());

             this.personDAO.save(person);

             Portal localPortal = this.portalDAO.load(command.getPortalId());

             if (localPortal != null) {

                 addMember(localPortal, person);

             }

             Region region = localPortal.getRegion().getParent();

             if (region.getRegionType().equals(RegionType.Regional)) {

                 Portal regionalPortal = portalDAO.findRegionalByRegion(region);

                 if (regionalPortal != null) {

                     addMember(regionalPortal, person);

                 }

             }

             Portal nationalPortal = portalDAO

                     .findNationalByCountry(localPortal.getCountry());

             if (nationalPortal != null) {

                 addMember(nationalPortal, person);

             }

             Portal globalPortal = portalDAO

                     .findByName("Direct Democracy Portal");

             if (globalPortal != null) {

                 addMember(globalPortal, person);

             }

             String encodedPassword = passwordEncoder.encodePassword(command

                     .getPassword(), null);

             User newUser = new User(new Date(), command.getUsername(),

                     encodedPassword,command.getEmail(), person);

             newUser.setAccountNonExpired(true);

             newUser.setCredentialsNonExpired(true);

             newUser.setEnabled(true);

             newUser.setAccountNonLocked(true);

             newUser.getEvents().add(

                     new Event(newUser, Action.Register, new Date()));

             Authority authority = new Authority(SecurityRoleType.ROLE_USER);

             newUser.getGrantedAuthorities().add(authority);

             UserSession userSession = new UserSession(newUser, sessionId,

                     new Date());

             userSession.setActive(true);

             this.userSessionDAO.save(userSession);

             return newUser;

         } else {

             throw new UserAlreadyExistException();

         }

     }

     /**

      * Send email confirmation request.

      *

      * @param command the command

      */

     public void sendEmailConfirmationRequest(RegisterCommand command) {

         SimpleMailMessage msg = new SimpleMailMessage(this.simpleMailMessage);

         msg.setTo(command.getEmail());

         msg.setText("Hello " + command.getName()

                 + ", thank you for registering. confirm with link below ");

         try {

             this.javaMailSenderImpl.send(msg);

         } catch (MailException ex) {

             // simply log it and go on...

             System.err.println(ex.getMessage());

         }

     }

     /*

      * (non-Javadoc)

      *

      * @see org.directdemocracyportal.democracy.service.UserService#getUsers()

      */

     public List<User> getUsers() {

         return this.userDAO.getAll();

     }

     /*

      * (non-Javadoc)

      *

      * @see org.directdemocracyportal.democracy.service.UserService#login(java.lang.String,

      *      java.lang.String, java.lang.String)

      */

     public User login(String username, String password, String sessionId) {

         String encodedPassword = passwordEncoder.encodePassword(password, null);

         User user = userDAO.findByUsername(username);

         if (user.getPassword().equals(encodedPassword)) {

             if (this.userSessionDAO.findByUserId(user.getId()) == null) {

                 user.getEvents().add(new Event(user, Action.Login, new Date()));

                 this.userSessionDAO.save(new UserSession(user, sessionId,

                         new Date()));

                 userDAO.save(user);

             }

         }

         return user;

     }

     /*

      * (non-Javadoc)

      *

      * @see org.directdemocracyportal.democracy.service.UserService#logout(org.directdemocracyportal.democracy.model.application.User)

      */

     public void logout(User user) {

         UserSession userSession = this.userSessionDAO

                 .findByUserId(user.getId());

         if (userSession != null) {

             userSession.getUser().getEvents()

                     .add(

                             new Event(userSession.getUser(), Action.Logout,

                                     new Date()));

             userSession.setEndedAt(new Date());

             userSession.setActive(false);

             this.userSessionDAO.save(userSession);

             this.userDAO.save(userSession.getUser());

         }

     }

     /*

      * (non-Javadoc)

      *

      * @see org.directdemocracyportal.democracy.service.UserService#getPortals()

      */

     public List<Portal> getPortals() {

         return this.portalDAO.getAll();

     }

     /*

      * (non-Javadoc)

      *

      * @see org.directdemocracyportal.democracy.service.UserService#endActiveUserSessions()

      */

     public void endActiveUserSessions() {

         this.userSessionDAO.endActiveSessions();

     }

     /*

      * (non-Javadoc)

      *

      * @see org.directdemocracyportal.democracy.service.UserService#getUser(java.lang.Long)

      */

     public User getUser(Long userId) {

         return this.userDAO.load(userId);

     }

 }