mirror of https://github.com/iSoron/uhabits.git
commit
48e43869c7
@ -1,38 +0,0 @@
|
|||||||
/*
|
|
||||||
* Copyright (C) 2016 Álinson Santos Xavier <isoron@gmail.com>
|
|
||||||
*
|
|
||||||
* This file is part of Loop Habit Tracker.
|
|
||||||
*
|
|
||||||
* Loop Habit Tracker is free software: you can redistribute it and/or modify
|
|
||||||
* it under the terms of the GNU General Public License as published by the
|
|
||||||
* Free Software Foundation, either version 3 of the License, or (at your
|
|
||||||
* option) any later version.
|
|
||||||
*
|
|
||||||
* Loop Habit Tracker is distributed in the hope that it will be useful, but
|
|
||||||
* WITHOUT ANY WARRANTY; without even the implied warranty of MERCHANTABILITY
|
|
||||||
* or FITNESS FOR A PARTICULAR PURPOSE. See the GNU General Public License for
|
|
||||||
* more details.
|
|
||||||
*
|
|
||||||
* You should have received a copy of the GNU General Public License along
|
|
||||||
* with this program. If not, see <http://www.gnu.org/licenses/>.
|
|
||||||
*/
|
|
||||||
|
|
||||||
package org.isoron.uhabits.receivers
|
|
||||||
|
|
||||||
import android.content.*
|
|
||||||
import android.content.Context.*
|
|
||||||
import android.net.*
|
|
||||||
import org.isoron.uhabits.*
|
|
||||||
|
|
||||||
class ConnectivityReceiver : BroadcastReceiver() {
|
|
||||||
override fun onReceive(context: Context?, intent: Intent?) {
|
|
||||||
if (context == null || intent == null) return
|
|
||||||
val app = context.applicationContext as HabitsApplication
|
|
||||||
val networkInfo = (context.getSystemService(CONNECTIVITY_SERVICE)
|
|
||||||
as ConnectivityManager).activeNetworkInfo
|
|
||||||
val isConnected = (networkInfo != null) &&
|
|
||||||
networkInfo.isConnectedOrConnecting
|
|
||||||
val syncManager = app.component.syncManager
|
|
||||||
syncManager.onNetworkStatusChanged(isConnected)
|
|
||||||
}
|
|
||||||
}
|
|
||||||
@ -1,59 +0,0 @@
|
|||||||
/*
|
|
||||||
* Copyright (C) 2016 Álinson Santos Xavier <isoron@gmail.com>
|
|
||||||
*
|
|
||||||
* This file is part of Loop Habit Tracker.
|
|
||||||
*
|
|
||||||
* Loop Habit Tracker is free software: you can redistribute it and/or modify
|
|
||||||
* it under the terms of the GNU General Public License as published by the
|
|
||||||
* Free Software Foundation, either version 3 of the License, or (at your
|
|
||||||
* option) any later version.
|
|
||||||
*
|
|
||||||
* Loop Habit Tracker is distributed in the hope that it will be useful, but
|
|
||||||
* WITHOUT ANY WARRANTY; without even the implied warranty of MERCHANTABILITY
|
|
||||||
* or FITNESS FOR A PARTICULAR PURPOSE. See the GNU General Public License for
|
|
||||||
* more details.
|
|
||||||
*
|
|
||||||
* You should have received a copy of the GNU General Public License along
|
|
||||||
* with this program. If not, see <http://www.gnu.org/licenses/>.
|
|
||||||
*/
|
|
||||||
|
|
||||||
package org.isoron.uhabits.sync;
|
|
||||||
|
|
||||||
import androidx.annotation.NonNull;
|
|
||||||
import androidx.annotation.Nullable;
|
|
||||||
|
|
||||||
import org.isoron.uhabits.core.database.*;
|
|
||||||
|
|
||||||
@Table(name = "Events")
|
|
||||||
public class Event
|
|
||||||
{
|
|
||||||
@Nullable
|
|
||||||
@Column
|
|
||||||
public Long id;
|
|
||||||
|
|
||||||
@NonNull
|
|
||||||
@Column(name = "timestamp")
|
|
||||||
public Long timestamp;
|
|
||||||
|
|
||||||
@NonNull
|
|
||||||
@Column(name = "message")
|
|
||||||
public String message;
|
|
||||||
|
|
||||||
@NonNull
|
|
||||||
@Column(name = "server_id")
|
|
||||||
public String serverId;
|
|
||||||
|
|
||||||
public Event()
|
|
||||||
{
|
|
||||||
timestamp = 0L;
|
|
||||||
message = "";
|
|
||||||
serverId = "";
|
|
||||||
}
|
|
||||||
|
|
||||||
public Event(@NonNull String serverId, long timestamp, @NonNull String message)
|
|
||||||
{
|
|
||||||
this.serverId = serverId;
|
|
||||||
this.timestamp = timestamp;
|
|
||||||
this.message = message;
|
|
||||||
}
|
|
||||||
}
|
|
||||||
@ -1,380 +0,0 @@
|
|||||||
/*
|
|
||||||
* Copyright (C) 2016 Álinson Santos Xavier <isoron@gmail.com>
|
|
||||||
*
|
|
||||||
* This file is part of Loop Habit Tracker.
|
|
||||||
*
|
|
||||||
* Loop Habit Tracker is free software: you can redistribute it and/or modify
|
|
||||||
* it under the terms of the GNU General Public License as published by the
|
|
||||||
* Free Software Foundation, either version 3 of the License, or (at your
|
|
||||||
* option) any later version.
|
|
||||||
*
|
|
||||||
* Loop Habit Tracker is distributed in the hope that it will be useful, but
|
|
||||||
* WITHOUT ANY WARRANTY; without even the implied warranty of MERCHANTABILITY
|
|
||||||
* or FITNESS FOR A PARTICULAR PURPOSE. See the GNU General Public License for
|
|
||||||
* more details.
|
|
||||||
*
|
|
||||||
* You should have received a copy of the GNU General Public License along
|
|
||||||
* with this program. If not, see <http://www.gnu.org/licenses/>.
|
|
||||||
*/
|
|
||||||
|
|
||||||
package org.isoron.uhabits.sync;
|
|
||||||
|
|
||||||
import android.util.*;
|
|
||||||
|
|
||||||
import androidx.annotation.NonNull;
|
|
||||||
import androidx.annotation.Nullable;
|
|
||||||
|
|
||||||
import org.isoron.androidbase.*;
|
|
||||||
import org.isoron.uhabits.BuildConfig;
|
|
||||||
import org.isoron.uhabits.core.*;
|
|
||||||
import org.isoron.uhabits.core.commands.*;
|
|
||||||
import org.isoron.uhabits.core.database.*;
|
|
||||||
import org.isoron.uhabits.core.preferences.*;
|
|
||||||
import org.isoron.uhabits.database.*;
|
|
||||||
import org.isoron.uhabits.utils.*;
|
|
||||||
import org.json.*;
|
|
||||||
|
|
||||||
import java.net.*;
|
|
||||||
import java.util.*;
|
|
||||||
|
|
||||||
import javax.inject.*;
|
|
||||||
|
|
||||||
import io.socket.client.*;
|
|
||||||
import io.socket.client.Socket;
|
|
||||||
import io.socket.emitter.*;
|
|
||||||
|
|
||||||
import static io.socket.client.Socket.EVENT_CONNECT;
|
|
||||||
import static io.socket.client.Socket.EVENT_CONNECTING;
|
|
||||||
import static io.socket.client.Socket.EVENT_CONNECT_ERROR;
|
|
||||||
import static io.socket.client.Socket.EVENT_CONNECT_TIMEOUT;
|
|
||||||
import static io.socket.client.Socket.EVENT_DISCONNECT;
|
|
||||||
import static io.socket.client.Socket.EVENT_PING;
|
|
||||||
import static io.socket.client.Socket.EVENT_PONG;
|
|
||||||
import static io.socket.client.Socket.EVENT_RECONNECT;
|
|
||||||
import static io.socket.client.Socket.EVENT_RECONNECT_ATTEMPT;
|
|
||||||
import static io.socket.client.Socket.EVENT_RECONNECT_ERROR;
|
|
||||||
import static io.socket.client.Socket.EVENT_RECONNECT_FAILED;
|
|
||||||
|
|
||||||
@AppScope
|
|
||||||
public class SyncManager implements CommandRunner.Listener
|
|
||||||
{
|
|
||||||
public static final String EVENT_AUTH = "auth";
|
|
||||||
|
|
||||||
public static final String EVENT_AUTH_OK = "authOK";
|
|
||||||
|
|
||||||
public static final String EVENT_EXECUTE_EVENT = "execute";
|
|
||||||
|
|
||||||
public static final String EVENT_FETCH = "fetch";
|
|
||||||
|
|
||||||
public static final String EVENT_FETCH_OK = "fetchOK";
|
|
||||||
|
|
||||||
public static final String EVENT_POST_EVENT = "postEvent";
|
|
||||||
|
|
||||||
@NonNull
|
|
||||||
private String clientId;
|
|
||||||
|
|
||||||
@NonNull
|
|
||||||
private String groupKey;
|
|
||||||
|
|
||||||
@NonNull
|
|
||||||
private Socket socket;
|
|
||||||
|
|
||||||
@NonNull
|
|
||||||
private LinkedList<Event> pendingConfirmation;
|
|
||||||
|
|
||||||
@NonNull
|
|
||||||
private LinkedList<Event> pendingEmit;
|
|
||||||
|
|
||||||
private boolean readyToEmit = false;
|
|
||||||
|
|
||||||
@NonNull
|
|
||||||
private final Preferences prefs;
|
|
||||||
|
|
||||||
@NonNull
|
|
||||||
private CommandRunner commandRunner;
|
|
||||||
|
|
||||||
@NonNull
|
|
||||||
private CommandParser commandParser;
|
|
||||||
|
|
||||||
private boolean isListening;
|
|
||||||
|
|
||||||
private SSLContextProvider sslProvider;
|
|
||||||
|
|
||||||
private final Repository<Event> repository;
|
|
||||||
|
|
||||||
@Inject
|
|
||||||
public SyncManager(@NonNull SSLContextProvider sslProvider,
|
|
||||||
@NonNull Preferences prefs,
|
|
||||||
@NonNull CommandRunner commandRunner,
|
|
||||||
@NonNull CommandParser commandParser)
|
|
||||||
{
|
|
||||||
Log.i("SyncManager", this.toString());
|
|
||||||
|
|
||||||
this.sslProvider = sslProvider;
|
|
||||||
this.prefs = prefs;
|
|
||||||
this.commandRunner = commandRunner;
|
|
||||||
this.commandParser = commandParser;
|
|
||||||
this.isListening = false;
|
|
||||||
|
|
||||||
repository = new Repository<>(Event.class,
|
|
||||||
new AndroidDatabase(DatabaseUtils.openDatabase()));
|
|
||||||
pendingConfirmation = new LinkedList<>();
|
|
||||||
pendingEmit = new LinkedList<>(repository.findAll("order by timestamp"));
|
|
||||||
|
|
||||||
groupKey = prefs.getSyncKey();
|
|
||||||
clientId = prefs.getSyncClientId();
|
|
||||||
String serverURL = prefs.getSyncAddress();
|
|
||||||
|
|
||||||
Log.d("SyncManager", clientId);
|
|
||||||
connect(serverURL);
|
|
||||||
}
|
|
||||||
|
|
||||||
@Override
|
|
||||||
public void onCommandExecuted(@NonNull Command command,
|
|
||||||
@Nullable Long refreshKey)
|
|
||||||
{
|
|
||||||
if (command.isRemote()) return;
|
|
||||||
|
|
||||||
JSONObject msg = toJSONObject(command.toJson());
|
|
||||||
Long now = new Date().getTime();
|
|
||||||
Event e = new Event(command.getId(), now, msg.toString());
|
|
||||||
repository.save(e);
|
|
||||||
|
|
||||||
Log.i("SyncManager", "Adding to outbox: " + msg.toString());
|
|
||||||
|
|
||||||
pendingEmit.add(e);
|
|
||||||
if (readyToEmit) emitPending();
|
|
||||||
}
|
|
||||||
|
|
||||||
public void onNetworkStatusChanged(boolean isConnected)
|
|
||||||
{
|
|
||||||
if (!isListening) return;
|
|
||||||
if (isConnected) socket.connect();
|
|
||||||
else socket.disconnect();
|
|
||||||
}
|
|
||||||
|
|
||||||
public void startListening()
|
|
||||||
{
|
|
||||||
if (!prefs.isSyncEnabled()) return;
|
|
||||||
if (groupKey.isEmpty()) return;
|
|
||||||
if (isListening) return;
|
|
||||||
|
|
||||||
isListening = true;
|
|
||||||
socket.connect();
|
|
||||||
commandRunner.addListener(this);
|
|
||||||
}
|
|
||||||
|
|
||||||
public void stopListening()
|
|
||||||
{
|
|
||||||
if (!isListening) return;
|
|
||||||
|
|
||||||
commandRunner.removeListener(this);
|
|
||||||
socket.close();
|
|
||||||
isListening = false;
|
|
||||||
}
|
|
||||||
|
|
||||||
private void connect(String serverURL)
|
|
||||||
{
|
|
||||||
try
|
|
||||||
{
|
|
||||||
IO.setDefaultSSLContext(sslProvider.getCACertSSLContext());
|
|
||||||
socket = IO.socket(serverURL);
|
|
||||||
|
|
||||||
logSocketEvent(socket, EVENT_CONNECT, "Connected");
|
|
||||||
logSocketEvent(socket, EVENT_CONNECT_TIMEOUT, "Connect timeout");
|
|
||||||
logSocketEvent(socket, EVENT_CONNECTING, "Connecting...");
|
|
||||||
logSocketEvent(socket, EVENT_CONNECT_ERROR, "Connect error");
|
|
||||||
logSocketEvent(socket, EVENT_DISCONNECT, "Disconnected");
|
|
||||||
logSocketEvent(socket, EVENT_RECONNECT, "Reconnected");
|
|
||||||
logSocketEvent(socket, EVENT_RECONNECT_ATTEMPT, "Reconnecting...");
|
|
||||||
logSocketEvent(socket, EVENT_RECONNECT_ERROR, "Reconnect error");
|
|
||||||
logSocketEvent(socket, EVENT_RECONNECT_FAILED, "Reconnect failed");
|
|
||||||
logSocketEvent(socket, EVENT_DISCONNECT, "Disconnected");
|
|
||||||
logSocketEvent(socket, EVENT_PING, "Ping");
|
|
||||||
logSocketEvent(socket, EVENT_PONG, "Pong");
|
|
||||||
|
|
||||||
socket.on(EVENT_CONNECT, new OnConnectListener());
|
|
||||||
socket.on(EVENT_DISCONNECT, new OnDisconnectListener());
|
|
||||||
socket.on(EVENT_EXECUTE_EVENT, new OnExecuteCommandListener());
|
|
||||||
socket.on(EVENT_AUTH_OK, new OnAuthOKListener());
|
|
||||||
socket.on(EVENT_FETCH_OK, new OnFetchOKListener());
|
|
||||||
}
|
|
||||||
catch (URISyntaxException e)
|
|
||||||
{
|
|
||||||
throw new RuntimeException(e);
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
||||||
private void emitPending()
|
|
||||||
{
|
|
||||||
try
|
|
||||||
{
|
|
||||||
for (Event e : pendingEmit)
|
|
||||||
{
|
|
||||||
Log.i("SyncManager", "Emitting: " + e.message);
|
|
||||||
socket.emit(EVENT_POST_EVENT, new JSONObject(e.message));
|
|
||||||
pendingConfirmation.add(e);
|
|
||||||
}
|
|
||||||
|
|
||||||
pendingEmit.clear();
|
|
||||||
}
|
|
||||||
catch (JSONException e)
|
|
||||||
{
|
|
||||||
throw new RuntimeException(e);
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
||||||
private void logSocketEvent(Socket socket, String event, final String msg)
|
|
||||||
{
|
|
||||||
socket.on(event, args ->
|
|
||||||
{
|
|
||||||
Log.i("SyncManager", msg);
|
|
||||||
for (Object o : args)
|
|
||||||
if (o instanceof SocketIOException)
|
|
||||||
((SocketIOException) o).printStackTrace();
|
|
||||||
});
|
|
||||||
}
|
|
||||||
|
|
||||||
private JSONObject toJSONObject(String json)
|
|
||||||
{
|
|
||||||
try
|
|
||||||
{
|
|
||||||
return new JSONObject(json);
|
|
||||||
}
|
|
||||||
catch (JSONException e)
|
|
||||||
{
|
|
||||||
throw new RuntimeException(e);
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
||||||
private void updateLastSync(Long timestamp)
|
|
||||||
{
|
|
||||||
prefs.setLastSync(timestamp + 1);
|
|
||||||
}
|
|
||||||
|
|
||||||
private class OnAuthOKListener implements Emitter.Listener
|
|
||||||
{
|
|
||||||
@Override
|
|
||||||
public void call(Object... args)
|
|
||||||
{
|
|
||||||
Log.i("SyncManager", "Auth OK");
|
|
||||||
Log.i("SyncManager", "Requesting commands since last sync");
|
|
||||||
|
|
||||||
Long lastSync = prefs.getLastSync();
|
|
||||||
socket.emit(EVENT_FETCH, buildFetchMessage(lastSync));
|
|
||||||
}
|
|
||||||
|
|
||||||
private JSONObject buildFetchMessage(Long lastSync)
|
|
||||||
{
|
|
||||||
try
|
|
||||||
{
|
|
||||||
JSONObject json = new JSONObject();
|
|
||||||
json.put("since", lastSync);
|
|
||||||
return json;
|
|
||||||
}
|
|
||||||
catch (JSONException e)
|
|
||||||
{
|
|
||||||
throw new RuntimeException(e);
|
|
||||||
}
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
||||||
private class OnConnectListener implements Emitter.Listener
|
|
||||||
{
|
|
||||||
@Override
|
|
||||||
public void call(Object... args)
|
|
||||||
{
|
|
||||||
Log.i("SyncManager", "Sending auth message");
|
|
||||||
socket.emit(EVENT_AUTH, buildAuthMessage());
|
|
||||||
}
|
|
||||||
|
|
||||||
private JSONObject buildAuthMessage()
|
|
||||||
{
|
|
||||||
try
|
|
||||||
{
|
|
||||||
JSONObject json = new JSONObject();
|
|
||||||
json.put("groupKey", groupKey);
|
|
||||||
json.put("clientId", clientId);
|
|
||||||
json.put("version", BuildConfig.VERSION_NAME);
|
|
||||||
return json;
|
|
||||||
}
|
|
||||||
catch (JSONException e)
|
|
||||||
{
|
|
||||||
throw new RuntimeException(e);
|
|
||||||
}
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
||||||
private class OnDisconnectListener implements Emitter.Listener
|
|
||||||
{
|
|
||||||
@Override
|
|
||||||
public void call(Object... args)
|
|
||||||
{
|
|
||||||
readyToEmit = false;
|
|
||||||
for (Event e : pendingConfirmation) pendingEmit.add(e);
|
|
||||||
pendingConfirmation.clear();
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
||||||
private class OnExecuteCommandListener implements Emitter.Listener
|
|
||||||
{
|
|
||||||
@Override
|
|
||||||
public void call(Object... args)
|
|
||||||
{
|
|
||||||
try
|
|
||||||
{
|
|
||||||
Log.d("SyncManager",
|
|
||||||
String.format("Received command: %s", args[0].toString()));
|
|
||||||
JSONObject root = new JSONObject(args[0].toString());
|
|
||||||
updateLastSync(root.getLong("timestamp"));
|
|
||||||
executeCommand(root);
|
|
||||||
}
|
|
||||||
catch (JSONException e)
|
|
||||||
{
|
|
||||||
throw new RuntimeException(e);
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
||||||
private void executeCommand(JSONObject root) throws JSONException
|
|
||||||
{
|
|
||||||
Command received = commandParser.parse(root.toString());
|
|
||||||
received.setRemote(true);
|
|
||||||
|
|
||||||
for (Event e : pendingConfirmation)
|
|
||||||
{
|
|
||||||
if (e.serverId.equals(received.getId()))
|
|
||||||
{
|
|
||||||
Log.i("SyncManager", "Pending command confirmed");
|
|
||||||
pendingConfirmation.remove(e);
|
|
||||||
repository.remove(e);
|
|
||||||
return;
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
||||||
Log.d("SyncManager", "Executing received command");
|
|
||||||
commandRunner.execute(received, null);
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
||||||
private class OnFetchOKListener implements Emitter.Listener
|
|
||||||
{
|
|
||||||
@Override
|
|
||||||
public void call(Object... args)
|
|
||||||
{
|
|
||||||
try
|
|
||||||
{
|
|
||||||
Log.i("SyncManager", "Fetch OK");
|
|
||||||
|
|
||||||
JSONObject json = (JSONObject) args[0];
|
|
||||||
updateLastSync(json.getLong("timestamp"));
|
|
||||||
|
|
||||||
emitPending();
|
|
||||||
readyToEmit = true;
|
|
||||||
}
|
|
||||||
catch (JSONException e)
|
|
||||||
{
|
|
||||||
throw new RuntimeException(e);
|
|
||||||
}
|
|
||||||
}
|
|
||||||
}
|
|
||||||
}
|
|
||||||
@ -1,90 +0,0 @@
|
|||||||
/*
|
|
||||||
* Copyright (C) 2016 Álinson Santos Xavier <isoron@gmail.com>
|
|
||||||
*
|
|
||||||
* This file is part of Loop Habit Tracker.
|
|
||||||
*
|
|
||||||
* Loop Habit Tracker is free software: you can redistribute it and/or modify
|
|
||||||
* it under the terms of the GNU General Public License as published by the
|
|
||||||
* Free Software Foundation, either version 3 of the License, or (at your
|
|
||||||
* option) any later version.
|
|
||||||
*
|
|
||||||
* Loop Habit Tracker is distributed in the hope that it will be useful, but
|
|
||||||
* WITHOUT ANY WARRANTY; without even the implied warranty of MERCHANTABILITY
|
|
||||||
* or FITNESS FOR A PARTICULAR PURPOSE. See the GNU General Public License for
|
|
||||||
* more details.
|
|
||||||
*
|
|
||||||
* You should have received a copy of the GNU General Public License along
|
|
||||||
* with this program. If not, see <http://www.gnu.org/licenses/>.
|
|
||||||
*/
|
|
||||||
|
|
||||||
package org.isoron.uhabits.sync;
|
|
||||||
|
|
||||||
import android.app.*;
|
|
||||||
import android.content.*;
|
|
||||||
import android.net.*;
|
|
||||||
import android.os.*;
|
|
||||||
import androidx.core.app.*;
|
|
||||||
|
|
||||||
import org.isoron.uhabits.*;
|
|
||||||
import org.isoron.uhabits.core.preferences.*;
|
|
||||||
import org.isoron.uhabits.receivers.*;
|
|
||||||
|
|
||||||
public class SyncService extends Service implements Preferences.Listener
|
|
||||||
{
|
|
||||||
private SyncManager syncManager;
|
|
||||||
|
|
||||||
private Preferences prefs;
|
|
||||||
|
|
||||||
private ConnectivityReceiver connectivityReceiver;
|
|
||||||
|
|
||||||
public SyncService()
|
|
||||||
{
|
|
||||||
}
|
|
||||||
|
|
||||||
@Override
|
|
||||||
public IBinder onBind(Intent intent)
|
|
||||||
{
|
|
||||||
return null;
|
|
||||||
}
|
|
||||||
|
|
||||||
@Override
|
|
||||||
public void onCreate()
|
|
||||||
{
|
|
||||||
Intent notificationIntent = new Intent(this, SyncService.class);
|
|
||||||
PendingIntent pendingIntent = PendingIntent.getActivity(this, 0, notificationIntent, 0);
|
|
||||||
|
|
||||||
Notification notification = new NotificationCompat.Builder(this)
|
|
||||||
.setContentTitle("Loop Habit Tracker")
|
|
||||||
.setContentText("Sync service running")
|
|
||||||
.setSmallIcon(R.drawable.ic_notification)
|
|
||||||
.setPriority(NotificationCompat.PRIORITY_MIN)
|
|
||||||
.setContentIntent(pendingIntent)
|
|
||||||
.build();
|
|
||||||
|
|
||||||
startForeground(99999, notification);
|
|
||||||
|
|
||||||
connectivityReceiver = new ConnectivityReceiver();
|
|
||||||
IntentFilter filter = new IntentFilter(ConnectivityManager.CONNECTIVITY_ACTION);
|
|
||||||
this.registerReceiver(connectivityReceiver, filter);
|
|
||||||
|
|
||||||
HabitsApplication app = (HabitsApplication) getApplicationContext();
|
|
||||||
syncManager = app.getComponent().getSyncManager();
|
|
||||||
syncManager.startListening();
|
|
||||||
|
|
||||||
prefs = app.getComponent().getPreferences();
|
|
||||||
prefs.addListener(this);
|
|
||||||
}
|
|
||||||
|
|
||||||
@Override
|
|
||||||
public void onSyncFeatureChanged()
|
|
||||||
{
|
|
||||||
if(!prefs.isSyncEnabled()) stopSelf();
|
|
||||||
}
|
|
||||||
|
|
||||||
@Override
|
|
||||||
public void onDestroy()
|
|
||||||
{
|
|
||||||
unregisterReceiver(connectivityReceiver);
|
|
||||||
syncManager.stopListening();
|
|
||||||
}
|
|
||||||
}
|
|
||||||
Loading…
Reference in new issue