package fr.ifremer.quadrige3.core.service.administration.program;
   
   /*-
    * #%L
    * Quadrige3 Core :: Quadrige3 Client Core
    * $Id:$
    * $HeadURL:$
    * %%
    * Copyright (C) 2017 Ifremer
   * %%
   * This program is free software: you can redistribute it and/or modify
   * it under the terms of the GNU Affero General Public License as published by
   * the Free Software Foundation, either version 3 of the License, or
   * (at your option) any later version.
   *
   * This program is distributed in the hope that it will be useful,
   * but WITHOUT ANY WARRANTY; without even the implied warranty of
   * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
   * GNU General Public License for more details.
   *
   * You should have received a copy of the GNU Affero General Public License
   * along with this program.  If not, see <http://www.gnu.org/licenses/>.
   * #L%
   */
  
  import com.google.common.collect.Lists;
  import com.google.common.collect.Sets;
  import fr.ifremer.quadrige3.core.config.QuadrigeCoreConfiguration;
  import fr.ifremer.quadrige3.core.dao.administration.program.Program;
  import fr.ifremer.quadrige3.core.dao.administration.program.ProgramDao;
  import fr.ifremer.quadrige3.core.dao.administration.program.ProgramStrategyJdbcDao;
  import fr.ifremer.quadrige3.core.dao.administration.user.PrivilegeCode;
  import fr.ifremer.quadrige3.core.dao.technical.Assert;
  import fr.ifremer.quadrige3.core.dao.technical.Beans;
  import fr.ifremer.quadrige3.core.service.administration.user.UserService;
  import fr.ifremer.quadrige3.core.vo.administration.program.ProgramVO;
  import org.apache.commons.collections4.CollectionUtils;
  import org.springframework.context.annotation.Lazy;
  import org.springframework.stereotype.Service;
  
  import javax.annotation.Resource;
  import java.util.Collection;
  import java.util.List;
  import java.util.Set;
  import java.util.stream.Collectors;
  
  /**
   * <p>
   * ProgramServiceImpl class.
   * </p>
   *
   */
  @Service("programService")
  @Lazy
  public class ProgramServiceImpl implements ProgramService {
  
  	@Resource
  	private ProgramDao programDao;
  	@Resource
  	private ProgramStrategyJdbcDao programStrategyJdbcDao;
  	@Resource
  	private QuadrigeCoreConfiguration configuration;
  
  	@Resource
  	private UserService userService;
  
  	@Override
  	public List<String> getAllProgramCodes() {
  
  		return programStrategyJdbcDao.getAllProgramCodes();
  	}
  
  	/** {@inheritDoc} */
  	@Override
  	public List<ProgramVO> save(List<ProgramVO> programs) {
  		List<ProgramVO> result = Lists.newArrayList();
  
  		if (CollectionUtils.isNotEmpty(programs)) {
  			for (ProgramVO source : programs) {
  				ProgramVO target = save(source);
  				result.add(target);
  			}
  		}
  
  		return result;
  	}
  
  	/** {@inheritDoc} */
  	@Override
  	public ProgramVO save(ProgramVO source) {
  		Assert.notNull(source);
  		Assert.notNull(source.getProgCd());
  
  		// Load (or create) the entity
  		Program entity = programDao.get(source.getProgCd());
  		boolean isNew = false;
  		if (entity == null) {
  			entity = Program.Factory.newInstance();
  			isNew = true;
 		}
 
 		// VO -> Entity
 		programDao.programVOToEntity(source, entity, true);
 
 		// Save it
 		ProgramVO target;
 		if (isNew) {
 			target = (ProgramVO) programDao.create(ProgramDao.TRANSFORM_PROGRAMVO, entity);
 		} else {
 			programDao.update(entity);
 			target = programDao.toProgramVO(entity);
 		}
 
 		return target;
 	}
 
 	/** {@inheritDoc} */
 	@Override
 	public ProgramVO getByCode(String progCd) {
 		return (ProgramVO) programDao.get(ProgramDao.TRANSFORM_PROGRAMVO, progCd);
 	}
 
 	@Override
 	public Set<String> getReadableProgramCodesByQuserId(int quserId) {
 		List<String> programCodes = isAdmin(quserId)
 			? getAllProgramCodes()
 			: Beans.transformCollection(programStrategyJdbcDao.getReadableProgramsByUserId(quserId), ProgramVO::getProgCd);
 		if (CollectionUtils.isEmpty(programCodes)) return Sets.newHashSet();
 		return filterProgramCodes(programCodes);
 	}
 
 	/** {@inheritDoc} */
 	@Override
     public Set<String> getWritableProgramCodesByQuserId(int quserId) {
         List<String> programCodes = isAdmin(quserId)
             ? getAllProgramCodes()
             : Beans.transformCollection(programStrategyJdbcDao.getWritableProgramsByUserId(quserId), ProgramVO::getProgCd);
         if (CollectionUtils.isEmpty(programCodes)) return Sets.newHashSet();
         return filterProgramCodes(programCodes);
     }
 
 	/** {@inheritDoc} */
 	@Override
 	public Set<String> getManagedProgramCodesByQuserId(int quserId) {
 		List<String> programCodes = isAdmin(quserId)
 			? getAllProgramCodes()
 			: Beans.transformCollection(programStrategyJdbcDao.getManagedProgramsByUserId(null, quserId), ProgramVO::getProgCd);
 		if (CollectionUtils.isEmpty(programCodes)) return Sets.newHashSet();
 		return filterProgramCodes(programCodes);
 	}
 
 	protected Set<String> filterProgramCodes(Collection<String> programCodes) {
 		// Filter by configuration
 		Set<String> includeProgramCodes = configuration.getSynchroProgramCodeIncludes();
 
 		return programCodes.stream()
 			.filter(programCode -> CollectionUtils.isEmpty(includeProgramCodes) || includeProgramCodes.contains(programCode))
 			.collect(Collectors.toSet());
 	}
 
 	protected boolean isAdmin(int userId) {
 		return userService.hasPrivilege(userId, PrivilegeCode.REFERENTIAL_ADMINISTRATOR.getValue());
 	}
 }