package dsystem.server.xmmp;

import org.jivesoftware.smack.ConnectionConfiguration;
import org.jivesoftware.smack.packet.Message;
import org.jivesoftware.smack.packet.Presence;
import org.jivesoftware.smack.roster.Roster;
import org.jivesoftware.smack.roster.RosterEntry;
import org.jivesoftware.smack.tcp.XMPPTCPConnection;
import org.jivesoftware.smack.tcp.XMPPTCPConnectionConfiguration;
import org.jxmpp.jid.impl.JidCreate;

import java.util.Collection;

import static java.lang.System.out;

public class MessageSender{
    public static void main( String[] args ){

        try{

            out.println( "Configure connection" );
            XMPPTCPConnectionConfiguration configuration = XMPPTCPConnectionConfiguration.builder()
                .setUsernameAndPassword( "testuser1", "testpass1" )
                .setXmppDomain( "satellite.dvo.ru" )
                .setResource( "MessageSender" )
                .setSecurityMode( ConnectionConfiguration.SecurityMode.ifpossible )
                .setCompressionEnabled( true )
                .build();

            out.println( "Create connection" );
            XMPPTCPConnection connection = new XMPPTCPConnection( configuration );
            connection.connect();

            out.println( "Log in" );
            connection.login();

            connection.sendStanza( new Presence( Presence.Type.available ) );

            out.println( "List roster" );
            Roster roster = Roster.getInstanceFor(connection);
            out.println( "Num entries " + roster.getEntryCount() );
            out.println( "Num groups " + roster.getGroupCount() );

            Collection<RosterEntry> entries = roster.getEntries();
            for (RosterEntry entry : entries) {
                out.println( "Roster entry" );
                out.println(entry.getJid());
            }

            Message message = new Message();
            message.setTo( JidCreate.from( "[email protected]" ) );
            message.setType( Message.Type.chat );
            message.setBody( "Hello!" );
            message.setSubject( "Test!" );

            connection.sendStanza( message );

            Thread.sleep( 500 );

            out.println( "Close connection" );
            connection.disconnect();
        }catch( Exception e ){
            e.printStackTrace();
        }
    }
}