/**

 * Back 2 Browser Bytecode Translator

 * Copyright (C) 2012 Jaroslav Tulach <jaroslav.tulach@apidesign.org>

 *

 * This program is free software: you can redistribute it and/or modify

 * it under the terms of the GNU General Public License as published by

 * the Free Software Foundation, version 2 of the License.

 *

 * This program is distributed in the hope that it will be useful,

 * but WITHOUT ANY WARRANTY; without even the implied warranty of

 * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the

 * GNU General Public License for more details.

 *

 * You should have received a copy of the GNU General Public License

 * along with this program. Look for COPYING file in the top folder.

 * If not, see http://opensource.org/licenses/GPL-2.0.

 */

package org.apidesign.bck2brwsr.launcher.fximpl;

import com.sun.javafx.scene.web.Debugger;

import java.io.File;

import java.io.IOException;

import java.io.InputStream;

import java.io.InterruptedIOException;

import java.io.OutputStream;

import java.io.UnsupportedEncodingException;

import java.lang.reflect.Method;

import java.util.concurrent.ArrayBlockingQueue;

import java.util.concurrent.Executors;

import java.util.concurrent.TimeUnit;

import java.util.concurrent.atomic.AtomicReference;

import java.util.logging.Level;

import java.util.logging.Logger;

import javafx.application.Platform;

import javafx.util.Callback;

/** Simulates WebKit protocol over WebSockets.

 *

 * @author Jaroslav Tulach

 */

abstract class WebDebug extends OutputStream 

implements Callback<String, Void>, Runnable {

    private static final Logger LOG = Logger.getLogger(WebDebug.class.getName());

    private final Debugger debug;

    private final StringBuilder cmd = new StringBuilder();

    private final ToDbgInputStream toDbg;

    private final String ud;

    WebDebug(Debugger debug, String ud) throws Exception {

        this.debug = debug;

        this.ud = ud;

        toDbg = new ToDbgInputStream();

        debug.setEnabled(true);

        debug.setMessageCallback(this);

    }

    static WebDebug create(Debugger debug, String ud) throws Exception {

        WebDebug web = new WebDebug(debug, ud) {};

        Executors.newFixedThreadPool(1).execute(web);

        return web;

    }

    @Override

    public void run() {

        try {

            String p = "/home/jarda/src/bck2brwsr/html~demo/twitter/src/main/resources/org/apidesign/html/demo/twitter/index.html";

            File f = new File(p);

            String[] args = {"--livehtml", f.getAbsolutePath()};

            File dir = f.getParentFile();

            cliHandler(args, toDbg, this, System.err, dir);

        } catch (Exception ex) {

            LOG.log(Level.SEVERE, null, ex);

        }

    }

    @Override

    public void close() {

        try {

            toDbg.close();

        } catch (IOException ex) {

            LOG.log(Level.SEVERE, null, ex);

        }

    }

    @Override

    public Void call(String p) {

        assert p.indexOf('\n') == -1 : "No new line: " + p;

        LOG.log(Level.INFO, "toDbgr: {0}", p);

        toDbg.pushMsg(p);

        return null;

    }

    @Override

    public void write(int b) throws IOException {

        if (b == '\n') {

            final String msg = cmd.toString();

            Platform.runLater(new Runnable() {

                @Override

                public void run() {

                    LOG.log(Level.INFO, "toView: {0}", msg);

                    debug.sendMessage(msg);

                }

            });

            cmd.setLength(0);

        } else {

            if (cmd.length() > 100000) {

                LOG.log(Level.WARNING, "Too big:\n{0}", cmd);

            }

            cmd.append((char)b);

        }

    }   

    private void cliHandler(

        String[] args, InputStream is, OutputStream os, OutputStream err, File dir

    ) {

        try {

            Class<?> main = Class.forName("org.netbeans.MainImpl");

            Method m = main.getDeclaredMethod("execute", String[].class, InputStream.class, 

                OutputStream.class, OutputStream.class, AtomicReference.class

            );

            m.setAccessible(true);

            System.setProperty("netbeans.user", ud);

            int ret = (Integer)m.invoke(null, args, is, os, err, null);

            LOG.log(Level.INFO, "Return value: {0}", ret);

        } catch (Exception ex) {

            LOG.log(Level.SEVERE, null, ex);

        } finally {

            LOG.info("Communication is over");

        }

    }

    private class ToDbgInputStream extends InputStream {

        private byte[] current;

        private int currentPos;

        private final ArrayBlockingQueue<byte[]> pending = new ArrayBlockingQueue<byte[]>(64);

        public ToDbgInputStream() {

        }

        @Override

        public int read() throws IOException {

            return read(null, 0, 1);

        }

        @Override

        public int read(byte[] arr, int offset, int len) throws IOException {

            if (current == null || current.length <= currentPos) {

                for (;;) {

                    WebDebug.this.flush();

                    try {

                        current = pending.poll(100, TimeUnit.MILLISECONDS);

                        if (current == null) {

                            return 0;

                        }

                        break;

                    } catch (InterruptedException ex) {

                        throw (InterruptedIOException)new InterruptedIOException().initCause(ex);

                    }

                }

                LOG.info("Will return: " + new String(current));

                currentPos = 0;

            }

            int cnt = 0;

            while (len-- > 0 && currentPos < current.length) {

                final byte nextByte = current[currentPos++];

                if (arr == null) {

                    return nextByte;

                }

                arr[offset + cnt++] = nextByte;

            }

            LOG.log(Level.INFO, "read returns: {0}", new String(arr, offset, cnt));

            return cnt;

        }

        private void pushMsg(String p) {

            try {

                pending.offer((p + '\n').getBytes("UTF-8"));

            } catch (UnsupportedEncodingException ex) {

                throw new IllegalStateException(ex);

            }

        }

    }

}