package org.freertr.tab;

import java.util.ArrayList;
import java.util.List;
import org.freertr.user.userHelping;
import org.freertr.util.bits;
import org.freertr.util.cmds;

/**
 * average calculator
 *
 * @author matecsaba
 */
public class tabAverage {

    /**
     * mode, 0=none, 1=min, 2=avg, 3=max, 4=sum, 5=dif-min, 6=dif-avg,
     * 7=dig-max, 8=dif-sum
     */
    public int algorithm = 1;

    /**
     * number of bucket
     */
    public int buckets = 5;

    /**
     * minimum result
     */
    public int minimum;

    /**
     * maximum result
     */
    public int maximum;

    /**
     * divide result
     */
    public int divisor = 1;

    /**
     * multiply result
     */
    public int multiply = 1;

    /**
     * relaxer changes
     */
    public int ignorer = 0;

    /**
     * discard smallest values
     */
    public int discardLo = 0;

    /**
     * discard highest values
     */
    public int discardHi = 0;

    private int lastReported;

    private final List<Integer> pastValues;

    /**
     * create instance
     *
     * @param min minimum
     * @param max maximum
     */
    public tabAverage(int min, int max) {
        pastValues = new ArrayList<Integer>();
        minimum = min;
        maximum = max;
        lastReported = max;
    }

    public String toString() {
        String a = "";
        for (int i = 0; i < pastValues.size(); i++) {
            a += " " + pastValues.get(i);
        }
        return a;
    }

    /**
     * get algorithm name
     *
     * @return name
     */
    public String getAlgoName() {
        switch (algorithm) {
            case 0:
                return "none";
            case 1:
                return "minimum";
            case 2:
                return "average";
            case 3:
                return "maximum";
            case 4:
                return "summary";
            case 5:
                return "dif-min";
            case 6:
                return "dif-avg";
            case 7:
                return "dif-max";
            case 8:
                return "dif-sum";
            default:
                return "unknown=" + algorithm;
        }
    }

    /**
     * set algorithm name
     *
     * @param a name
     */
    public void string2algo(String a) {
        if (a.equals("none")) {
            algorithm = 0;
            return;
        }
        if (a.equals("minimum")) {
            algorithm = 1;
            return;
        }
        if (a.equals("average")) {
            algorithm = 2;
            return;
        }
        if (a.equals("maximum")) {
            algorithm = 3;
            return;
        }
        if (a.equals("summary")) {
            algorithm = 4;
            return;
        }
        if (a.equals("dif-min")) {
            algorithm = 5;
            return;
        }
        if (a.equals("dif-avg")) {
            algorithm = 6;
            return;
        }
        if (a.equals("dif-max")) {
            algorithm = 7;
            return;
        }
        if (a.equals("dif-sum")) {
            algorithm = 8;
            return;
        }
        algorithm = 0;
    }

    /**
     * add value
     *
     * @param val value
     */
    public void addValue(int val) {
        synchronized (pastValues) {
            pastValues.add(val);
            for (; pastValues.size() > buckets;) {
                pastValues.remove(0);
            }
        }
    }

    /**
     * update parameters
     *
     * @param src source
     */
    public void updateFrom(tabAverage src) {
        algorithm = src.algorithm;
        buckets = src.buckets;
        minimum = src.minimum;
        maximum = src.maximum;
        divisor = src.divisor;
        multiply = src.multiply;
        ignorer = src.ignorer;
    }

    /**
     * get result
     *
     * @param met default value
     * @return result
     */
    public int getResult(int met) {
        List<Integer> vals = pastValues;
        for (int o = 0; o < discardLo; o++) {
            List<Integer> v = new ArrayList<Integer>();
            synchronized (vals) {
                v.addAll(vals);
            }
            int val = Integer.MAX_VALUE;
            int seq = -1;
            for (int i = 0; i < v.size(); i++) {
                int cur = v.get(i);
                if (cur < val) {
                    val = cur;
                    seq = i;
                }
            }
            if (seq < 0) {
                return met;
            }
            v.remove(seq);
            vals = v;
        }
        for (int o = 0; o < discardHi; o++) {
            List<Integer> v = new ArrayList<Integer>();
            synchronized (vals) {
                v.addAll(vals);
            }
            int val = Integer.MIN_VALUE;
            int seq = -1;
            for (int i = 0; i < v.size(); i++) {
                int cur = v.get(i);
                if (cur > val) {
                    val = cur;
                    seq = i;
                }
            }
            if (seq < 0) {
                return met;
            }
            v.remove(seq);
            vals = v;
        }
        if (vals.size() < 1) {
            return met;
        }
        switch (algorithm) {
            case 1:
                met = Integer.MAX_VALUE;
                synchronized (vals) {
                    for (int i = 0; i < vals.size(); i++) {
                        int cur = vals.get(i);
                        if (cur < met) {
                            met = cur;
                        }
                    }
                }
                break;
            case 2:
                met = 0;
                synchronized (vals) {
                    for (int i = 0; i < vals.size(); i++) {
                        int cur = vals.get(i);
                        met += cur;
                    }
                    met /= vals.size();
                }
                break;
            case 3:
                met = Integer.MIN_VALUE;
                synchronized (vals) {
                    for (int i = 0; i < vals.size(); i++) {
                        int cur = vals.get(i);
                        if (cur > met) {
                            met = cur;
                        }
                    }
                }
                break;
            case 4:
                met = 0;
                synchronized (vals) {
                    for (int i = 0; i < vals.size(); i++) {
                        int cur = vals.get(i);
                        met += cur;
                    }
                }
                break;
            case 5:
                met = Integer.MAX_VALUE;
                synchronized (vals) {
                    int prv = vals.get(0);
                    for (int i = 1; i < vals.size(); i++) {
                        int cur = vals.get(i);
                        int dif = prv - cur;
                        prv = cur;
                        if (dif < 0) {
                            dif = -dif;
                        }
                        if (dif < met) {
                            met = dif;
                        }
                    }
                }
                break;
            case 6:
                met = 0;
                synchronized (vals) {
                    int prv = vals.get(0);
                    for (int i = 1; i < vals.size(); i++) {
                        int cur = vals.get(i);
                        int dif = prv - cur;
                        prv = cur;
                        if (dif < 0) {
                            dif = -dif;
                        }
                        met += dif;
                    }
                    met /= vals.size();
                }
                break;
            case 7:
                met = Integer.MIN_VALUE;
                synchronized (vals) {
                    int prv = vals.get(0);
                    for (int i = 1; i < vals.size(); i++) {
                        int cur = vals.get(i);
                        int dif = prv - cur;
                        prv = cur;
                        if (dif < 0) {
                            dif = -dif;
                        }
                        if (dif > met) {
                            met = dif;
                        }
                    }
                }
                break;
            case 8:
                met = 0;
                synchronized (vals) {
                    int prv = vals.get(0);
                    for (int i = 1; i < vals.size(); i++) {
                        int cur = vals.get(i);
                        int dif = prv - cur;
                        prv = cur;
                        if (dif < 0) {
                            dif = -dif;
                        }
                        met += dif;
                    }
                }
                break;
            default:
                return met;
        }
        met *= multiply;
        met /= divisor;
        if (met < minimum) {
            met = minimum;
        }
        if (met > maximum) {
            met = maximum;
        }
        int i = met - lastReported;
        if (i < 0) {
            i = -i;
        }
        if (i < ignorer) {
            return lastReported;
        }
        lastReported = met;
        return met;
    }

