src/main/java/de/ids_mannheim/korap/interfaces/defaults/DefaultAuditing.java

package de.ids_mannheim.korap.interfaces.defaults;

import de.ids_mannheim.korap.auditing.AuditRecord;
import de.ids_mannheim.korap.config.ContextHolder;
import de.ids_mannheim.korap.config.Configurable;
import de.ids_mannheim.korap.interfaces.db.AuditingIface;
import de.ids_mannheim.korap.user.User;
import org.joda.time.DateTime;
import org.joda.time.LocalDate;

import java.io.File;
import java.io.FileNotFoundException;
import java.io.FileOutputStream;
import java.io.IOException;
import java.util.List;

/**
 * @author hanl
 * @date 05/06/2015
 */
@Configurable(ContextHolder.KUSTVAKT_AUDITING)
public class DefaultAuditing extends AuditingIface {

    private FileOutputStream stream;


    public DefaultAuditing () {
        try {
            File f = new File("logs");
            f.mkdirs();
            stream = new FileOutputStream(new File(f, "default_audit.log"));
        }
        catch (FileNotFoundException e) {
            e.printStackTrace();
        }
    }


    @Override
    public <T extends AuditRecord> List<T> retrieveRecords (
            AuditRecord.CATEGORY category, DateTime day, DateTime until,
            boolean exact, int limit) {
        throw new UnsupportedOperationException("Operation not supported!");
    }


    @Override
    public <T extends AuditRecord> List<T> retrieveRecords (
            AuditRecord.CATEGORY category, User user, int limit) {
        throw new UnsupportedOperationException("Operation not supported!");
    }


    @Override
    public <T extends AuditRecord> List<T> retrieveRecords (LocalDate day,
            int hitMax) {
        throw new UnsupportedOperationException("Operation not supported!");
    }


    @Override
    public <T extends AuditRecord> List<T> retrieveRecords (String userID,
            LocalDate start, LocalDate end, int hitMax) {
        throw new UnsupportedOperationException("Operation not supported!");
    }


    @Override
    public void apply () {
        List<AuditRecord> rcs = getRecordsToSave();
        try {
            for (AuditRecord r : rcs)
                stream.write((r.toString() + "\n").getBytes());
        }
        catch (IOException e) {
            e.printStackTrace();
        }
    }


    @Override
    public void finish () {
        try {
            stream.flush();
            stream.close();
        }
        catch (IOException e) {
            e.printStackTrace();
        }
    }
}