rrenkert@8304: package org.dive4elements.river.exports.injector;
rrenkert@8304: 
rrenkert@8326: import org.apache.log4j.Logger;
rrenkert@8304: import org.dive4elements.artifacts.Artifact;
rrenkert@8304: import org.dive4elements.artifacts.CallContext;
rrenkert@8304: import org.dive4elements.artifacts.ContextInjector;
rrenkert@8304: import org.dive4elements.river.artifacts.D4EArtifact;
rrenkert@8304: import org.dive4elements.river.artifacts.access.RiverAccess;
rrenkert@8304: import org.dive4elements.river.model.Gauge;
rrenkert@8304: import org.w3c.dom.Document;
rrenkert@8304: import org.w3c.dom.Element;
rrenkert@8304: 
rrenkert@8304: import static org.dive4elements.river.exports.injector.InjectorConstants.CURRENT_KM;
rrenkert@8304: import static org.dive4elements.river.exports.injector.InjectorConstants.PNP;
rrenkert@8304: import static org.dive4elements.river.exports.injector.InjectorConstants.GAUGE_EPSILON;
rrenkert@8304: 
rrenkert@8304: public class PNPInjector
rrenkert@8304: implements ContextInjector
rrenkert@8304: {
rrenkert@8304: 
rrenkert@8326:     private Logger log = Logger.getLogger(PNPInjector.class);
rrenkert@8304:     @Override
rrenkert@8304:     public void setup(Element cfg) {
rrenkert@8304:         // TODO Auto-generated method stub
rrenkert@8304: 
rrenkert@8304:     }
rrenkert@8304: 
rrenkert@8304:     @Override
rrenkert@8304:     public void injectContext(
rrenkert@8304:         CallContext ctx,
rrenkert@8304:         Artifact artifact,
rrenkert@8304:         Document request
rrenkert@8304:     ) {
rrenkert@8304:         Object currentKm = ctx.getContextValue(CURRENT_KM);
rrenkert@8304:         if (currentKm == null) {
rrenkert@8326:             log.debug("no current km. not injecting pnp");
rrenkert@8304:             return;
rrenkert@8304:         }
rrenkert@8304: 
rrenkert@8304:         RiverAccess access = new RiverAccess((D4EArtifact)artifact);
rrenkert@8326:         Double km = Double.valueOf(currentKm.toString());
rrenkert@8326:         if (Double.isNaN(km) || Double.isInfinite(km)) {
rrenkert@8326:             log.debug("current km is NAN or infinte. not injecting pnp.");
rrenkert@8326:             return;
rrenkert@8326:         }
rrenkert@8304:         Gauge gauge =
rrenkert@8304:             access.getRiver().determineGaugeByStation(
rrenkert@8304:                 km - GAUGE_EPSILON,
rrenkert@8304:                 km + GAUGE_EPSILON);
rrenkert@8304: 
rrenkert@8304:         if (gauge == null) {
rrenkert@8326:             log.debug("no gauge found at current km. not injecting pnp");
rrenkert@8304:             return;
rrenkert@8304:         }
rrenkert@8326:         log.debug("injecting pnp: " + gauge.getDatum());
rrenkert@8304:         ctx.putContextValue(PNP, gauge.getDatum());
rrenkert@8304:     }
rrenkert@8304: 
rrenkert@8304: }