package com.demo.core.ws;

import com.demo.core.common.Log;
import io.socket.client.IO;
import io.socket.client.Socket;
import io.socket.emitter.Emitter;


import org.json.JSONArray;
import org.json.JSONObject;
import org.junit.runner.RunWith;
import org.junit.runners.JUnit4;
import org.testng.annotations.Test;

import java.net.URISyntaxException;
import java.util.Map;
import java.util.concurrent.BlockingQueue;
import java.util.concurrent.LinkedBlockingQueue;


/**
 * Created by igorakintev on 4/21/17.
 */

public class SocketIOAPI {

    private Socket socket;

    @Test()
    public void test() throws URISyntaxException, InterruptedException {
        final BlockingQueue<Object> values = new LinkedBlockingQueue<Object>();

        String localhostURL = "http://localhost:3001";
        String stagingSocketURL = "http://tia-test.us-west-2.elasticbeanstalk.com";

        IO.Options opts = new IO.Options();
        opts.forceNew = true;
        opts.reconnection = false;

        socket = IO.socket(stagingSocketURL, opts);

        socket.on(Socket.EVENT_CONNECT, new Emitter.Listener() {
            @Override
            public void call(Object... objects) {
                Log.info("Connected " + socket.id());

                JSONArray obj = new JSONArray();
                JSONArray obj1 = new JSONArray();
                obj.put("uuid");
                obj1.put("4532363456456");
                obj.put(obj1);

                socket.emit("Authentication", obj);
//              socket.emit("TiaMessage", "{'uuid', {'21424534654'}}");
            }
        });
        socket.on(Socket.EVENT_CONNECTING, new Emitter.Listener() {
            @Override
            public void call(Object... objects) {
                Log.info("Connecting...");
            }
        });
        socket.on(Socket.EVENT_CONNECT_TIMEOUT, new Emitter.Listener() {
            @Override
            public void call(Object... objects) {
                Log.info("Connection timeout");
            }
        });
        socket.on(Socket.EVENT_CONNECT_ERROR, new Emitter.Listener() {
            @Override
            public void call(Object... objects) {
                Log.info("Connection error");
            }
        });
        socket.on(Socket.EVENT_MESSAGE, new Emitter.Listener() {
            @Override
            public void call(Object... objects) {
                Log.info("New message");
            }
        });
        socket.on(Socket.EVENT_DISCONNECT, new Emitter.Listener() {
            @Override
            public void call(Object... objects) {
                Log.info("Disconected event");
            }
        });
        socket.on("Authentication", new Emitter.Listener() {
            @Override
            public void call(Object... args) {
                Log.info("Auth!");
                for (int i = 0; i < args.length; i++) {
                    System.out.println(args[i]);
                }
            }
        });
        socket.on("ErrorMessage", new Emitter.Listener() {
            @Override
            public void call(Object... args) {
                Log.info("Error getted!");
            }
        });
        socket.on("TiaMessage", new Emitter.Listener() {
            @Override
            public void call(Object... args) {
                Log.info("TiaMessage!");
            }
        });
        socket.on("GetNextCard", new Emitter.Listener() {
            @Override
            public void call(Object... args) {
                Log.info("GetNextCard!");
            }
        });
        socket.on("logged_out", new Emitter.Listener() {
            @Override
            public void call(Object... args) {
                Log.info("logged_out!");
            }
        });

        socket.connect();
        values.take();

        socket.disconnect();


    }

}