package org.freertr.user;

import java.util.ArrayList;
import java.util.List;
import org.freertr.addr.addrMac;
import org.freertr.cfg.cfgAll;
import org.freertr.cfg.cfgInit;
import org.freertr.tab.tabGen;
import org.freertr.util.bits;
import org.freertr.util.cmds;

/**
 * process hw population
 *
 * @author matecsaba
 */
public class userHwpop {

    /**
     * create instance
     */
    public userHwpop() {
    }

    private cmds orig;

    private int apply = 0;

    private void doResult(String head, List<String> res, int wht) {
        orig.error("apply these for " + head + ":");
        for (int i = 0; i < res.size(); i++) {
            orig.pipe.linePut(res.get(i));
        }
        if ((apply & wht) == 0) {
            return;
        }
        orig.error("applying");
        int rep = cfgInit.executeSWcommands(res, false);
        orig.error("errors=" + rep);
    }

    /**
     * do the work
     *
     * @param cmd command to do
     */
    public void doer(cmds cmd) {
        orig = cmd;
        orig.error("populating forwarding ports");
        String inf = null;
        String mpf = null;
        String srv = null;
        boolean shted = true;
        boolean lnklg = true;
        int aut = 0;
        int wht = 0;
        for (;;) {
            String s = cmd.word();
            if (s.length() < 1) {
                break;
            }
            s = s.toLowerCase();
            if (s.equals("uclipm")) {
                inf = cmd.word();
                continue;
            }
            if (s.equals("shut")) {
                shted = true;
                continue;
            }
            if (s.equals("noshut")) {
                shted = false;
                continue;
            }
            if (s.equals("lnklog")) {
                lnklg = true;
                continue;
            }
            if (s.equals("nolnklog")) {
                lnklg = false;
                continue;
            }
            if (s.equals("map")) {
                mpf = cmd.word();
                continue;
            }
            if (s.equals("ports")) {
                s = cmd.word();
                wht = 0;
                if (s.equals("ready")) {
                    wht = 1;
                }
                if (s.equals("speed")) {
                    wht = 2;
                }
                if (s.equals("all")) {
                    wht = 3;
                }
                continue;
            }
            if (s.equals("auto")) {
                aut = 0;
                s = cmd.word();
                if (s.equals("normal")) {
                    aut = 1;
                }
                if (s.equals("split")) {
                    aut = 2;
                }
                continue;
            }
            if (s.equals("server")) {
                srv = cmd.word();
                srv += " " + cmd.word();
                continue;
            }
            if (s.equals("apply")) {
                s = cmd.word();
                if (s.equals("add")) {
                    apply |= 1;
                }
                if (s.equals("del")) {
                    apply |= 2;
                }
                if (s.equals("chg")) {
                    apply |= 4;
                }
                if (s.equals("none")) {
                    apply = 0;
                }
                if (s.equals("all")) {
                    apply = -1;
                }
                continue;
            }
        }
        if (inf == null) {
            orig.error("no input specified");
            return;
        }
        if (srv == null) {
            orig.error("no server specified");
            return;
        }
        List<String> txt = bits.txt2buf(inf);
        if (txt == null) {
            orig.error("error reading input");
            return;
        }
        List<String> txt2 = null;
        tabGen<userHwpopPrt> map = new tabGen<userHwpopPrt>();
        if (mpf != null) {
            txt2 = bits.txt2buf(mpf);
        }
        if (txt2 != null) {
            for (int i = 0; i < txt2.size(); i++) {
                cmd = new cmds("hwp", txt2.get(i));
                userHwpopPrt res = new userHwpopPrt();
                res.addr = addrMac.getRandom();
                res.port = bits.str2num(cmd.word());
                res.pipe = bits.str2num(cmd.word());
                res.piPort = bits.str2num(cmd.word());
                map.add(res);
            }
        }
        orig.error("found " + map.size() + " custom mappings");
        orig.error("will use automap mode " + aut + " otherwise on " + wht + " ports");
        tabGen<userHwpopPrt> ned = new tabGen<userHwpopPrt>();
        for (int i = 0; i < txt.size(); i++) {
            cmd = new cmds("hwp", txt.get(i).trim().toLowerCase());
            userHwpopPrt res = new userHwpopPrt();
            res.addr = addrMac.getRandom();
            String a = cmd.word("|").trim();
            res.desc = a;
            if ((aut == 1) && (!a.endsWith("/0"))) {
                continue;
            }
            cmd.word("|"); // mac
            res.port = bits.str2num(cmd.word("|").trim());
            res.pipe = bits.str2num(cmd.word("/").trim());
            res.piPort = bits.str2num(cmd.word("|").trim());
            a = cmd.word("|").trim();
            if (a.length() < 1) {
                continue;
            }
            res.speed = bits.str2num(a.substring(0, a.length() - 1));
            cmd.word("|"); // fec
            cmd.word("|"); // an
            cmd.word("|"); // kr
            a = cmd.word("|").trim(); // rdy
            boolean rdy = a.equals("yes");
            if (!rdy && !a.equals("no")) {
                continue;
            }
            cmd.word("|"); // adm
            cmd.word("|"); // opr
            cmd.word("|"); // lpbk
            cmd.word("|"); // rx
            cmd.word("|"); // tx
            res.addr.fromString(cmd.word("|").trim()); // mac
            cmd.word("|"); // e
            switch (wht) {
                case 1: // ready
                    if (!rdy) {
                        continue;
                    }
                    break;
                case 2: // speed
                    if (res.speed < 1) {
                        continue;
                    }
                    break;
                case 3: // all
                    break;
                default:
                    continue;
            }
            ned.add(res);
        }
        orig.error("found " + ned.size() + " dataplane interfaces");
        if (ned.size() < 1) {
            orig.error("no interfaces found");
            return;
        }
        txt = cfgAll.getShRun(1);
        txt = userFilter.getSection(txt, userReader.filter2reg(srv));
        if (txt.size() < 1) {
            orig.error("no server found");
            return;
        }
        tabGen<userHwpopPrt> fnd = new tabGen<userHwpopPrt>();
        for (int i = 0; i < txt.size(); i++) {
            cmd = new cmds("srv", txt.get(i).trim());
            if (!cmd.word().equals("export-port")) {
                continue;
            }
            userHwpopPrt res = new userHwpopPrt();
            res.addr = addrMac.getRandom();
            res.desc = cmd.word();
            res.port = bits.str2num(cmd.word());
            res.speed = bits.str2num(cmd.word());
            fnd.add(res);
        }
        orig.error("found " + fnd.size() + " exported interfaces");
        txt2 = new ArrayList<String>();
        txt.clear();
        txt.add("server " + srv);
        for (int i = 0; i < ned.size(); i++) {
            userHwpopPrt ntry = ned.get(i);
            if (fnd.find(ntry) != null) {
                continue;
            }
            int sdn = ntry.port;
            int spd = ntry.speed;
            switch (aut) {
                case 1: // normal
                    sdn = bits.str2num(ntry.desc.substring(0, ntry.desc.indexOf("/")));
                    break;
                case 2: // split
                    sdn = bits.str2num(ntry.desc.replaceAll("/", ""));
                    break;
            }
            userHwpopPrt mpd = map.find(ntry);
            if (mpd != null) {
                sdn = mpd.pipe;
                if (mpd.piPort > 0) {
                    spd = mpd.piPort;
                }
            }
            txt2.add("interface sdn" + sdn);
            txt2.add(cmds.tabulator + "macaddr " + ntry.addr);
            txt2.add(cmds.tabulator + "description frontpanel port " + ntry.desc);
            if (shted) {
                txt2.add(cmds.tabulator + "shutdown");
            }
            if (lnklg) {
                txt2.add(cmds.tabulator + "log-link-change");
            }
            txt2.add(cmds.tabulator + cmds.finish);
            txt2.add(cmds.comment);
            txt.add(cmds.tabulator + "export-port sdn" + sdn + " " + ntry.port + " " + spd);
        }
        txt.add(cmds.tabulator + cmds.finish);
        txt2.addAll(txt);
        doResult("new ports to appear", txt2, 1);
        txt2.clear();
        txt.clear();
        txt.add("server " + srv);
        for (int i = 0; i < fnd.size(); i++) {
            userHwpopPrt ntry = fnd.get(i);
            if (ned.find(ntry) != null) {
                continue;
            }
            txt2.add("no interface " + ntry.desc);
            txt.add(cmds.tabulator + "no export-port " + ntry.desc + " " + ntry.port);
        }
        txt.add(cmds.tabulator + cmds.finish);
        txt.addAll(txt2);
        doResult("old ports to disappear", txt, 2);
        txt2.clear();
        txt.clear();
        txt.add("server " + srv);
        for (int i = 0; i < ned.size(); i++) {
            userHwpopPrt ntry = ned.get(i);
            userHwpopPrt old = fnd.find(ntry);
            if (old == null) {
                continue;
            }
            if (ntry.speed == old.speed) {
                continue;
            }
            txt.add(cmds.tabulator + "export-port " + old.desc + " " + ntry.port + " " + ntry.speed);
        }
        txt.add(cmds.tabulator + cmds.finish);
        doResult("updated port speeds", txt, 4);
    }

}

class userHwpopPrt implements Comparable<userHwpopPrt> {

    public int port;

    public int pipe;

    public int piPort;

    public int speed;

    public addrMac addr;

    public String desc;

    public int compareTo(userHwpopPrt o) {
        if (port < o.port) {
            return -1;
        }
        if (port > o.port) {
            return +1;
        }
        return 0;
    }

}