package fr.ifremer.quadrige2.core.service.administration.program;
   
   /*-
    * #%L
    * Quadrige2 Core :: Quadrige2 Server 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.base.Preconditions;
  import com.google.common.collect.Lists;
  import com.google.common.collect.Sets;
  import fr.ifremer.quadrige2.core.exception.Exceptions;
  import fr.ifremer.quadrige2.core.config.Quadrige2Configuration;
  import fr.ifremer.quadrige2.core.dao.administration.program.ProgramDao;
  import fr.ifremer.quadrige2.core.dao.administration.program.ProgramStrategyJdbcDao;
  import fr.ifremer.quadrige2.core.exception.BadUpdateDtException;
  import fr.ifremer.quadrige2.core.exception.DataLockedException;
  import fr.ifremer.quadrige2.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;
  
  /**
   * <p>
   * ProgramServiceImpl class.
   * </p>
   * 
   */
  @Service("programService")
  @Lazy
  public class ProgramServiceImpl implements ProgramService {
  
  	@Resource
  	private ProgramDao programDao;
  
  	@Resource
  	protected ProgramStrategyJdbcDao programStrategyJdbcDao;
  
  	@Resource
  	protected Quadrige2Configuration config;
  
  	/** {@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) {
  		Preconditions.checkNotNull(source);
  		Preconditions.checkNotNull(source.getProgCd());
  
  
  		// Save program
  		try {
  			return programDao.save(source);
  		} catch (RuntimeException e) {
  			if (Exceptions.hasCause(e, BadUpdateDtException.class)) {
  				throw new BadUpdateDtException(Exceptions.getCause(e, BadUpdateDtException.class).getMessage(), e);
  			}
  			if (Exceptions.hasCause(e, DataLockedException.class)) {
  				throw new DataLockedException(Exceptions.getCause(e, DataLockedException.class).getMessage(), e);
  			}
  			throw e;
  		}
  	}
  
 	/** {@inheritDoc} */
 	@Override
 	public ProgramVO getByCode(String progCd) {
 		return (ProgramVO) programDao.get(ProgramDao.TRANSFORM_PROGRAMVO, progCd);
 	}
 
 	/** {@inheritDoc} */
 	@Override
 	public List<ProgramVO> getWritableProgramsByQuserId(int quserId) {
 		List<ProgramVO> programs = programStrategyJdbcDao.getWritableProgramsByUserId(quserId);
 		Set<String> programCodes = config.getSynchroProgramCodeIncludes();
 
 		if (CollectionUtils.isEmpty(programs) || CollectionUtils.isEmpty(programCodes)) {
 			return programs;
 		}
 
 		// Filter on programs to includes
 		List<ProgramVO> result = Lists.newArrayList();
 		for (ProgramVO programVO : programs) {
 			if (programCodes.contains(programVO.getProgCd())) {
 				result.add(programVO);
 			}
 		}
 
 		return result;
 	}
 
 	/** {@inheritDoc} */
 	@Override
 	public Set<String> getWritableProgramCodesByQuserId(int quserId) {
 		List<ProgramVO> writablePrograms = programStrategyJdbcDao.getWritableProgramsByUserId(quserId);
 		Set<String> configProgramCodes = config.getSynchroProgramCodeIncludes();
 
 		if (CollectionUtils.isEmpty(writablePrograms)) {
 			return null;
 		}
 
 		// Filter on programs to includes
 		Set<String> result = Sets.newHashSet();
 		for (ProgramVO programVO : writablePrograms) {
 			if (CollectionUtils.isEmpty(configProgramCodes)
 					|| configProgramCodes.contains(programVO.getProgCd())) {
 				result.add(programVO.getProgCd());
 			}
 		}
 
 		return result;
 	}
 
 	/** {@inheritDoc} */
 	@Override
 	public boolean hasAccessRightOnProgram(int quserId) {
 		return CollectionUtils.isNotEmpty(
 				getWritableProgramsByQuserId(quserId)
 				);
 	}
 
 	/** {@inheritDoc} */
 	@Override
 	public boolean hasWritePermission(int quserId, Collection<String> progCds) {
 		if (CollectionUtils.isEmpty(progCds)) return true; // make no sense
 
 		List<ProgramVO> writablePrograms = getWritableProgramsByQuserId(quserId);
 		if (CollectionUtils.isEmpty(writablePrograms)) {
 			return CollectionUtils.isEmpty(progCds);
 		}
 		List<String> writableProgramCodes = Lists.transform(writablePrograms, ProgramVO::getProgCd);
 		for (String progCd : progCds) {
 			if (!writableProgramCodes.contains(progCd)) {
 				return false;
 			}
 		}
 		return true;
 	}
 
 	@Override
 	public boolean hasSomeWritePermission(int quserId) {
 		List<ProgramVO> writablePrograms = getWritableProgramsByQuserId(quserId);
 		return CollectionUtils.isNotEmpty(writablePrograms);
 	}
 }