X-Git-Url: http://erislabs.net/gitweb/?a=blobdiff_plain;f=source%2Fmircoders%2Flocalizer%2Fbasic%2FMirBasicOpenPostingLocalizer.java;h=a851ac08d4fcb258b126c4dee0e7d9be989b9893;hb=42680c1f9fe3250bcbd0f9ed5d9dee6188333b15;hp=e3060db487fde46311a5bd1964276fe517696bbe;hpb=781ae5e450f0fdc85d3ee5b4b586aa542611a562;p=mir.git diff --git a/source/mircoders/localizer/basic/MirBasicOpenPostingLocalizer.java b/source/mircoders/localizer/basic/MirBasicOpenPostingLocalizer.java index e3060db4..a851ac08 100755 --- a/source/mircoders/localizer/basic/MirBasicOpenPostingLocalizer.java +++ b/source/mircoders/localizer/basic/MirBasicOpenPostingLocalizer.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,79 +18,191 @@ * 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.localizer.basic; -import java.util.*; -import javax.servlet.http.*; - -import mir.misc.*; -import mir.util.*; -import mircoders.global.*; -import mircoders.localizer.*; -import mircoders.entity.*; +import mir.config.MirPropertiesConfiguration; +import mir.log.LoggerWrapper; +import mir.session.Request; +import mir.session.Session; +import mir.session.SessionHandler; +import mircoders.abuse.FilterType; +import mircoders.abuse.IPFilterType; +import mircoders.abuse.RegularExpressionFilterType; +import mircoders.abuse.ThrottleFilter; +import mircoders.abuse.PostingSizeFilterType; +import mircoders.abuse.URLBlacklistFilterType; +import mircoders.entity.EntityComment; +import mircoders.entity.EntityContent; +import mircoders.global.MirGlobal; +import mircoders.global.ProducerEngine; +import mircoders.localizer.MirLocalizerExc; +import mircoders.localizer.MirLocalizerFailure; +import mircoders.localizer.MirOpenPostingLocalizer; + +import java.util.ArrayList; +import java.util.Collections; +import java.util.HashMap; +import java.util.Iterator; +import java.util.List; +import java.util.Map; +import java.util.Random; +import java.util.Arrays; public class MirBasicOpenPostingLocalizer implements MirOpenPostingLocalizer { private List afterContentProducerTasks; private List afterCommentProducerTasks; + private List filterTypes; + private Map filterTypesMap; + protected LoggerWrapper logger; + protected MirPropertiesConfiguration configuration; + + public MirBasicOpenPostingLocalizer() throws MirLocalizerFailure { + logger = new LoggerWrapper("Localizer.Basic.OpenPosting"); + + try { + configuration = MirPropertiesConfiguration.instance(); + } + catch (Throwable e) { + throw new MirLocalizerFailure("Can't get configuration: " + e.getMessage(), e); + } - protected static Logfile logger = Logfile.getInstance( MirGlobal.getConfigProperty("Home") + "/" + MirGlobal.getConfigProperty("Mir.Localizer.Logfile")); + try { + String contentProducers = MirGlobal.config().getString("Mir.Localizer.OpenPosting.ContentProducers"); + String commentProducers = MirGlobal.config().getString("Mir.Localizer.OpenPosting.CommentProducers"); - public MirBasicOpenPostingLocalizer() { - String contentProducers = MirGlobal.getConfigProperty("Mir.Localizer.OpenPosting.ContentProducers"); - String commentProducers = MirGlobal.getConfigProperty("Mir.Localizer.OpenPosting.CommentProducers"); + afterContentProducerTasks = ProducerEngine.ProducerTask.parseProducerTaskList(contentProducers); + afterCommentProducerTasks = ProducerEngine.ProducerTask.parseProducerTaskList(commentProducers); + } + catch (Throwable t) { + logger.error("Setting up MirBasicOpenPostingLocalizer failed: " + t.getMessage()); - afterContentProducerTasks = parseProducerTaskList(contentProducers); - afterCommentProducerTasks = parseProducerTaskList(commentProducers); + throw new MirLocalizerFailure(t); + } + + filterTypes = new ArrayList(); + filterTypesMap = new HashMap(); + + addSimpleAntiAbuseFilterType(new RegularExpressionFilterType("regexp")); + addSimpleAntiAbuseFilterType(new RegularExpressionFilterType("useragent", false, false, + RegularExpressionFilterType.REQUEST_HEADERS, new String[] {"User-Agent"})); + addSimpleAntiAbuseFilterType(new IPFilterType("ip")); + addSimpleAntiAbuseFilterType(new RegularExpressionFilterType("hostname", false, false, + RegularExpressionFilterType.REQUEST_HEADERS, new String[] {"hostname"})); + addSimpleAntiAbuseFilterType(new ThrottleFilter("throttle")); + addSimpleAntiAbuseFilterType(new PostingSizeFilterType("size")); + addSimpleAntiAbuseFilterType(new URLBlacklistFilterType("urlblacklist", + Arrays.asList(MirGlobal.config().getStringArray("Mir.URLBlacklistFilter.WhiteList")))); + } + + public SessionHandler getOpenSessionHandler(String aSessionType) throws MirLocalizerExc, MirLocalizerFailure { + if ("email".equals(aSessionType)) + return new MirBasicEmailArticleHandler(); + + if ("comment".equals(aSessionType)) + return new MirBasicCommentPostingHandler(configuration.getBoolean("Localizer.OpenSession.PersistentUploadedFiles")); + + if ("translation".equals(aSessionType)) + return new MirBasicTranslationPostingHandler(); + + return new MirBasicArticlePostingHandler(configuration.getBoolean("Localizer.OpenSession.PersistentUploadedFiles")); + } + + public SessionHandler getOpenSessionHandler(Request aRequest, Session aSession) throws MirLocalizerExc, MirLocalizerFailure { + if (aSession.getAttribute("handler")==null) + { + aSession.setAttribute("handler", getOpenSessionHandler(aRequest.getParameter("sessiontype"))); + } + + return (SessionHandler) aSession.getAttribute("handler"); } public void afterContentPosting() { - MirGlobal.producerEngine().addTasks(afterContentProducerTasks); + Iterator i = afterContentProducerTasks.iterator(); + + while (i.hasNext()) { + ProducerEngine.ProducerTask task = (ProducerEngine.ProducerTask) i.next(); + + try { + MirGlobal.getProducerEngine().addTask(task); + } + catch (Throwable t) { + logger.error("Error adding content task "+task.getProducer()+"::"+task.getVerb()+": " + t.toString()); + } + } } - public void afterContentPosting(EntityContent aContent) { + public void afterArticlePosting() { afterContentPosting(); } - public void afterCommentPosting() { - MirGlobal.producerEngine().addTasks(afterCommentProducerTasks); + public void afterArticlePosting(EntityContent anArticle) { + afterContentPosting(anArticle); + } + + public void afterContentPosting(EntityContent anArticle) { + afterArticlePosting(); } public void afterCommentPosting(EntityComment aComment) { afterCommentPosting(); } - public String chooseOpenPostingLanguage(HttpServletRequest req) { - Locale locale = req.getLocale(); + public void afterCommentPosting() { + Iterator i = afterCommentProducerTasks.iterator(); - return locale.getLanguage(); + while (i.hasNext()) { + ProducerEngine.ProducerTask task = (ProducerEngine.ProducerTask) i.next(); + + try { + MirGlobal.getProducerEngine().addTask(task); + } + catch (Throwable t) { + logger.error("Error adding comment task "+task.getProducer()+"::"+task.getVerb()+": " + t.toString()); + } + } } - protected List parseProducerTaskList(String aList) { - Iterator i; - List result = new Vector(); + public String generateOnetimePassword() { + Random r = new Random(); + int random = r.nextInt(); - i = StringRoutines.splitString(aList, ";").iterator(); - while (i.hasNext()) { - String taskExpression = (String) i.next(); - List parts = StringRoutines.splitString(taskExpression, "."); + long l = System.currentTimeMillis(); - if (parts.size()!=2) - logger.printError("Invalid producer expression: '" + taskExpression + "'"); - else - result.add(new ProducerEngine.ProducerTask((String) parts.get(0), (String) parts.get(1))); + l = (l*l*l*l)/random; + if (l<0) { + l = l * -1; } - return result; + String returnString = ""+l; + + return returnString.substring(5); + } + + public List getAntiAbuseFilterTypes() { + return Collections.unmodifiableList(filterTypes); + } + + public boolean allowArticlePublication(EntityContent anArticle){ + return anArticle != null && "1".equals(anArticle.getFieldValue("is_published")); + } + + public void removeSimpleAntiAbuseFilterType(String aName) { + filterTypes.remove(filterTypesMap.get(aName)); + filterTypesMap.remove(aName); + } + + public void addSimpleAntiAbuseFilterType(FilterType aFilterType) { + removeSimpleAntiAbuseFilterType(aFilterType.getName()); + filterTypesMap.put(aFilterType.getName(), aFilterType); + filterTypes.add(aFilterType); } }