package jekpro.platform.swing;

import jekpro.model.pretty.Foyer;
import jekpro.tools.call.*;
import jekpro.tools.term.TermAtomic;

import java.lang.management.GarbageCollectorMXBean;
import java.lang.management.ManagementFactory;
import java.lang.management.ThreadMXBean;
import java.util.Iterator;

/**
 * The foreign predicates for the module stats.
 * <p/>
 * Warranty & Liability
 * To the extent permitted by applicable law and unless explicitly
 * otherwise agreed upon, XLOG Technologies GmbH makes no warranties
 * regarding the provided information. XLOG Technologies GmbH assumes
 * no liability that any problems might be solved with the information
 * provided by XLOG Technologies GmbH.
 * <p/>
 * Rights & License
 * All industrial property rights regarding the information - copyright
 * and patent rights in particular - are the sole property of XLOG
 * Technologies GmbH. If the company was not the originator of some
 * excerpts, XLOG Technologies GmbH has at least obtained the right to
 * reproduce, change and translate the information.
 * <p/>
 * Reproduction is restricted to the whole unaltered document. Reproduction
 * of the information is only allowed for non-commercial uses. Selling,
 * giving away or letting of the execution of the library is prohibited.
 * The library can be distributed as part of your applications and libraries
 * for execution provided this comment remains unchanged.
 * <p/>
 * Trademarks
 * Jekejeke is a registered trademark of XLOG Technologies GmbH.
 */
public final class ForeignStatistics {
    private final static String OP_STATISTIC_MAX = "max";
    private final static String OP_STATISTIC_USED = "used";
    private final static String OP_STATISTIC_FREE = "free";
    final static String OP_STATISTIC_UPTIME = "uptime";
    final static String OP_STATISTIC_GCTIME = "gctime";
    final static String OP_STATISTIC_TIME = "time";
    final static String OP_STATISTIC_WALL = "wall";

    private final static String OP_SYS_THREAD_LOCAL_CLAUSES = "sys_thread_local_clauses";

    private final static String[] OP_STATISTICS = {
            OP_STATISTIC_MAX,
            OP_STATISTIC_USED,
            OP_STATISTIC_FREE,
            OP_STATISTIC_UPTIME,
            OP_STATISTIC_GCTIME,
            OP_STATISTIC_TIME,
            OP_STATISTIC_WALL};

    private final static String[] OP_STATISTICS_WEB = {
            OP_STATISTIC_UPTIME,
            OP_STATISTIC_WALL};

    private final static String[] OP_THREAD_STATISTICS = {
            OP_SYS_THREAD_LOCAL_CLAUSES};

    /*********************************************************************/
    /* Statistics                                                        */
    /*********************************************************************/

    /**
     * <p>Retrieve the known statistics names.</p>
     *
     * @param inter The interpreter.
     * @param co    The call out.
     * @return The statistics name.
     */
    public static String sysCurrentStat(Interpreter inter, CallOut co) {
        ArrayEnumeration<String> dc;
        if (co.getFirst()) {
            int hint = ((Integer) inter.getProperty("sys_hint")).intValue();
            switch (hint) {
                case Foyer.HINT_WEB:
                    dc = new ArrayEnumeration<String>(OP_STATISTICS_WEB);
                    break;
                default:
                    dc = new ArrayEnumeration<String>(OP_STATISTICS);
                    break;
            }
            co.setData(dc);
        } else {
            dc = (ArrayEnumeration<String>) co.getData();
        }
        if (!dc.hasMoreElements())
            return null;
        String res = dc.nextElement();
        co.setRetry(dc.hasMoreElements());
        return res;
    }

