/*
 * Click nbfs://nbhost/SystemFileSystem/Templates/Licenses/license-default.txt to change this license
 * Click nbfs://nbhost/SystemFileSystem/Templates/Classes/Class.java to edit this template
 */
package com.megatim.apifdxweb.core.impl.tmp;

import com.megatim.apifdxweb.core.ifaces.helper.RoutingChecker;
import com.megatim.apifdxweb.core.ifaces.tmp.TokenTmpManager;
import com.megatim.apifdxweb.dao.ifaces.tmp.TokenTmpDAO;
import com.megatim.apifdxweb.model.tmp.StatutTmp;
import com.megatim.apifdxweb.model.tmp.TokenTmp;
import com.megatim.fdxcommons.core.ifaces.helper.DataInMemoryHandler;
import com.mgt.rs.security.core.service.AuthenticationTokenService;
import java.time.LocalDateTime;
import java.time.format.DateTimeFormatter;
import java.util.List;
import java.util.UUID;
import javax.ejb.EJB;
import javax.enterprise.context.Dependent;
import javax.inject.Inject;
import javax.transaction.Transactional;

/**
 *
 * @author ASUS
 */
@Dependent
public class TokenTmpManagerImpl implements TokenTmpManager {

    @EJB
    private TokenTmpDAO dao;

    @Inject
    private AuthenticationTokenService authenticationTokenService;

    @Inject
    private DataInMemoryHandler dataInMemoryHandler;

    @Inject
    private RoutingChecker routingChecker;

    @Override
    public TokenTmpDAO getDao() {
        return this.dao;
    }

    @Override
    @Transactional
    public TokenTmp saveEntity(TokenTmp entity, String connectedParticipant) {
        
        stopIfProductionNotPermitted(entity.getCodeTypeFichier(), connectedParticipant);
        
        TokenTmp foundToken = dao.getByParticipantAndTypeFichier(connectedParticipant, entity.getCodeTypeFichier());
        if (foundToken != null) {
            foundToken.setStatutTmp(StatutTmp.EXPIRE);
            save(foundToken);
        }
        
        DateTimeFormatter formatter = DateTimeFormatter.ofPattern("yyyyMMddHHmmss");
        String str = LocalDateTime.now().format(formatter);
        UUID uuid = UUID.nameUUIDFromBytes((str + entity.toString()).getBytes());

        entity.setToken(uuid.toString());
        entity.setCodeParticipant(connectedParticipant);
        entity.setDateExpiration(entity.getDateCreation().plusMinutes(entity.getValidite()));

        return save(entity);

    }

    @Override
    public List<TokenTmp> getByStatutTmp(StatutTmp statut) {
        return dao.getByStatutTmp(statut);
    }

    @Override
    public List<TokenTmp> getExpiredToken() {
        return dao.getExpiredToken();
    }

    private void stopIfProductionNotPermitted(String codeTypeFichier, String connectedParticipant) {
        
        routingChecker.stopIfCurrentReferentielNotExists(dataInMemoryHandler.getDataInMemory());
        routingChecker.stopIfTypeFichierNotExists(codeTypeFichier, dataInMemoryHandler.getDataInMemory());
        routingChecker.stopIfNotProducer(codeTypeFichier, dataInMemoryHandler.getDataInMemory(), connectedParticipant);
    
    }

}