<repositories>
    <repository>
        <id>sonatype</id>
        <url>https://oss.sonatype.org/content/repositories/snapshots</url>
    </repository>
</repositories>
<dependency>
    <groupId>io.github.360matt</groupId>
    <artifactId>Sokeese-v2</artifactId>
    <version>2.0.1-SNAPSHOT</version>
</dependency>

SokeeseServer server = new SokeeseServer ( 4000 ) ;

new Thread ( ( ) -> {
  try {
     server. listen ( ) ; // blocking method
      // you can do a infinite loop if you want here
 
      System. out. println ( "server closed" ) ; // example print when the server shutdown
    } catch ( IOException e ) {
     e. printStackTrace ( ) ;
  }
} ). start ( ) ;


server. close ( ) ;
// close the server, close socket, in/out

ClientsManager manager = server. getClientsManager ( ) ;

LoggedClient client = manager. get ( "by name" ) ;
LoggedClient client = server. getClient ( "by name" ) ;

manager. disconnect ( "by name" ) ;
server. disconnect ( "by name" ) ;

// _____________________________________________________

Collection <LoggedClient > allClients = manager. getInstances ( ) ;

manager. disconnectAll ( ) ;
server. disconnectAll ( ) ;
 

server. addLoginEvent ( (loginEvent -> {

    loginEvent. getClientName ( ) ; // client's name who want to connect
    loginEvent. getPassword ( ) ; // client's password who want to connect

    loginEvent. getSocket ( ) ; // get client's Socket connection

    // if other registered event has set status to INVALID_CREDENTIALS
    loginEvent. onException (ServerCredentialsException. class, (exEvent ) -> {
        // exEvent is ServerCredentialsException type
    } ) ;

    loginEvent. onException ( IOException. class, (exEvent ) -> {
        // catch a IO exception here
    } ) ;



    loginEvent. setStatus (StatusCode. OK ) ;
    // the status codes are Integer,
    // you must respect the protocol code by helping you with the StatusCode class.

    loginEvent. setStatus ( "A custom error message, will be throw by client." ) ;
    // You can define your own status as a String,
    // however, this will be considered an error code.


    // IMPORTANT !!
    // if you define an error code,
    // the event is canceled and the rest of the events will not be executed,
    // so it will be impossible to modify the status code again.


    //you won't need these methods,
    // they will always return 0 - ""
    int code = loginEvent. getStatusCode ( ) ;
    String custom = loginEvent. getStatusCustom ( ) ;

    loginEvent. freeze ( 100 ) ;
    // freeze the event for 100ms AFTER all event.

    loginEvent. freeze ( 0 ) ;
    // remove freeze also

} ) ) ;
 

server. on (TestObj. class, (obj, request ) -> {
    // obj is type of TestObj

    request. getClientName ( ) ; // the sender of request

    request. reply ( 0 ) ;
    request. reply ( "" ) ;
    request. reply ( new Object ( ) ) ;

    LoggedClient loggedClient = request. getClientInstance ( ) ;
    // get the client instance.
    // you can per example: disconnect, etc ...
} ) ;
 

LoggedClient client ;

client. send ( new Object ( ) ) ;
client. sendOrThrow ( new Object ( ) ) ;
// send to a client an object


client. send ( new Object ( ), new Object ( ), new Object ( ) ) ;
client. sendOrThrow ( new Object ( ), new Object ( ), new Object ( ) ) ;
// send to a client multiples objects

client. send ( new Object ( ), (replyBuilder -> {
  replyBuilder. on ( String. class, (obj, instance ) -> {
    // instance is current instance.
  } ) ;
} ) ) ;
// send to the client and wait reply

client. getClientName ( ) ;
// get the client name

client. close ( ) ;
// disconnect / close Socket-in/out

client. getServer ( ) ;
// get current server.

client. getSocket ( ) ;
// get Socket connection.
 

server. send ( "recipient's name", new Object ( ) ) ;
// send to a client an object

server. send ( new String [ ] { "one", "two" }, new Object ( ) ) ;
// send to multiples client an object

server. send ( "recipient's name", new Object ( ), new Object ( ) ) ;
// send to a client multiples Objects

server. send ( new String [ ] { "one", "two" }, new Object ( ), new Object ( ) ) ;
// send to multiples client multiples Objects

server. send ( "recipient's name", new Object ( ), (replyBuilder -> {
  replyBuilder. on ( String. class, (obj, client ) -> {

  } ) ;
  } ) ) ;
// send to client an object and catch reply


server. send ( new String [ ] { "one", "two", "three" }, new Object ( ), (replyBuilder -> {
  replyBuilder. on ( String. class, (obj, client ) -> {

  } ) ;
} ) ) ;
// send to multiple client an object and catch replies
 

SokeeseClient client_alpha = new SokeeseClient ( ) ;

new Thread ( ( ) -> {
  try {
    client. connect ( "127.0.0.1", 4000, "name", "password" ) ;
    System. out. println ( "Alpha closed" ) ;
  } catch ( IOException | RuntimeException | ClientCodeSentException | ClientCredentialsException | ClientAlreadyLoggedException | ClassNotFoundException  e ) {
    e. printStackTrace ( ) ;
  }
} ). start ( ) ;

client. close ( ) ;
// close the client, close socket, in/out
 

client. on (TestObj. class, (obj, event ) -> {
    // obj is type of TestObj

    event. getClientName ( ) ; // get sender name

    event. reply ( "" ) ; // reply String
    event. reply ( 0 ) ; // reply int
    event. reply ( new Object ( ) ) ; // reply Object
} ) ;
 

client. send ( new Object ( ) ) ;
client. sendOrThrow ( new Object ( ) ) ;
// send to server an object



client. send ( "recipient's name", new Object ( ) ) ;
client. sendOrThrow ( "recipient's name", new Object ( ) ) ;
// send to a client an object

client. send ( "recipient's name", new Object ( ), new Object ( ) ) ;
client. sendOrThrow ( "recipient's name", new Object ( ), new Object ( ) ) ;
// send to a client multiple objects

client. send ( new String [ ] { "one", "two" }, new Object ( ) ) ;
client. sendOrThrow ( new String [ ] { "one", "two" }, new Object ( ) ) ;
// send to multiple client an object

client. send ( new String [ ] { "one", "two" }, new Object ( ), new Object ( ) ) ;
client. sendOrThrow ( new String [ ] { "one", "two" }, new Object ( ), new Object ( ) ) ;
// send to multiple client multiples objects


// _______________________________________________________________________

client. send ( "recipient's name", new Object ( ), replyBuilder -> {
    replyBuilder. on ( String. class, (obj, clientName ) -> {

    } ) ;
} ) ;

client. sendOrThrow ( "recipient's name", new Object ( ), replyBuilder -> {
    // ...
} ) ;

client. sendOrThrow ( new String [ ] { "one", "two" }, new Object ( ), replyBuilder -> {
    // ...
} ) ;

// _______________________________________________________________________


client. send ( "*", new Object ( ) ) ;
// send to everyone without server

client. send ( "**", new Object ( ) ) ;
// send to everyone WITH server

client. send ( "", new Object ( ) ) ;
client. send ( ( String ) null, new Object ( ) ) ;
// send to server

// reply builder is available for server / everyone