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 java.io.InputStream;

import java.util.ArrayList;

import java.util.Date;

import java.util.List;

import java.util.Vector;

import org.apache.commons.logging.Log;

import org.apache.commons.logging.LogFactory;

import org.apache.solr.client.solrj.SolrServerException;

import org.dataone.client.MNode;

import org.dataone.configuration.Settings;

import org.dataone.service.exceptions.InvalidRequest;

import org.dataone.service.exceptions.InvalidToken;

import org.dataone.service.exceptions.NotAuthorized;

import org.dataone.service.exceptions.NotImplemented;

import org.dataone.service.exceptions.ServiceFailure;

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

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

/**

 * A class represents the object to generate massive solr indexes.

 * This can happen during an update of Metacat (generating index for all existing documents)

 * or regenerate index for those documents

 * failing to build index during the insert or update.

 *

 * @author tao

 *

 */

    private static final int MAXWAITNUMBER = 180;

    private static final String MNAPPENDIX = "/d1/mn";

    private SolrIndex solrIndex = null;

    private SystemMetadataEventListener systemMetadataListener = null;

    private Log log = LogFactory.getLog(IndexGenerator.class);

    private MNode mNode = null;

    /**

     * Constructor

     * @param solrIndex

     * @param systemMetadataListener

     */

    public IndexGenerator(SolrIndex solrIndex, SystemMetadataEventListener systemMetadataListener) {

        this.solrIndex = solrIndex;

        this.systemMetadataListener = systemMetadataListener;

        this.mNode = new MNode(buildMNBaseURL());

    }

    /**

     * Build the index for all documents in Metacat without overwriting.

     * @throws SolrServerException

     * @throws ServiceFailure

     * @throws NotImplemented

     * @throws NotAuthorized

     * @throws InvalidToken

     * @throws InvalidRequest

     */

    public void indexAll() throws InvalidRequest, InvalidToken, NotAuthorized,

                            NotImplemented, ServiceFailure, SolrServerException {

        boolean force = false;

        indexAll(force);

    }

    /**

     * Build the index for all documents. If force is true, the existed index for documents

     * will be overwritten.

     * @param force

     * @throws SolrServerException

     * @throws ServiceFailure

     * @throws NotImplemented

     * @throws NotAuthorized

     * @throws InvalidToken

     * @throws InvalidRequest

     */

    public void indexAll(boolean force) throws InvalidRequest, InvalidToken,

                NotAuthorized, NotImplemented, ServiceFailure, SolrServerException {

        Date since = null;

        Date until = null;

        index(since, until, force);

    }

    /**

     * Build the index for the docs which have been modified since the specified date.

     * @param since

     * @param force

     * @throws SolrServerException

     * @throws ServiceFailure

     * @throws NotImplemented

     * @throws NotAuthorized

     * @throws InvalidToken

     * @throws InvalidRequest

     */

    public void index(Date since, boolean force) throws InvalidRequest, InvalidToken,

                    NotAuthorized, NotImplemented, ServiceFailure, SolrServerException {

        Date until = null;

        index(since, until, force);

    }

    /**

     *  Build the index for the docs which have been modified between the specified date.s

     * @param since

     * @param until

     * @param force

     * @throws SolrServerException

     * @throws ServiceFailure

     * @throws NotImplemented

     * @throws NotAuthorized

     * @throws InvalidToken

     * @throws InvalidRequest

     */

    public void index(Date since, Date until, boolean force) throws SolrServerException, InvalidRequest,

                                                InvalidToken, NotAuthorized, NotImplemented, ServiceFailure {

        List<String> solrIds = null;

        List<String> metacatIds = null;

        if(!force) {

            solrIds = getSolrDocIds();

        }

                if(metacatId != null) {

                    boolean buildIndex = true;

                    if(!force && solrIds != null && solrIds.contains(metacatId)) {

                        //solr already indexs the id and we don't force it to rebuild it, so set the buildIndex to be false

                        buildIndex = false;

                    }

                    if(buildIndex) {

                        try {

                            generateIndex(metacatId);

                        } catch (Exception e) {

                            log.error("IndexGenerator.index - Metacat Index couldn't generate the index for the id - "+metacatId+" because "+e.getMessage());

                        }

                    }

                }

            }

        try {

            indexAll();

        } catch (InvalidRequest e) {

            // TODO Auto-generated catch block

            //e.printStackTrace();

            log.error("IndexGenerator.run - Metadata-Index couldn't generate indexes for those documents which haven't been indexed : "+e.getMessage());

        } catch (InvalidToken e) {

            // TODO Auto-generated catch block

            //e.printStackTrace();

            log.error("IndexGenerator.run - Metadata-Index couldn't generate indexes for those documents which haven't been indexed : "+e.getMessage());

        } catch (NotAuthorized e) {

            // TODO Auto-generated catch block

            //e.printStackTrace();

        } catch (NotImplemented e) {

            // TODO Auto-generated catch block

            //e.printStackTrace();

            log.error("IndexGenerator.run - Metadata-Index couldn't generate indexes for those documents which haven't been indexed : "+e.getMessage());

        } catch (ServiceFailure e) {

            // TODO Auto-generated catch block

            //e.printStackTrace();

            log.error("IndexGenerator.run - Metadata-Index couldn't generate indexes for those documents which haven't been indexed : "+e.getMessage());

        } catch (SolrServerException e) {

            // TODO Auto-generated catch block

            //e.printStackTrace();

            log.error("IndexGenerator.run - Metadata-Index couldn't generate indexes for those documents which haven't been indexed : "+e.getMessage());

        }

    }

     * Get the indexed ids list from the solr server.

     * An empty list will be returned if there is no ids.

     */

    private List<String> getSolrDocIds() throws SolrServerException {

        List<String> ids = solrIndex.getSolrIds();

        return ids;

    }

    /*

     * Get the ids of the metacat. If since and util are null, it will return all of them

     */

    private List<String> getMetadataIds(Date since, Date until) throws InvalidRequest,

                        InvalidToken, NotAuthorized, NotImplemented, ServiceFailure {

        while (true) {

            try {

                mNode.ping();

                break;

            } catch (Exception e) {

                if(times <= MAXWAITNUMBER) {

                    log.warn("IndexGenerator.getMetadataIds - the mnode "+ mNode.getNodeBaseServiceUrl()+

                                    " is not ready :" +e.getMessage()+"\nWe will try to access it 10 seconds later ");

                    try {

                        Thread.sleep(WAITTIME);

                    } catch (Exception ee) {

                        log.warn("IndexGenerator.getMetadataIds - the thread can't sleep for 10 seconds to wait the MNode");

                    }

                } else {

                    throw new ServiceFailure("503", "IndexGenerator.getMetadataIds - the mnode "+ mNode.getNodeBaseServiceUrl()+

                                    " is not ready even though Metacat-index wailted for 30 minutes. We can't get the objects list from it and the building index can't happen this time");

                }

            }

            times++;

        }

            objects = mNode.listObjects();

        } else {

            objects = mNode.listObjects(since, until, null, true, 0, Integer.MAX_VALUE);

        }

            List<ObjectInfo> objectInfoList = objects.getObjectInfoList();

            if(objectInfoList != null) {

                for(ObjectInfo info : objectInfoList) {

                    if(info != null) {

                        Identifier identifier = info.getIdentifier();

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

                            ids.add(identifier.getValue());

                        }

                    }

                }

            }

        }

    }

    /*

     * Build up the mn base url

     */

    private String buildMNBaseURL() {

        return url;

    }

    /*

     * Generate index for the id.

     */

    private void generateIndex(String id) throws Exception {

        if(id != null)  {

                SystemMetadata sysmeta = systemMetadataListener.getSystemMetadata(id);

                if(sysmeta != null) {

                        InputStream data = systemMetadataListener.getDataObject(id);

                        Identifier obsolete = sysmeta.getObsoletes();

                        }

                        solrIndex.update(id, obsoleteChain, sysmeta, data);

                    throw new Exception("IndexGenerator.generate - there is no found SystemMetadata associated with the id "+id);

                }

        }

    }

}