    /**
     * <p>Retrieve a statistic.</p>
     * <p>Swing version.</p>
     *
     * @param inter The interpreter.
     * @param name  The statistics name.
     * @return The value, or null.
     * @throws InterpreterMessage Validation error.
     */
    public static Object sysGetStat(Interpreter inter, String name)
            throws InterpreterMessage {
        if (OP_STATISTIC_MAX.equals(name)) {
            return TermAtomic.normBigInteger(Runtime.getRuntime().maxMemory());
        } else if (OP_STATISTIC_USED.equals(name)) {
            return TermAtomic.normBigInteger(Runtime.getRuntime().totalMemory() -
                    Runtime.getRuntime().freeMemory());
        } else if (OP_STATISTIC_FREE.equals(name)) {
            return TermAtomic.normBigInteger(Runtime.getRuntime().freeMemory());
        } else if (OP_STATISTIC_UPTIME.equals(name)) {
            int hint = ((Integer) inter.getProperty("sys_hint")).intValue();
            switch (hint) {
                case Foyer.HINT_WEB:
                    return TermAtomic.normBigInteger(System.currentTimeMillis() - 1545076144751L);
                default:
                    return TermAtomic.normBigInteger(ManagementFactory.getRuntimeMXBean().getUptime());
            }
        } else if (OP_STATISTIC_GCTIME.equals(name)) {
            int hint = ((Integer) inter.getProperty("sys_hint")).intValue();
            switch (hint) {
                case Foyer.HINT_WEB:
                    return null;
                default:
                    Iterator<GarbageCollectorMXBean> iter =
                            ManagementFactory.getGarbageCollectorMXBeans().iterator();
                    long gcsum = 0;
                    boolean has = false;
                    while (iter.hasNext()) {
                        GarbageCollectorMXBean gb = iter.next();
                        long gctime = gb.getCollectionTime();
                        if (gctime != -1) {
                            gcsum += gctime;
                            has = true;
                        }
                    }
                    if (has) {
                        return TermAtomic.normBigInteger(gcsum);
                    } else {
                        return null;
                    }
            }
        } else if (OP_STATISTIC_TIME.equals(name)) {
            int hint = ((Integer) inter.getProperty("sys_hint")).intValue();
            switch (hint) {
                case Foyer.HINT_WEB:
                    return null;
                default:
                    ThreadMXBean tb = ManagementFactory.getThreadMXBean();
                    if (tb.isThreadCpuTimeEnabled()) {
                        long cputime = tb.getCurrentThreadCpuTime() / 1000000L;
                        return TermAtomic.normBigInteger(cputime);
                    } else {
                        return null;
                    }
            }
        } else if (OP_STATISTIC_WALL.equals(name)) {
            return TermAtomic.normBigInteger(System.currentTimeMillis());
        } else {
            throw new InterpreterMessage(InterpreterMessage.domainError(
                    "prolog_flag", name));
        }
    }

    /*********************************************************************/
    /* Thread Statistics                                                 */
    /*********************************************************************/

    /**
     * <p>Retrieve the known thread statistics names.</p>
     *
     * @param co The call out.
     * @return The thread statistics name.
     */
    public static String sysCurrentThreadStat(CallOut co) {
        ArrayEnumeration<String> dc;
        if (co.getFirst()) {
            dc = new ArrayEnumeration<String>(OP_THREAD_STATISTICS);
            co.setData(dc);
        } else {
            dc = (ArrayEnumeration<String>) co.getData();
        }
        if (!dc.hasMoreElements())
            return null;
        String res = dc.nextElement();
        co.setRetry(dc.hasMoreElements());
        return res;
    }

    /**
     * <p>Retrieve a thread statistic.</p>
     *
     * @param name The thread statistics name.
     * @return The value, or null.
     * @throws InterpreterMessage Validation error.
     */
    public static Object sysGetThreadStat(Thread t, String name)
            throws InterpreterMessage {
        if (OP_SYS_THREAD_LOCAL_CLAUSES.equals(name)) {
            Controller contr = Controller.currentController(t);
            if (contr != null) {
                long total = contr.getThreadLocalClauses();
                return TermAtomic.normBigInteger(total);
            } else {
                return null;
            }
        } else {
            throw new InterpreterMessage(InterpreterMessage.domainError(
                    "prolog_flag", name));
        }
    }

}