Metacat

/**

 *  '$RCSfile$'

 *    Purpose: A class that gets Accession Number, check for uniqueness

 *             and register it into db

 *  Copyright: 2000 Regents of the University of California and the

 *             National Center for Ecological Analysis and Synthesis

 *    Authors: Jivka Bojilova, Matt Jones

 *

 *   '$Author: leinfelder $'

 *     '$Date: 2011-11-02 20:40:12 -0700 (Wed, 02 Nov 2011) $'

 * '$Revision: 6595 $'

 *

 * This program is free software; you can redistribute it and/or modify

 * it under the terms of the GNU General Public License as published by

 * the Free Software Foundation; either version 2 of the License, or

 * (at your option) any later version.

 *

 * This program is distributed in the hope that it will be useful,

 * but WITHOUT ANY WARRANTY; without even the implied warranty of

 * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the

 * GNU General Public License for more details.

 *

 * You should have received a copy of the GNU General Public License

 * along with this program; if not, write to the Free Software

 * Foundation, Inc., 59 Temple Place, Suite 330, Boston, MA  02111-1307  USA

 */

package edu.ucsb.nceas.metacat.index;

import org.apache.commons.logging.Log;

import org.apache.commons.logging.LogFactory;

import org.dataone.service.types.v1.SystemMetadata;

import com.hazelcast.core.IMap;

import com.hazelcast.core.ItemEvent;

import com.hazelcast.core.ItemListener;

import edu.ucsb.nceas.metacat.index.event.EventlogFactory;

	private static Log log = LogFactory.getLog(SystemMetadataEventListener.class);

	private SolrIndex solrIndex = null;

     * @see setSolrIndex()

     * @see start()

    }

    /**

     * Sets the SolrIndex instance and initializes the listener

     * @param solrIndex

     */

    public SystemMetadataEventListener(SolrIndex solrIndex) {

    	this.solrIndex = solrIndex;

			start();

		} catch (Exception e) {

			log.error(e.getMessage(), e);

		}

    /**

     * Get the SolrIndex that this listener communicates with

     * @return a SolrIndex instance that indexes the content being listened to

     */

    public SolrIndex getSolrIndex() {

		return solrIndex;

	}

    /**

     * Set the SolrIndex instance that the listener modifies

     * @param solrIndex

     */

	public void setSolrIndex(SolrIndex solrIndex) {

		this.solrIndex = solrIndex;

	}

	/**

     * Registers this instance as a system metadata map event listener

	 * @throws FileNotFoundException

        IMap<Identifier, String> objectPathMap = DistributedMapsFactory.getObjectPathMap();

        indexQueue.addItemListener(this, true);

        log.info("System Metadata size: " + indexQueue.size());

    /**

     * @throws FileNotFoundException

    /**

     * Get the obsoletes chain of the specified id. The returned list doesn't include

     * the specified id itself. The newer version has the lower index number in the list.

     * Empty list will be returned if there is no document to be obsoleted by this id.

     * @param id

     * @return

     * @throws FileNotFoundException

        while (id != null) {

            if(metadata != null) {

                Identifier identifier = metadata.getObsoletes();

                if(identifier != null && identifier.getValue() != null && !identifier.getValue().trim().equals("")) {

                    obsoletes.add(identifier.getValue());

                    id = identifier.getValue();

                }

            }

        }

        return obsoletes;

    }

		if(pid != null) {

		    try {

	            solrIndex.remove(pid.getValue());

	        } catch (Exception e) {

	            String error = "SystemMetadataEventListener.itemRemoved - couldn't remove the index for the pid "+pid.getValue()+" since "+e.getMessage();

	            SystemMetadata systemMetadata = entryEvent.getItem();

	            writeEventLog(systemMetadata, pid, error);

	            log.error(error, e);

	        }

		    writeEventLog(systemMetadata, pid, "SystemMetadataEventListener.itemAdded -could not get the SystemMetadata");

		    return;

		}

		List<String> obsoletesChain = null;

		    try {

				obsoletesChain = getObsoletes(pid.getValue());

			} catch (Exception e) {

			    writeEventLog(systemMetadata, pid, error);

	            log.error(error, e);

	            return;

		try {

			objectPath = DistributedMapsFactory.getObjectPathMap().get(pid);

		} catch (Exception e) {

		    writeEventLog(systemMetadata, pid, error);

			log.error(error, e);

		    InputStream data = null;

	        try {

	            data = new FileInputStream(objectPath);

	            solrIndex.update(pid.getValue(), obsoletesChain, systemMetadata, data);

	        } catch (Exception e) {

	            writeEventLog(systemMetadata, pid, error);

	            log.error(error, e);

	private void writeEventLog(SystemMetadata systemMetadata, Identifier pid, String error) {

	    IndexEvent event = new IndexEvent();

        event.setIdentifier(pid);

	    event.setDate(Calendar.getInstance().getTime());

	    String action = null;

	    if (systemMetadata == null ) {

	        action = Event.CREATE.xmlValue();

            event.setAction(Event.CREATE);

	    }

            event.setAction(Event.DELETE);

        } else {

            action = Event.CREATE.xmlValue();

            event.setAction(Event.CREATE);

        }

        event.setDescription("Failed to "+action+"the solr index for the id "+pid.getValue()+" since "+error);

        try {

            EventlogFactory.createIndexEventLog().write(event);

        } catch (Exception ee) {

            log.error("SolrIndex.insertToIndex - IndexEventLog can't log the index inserting event :"+ee.getMessage());

        }

	}