package org.freertr.clnt;

import java.util.ArrayList;
import java.util.List;
import org.freertr.addr.addrIP;
import org.freertr.cfg.cfgAll;
import org.freertr.enc.enc7bit;
import org.freertr.pipe.pipeConnect;
import org.freertr.pipe.pipeDiscard;
import org.freertr.pipe.pipeReader;
import org.freertr.pipe.pipeSide;
import org.freertr.serv.servGeneric;
import org.freertr.tab.tabGen;
import org.freertr.user.userFormat;
import org.freertr.user.userTerminal;
import org.freertr.util.bits;
import org.freertr.util.debugger;
import org.freertr.util.logger;
import org.freertr.util.syncInt;

/**
 * whois (rfc3912) client
 *
 * @author matecsaba
 */
public class clntWhois {

    /**
     * startup counter
     */
    public final static syncInt cntrStart = new syncInt(0);

    /**
     * error counter
     */
    public final static syncInt cntrError = new syncInt(0);

    /**
     * stop counter
     */
    public final static syncInt cntrStop = new syncInt(0);

    /**
     * port number
     */
    public final static int port = 43;

    /**
     * asn name cache
     */
    private final static tabGen<clntWhoisAsn> asnameCache = new tabGen<clntWhoisAsn>();

    /**
     * show local cache
     *
     * @return text
     */
    public static userFormat showLocalCache() {
        userFormat res = new userFormat("|", "asn|name|ago|created|hit|info");
        for (int i = 0; i < asnameCache.size(); i++) {
            clntWhoisAsn ntry = asnameCache.get(i);
            if (ntry == null) {
                continue;
            }
            res.add("" + ntry + "|" + asn2infos(ntry.asn));
        }
        return res;
    }

    /**
     * clear local cache
     */
    public static void purgeLocalCache() {
        asnameCache.clear();
    }

    private final clntProxy proxy;

    private final String server;

    private final String option;

    private final pipeSide console;

    /**
     * create new client
     *
     * @param con console to log
     * @param srv server to use
     * @param opt option to use
     * @param prx proxy to use
     */
    public clntWhois(pipeSide con, clntProxy prx, String srv, String opt) {
        if (opt == null) {
            opt = "";
        } else {
            opt = opt + " ";
        }
        console = pipeDiscard.needAny(con);
        server = srv;
        option = opt;
        proxy = prx;
    }

    private String removeSpecials(String s) {
        s = s.replaceAll("\\\\", "-");
        s = s.replaceAll("\\ ", "");
        s = s.replaceAll("\\!", "-");
        s = s.replaceAll("\\|", "-");
        s = s.replaceAll("\\:", "-");
        s = s.replaceAll("\\;", "-");
        s = s.replaceAll("\\,", "-");
        s = s.replaceAll("\\#", "-");
        s = s.replaceAll("\\(", "-");
        s = s.replaceAll("\\)", "-");
        s = s.replaceAll("\\[", "-");
        s = s.replaceAll("\\]", "-");
        return s;
    }

    /**
     * do one query
     *
     * @param asn asn to question
     * @return response, null if error
     */
    public String doQuery(int asn) {
        if (doQuery("as" + bits.num2str(asn)) == null) {
            asnameCache.put(new clntWhoisAsn(asn));
            return asn2str(asn);
        }
        clntWhoisAsn ntry = new clntWhoisAsn(asn);
        ntry = asnameCache.find(ntry);
        if (ntry != null) {
            ntry.hits++;
            if (ntry.name == null) {
                return asn2str(asn);
            }
            return ntry.name;
        }
        asnameCache.put(new clntWhoisAsn(asn));
        return asn2str(asn);
    }

    /**
     * do one query
     *
     * @param quest question to ask
     * @return response, null if error
     */
    public List<String> doQuery(String quest) {
        if (debugger.clntIpInfo) {
            logger.debug("working on " + option + quest + " at " + server);
        }
        cntrStart.add(1);
        console.linePut("querying " + option + quest + " at " + server);
        if (proxy == null) {
            cntrError.add(1);
            return null;
        }
        if (server == null) {
            cntrError.add(1);
            return null;
        }
        addrIP trg = userTerminal.justResolv(server, 0);
        if (trg == null) {
            cntrError.add(1);
            return null;
        }
        pipeSide pipe = proxy.doConnect(servGeneric.protoTcp, trg, port, "whois");
        if (pipe == null) {
            cntrError.add(1);
            return null;
        }
        pipe.lineRx = pipeSide.modTyp.modeCRorLF;
        pipe.lineTx = pipeSide.modTyp.modeCRLF;
        pipe.linePut(option + quest);
        pipeReader rd = new pipeReader();
        rd.setLineMode(pipeSide.modTyp.modeCRorLF);
        pipeConnect.connect(pipe, rd.getPipe(), true);
        rd.waitFor();
        List<String> res = rd.getResult();
        String asNum = null;
        String asNam = null;
        for (int i = 0; i < res.size(); i++) {
            String s = res.get(i);
            s = enc7bit.decodeExtStr(s);
            s = s.trim();
            int o = s.indexOf(":");
            if (o < 1) {
                continue;
            }
            String a = s.substring(0, o).toLowerCase();
            s = s.substring(o + 1, s.length()).trim();
            s = removeSpecials(s);
            if (a.equals("aut-num")) {
                asNum = s;
                continue;
            }
            if (a.equals("as-name")) {
                asNam = s;
                continue;
            }
        }
        cntrStop.add(1);
        if (asNam == null) {
            return res;
        }
        if (asNum == null) {
            return res;
        }
        asNum = asNum.trim().toLowerCase();
        if (!asNum.startsWith("as")) {
            return res;
        }
        clntWhoisAsn ntry = new clntWhoisAsn(bits.str2num(asNum.substring(2, asNum.length())));
        ntry.name = asNam;
        asnameCache.put(ntry);
        return res;
    }

