import android.app.Service;
import android.content.Context;
import android.content.Intent;
import android.content.SharedPreferences;
import android.os.Binder;
import android.os.Handler;
import android.os.IBinder;
import android.os.Looper;
import android.util.Log;
import com.google.gson.JsonElement;
import java.text.SimpleDateFormat;
import java.util.Calendar;
import microsoft.aspnet.signalr.client.hubs.Subscription;
import microsoft.aspnet.signalr.client.Action;
import microsoft.aspnet.signalr.client.ErrorCallback;
import microsoft.aspnet.signalr.client.LogLevel;
import microsoft.aspnet.signalr.client.Logger;
import microsoft.aspnet.signalr.client.MessageReceivedHandler;
import microsoft.aspnet.signalr.client.hubs.HubConnection;
import microsoft.aspnet.signalr.client.hubs.HubProxy;
import desk.zupport.chatsystem.Chatting;
import desk.zupport.chatsystem.Data.ApplicationEnvironmentURL;
import desk.zupport.chatsystem.fragment.ActiveFragment;
import desk.zupport.chatsystem.fragment.IncommingFragment;
import desk.zupport.chatsystem.fragment.OtherFragment;
/**
* Created by baman on 8/19/16.
*/
public class SignalRService extends Service {
private HubConnection mHubConnection;
private HubProxy mHubProxy;
private Handler mHandler; // to display Toast message
private final LocalBinder mBinder = new LocalBinder();
public Boolean is_service_connected = false;
public String ProfileId;
public String profileToken;
public String CompanyID;
public String DisplayName;
private Context context;
public ApplicationEnvironmentURL applicationEnvironment;
public String environment;
public String HubURL;
public SignalRService() {
mHubConnection = new HubConnection("YOUR CONNECTION NAME");
}
@Override
public void onCreate() {
super.onCreate();
Log.d("service", "Inside oncreate - service");
// context = this.getApplicationContext();
context = getBaseContext();
SharedPreferences prefs = getSharedPreferences("YOUR FILE NAME", MODE_PRIVATE);
ProfileId = prefs.getString("ProfileId", "Not defined");
profileToken = prefs.getString("profileToken", "Not defined");
CompanyID = prefs.getString("companyId", "Not defined");
DisplayName = prefs.getString("DisplayName", "Not defined");
mHandler = new Handler(Looper.getMainLooper());
}
@Override
public int onStartCommand(Intent intent, int flags, int startId) {
Log.d("service", "service start - service");
int result = super.onStartCommand(intent, flags, startId);
startSignalR();
return result;
}
@Override
public void onDestroy() {
mHubConnection.stop();
super.onDestroy();
}
@Override
public boolean onUnbind(Intent intent) {
Log.d("Unbounding", "SignalRservice Service unbound");
return super.onUnbind(intent);
}
@Override
public IBinder onBind(Intent intent) {
// Return the communication channel to the service.
Log.d("service", "onBind - service");
startSignalR();
return (IBinder) mBinder;
}
/**
* Class used for the client Binder. Because we know this service always
* runs in the same process as its clients, we don't need to deal with IPC.
*/
public class LocalBinder extends Binder {
public SignalRService getService() {
// Return this instance of SignalRService so clients can call public methods
return SignalRService.this;
}
}
/**
* method for clients (activities)
*/
private void getIncommingcht(){
Log.d("Inside : ", "getIncommingcht - service - Method");
mHubProxy.invoke("addGroup", ProileId, Copanyid, "true", Token);
mHubProxy.invoke("GetChatQueue",ProileId, Token);
}
public void selectVisitor(String visitor_id, String CompanyID, String DisplayName, String startTime){
String timeStamp = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss").format(Calendar.getInstance().getTime());
mHubProxy.invoke("seleVisitr", DisplayName, timeStamp, startTime);
}
private void startSignalR() {
// Create a new console logger
Logger logger = new Logger() {
@Override
public void log(String message, LogLevel level) {
Log.d("Log Message : ", message);
}
};
// Connect to the server
HubConnection conn = new HubConnection("Your HUB URL HERE", "", true, logger);
// Create the hub proxy
HubProxy proxy = conn.createHubProxy("chatHub");
mHubProxy = proxy;
Subscription subscription = proxy.subscribe("getResponse");
subscription.addReceivedHandler(new Action<JsonElement[]>(){
public void run(JsonElement[] eventParameters) throws Exception {
Log.d("getVisitorResponse-data", String.valueOf(eventParameters[0]));
Log.d("getVisitorResponse-time", String.valueOf(eventParameters[1]));
IncommingFragment.getVisitorResponse(eventParameters[0]);
}
});
Subscription subscription1 = proxy.subscribe("recieveChat");
subscription1.addReceivedHandler(new Action<JsonElement[]>(){
public void run(JsonElement[] eventParameters) throws Exception {
Log.d("IncomingChat_data", String.valueOf(eventParameters[0]));
IncommingFragment.receivedincommingchats(eventParameters[0]);
}
});
Subscription subscription2 = proxy.subscribe("visitor_mobile");
subscription2.addReceivedHandler(new Action<JsonElement[]>(){
public void run(JsonElement[] eventParameters) throws Exception {
Log.d("visitorSelected_mobile", String.valueOf(eventParameters[1]));
ActiveFragment.selectedVisitorsList(String.valueOf(eventParameters[1]));
}
});
/*proxy.subscribe(new Object() {
@SuppressWarnings("unused")
public void recieveIncomingChat(RecieveIncomingchats recieveIncomingchats) {
MainFragment.receivedincommingchats(recieveIncomingchats);
Log.d("hit:", "Hit on receive Incoming chats");
}
@SuppressWarnings("unused")
public void serviceStatus(boolean temp){
Log.d("service_status", "status called");
}
});*/
// Subscribe to the error event
conn.error(new ErrorCallback() {
@Override
public void onError(Throwable error) {
error.printStackTrace();
}
});
// Subscribe to the connected event
conn.connected(new Runnable() {
@Override
public void run() {
System.out.println("CONNECTED");
is_service_connected = true;
getIncommingcht();
}
});
// Subscribe to the closed event
conn.closed(new Runnable() {
@Override
public void run() {
System.out.println("DISCONNECTED");
}
});
// Start the connection
conn.start().done(new Action<Void>() {
@Override
public void run(Void obj) throws Exception {
System.out.println("Done Connecting!");
}
});
// Subscribe to the received event
conn.received(new MessageReceivedHandler() {
@Override
public void onMessageReceived(JsonElement json) {
System.out.println("RAW received message: " + json.toString());
}
});
}
}
