package au.gov.amsa.detection.behaviour;

import java.util.Date;
import java.util.function.Predicate;
import java.util.regex.Pattern;
import java.util.stream.Stream;

import com.google.common.annotations.VisibleForTesting;
import com.google.common.base.Optional;

import au.gov.amsa.detection.ArbitraryId;
import au.gov.amsa.detection.Streams;
import au.gov.amsa.detection.Util;
import au.gov.amsa.detection.model.Craft;
import au.gov.amsa.detection.model.Detection;
import au.gov.amsa.detection.model.DetectionRule;
import au.gov.amsa.detection.model.DetectionRule.Behaviour;
import au.gov.amsa.detection.model.DetectionRule.Events.Create;
import au.gov.amsa.detection.model.DetectionRule.Events.PositionInRegion;
import au.gov.amsa.detection.model.MessageTemplate;
import au.gov.amsa.detection.model.Region;

public class DetectionRuleBehaviour implements Behaviour {

    private final DetectionRule self;

    public DetectionRuleBehaviour(DetectionRule self) {
        this.self = self;
    }

    @Override
    public void onEntryCreated(Create event) {
        self.setId(ArbitraryId.next());
        self.setName(event.getName());
        self.setDescription(event.getDescription());
        self.setStartTime(event.getStartTime());
        self.setEndTime(event.getEndTime());
        self.setMinIntervalSecs(event.getMinIntervalSecs());
        self.setMinIntervalSecsOut(event.getMinIntervalSecsOut());
        self.setMustCross(event.getMustCross());
        self.setCraftIdentifierPattern(event.getCraftIdentifierPattern());
        self.setRegion_R1(Region.find(event.getRegionID()).get());
    }

    @Override
    public void onEntryPositionInRegion(PositionInRegion event) {

        // create a detection only if certain criteria satisfied
        if (shouldCreateDetection(event)) {
            Detection detection = createNewDetection(event);

            // because detection is not self this signal will run in a distinct
            // transaction after this method has had its transaction committed
            detection.signal(
                    Detection.Events.Send.builder().sendTime(detection.getCreatedTime()).build());
        }

    }

    private boolean shouldCreateDetection(PositionInRegion event) {

        // use a lambda for this bit so we can mock it out for unit testing
        Predicate<PositionInRegion> matchesCraftIdentifierPattern = p -> {
            Craft craft = Craft.find(p.getCraftID()).get();
            String craftIdentifier = craft.getCraftIdentifierType_R20().getName() + "="
                    + craft.getIdentifier();
            return Pattern.matches(self.getCraftIdentifierPattern(), craftIdentifier);
        };

        return shouldCreateDetection(self, event, matchesCraftIdentifierPattern);
    }

    @VisibleForTesting
    static boolean shouldCreateDetection(DetectionRule self, PositionInRegion event,
            Predicate<PositionInRegion> matchesCraftIdentifierPattern) {
        final boolean createDetection;
        if (self.getMustCross() && !event.getHasBeenOutsideRegion()) {
            createDetection = false;
        } else if (!matchesCraftIdentifierPattern.test(event))
            createDetection = false;
        else if (Util.between(event.getTime(), self.getStartTime(), self.getEndTime())) {

            Optional<Detection> latestDetection = Optional.fromNullable(self.getDetection_R18());

            if (!latestDetection.isPresent()) {
                createDetection = true;
            } else if (Util.beforeOrEquals(event.getTime(),
                    latestDetection.get().getReportTime())) {
                // ignore if position time before latest detection position time
                createDetection = false;
            } else if (forcedUpdateRequired(self, event.getCurrentTime(), latestDetection.get())) {
                createDetection = true;
            } else if (event.getCurrentTime().getTime()
                    - latestDetection.get().getCreatedTime().getTime() >= self.getMinIntervalSecs()
                            * 1000) {
                createDetection = true;
            } else
            // if been outside for a while and
            if (event.getIsEntrance()
                    && timeOutside(event) >= self.getMinIntervalSecsOut() * 1000) {
                createDetection = true;
            } else
                createDetection = false;
        } else
            createDetection = false;

        return createDetection;

    }

    private static long timeOutside(PositionInRegion event) {
        return event.getLastTimeEntered().getTime() - event.getLastExitTimeFromRegion().getTime();
    }

    private static boolean forcedUpdateRequired(DetectionRule self, Date detectionCreateTime,
            Detection latestDetection) {
        Stream<MessageTemplate> templates = getTemplate(self, detectionCreateTime);
        return templates
                .filter(t -> latestDetection.getCreatedTime().before(t.getForceUpdateBeforeTime()))
                .findAny().isPresent();
    }

    private Detection createNewDetection(PositionInRegion event) {
        Detection detection = Detection.create(ArbitraryId.next());
        Craft craft = Craft.find(event.getCraftID()).get();
        detection.relateAcrossR6(craft);
        detection.setReportAltitudeMetres(event.getAltitudeMetres());
        detection.setReportLatitude(event.getLatitude());
        detection.setReportLongitude(event.getLongitude());
        detection.setReportTime(event.getTime());
        detection.setCreatedTime(event.getCurrentTime());
        // establish latest detection for rule
        detection.relateAcrossR18(self);
        detection.setDetectionRule_R7(self);
        detection.setState(Detection.State.CREATED);
        detection.persist();
        return detection;
    }

    private static Stream<MessageTemplate> getTemplate(DetectionRule self,
            Date detectionCreateTime) {
        return Streams.fromNullable(self.getMessageTemplate_R8())
                // only between time range
                .filter(template -> Util.between(detectionCreateTime, template.getStartTime(),
                        template.getEndTime()));
    }

}

@@ -54,24 +54,62 @@
 .util.Date;%0A
+import java.util.concurrent.TimeUnit;%0A
 import java.
@@ -3419,17 +3419,16 @@
 R18());%0A
-%0A
         
@@ -4025,33 +4025,24 @@
  %3E= 
-self.getMinIntervalSecs()
+TimeUnit.SECONDS
 %0A   
@@ -4066,22 +4066,52 @@
         
-* 1000
+.toMillis(self.getMinIntervalSecs())
 ) %7B%0A    

fix overflow bug