X-Git-Url: http://erislabs.net/gitweb/?a=blobdiff_plain;f=source%2Fmircoders%2Fproducer%2FUnIndexingProducerNode.java;h=cf26e15507effe89b05dbf512d37f1be1bde108c;hb=6b6b6215ebe066b81f1fa6b0c71a532ca7b4fc3f;hp=b180bbf1c1c56541b5f424adaeb58864c91279b8;hpb=d10337c6edde3be5436b154a76aac8500bb94d66;p=mir.git diff --git a/source/mircoders/producer/UnIndexingProducerNode.java b/source/mircoders/producer/UnIndexingProducerNode.java index b180bbf1..cf26e155 100755 --- a/source/mircoders/producer/UnIndexingProducerNode.java +++ b/source/mircoders/producer/UnIndexingProducerNode.java @@ -1,5 +1,5 @@ /* - * Copyright (C) 2001, 2002 The Mir-coders group + * Copyright (C) 2001, 2002 The Mir-coders group * * This file is part of Mir. * @@ -18,50 +18,51 @@ * Foundation, Inc., 59 Temple Place, Suite 330, Boston, MA 02111-1307 USA * * In addition, as a special exception, The Mir-coders gives permission to link - * the code of this program with the com.oreilly.servlet library, any library - * licensed under the Apache Software License, The Sun (tm) Java Advanced - * Imaging library (JAI), The Sun JIMI library (or with modified versions of - * the above that use the same license as the above), and distribute linked - * combinations including the two. You must obey the GNU General Public - * License in all respects for all of the code used other than the above - * mentioned libraries. If you modify this file, you may extend this exception - * to your version of the file, but you are not obligated to do so. If you do - * not wish to do so, delete this exception statement from your version. + * the code of this program with any library licensed under the Apache Software License, + * The Sun (tm) Java Advanced Imaging library (JAI), The Sun JIMI library + * (or with modified versions of the above that use the same license as the above), + * and distribute linked combinations including the two. You must obey the + * GNU General Public License in all respects for all of the code used other than + * the above mentioned libraries. If you modify this file, you may extend this + * exception to your version of the file, but you are not obligated to do so. + * If you do not wish to do so, delete this exception statement from your version. */ - package mircoders.producer; -import java.util.*; -import java.io.*; - -import freemarker.template.*; - -import mir.util.*; -import mir.log.*; -import mir.producer.*; -import mircoders.global.*; -import mircoders.localizer.*; -import mir.entity.*; -import mir.entity.adapter.*; -import mircoders.entity.*; -import mircoders.storage.*; -import mircoders.search.*; - - +import mir.entity.Entity; +import mir.entity.adapter.EntityAdapter; +import mir.log.LoggerWrapper; +import mir.producer.ProducerFailure; +import mir.producer.ProducerNode; +import mir.producer.ProductionContext; +import mir.util.FileRoutines; +import mir.util.ParameterExpander; +import mircoders.entity.EntityContent; +import mircoders.search.IndexUtil; + +import java.io.File; + +/** + * UnIndexingProducerNode is one of the 2 producer nodes that works on + * the search index db. There's IndexingProducerNode and + * UnIndexingProducerNode. The first one adds/updates an article to + * the search index the second one removes an article + */ public class UnIndexingProducerNode implements ProducerNode { private String contentKey; private String indexPath; + private File indexBasePath; - - public UnIndexingProducerNode(String aContentKey, String pathToIndex) { + public UnIndexingProducerNode(File anIndexBasePath, String aContentKey, String pathToIndex) { contentKey = aContentKey; indexPath=pathToIndex; + indexBasePath = anIndexBasePath; } - public void produce(Map aValueMap, String aVerb, LoggerWrapper aLogger) throws ProducerFailure { + public void produce(ProductionContext aProductionContext) throws ProducerFailure { Object data; Entity entity; - String index=null; + File indexFile; long startTime; long endTime; @@ -69,8 +70,10 @@ public class UnIndexingProducerNode implements ProducerNode { startTime = System.currentTimeMillis(); try { - index = ParameterExpander.expandExpression(aValueMap, indexPath); - data = ParameterExpander.findValueForKey( aValueMap, contentKey ); + indexFile = FileRoutines.getAbsoluteOrRelativeFile(indexBasePath, + ParameterExpander.expandExpression(aProductionContext.getValueSet(), indexPath)); + + data = ParameterExpander.findValueForKey(aProductionContext.getValueSet(), contentKey); if (! (data instanceof EntityAdapter)) { throw new ProducerFailure("UnIndexingProducerNode: value of '"+contentKey+"' is not an EntityAdapter, but an " + data.getClass().getName(), null); @@ -80,19 +83,18 @@ public class UnIndexingProducerNode implements ProducerNode { if (! (entity instanceof EntityContent)) { throw new ProducerFailure("UnIndexingProducerNode: value of '"+contentKey+"' is not a content EntityAdapter, but a " + entity.getClass().getName() + " adapter", null); } - aLogger.info("UnIndexing " + (String) entity.getValue("id") + " out of " + index); + aProductionContext.getLogger().info("UnIndexing " + entity.getFieldValue("id") + " out of " + indexFile.getAbsolutePath()); - IndexUtil.unindexEntity((EntityContent) entity,index); - + IndexUtil.unindexEntity((EntityContent) entity, indexFile); } catch (Throwable t) { - aLogger.error("Error while unindexing content: " + t.getMessage()); - t.printStackTrace(new PrintWriter(new LoggerToWriterAdapter(aLogger, LoggerWrapper.DEBUG_MESSAGE))); + aProductionContext.getLogger().error("Error while unindexing content: " + t.getMessage()); + t.printStackTrace(aProductionContext.getLogger().asPrintWriter(LoggerWrapper.DEBUG_MESSAGE)); } - + endTime = System.currentTimeMillis(); - aLogger.info(" UnIndexTime: " + (endTime-startTime) + " ms
"); + aProductionContext.getLogger().info(" UnIndexTime: " + (endTime-startTime) + " ms
"); } }