rrenkert@8251: package org.dive4elements.river.exports.injector; rrenkert@8251: rrenkert@8251: import org.apache.log4j.Logger; rrenkert@8251: import org.dive4elements.artifacts.Artifact; rrenkert@8251: import org.dive4elements.artifacts.CallContext; rrenkert@8251: import org.dive4elements.artifacts.ContextInjector; rrenkert@8251: import org.dive4elements.river.artifacts.D4EArtifact; rrenkert@8251: import org.dive4elements.river.artifacts.access.RangeAccess; rrenkert@8251: import org.dive4elements.river.model.Gauge; rrenkert@8251: import org.w3c.dom.Document; rrenkert@8251: import org.w3c.dom.Element; rrenkert@8251: rrenkert@8251: import static org.dive4elements.river.exports.injector.InjectorConstants.CURRENT_KM; rrenkert@8251: import static org.dive4elements.river.exports.injector.InjectorConstants.GAUGE_EPSILON;; rrenkert@8251: rrenkert@8251: rrenkert@8251: public class DischargeInjector rrenkert@8251: implements ContextInjector rrenkert@8251: { rrenkert@8251: rrenkert@8251: private static Logger log = Logger.getLogger(DischargeInjector.class); rrenkert@8251: rrenkert@8251: @Override rrenkert@8251: public void setup(Element cfg) { rrenkert@8251: } rrenkert@8251: rrenkert@8251: @Override rrenkert@8251: public void injectContext(CallContext ctx, Artifact artifact, Document doc) { rrenkert@8251: RangeAccess access = new RangeAccess((D4EArtifact)artifact); rrenkert@8251: double km = access.getFrom(); rrenkert@8251: Gauge gauge = access.getRiver().determineGaugeByStation( rrenkert@8251: km - GAUGE_EPSILON, km + GAUGE_EPSILON); rrenkert@8251: if (gauge == null) { rrenkert@8251: log.error("No Gauge could be found at station " + km + "!"); rrenkert@8251: return; rrenkert@8251: } rrenkert@8251: ctx.putContextValue(CURRENT_KM, km); rrenkert@8251: } rrenkert@8251: rrenkert@8251: }