    /**
     * get info for an asn
     *
     * @param i asn to query
     * @return info got
     */
    public static String asn2info(int i) {
        if (cfgAll.whoisOnline == null) {
            return asn2str(i);
        }
        int o = cfgAll.whoisOnline.size();
        if (o < 1) {
            return asn2str(i);
        }
        return cfgAll.whoisOnline.get(bits.random(0, o)) + bits.num2str(i);
    }

    /**
     * get all infos for an asn
     *
     * @param i asn to query
     * @return info got, null if nothing
     */
    public static List<String> asn2infos(int i) {
        List<String> res = new ArrayList<String>();
        if (cfgAll.whoisOnline == null) {
            return res;
        }
        int p = cfgAll.whoisOnline.size();
        for (int o = 0; o < p; o++) {
            res.add(cfgAll.whoisOnline.get(o) + bits.num2str(i));
        }
        return res;
    }

    private static String asn2str(int i) {
        return "as" + bits.num2str(i);
    }

    /**
     * get all infos for an asn
     *
     * @param i asn to query
     * @param b true to do an external lookup on local cache miss
     * @return as name mixed
     */
    public static String asn2mixed(int i, boolean b) {
        return bits.num2str(i) + "-" + asn2name(i, b);
    }

    /**
     * find name of asn
     *
     * @param i asn number
     * @param b true to do an external lookup on local cache miss
     * @return name
     */
    public static String asn2name(int i, boolean b) {
        clntWhoisAsn ntry = new clntWhoisAsn(i);
        ntry = asnameCache.find(ntry);
        if (ntry != null) {
            ntry.hits++;
            if (ntry.name == null) {
                return asn2str(i);
            }
            return ntry.name;
        }
        if (!b) {
            return asn2str(i);
        }
        clntWhois w = new clntWhois(null, cfgAll.getClntPrx(cfgAll.whoisProxy), cfgAll.whoisServer, cfgAll.whoisOption);
        return w.doQuery(i);
    }

    /**
     * convert asn list to string
     *
     * @param lst list to convert
     * @param beg beginning
     * @param end ending
     * @return list
     */
    public static String asnList2str(List<Integer> lst, String beg, String end) {
        if (lst == null) {
            return "";
        }
        if (lst.size() < 1) {
            return "";
        }
        String s = "";
        for (int i = 0; i < lst.size(); i++) {
            int o = lst.get(i);
            String a = asn2name(o, true);
            s += " " + a;
        }
        return beg + s.substring(1, s.length()) + end;
    }

    /**
     * convert asn list to string
     *
     * @param lst list to convert
     * @param beg beginning
     * @param end ending
     * @return list
     */
    public static String asnList2mixed(List<Integer> lst, String beg, String end) {
        if (lst == null) {
            return "";
        }
        if (lst.size() < 1) {
            return "";
        }
        String s = "";
        for (int i = 0; i < lst.size(); i++) {
            int o = lst.get(i);
            s += " " + asn2mixed(o, true);
        }
        return beg + s.substring(1, s.length()) + end;
    }

    /**
     * convert asn list to string
     *
     * @param lst list to convert
     * @param beg beginning
     * @param end ending
     * @return list
     */
    public static String asnList2info(List<Integer> lst, String beg, String end) {
        if (lst == null) {
            return "";
        }
        if (lst.size() < 1) {
            return "";
        }
        String s = "";
        for (int i = 0; i < lst.size(); i++) {
            int o = lst.get(i);
            String a = asn2info(o);
            s += " " + a;
        }
        return beg + s.substring(1, s.length()) + end;
    }

}

class clntWhoisAsn implements Comparable<clntWhoisAsn> {

    /**
     * as number
     */
    public final int asn;

    /**
     * time created
     */
    public final long created;

    /**
     * hit count
     */
    public int hits = 1;

    /**
     * name cached
     */
    public String name;

    /**
     * create entry
     *
     * @param i asn
     */
    public clntWhoisAsn(int i) {
        asn = i;
        created = bits.getTime();
    }

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

    public String toString() {
        return bits.num2str(asn) + "|" + name + "|" + bits.timePast(created) + "|" + bits.time2str(cfgAll.timeZoneName, created + cfgAll.timeServerOffset, 3) + "|" + hits;
    }
}