    /**
     * get config
     *
     * @param l list to append
     * @param beg beginning
     */
    public void getConfig(List<String> l, String beg) {
        l.add(cmds.tabulator + beg + "dynamic-metric size " + buckets);
        l.add(cmds.tabulator + beg + "dynamic-metric minimum " + minimum);
        l.add(cmds.tabulator + beg + "dynamic-metric maximum " + maximum);
        l.add(cmds.tabulator + beg + "dynamic-metric divisor " + divisor);
        l.add(cmds.tabulator + beg + "dynamic-metric multiply " + multiply);
        l.add(cmds.tabulator + beg + "dynamic-metric ignore " + ignorer);
        l.add(cmds.tabulator + beg + "dynamic-metric skip-min " + discardLo);
        l.add(cmds.tabulator + beg + "dynamic-metric skip-max " + discardHi);
        l.add(cmds.tabulator + beg + "dynamic-metric algo " + getAlgoName());
    }

    /**
     * do configuration
     *
     * @param a command
     * @param cmd commands
     * @return true if hit, false if not
     */
    public boolean doConfig(String a, cmds cmd) {
        if (a.equals("size")) {
            buckets = bits.str2num(cmd.word());
            return true;
        }
        if (a.equals("minimum")) {
            minimum = bits.str2num(cmd.word());
            return true;
        }
        if (a.equals("maximum")) {
            maximum = bits.str2num(cmd.word());
            return true;
        }
        if (a.equals("divisor")) {
            divisor = bits.str2num(cmd.word());
            return true;
        }
        if (a.equals("multiply")) {
            multiply = bits.str2num(cmd.word());
            return true;
        }
        if (a.equals("ignore")) {
            ignorer = bits.str2num(cmd.word());
            return true;
        }
        if (a.equals("skip-min")) {
            discardLo = bits.str2num(cmd.word());
            return true;
        }
        if (a.equals("skip-max")) {
            discardHi = bits.str2num(cmd.word());
            return true;
        }
        return false;
    }

    /**
     * get help
     *
     * @param l list to append
     */
    public static void getHelp(userHelping l) {
        l.add(null, "5 6           time                      measurement interval");
        l.add(null, "6 .             <num>                   time in ms");
        l.add(null, "5 6           size                      number of measurement");
        l.add(null, "6 .             <num>                   number of values");
        l.add(null, "5 6           minimum                   lowest result");
        l.add(null, "6 .             <num>                   value");
        l.add(null, "5 6           maximum                   highest result");
        l.add(null, "6 .             <num>                   value");
        l.add(null, "5 6           divisor                   divide result");
        l.add(null, "6 .             <num>                   value");
        l.add(null, "5 6           multiply                  multiply result");
        l.add(null, "6 .             <num>                   value");
        l.add(null, "5 6           ignore                    ignore small differences");
        l.add(null, "6 .             <num>                   value");
        l.add(null, "5 6           skip-min                  discard small measures");
        l.add(null, "6 .             <num>                   number of values");
        l.add(null, "5 6           skip-max                  discard big measures");
        l.add(null, "6 .             <num>                   number of values");
        l.add(null, "5 6           algo                      calculation to do");
        l.add(null, "6 .             none                    nothing");
        l.add(null, "6 .             minimum                 take lowest");
        l.add(null, "6 .             average                 take average");
        l.add(null, "6 .             maximum                 take highest");
        l.add(null, "6 .             summary                 take summary");
        l.add(null, "6 .             dif-min                 take lowest of differences");
        l.add(null, "6 .             dif-avg                 take average of differences");
        l.add(null, "6 .             dif-max                 take highest of differences");
        l.add(null, "6 .             dif-sum                 take summary of differences");
    }

}