D-Net

package eu.dnetlib.openaire.user.utils;

import eu.dnetlib.openaire.user.UserVerification;

import eu.dnetlib.openaire.user.dao.UserVerificationDAO;

import eu.dnetlib.openaire.user.store.DataSourceConnector;

import org.apache.log4j.Logger;

import org.springframework.beans.factory.annotation.Autowired;

import org.springframework.stereotype.Component;

import java.sql.SQLException;

import java.sql.Timestamp;

/**

 * Created by kiatrop on 2/10/2017.

 */

@Component(value = "verificationActions")

public class VerificationActions {

    @Autowired

    private DataSourceConnector dataSourceConnector;

    private Logger logger = Logger.getLogger(VerificationActions.class);

    @Autowired

    private UserVerificationDAO userVerificationDAO;

    /**

     * Adds new row in the verification table

     */

    public void addVerificationEntry(String username, String verificationCode, Timestamp date) {

        try {

            UserVerification userVerification  = new UserVerification(username);

            userVerification.setVerificationCode(verificationCode);

            userVerification.setDate(date);

            userVerificationDAO.insert(userVerification);

            logger.info("Insert user: " + username);

        } catch (SQLException e) {

            e.printStackTrace();

            logger.info("Fail to insert user.", e);

        }

    }

    /**

     * Updates the row of verification table with the new date for the given username

     */

    public void updateVerificationEntry(String username, String verificationCode, Timestamp date) {

        try {

            UserVerification userVerification  = new UserVerification(username);

            userVerification.setVerificationCode(verificationCode);

            userVerification.setDate(date);

            userVerificationDAO.update(userVerification);

            logger.info("Update user: " + username + " with verification code " + verificationCode);

        } catch (SQLException e) {

            e.printStackTrace();

            logger.info("Fail to update user.", e);

        }

    }

    /**

     * Checks if the verification row exists for the given username

     */

    public boolean verificationEntryExists(String username) {

        try {

            UserVerification userVerification = userVerificationDAO.fetchByUsername(username);

            if (userVerification == null) {

                logger.info("There is no user with username: " + username);

                return false;

            }

            else {

                logger.info("User: " + username + " was found!");

                return true;

            }

        } catch (SQLException e) {

            e.printStackTrace();

            logger.info("Fail to search user.", e);

        }

        return true;

        //TODO

        //return false;

        //throw new UnsupportedOperationException();

    }

    /**

     * Checks if the verification row exists for the given username

     */

    public boolean verificationEntryExists(String username, String verificationCode) {

        //TODO

        //return false;

        throw new UnsupportedOperationException();

    }

    public DataSourceConnector getDataSourceConnector() {

        return dataSourceConnector;

    }

    public void setDataSourceConnector(DataSourceConnector dataSourceConnector) {

        this.dataSourceConnector = dataSourceConnector;

    }

}