package sk2;

import java.net.InetSocketAddress;
import java.nio.ByteBuffer;
import java.nio.channels.SelectionKey;
import java.nio.channels.Selector;
import java.nio.channels.SocketChannel;

public class NioCli {
    private SocketChannel sock;                     // gniazdo w NIO
    private Selector sel;                           // selektor – opakowuje mechanizm typu 'select'
    private SelectionKey sockKey;                   
    private ByteBuffer bb = ByteBuffer.allocate(8); // bufor – odpowiednio opakowana tablica bajtów
    
    public NioCli(String[] args) throws Throwable{
        // Selektory, gniazda, etc. są tworzone przez metody statyczne, używające dostarczanej
        // przez VM implementacji klasy SelectorProvider
        sel = Selector.open();
        sock = SocketChannel.open(new InetSocketAddress(args[0], Integer.parseInt(args[1])));
        
        sock.configureBlocking(false);              // Używanie Selectora wymaga nieblokującego I/O
        sockKey = sock.register(sel, SelectionKey.OP_READ); // Tak każe się czekać na zdarzenie
    }
        
    private void select() throws Throwable{
        sel.select();                               // oczekiwanie na zdarzenie
        
        // selectedKeys() zawiera listę kluczy dla których można wykonać żądaną operację
        // i ustawia im dostępne zdarzenia (readyOps, isReadable, is…)
        assert sel.selectedKeys().size() == 1;      
        assert sel.selectedKeys().iterator().next() == sockKey;
        
        bb.clear();                                 // przygotowanie bufora do pracy
        int count = sock.read(bb);
             
        if(count == -1) {                           // -1 oznacza EOF
            sockKey.cancel();                       // cancel usuwa klucz z selektora
            return;
        }
        
        System.out.write(bb.array(), 0, bb.position());

        sel.selectedKeys().clear();                 // klucze są w zbiorze do momentu usunięcia
    }
    
    public static void main(String[] args) throws Throwable{
        NioCli cli = new NioCli(args);
        while(cli.sockKey.isValid())
            cli.select();
    }
}