ingo@1147: package de.intevation.flys.wsplgen; ingo@1147: ingo@1147: import java.util.regex.Matcher; ingo@1147: import java.util.regex.Pattern; ingo@1147: ingo@1147: import org.apache.log4j.Logger; ingo@1147: ingo@1149: import de.intevation.flys.artifacts.model.WSPLGENCalculation; ingo@1147: import de.intevation.flys.artifacts.model.WSPLGENJob; ingo@1147: ingo@1147: ingo@1147: public class ProblemObserver extends JobObserver { ingo@1147: ingo@1147: private static Logger logger = Logger.getLogger(ProblemObserver.class); ingo@1147: ingo@1147: ingo@1147: public static final Pattern WSPLGEN_ERROR_START = Pattern.compile( ingo@1648: ".*->(.*Fehler)(\\s*\\((\\d+)\\).*)*", ingo@1147: Pattern.DOTALL); ingo@1147: ingo@1147: public static final Pattern WSPLGEN_ERROR_END = Pattern.compile( ingo@1648: ".*<-(.*Fehler).*", ingo@1147: Pattern.DOTALL); ingo@1147: ingo@1147: public static final Pattern WSPLGEN_WARNING_START = Pattern.compile( ingo@1147: ".*->Warnung\\s*\\((\\d+)\\).*", ingo@1147: Pattern.DOTALL); ingo@1147: ingo@1147: public static final Pattern WSPLGEN_WARNING_END = Pattern.compile( ingo@1147: ".*<-Warnung .*", ingo@1147: Pattern.DOTALL); ingo@1147: ingo@1147: ingo@1147: protected int error; ingo@1147: protected int warning; ingo@1147: ingo@1149: protected WSPLGENCalculation calculation; ingo@1147: ingo@1147: ingo@1147: public ProblemObserver(WSPLGENJob job) { ingo@1147: super(job); ingo@1149: error = -1; ingo@1149: warning = -1; ingo@1149: calculation = job.getCalculation(); ingo@1147: } ingo@1147: ingo@1147: ingo@1147: public void run() { ingo@1147: logger.debug("Start observation..."); ingo@1147: ingo@1147: super.run(); ingo@1147: } ingo@1147: ingo@1147: ingo@1147: @Override ingo@1147: protected void prepareRegexes() { ingo@1147: // do nothing ingo@1147: } ingo@1147: ingo@1147: ingo@1147: @Override ingo@1147: protected void update(String log) { ingo@1147: Matcher startError = WSPLGEN_ERROR_START.matcher(log); ingo@1147: if (startError.matches()) { ingo@1648: if (startError.groupCount() >= 2) { ingo@1649: String tmp = startError.group(3); ingo@1648: ingo@1648: if (tmp != null && tmp.length() > 0) { ingo@1648: error = Integer.parseInt(tmp); ingo@1648: } ingo@1648: else error = 1; ingo@1648: } ingo@1648: else { ingo@1648: error = 1; ingo@1648: } ingo@1648: ingo@1147: return; ingo@1147: } ingo@1147: ingo@1147: Matcher endError = WSPLGEN_ERROR_END.matcher(log); ingo@1147: if (endError.matches()) { ingo@1147: error = -1; ingo@1147: } ingo@1147: ingo@1147: if (error > 0) { ingo@1149: calculation.addError(new Integer(error), log); ingo@1147: } ingo@1147: ingo@1147: Matcher startWarning = WSPLGEN_WARNING_START.matcher(log); ingo@1147: if (startWarning.matches()) { ingo@1147: warning = Integer.parseInt(startWarning.group(1)); ingo@1147: return; ingo@1147: } ingo@1147: ingo@1147: Matcher endWarning = WSPLGEN_WARNING_END.matcher(log); ingo@1147: if (endWarning.matches()) { ingo@1147: warning = -1; ingo@1147: } ingo@1147: ingo@1147: if (warning > 0) { ingo@1149: calculation.addWarning(new Integer(warning), log); ingo@1147: } ingo@1147: } ingo@1147: ingo@1147: ingo@1147: public int numErrors() { ingo@1149: return calculation.numErrors(); ingo@1147: } ingo@1147: ingo@1147: ingo@1147: public int numWarnings() { ingo@1149: return calculation.numWarnings(); ingo@1147: } ingo@1147: } ingo@1147: // vim:set ts=4 sw=4 si et sta sts=5 fenc=utf-8 :