// 
// Decompiled by Procyon v0.6.0
// 

package org.jline.terminal.impl.jansi;

import org.jline.terminal.impl.jansi.win.JansiWinSysTerminal;
import org.fusesource.jansi.internal.Kernel32;
import org.jline.terminal.Size;
import org.jline.terminal.Attributes;
import java.io.FileOutputStream;
import java.io.OutputStream;
import java.io.FileInputStream;
import java.io.InputStream;
import java.io.IOException;
import org.jline.utils.ExecHelper;
import org.jline.utils.OSUtils;
import org.fusesource.jansi.internal.CLibrary;
import org.jline.terminal.spi.SystemStream;
import org.jline.terminal.spi.TerminalProvider;
import java.io.FileDescriptor;
import org.jline.terminal.spi.Pty;
import org.jline.terminal.impl.AbstractPty;

public abstract class JansiNativePty extends AbstractPty implements Pty
{
    private final int master;
    private final int slave;
    private final int slaveOut;
    private final String name;
    private final FileDescriptor masterFD;
    private final FileDescriptor slaveFD;
    private final FileDescriptor slaveOutFD;
    
    public JansiNativePty(final TerminalProvider provider, final SystemStream systemStream, final int master, final FileDescriptor masterFD, final int slave, final FileDescriptor slaveFD, final String name) {
        this(provider, systemStream, master, masterFD, slave, slaveFD, slave, slaveFD, name);
    }
    
    public JansiNativePty(final TerminalProvider provider, final SystemStream systemStream, final int master, final FileDescriptor masterFD, final int slave, final FileDescriptor slaveFD, final int slaveOut, final FileDescriptor slaveOutFD, final String name) {
        super(provider, systemStream);
        this.master = master;
        this.slave = slave;
        this.slaveOut = slaveOut;
        this.name = name;
        this.masterFD = masterFD;
        this.slaveFD = slaveFD;
        this.slaveOutFD = slaveOutFD;
    }
    
    protected static String ttyname() throws IOException {
        String name;
        if (JansiTerminalProvider.JANSI_MAJOR_VERSION > 1 || (JansiTerminalProvider.JANSI_MAJOR_VERSION == 1 && JansiTerminalProvider.JANSI_MINOR_VERSION >= 16)) {
            name = CLibrary.ttyname(0);
        }
        else {
            try {
                name = ExecHelper.exec(true, OSUtils.TTY_COMMAND);
            }
            catch (final IOException e) {
                throw new IOException("Not a tty", e);
            }
        }
        if (name != null) {
            name = name.trim();
        }
        if (name == null || name.isEmpty()) {
            throw new IOException("Not a tty");
        }
        return name;
    }
    
    @Override
    public void close() throws IOException {
        if (this.master > 0) {
            this.getMasterInput().close();
        }
        if (this.slave > 0) {
            this.getSlaveInput().close();
        }
    }
    
    public int getMaster() {
        return this.master;
    }
    
    public int getSlave() {
        return this.slave;
    }
    
    public int getSlaveOut() {
        return this.slaveOut;
    }
    
    public String getName() {
        return this.name;
    }
    
    public FileDescriptor getMasterFD() {
        return this.masterFD;
    }
    
    public FileDescriptor getSlaveFD() {
        return this.slaveFD;
    }
    
    public FileDescriptor getSlaveOutFD() {
        return this.slaveOutFD;
    }
    
    @Override
    public InputStream getMasterInput() {
        return new FileInputStream(this.getMasterFD());
    }
    
    @Override
    public OutputStream getMasterOutput() {
        return new FileOutputStream(this.getMasterFD());
    }
    
    @Override
    protected InputStream doGetSlaveInput() {
        return new FileInputStream(this.getSlaveFD());
    }
    
    @Override
    public OutputStream getSlaveOutput() {
        return new FileOutputStream(this.getSlaveOutFD());
    }
    
    @Override
    public Attributes getAttr() throws IOException {
        final CLibrary.Termios tios = new CLibrary.Termios();
        CLibrary.tcgetattr(this.slave, tios);
        return this.toAttributes(tios);
    }
    
    @Override
    protected void doSetAttr(final Attributes attr) throws IOException {
        final CLibrary.Termios tios = this.toTermios(attr);
        CLibrary.tcsetattr(this.slave, CLibrary.TCSANOW, tios);
    }
    
    @Override
    public Size getSize() throws IOException {
        final CLibrary.WinSize sz = new CLibrary.WinSize();
        final int res = CLibrary.ioctl(this.slave, CLibrary.TIOCGWINSZ, sz);
        if (res != 0) {
            throw new IOException("Error calling ioctl(TIOCGWINSZ): return code is " + res);
        }
        return new Size(sz.ws_col, sz.ws_row);
    }
    
    @Override
    public void setSize(final Size size) throws IOException {
        final CLibrary.WinSize sz = new CLibrary.WinSize((short)size.getRows(), (short)size.getColumns());
        final int res = CLibrary.ioctl(this.slave, CLibrary.TIOCSWINSZ, sz);
        if (res != 0) {
            throw new IOException("Error calling ioctl(TIOCSWINSZ): return code is " + res);
        }
    }
    
    protected abstract CLibrary.Termios toTermios(final Attributes p0);
    
    protected abstract Attributes toAttributes(final CLibrary.Termios p0);
    
    @Override
    public String toString() {
        return "JansiNativePty[" + this.getName() + "]";
    }
    
    public static boolean isPosixSystemStream(final SystemStream stream) {
        return CLibrary.isatty(fd(stream)) == 1;
    }
    
    public static String posixSystemStreamName(final SystemStream systemStream) {
        return CLibrary.ttyname(fd(systemStream));
    }
    
    public static int systemStreamWidth(final SystemStream systemStream) {
        try {
            if (OSUtils.IS_WINDOWS) {
                final Kernel32.CONSOLE_SCREEN_BUFFER_INFO info = new Kernel32.CONSOLE_SCREEN_BUFFER_INFO();
                final long outConsole = JansiWinSysTerminal.getConsole(systemStream);
                Kernel32.GetConsoleScreenBufferInfo(outConsole, info);
                return info.windowWidth();
            }
            final CLibrary.WinSize sz = new CLibrary.WinSize();
            final int res = CLibrary.ioctl(fd(systemStream), CLibrary.TIOCGWINSZ, sz);
            if (res != 0) {
                throw new IOException("Error calling ioctl(TIOCGWINSZ): return code is " + res);
            }
            return sz.ws_col;
        }
        catch (final Throwable t) {
            return -1;
        }
    }
    
    private static int fd(final SystemStream systemStream) {
        switch (systemStream) {
            case Input: {
                return 0;
            }
            case Output: {
                return 1;
            }
            case Error: {
                return 2;
            }
            default: {
                return -1;
            }
        }
    }
}