package org.freertr.cfg;

import java.util.ArrayList;
import java.util.List;
import org.freertr.clnt.clntTelemetry;
import org.freertr.serv.servStreamingMdt;
import org.freertr.tab.tabGen;
import org.freertr.user.userFilter;
import org.freertr.user.userHelping;
import org.freertr.util.bits;
import org.freertr.util.cmds;

/**
 * telemetry destination
 *
 * @author matecsaba
 */
public class cfgTlmtry implements Comparable<cfgTlmtry>, cfgGeneric {

    /**
     * name of telemetry export
     */
    public String name;

    /**
     * description
     */
    public String description;

    /**
     * worker
     */
    public clntTelemetry worker;

    /**
     * defaults text
     */
    public final static String[] defaultL = {
        "telemetry .*!" + cmds.tabulator + "port " + servStreamingMdt.port,
        "telemetry .*!" + cmds.tabulator + "interval 5000",
        "telemetry .*!" + cmds.tabulator + "delay 0",
        "telemetry .*!" + cmds.tabulator + "random-interval 0",
        "telemetry .*!" + cmds.tabulator + "random-delay 0",
        "telemetry .*!" + cmds.tabulator + cmds.negated + cmds.tabulator + "range",
        "telemetry .*!" + cmds.tabulator + cmds.negated + cmds.tabulator + "description",};

    /**
     * defaults filter
     */
    public static tabGen<userFilter> defaultF;

    /**
     * create new telemetry export
     *
     * @param s name
     */
    public cfgTlmtry(String s) {
        worker = new clntTelemetry();
        name = s;
    }

    public int compareTo(cfgTlmtry o) {
        return name.toLowerCase().compareTo(o.name.toLowerCase());
    }

    public String getPrompt() {
        return "tlmtdst";
    }

    public void getHelp(userHelping l) {
        l.add(null, "1  2,.    description              specify description");
        l.add(null, "2  2,.      <str>                  text");
        l.add(null, "1  2      rename                   rename this exporter");
        l.add(null, "2  .        <str>                  set new name");
        l.add(null, "1  2      target                   specify target address");
        l.add(null, "2  2,.      <str>                  name");
        l.add(null, "1  2      port                     specify target port");
        l.add(null, "2  .        <num>                  lines to skip");
        l.add(null, "1  2      sensor                   specify sensor to export");
        l.add(null, "2  .        <name:sns>             name of sensor");
        l.add(null, "1  2      interval                 specify time between runs");
        l.add(null, "2  .        <num>                  milliseconds between runs");
        l.add(null, "1  2      delay                    specify initial delay");
        l.add(null, "2  .        <num>                  milliseconds before start");
        l.add(null, "1  2      random-interval          specify random time between runs");
        l.add(null, "2  .        <num>                  milliseconds between runs");
        l.add(null, "1  2      random-delay             specify random initial delay");
        l.add(null, "2  .        <num>                  milliseconds before start");
        l.add(null, "1  2      range                    specify time range");
        l.add(null, "2  .        <name:tm>              name of time map");
        l.add(null, "1  2      proxy                    specify proxy profile to use");
        l.add(null, "2  .        <name:prx>             name of profile");
        l.add(null, "1  .      start                    start exporting");
        l.add(null, "1  .      stop                     stop exporting");
    }

    public List<String> getShRun(int filter) {
        List<String> l = new ArrayList<String>();
        l.add("telemetry " + name);
        cmds.cfgLine(l, description == null, cmds.tabulator, "description", description);
        cmds.cfgLine(l, worker.target == null, cmds.tabulator, "target", worker.target);
        l.add(cmds.tabulator + "port " + worker.port);
        l.add(cmds.tabulator + "interval " + worker.interval);
        l.add(cmds.tabulator + "delay " + worker.initial);
        l.add(cmds.tabulator + "random-interval " + worker.randInt);
        l.add(cmds.tabulator + "random-delay " + worker.randIni);
        cmds.cfgLine(l, worker.time == null, cmds.tabulator, "range", "" + worker.time);
        cmds.cfgLine(l, worker.proxy == null, cmds.tabulator, "proxy", "" + worker.proxy);
        for (int i = 0; i < worker.sensors.size(); i++) {
            cfgSensor ntry = worker.sensors.get(i);
            l.add(cmds.tabulator + "sensor " + ntry.name);
        }
        if (worker.need2run) {
            l.add(cmds.tabulator + "start");
        } else {
            l.add(cmds.tabulator + "stop");
        }
        l.add(cmds.tabulator + cmds.finish);
        l.add(cmds.comment);
        if ((filter & 1) == 0) {
            return l;
        }
        return userFilter.filterText(l, defaultF);
    }

    public void doCfgStr(cmds cmd) {
        String s = cmd.word();
        boolean negated = s.equals(cmds.negated);
        if (negated) {
            s = cmd.word();
        }
        if (s.equals("description")) {
            description = cmd.getRemaining();
            if (negated) {
                description = null;
            }
            return;
        }
        if (s.equals("rename")) {
            s = cmd.word();
            cfgTlmtry v = cfgAll.tlmdsFind(s, false);
            if (v != null) {
                cmd.error("already exists");
                return;
            }
            name = s;
            return;
        }
        if (s.equals("target")) {
            if (negated) {
                worker.target = null;
                return;
            }
            worker.target = cmd.getRemaining();
            return;
        }
        if (s.equals("port")) {
            worker.port = bits.str2num(cmd.word());
            return;
        }
        if (s.equals("delay")) {
            if (negated) {
                worker.initial = 0;
            } else {
                worker.initial = bits.str2num(cmd.word());
            }
            return;
        }
        if (s.equals("interval")) {
            if (negated) {
                worker.interval = 5000;
            } else {
                worker.interval = bits.str2num(cmd.word());
            }
            return;
        }
        if (s.equals("random-interval")) {
            if (negated) {
                worker.randInt = 0;
            } else {
                worker.randInt = bits.str2num(cmd.word());
            }
            return;
        }
        if (s.equals("random-delay")) {
            if (negated) {
                worker.randIni = 0;
            } else {
                worker.randIni = bits.str2num(cmd.word());
            }
            return;
        }
        if (s.equals("range")) {
            if (negated) {
                worker.time = null;
            } else {
                worker.time = cfgAll.timeFind(cmd.word(), false);
            }
            return;
        }
        if (s.equals("sensor")) {
            cfgSensor ntry = cfgAll.sensorFind(cmd.word(), false);
            if (ntry == null) {
                cmd.error("no such sensor");
                return;
            }
            if (negated) {
                worker.sensors.del(ntry);
                return;
            }
            worker.sensors.put(ntry);
            return;
        }
        if (s.equals("proxy")) {
            if (negated) {
                worker.proxy = null;
                return;
            }
            cfgProxy prx = cfgAll.proxyFind(cmd.word(), false);
            if (prx == null) {
                cmd.error("no such proxy");
                return;
            }
            worker.proxy = prx.proxy;
            return;
        }
        if (s.equals("start")) {
            if (negated) {
                worker.stopWork();
            } else {
                worker.startWork();
            }
            return;
        }
        if (s.equals("stop")) {
            if (negated) {
                worker.startWork();
            } else {
                worker.stopWork();
            }
            return;
        }
        cmd.badCmd();
    }

}