package com.venicehost.jaziresakhtafzar;

import android.app.Service;
import android.content.Intent;
import android.os.Binder;
import android.os.IBinder;
import android.util.Log;
import android.widget.Toast;

import okhttp3.OkHttpClient;
import okhttp3.Request;
import okhttp3.Response;
import okhttp3.WebSocket;
import okhttp3.WebSocketListener;
import okio.ByteString;

public class Socket extends Service {
    /*public Socket() {
        super();
    }*/

    //public static  ws;
    //public WebSocket wss;
    public final OkHttpClient client = new OkHttpClient();
    public final Request request = new Request.Builder().url("ws://147.135.204.100:2526").build();
    public final SocketListener listener = new SocketListener();
    public final WebSocket ws = client.newWebSocket(request, listener);
    private String res;
    //private final Socket instance = Socket.this;


    /*client =


    */

    /*public Socket getInstance() {
        return instance;
    }*/

    public class SocketBinder extends Binder {
        Socket getService() {
            return Socket.this;
        }
    }


    public final class SocketListener extends WebSocketListener {
        private static final int NORMAL_CLOSURE_STATUS = 1000;

        @Override
        public void onOpen(WebSocket webSocket, Response response) {
            webSocket.send("Hello, it's SSaurel !");
            webSocket.send("What's up ?");
            //wss = webSocket;
            //webSocket.send(ByteString.decodeHex("deadbeef"));
            //Toast.makeText(getApplicationContext(), "open", Toast.LENGTH_LONG).show();
            Log.d("test","open");
            //webSocket.close(NORMAL_CLOSURE_STATUS, "Goodbye !");
        }

        @Override
        public void onMessage(WebSocket webSocket, String text) {
            //Toast.makeText(getApplicationContext(), "message", Toast.LENGTH_LONG).show();
            Log.d("test","Receiving : " + text);
            output("Receiving : " + text);
        }

        @Override
        public void onMessage(WebSocket webSocket, ByteString bytes) {
            //Toast.makeText(getApplicationContext(), "message Byte", Toast.LENGTH_LONG).show();
            Log.d("test","Receiving bytes : " + bytes.hex());
            output("Receiving bytes : " + bytes.hex());
        }

        @Override
        public void onClosing(WebSocket webSocket, int code, String reason) {
            //Toast.makeText(getApplicationContext(), "close", Toast.LENGTH_LONG).show();
            webSocket.close(NORMAL_CLOSURE_STATUS, null);
            Log.d("test","Closing : " + code + " / " + reason);
            output("Closing : " + code + " / " + reason);
        }

        @Override
        public void onFailure(WebSocket webSocket, Throwable t, Response response) {
            //Toast.makeText(getApplicationContext(), "failure", Toast.LENGTH_LONG).show();
            Log.d("test","Error : " + t.getMessage());
            output("Error : " + t.getMessage());
        }
    }

    private void output(final String txt) {
        res = txt;
    }

    public String message() {
        return this.res;
    }

    public boolean send(String data) {
        return ws.send(data);
    }

    @Override
    public IBinder onBind(Intent intent) {
        return null;
    }

    @Override
    public void onCreate() {
        /*client = new OkHttpClient();
        request = new Request.Builder().url("ws://147.135.204.100:2526").build();
        listener = new SocketListener();
        ws = client.newWebSocket(request, listener);*/
        this.send("tessssst");
        //ws.send("ok!");
        //Toast.makeText(this, res, Toast.LENGTH_LONG).show();
    }

    @Override
    public void onDestroy() {
        //client.dispatcher().executorService().shutdown();
        Toast.makeText(this, "Service stopped", Toast.LENGTH_LONG).show();
    }

}