/*
 * To change this license header, choose License Headers in Project Properties.
 * To change this template file, choose Tools | Templates
 * and open the template in the editor.
 */
package getwepsarchives;

import archives.MongoArchive;
import csip.ServiceException;
import java.util.ArrayList;
import java.util.concurrent.ConcurrentHashMap;
import java.util.concurrent.CountDownLatch;
import java.util.logging.Level;
import java.util.logging.Logger;
import models.ModelArchive;
import models.WEPSModelArchive;
import models.WEPSModelArchive.WEPSMetaData;

/**
 *
 * @author <a href="mailto:shaun.case@colostate.edu">Shaun Case</a>
 */
public class ArchiveThread extends Thread {

    protected String suid;
    protected CountDownLatch latch;
    protected String dbLocation;
    protected MongoArchive mongoArchive;
    protected ArrayList<ModelArchive> tArchive;
    protected ModelArchive model;
    protected String errorMessage;
    protected WEPSMetaData wepsMetaData;
    ConcurrentHashMap<String, WEPSMetaData> metaDataResults;

    public ArchiveThread(String _suid, String _dbLocation, ConcurrentHashMap<String, WEPSMetaData> _metaDataResults, CountDownLatch _latch) throws Exception {
        suid = _suid;
        latch = _latch;
        dbLocation = _dbLocation;
        metaDataResults = _metaDataResults;
        if (dbLocation.contains("mongodb://")) {
            mongoArchive = new MongoArchive(dbLocation);
        }
    }

    @Override
    public void run() {

        try {
            tArchive = mongoArchive.getArchivesByFilter("_id", suid, 1);
        } catch (Exception ex) {
            errorMessage += "#\nCannot get that suid, " + suid + ", from the archive:  " + ex.getMessage() + "\n\n" + ex.toString();
        }

        if (tArchive.isEmpty()) {
            errorMessage += "#\nCould not find a WEPS model in the archive for that suid and mongodb location.";
        } else {

            model = tArchive.get(0);

            if (((WEPSModelArchive) model).badModelRun()) {
                errorMessage += "#\nFound a WEPS model in the archive, however the model was invalid: " + ((WEPSModelArchive) model).badModelMessage();
            } else {
                ((WEPSModelArchive) model).calcWEPSMetaData();

                try {
                    mongoArchive.shutdown();
                } catch (Exception ex) {
                    errorMessage += "#\nCould not shutdown mongo archive at: " + dbLocation + "\n\n" + ex.toString();
                }

                wepsMetaData = ((WEPSModelArchive) model).getWEPSMetaData();
                if ((null != wepsMetaData) && (null != metaDataResults)) {
                    metaDataResults.put(suid, wepsMetaData);
                }
            }
        }
        
        if ( (null != errorMessage) && !errorMessage.isEmpty()) {
            System.err.println(suid + ": " + errorMessage);
        }

        latch.countDown();

    }

}