/*
 * Licensed to Elasticsearch under one or more contributor
 * license agreements. See the NOTICE file distributed with
 * this work for additional information regarding copyright
 * ownership. Elasticsearch licenses this file to you under
 * the Apache License, Version 2.0 (the "License"); you may
 * not use this file except in compliance with the License.
 * You may obtain a copy of the License at
 *
 *    http://www.apache.org/licenses/LICENSE-2.0
 *
 * Unless required by applicable law or agreed to in writing,
 * software distributed under the License is distributed on an
 * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
 * KIND, either express or implied.  See the License for the
 * specific language governing permissions and limitations
 * under the License.
 */

package org.elasticsearch.script.models;

import org.dmg.pmml.RegressionModel;
import org.elasticsearch.common.collect.Tuple;

import java.util.HashMap;
import java.util.Map;

public class EsLogisticRegressionModel extends EsRegressionModelEvaluator {

    public EsLogisticRegressionModel(RegressionModel model) {
        super(model);
    }

    public EsLogisticRegressionModel(double[] coefficients,
                                     double intercept, String[] classes) {
        super(coefficients, intercept, classes);
    }

    @Override
    public Map<String, Object> evaluateDebug(Tuple<int[], double[]> featureValues) {
        double val = linearFunction(featureValues, intercept, coefficients);
        return prepareResult(val);
    }

    @Override
    Map<String, Object> evaluate(Tuple<int[], double[]> featureValues) {
        throw new UnsupportedOperationException("can only run with parameter debug: true");
    }

    protected Map<String, Object> prepareResult(double val) {
        // TODO: this should be several classes really...
        double prob = 1 / (1 + Math.exp(-1.0 * val));
        String classValue = prob > 0.5 ? classes[0] : classes[1];
        Map<String, Object> result = new HashMap<>();
        result.put("class", classValue);
        Map<String, Object> probs = new HashMap<>();
        probs.put(classes[0], prob);
        probs.put(classes[1], 1.0 - prob);
        result.put("probs", probs);
        return result;
    }

    public Map<String, Object> evaluateDebug(double[] featureValues) {
        double val = linearFunction(featureValues, intercept, coefficients);
        return prepareResult(val);
    }


}

@@ -1553,36 +1553,23 @@
 ride%0A   
- Map%3CString,
  Object
-%3E
  evaluat
@@ -1622,90 +1622,182 @@
     
-throw new UnsupportedOperationException(%22can only run with parameter debug: true%22)
+double val = linearFunction(featureValues, intercept, coefficients);%0A        double prob = 1 / (1 + Math.exp(-1.0 * val));%0A        return prob %3E 0.5 ? classes%5B0%5D : classes%5B1%5D
 ;%0A  

debug for lr