package jnpf.limsService.provider;

import jnpf.exception.DataException;
import jnpf.limsService.LimsTestWorkItemSnapshotService;
import lombok.Data;
import lombok.AllArgsConstructor;
import lombok.Value;

import javax.sql.DataSource;
import java.util.ArrayList;
import java.util.LinkedHashSet;
import java.util.List;
import java.util.Map;
import java.util.function.Supplier;

/** Reads persisted executable definitions; never accepts physical mappings from a caller. */
public class LimsElnReadonlyResolver {
    private final LimsElnSourceCatalog catalog;
    private final LimsElnSourceExecution execution;
    private final Supplier<LimsElnSourceCatalog.Actor> actors;

    public LimsElnReadonlyResolver(LimsElnSourceCatalog catalog, DataSource readOnlyDataSource,
            LimsTestWorkItemSnapshotService taskAccess, Supplier<LimsElnSourceCatalog.Actor> actors) {
        this.catalog = catalog;
        this.execution = new LimsElnSourceExecution(readOnlyDataSource, taskAccess);
        this.actors = actors;
    }

    public List<Snapshot> resolve(List<String> itemIds, List<PropertyRef> properties) {
        return resolve(itemIds, properties, actors.get());
    }

    List<Snapshot> resolve(List<String> itemIds, List<PropertyRef> properties, LimsElnSourceCatalog.Actor actor) {
        LimsElnSourceCatalog.requireActor(actor);
        if (properties == null || properties.size() > 50) throw new DataException("Source request exceeds limits");
        if (properties.stream().anyMatch(ref -> ref == null || ref.getRevision() < 1
                || ref.getPropertyCode() == null || !ref.getPropertyCode().matches("[a-zA-Z][a-zA-Z0-9_.-]{0,79}"))) {
            throw new DataException("Invalid source request");
        }
        List<LimsElnSourceCatalog.Version> versions = new ArrayList<>();
        for (PropertyRef property : new LinkedHashSet<>(properties)) {
            versions.add(catalog.published(property.getPropertyCode(), property.getRevision(), actor));
        }
        return execution.execute(itemIds, versions, actor);
    }

    @Value
    public static class PropertyRef {
        String propertyCode;
        int revision;
    }

    public static class SourceFailure extends DataException {
        private final String code;

        public SourceFailure(String code, String message) {
            super(message);
            this.code = code;
        }

        public String getCode() {
            return code;
        }
    }

    @Value
    @AllArgsConstructor
    @com.fasterxml.jackson.databind.annotation.JsonNaming(com.fasterxml.jackson.databind.PropertyNamingStrategies.LowerCamelCaseStrategy.class)
    public static class Snapshot {
        String sourceRef;
        String propertyCode;
        int propertyRevision;
        String dataType;
        String outcomeCode;
        @com.fasterxml.jackson.databind.annotation.JsonSerialize(using = LimsElnSourceScalarSerializer.class)
        Object value;
        String acquiredAt;
        String lineage;
        String reasonCode;
        String formattedValue;

        public Snapshot(String sourceRef, String propertyCode, int propertyRevision, String dataType,
                String outcomeCode, Object value, String acquiredAt, String lineage) {
            this(sourceRef, propertyCode, propertyRevision, dataType, outcomeCode, value, acquiredAt, lineage, null, null);
        }
    }

    @Data
    public static class FrozenDefinition {
        private String datasetCode;
        private int datasetRevision;
        private String schema;
        private String table;
        private String idColumn;
        private String tenantColumn;
        private String deleteColumn;
        private Map<String, Field> fields;
        private String resultField;
        private List<Join> joins = new ArrayList<>();
        private List<Condition> conditions = new ArrayList<>();
        private String scopeMode = "ALL";
        private Map<String, Map<String, String>> columnIdentities;
    }

    @Data
    public static class Field {
        private String column;
        private String dataType;
        private int step;
        private String valueMode = "RAW";
        private Map<String, String> nameOptions;
        private String format = "RAW";
    }

    @Data
    public static class Join {
        private String schema;
        private String table;
        private String tenantColumn;
        private int fromStep;
        private String fromColumn;
        private String targetColumn;
        private String deleteColumn;
        private String qualifierColumn;
        private String qualifierValue;
    }

    @Data
    public static class Condition {
        private String field;
        private String operator;
        private List<String> values = new ArrayList<>();
    }
}