package com.example.siemens.testgetmethod;

import android.app.Service;
import android.content.Intent;
import android.net.wifi.WifiConfiguration;
import android.os.Handler;
import android.os.HandlerThread;
import android.os.IBinder;
import android.os.Looper;
import android.os.Message;
import android.util.Log;
import android.widget.Toast;

import org.alljoyn.bus.BusAttachment;
import org.alljoyn.bus.BusObject;
import org.alljoyn.bus.Mutable;
import org.alljoyn.bus.SessionOpts;
import org.alljoyn.bus.SessionPortListener;
import org.alljoyn.bus.Status;

import javax.net.ssl.SSLEngineResult;

public class MyService extends Service {

    private final String TAG="MyService";

    public MyService() {
//        super();
    }

    @Override
    public IBinder onBind(Intent intent) {
        // TODO: Return the communication channel to the service.
//        throw new UnsupportedOperationException("Not yet implemented");
        return null;
    }

    public int onStartCommand(Intent intent, int flags, int startId) {
//        Log.i(TAG, "onStartCommand()");
        return START_STICKY;
    }

    public void onDestroy() {
//        backgroundHandler.exit();
    }

    public void onCreate(){
        Log.i(TAG,"onCreate method.");
        //mbus初始化
        mBus=new BusAttachment(getPackageName(),BusAttachment.RemoteMessage.Receive);
        startBusThread();
        if(backgroundHandler!=null)
            backgroundHandler.connect();
        else
            return;
    }

    private void startBusThread(){
        HandlerThread handlerThread=new HandlerThread("My HandlerThread");
        handlerThread.start();
        Looper loop=handlerThread.getLooper();
        backgroundHandler=new BackgroundHandler(loop);
        Log.i(TAG,"startBusThread method.");
    }

    //請求都線上程中執行
    private BackgroundHandler backgroundHandler=null;
    private final int CONNECT=2;

    //私有內部不可變類
    private final class BackgroundHandler extends Handler{
        public BackgroundHandler(Looper looper){
            super(looper);
        }

        public void connect(){
            Log.i(TAG,"backgroundHandler.connect()");
            Message msg=backgroundHandler.obtainMessage(CONNECT);//相當於message.what=2;
            backgroundHandler.sendMessage(msg);
        }

        public void handleMessage(Message msg){
            switch(msg.what){
                case CONNECT:
                    doConnect();
                    break;
                default:
                    break;
            }
        }
    }

    //建立匯流排附件物件,getPackageName()出現NullPointerException異常,先於建構函式執行，此時物件為null，所以放到oncreate裡邊去
//    private BusAttachment mBus=new BusAttachment(getPackageName(),BusAttachment.RemoteMessage.Receive);
    private BusAttachment mBus=null;
    //建立匯流排物件
    private MyBusObject myBusObject=new MyBusObject();
    //匯流排物件類，實現匯流排介面和匯流排物件介面
    class MyBusObject implements MyInterface,BusObject{
//        public void show(String args){
//            Toast.makeText(getApplicationContext(),args,Toast.LENGTH_SHORT).show();     //會呼叫的遠端方法
//
//        }
//
//        public int add(int a,int b){                        //會呼叫的遠端方法
//            return a+b;
//        }
        public String cat(String a,String b){
            a=a.replace('H','T');
            b=b.replace('W','B');
            return a+b;
        }
    }

    //session的埠號
    private static final short CONTACT_PORT=42;
    //匯流排物件，匯流排附件等連線到總線上的實現函式，建立的是service
    private void doConnect(){
        org.alljoyn.bus.alljoyn.DaemonInit.PrepareDaemon(getApplicationContext());  //啟動守護程序

        Status status=mBus.registerBusObject(myBusObject,"/myBusObject");                     //註冊匯流排物件
        if (Status.OK != status) {
            System.out.println("BusAttachment.registerBusObject() failed: " + status);
            System.exit(0);
            return;
        }

        //匯流排附件連線到總線上
        status=mBus.connect();
        if (status != Status.OK) {
            Log.i(TAG,"BusAttachment connect to bus failed.");
            System.exit(0);
            return;
        }

        //通訊的session port 設定
        Mutable.ShortValue contactPort = new Mutable.ShortValue(CONTACT_PORT);
        SessionOpts sessionOpts = new SessionOpts();
        sessionOpts.traffic = SessionOpts.TRAFFIC_MESSAGES;
        sessionOpts.isMultipoint = false;
        sessionOpts.proximity = SessionOpts.PROXIMITY_ANY;
        sessionOpts.transports = SessionOpts.TRANSPORT_ANY;

        //繫結通訊的session port
        status=mBus.bindSessionPort(contactPort,sessionOpts,new SessionPortListener(){
            @Override
            public boolean acceptSessionJoiner(short sessionPort, String joiner, SessionOpts sessionOpts){
                if (sessionPort == CONTACT_PORT) {
                    return true;
                } else {
                    return false;
                }
            }
        });
        if (status != Status.OK) {
            Log.i(TAG,"bind certain session port failed.");
            System.exit(0);
            return;
        }

        //向匯流排請求一個名稱
        int flags = 0; //do not use any request name flags
        status = mBus.requestName("com.test.well.known.name", flags);
        if (status != Status.OK) {
            Log.i(TAG,"request name from bus failed.");
            System.exit(0);
            return;
        }

        //在總線上宣告name的存在
        status = mBus.advertiseName("com.test.well.known.name", SessionOpts.TRANSPORT_ANY);
        if (status != Status.OK) {
            Log.i(TAG,"advertise name on bus failed.");
            mBus.releaseName("com.test.well.know.name");
            System.exit(0);
            return;
        }else
            Toast.makeText(getApplicationContext(),"advertise name=com.test.well.known.name",Toast.LENGTH_SHORT).show();

    }

    static{
        System.loadLibrary("alljoyn_java");
    }
}