package database.session;

import com.j256.ormlite.dao.Dao;
import com.j256.ormlite.dao.DaoManager;
import com.j256.ormlite.stmt.UpdateBuilder;
import database.DatabaseHelper;
import java.time.Instant;

public class SessionDao {
    private DatabaseHelper dbh = new DatabaseHelper();
    private Dao<Session, String> sessionDao;

    private Dao createSessionDaoConnection(){
        try {
            return DaoManager.createDao(dbh.setupDatabaseConnection(),Session.class);
        }catch (Exception e){
            System.out.println(e.getMessage());
            return null;
        }
    }

    public int setStartSession(Session session) throws Exception {
        sessionDao = createSessionDaoConnection();
        sessionDao.create(session);
        return session.getSession_id();
    }

    public void setEndSession(int session_id) throws Exception {
        sessionDao = createSessionDaoConnection();
        UpdateBuilder<Session,String> updateBuilder = sessionDao.updateBuilder();
        long now = Instant.now().toEpochMilli();
        updateBuilder.updateColumnValue("end_session",now);
        updateBuilder.where().eq("session_id",session_id);
        updateBuilder.update();
    }
}