This repository has been archived on 2023-11-18. You can view files and clone it, but cannot push or open issues or pull requests.
ha_client/lib/managers/location_manager.class.dart

195 lines
7.1 KiB
Dart
Raw Normal View History

part of '../main.dart';
class LocationManager {
2019-10-20 20:54:29 +03:00
static final LocationManager _instance = LocationManager
._internal();
factory LocationManager() {
return _instance;
}
LocationManager._internal() {
init();
}
2019-10-21 21:22:25 +03:00
final int defaultUpdateIntervalMinutes = 20;
final String backgroundTaskId = "haclocationtask0";
2019-10-21 21:22:25 +03:00
final String backgroundTaskTag = "haclocation";
2019-10-20 20:54:29 +03:00
Duration _updateInterval;
2019-10-24 21:34:38 +03:00
bool _isRunning;
2019-10-20 20:54:29 +03:00
void init() async {
SharedPreferences prefs = await SharedPreferences.getInstance();
await prefs.reload();
_updateInterval = Duration(minutes: prefs.getInt("location-interval") ??
defaultUpdateIntervalMinutes);
2019-10-24 21:34:38 +03:00
_isRunning = prefs.getBool("location-enabled") ?? false;
if (_isRunning) {
await _startLocationService();
2019-10-20 20:54:29 +03:00
}
}
2019-10-24 21:58:48 +03:00
setSettings(bool enabled, int interval) async {
2019-10-20 20:54:29 +03:00
SharedPreferences prefs = await SharedPreferences.getInstance();
if (interval != _updateInterval.inMinutes) {
prefs.setInt("location-interval", interval);
_updateInterval = Duration(minutes: interval);
2019-10-24 21:34:38 +03:00
if (_isRunning) {
Logger.d("Stopping location tracking...");
_isRunning = false;
await _stopLocationService();
}
2019-10-20 20:54:29 +03:00
}
2019-10-24 21:34:38 +03:00
if (enabled && !_isRunning) {
Logger.d("Starting location tracking");
2019-10-20 20:54:29 +03:00
SharedPreferences prefs = await SharedPreferences.getInstance();
prefs.setBool("location-enabled", enabled);
2019-10-24 21:34:38 +03:00
_isRunning = true;
await _startLocationService();
} else if (!enabled && _isRunning) {
Logger.d("Stopping location tracking...");
2019-10-20 20:54:29 +03:00
SharedPreferences prefs = await SharedPreferences.getInstance();
prefs.setBool("location-enabled", enabled);
2019-10-24 21:34:38 +03:00
_isRunning = false;
await _stopLocationService();
2019-10-20 20:54:29 +03:00
}
}
2019-10-24 21:34:38 +03:00
_startLocationService() async {
2019-10-21 21:22:25 +03:00
String webhookId = ConnectionManager().webhookId;
String httpWebHost = ConnectionManager().httpWebHost;
if (webhookId != null && webhookId.isNotEmpty) {
Duration interval;
int delayFactor;
int taskCount;
Logger.d("Starting location update for every ${_updateInterval
.inMinutes} minutes...");
if (_updateInterval.inMinutes == 10) {
interval = Duration(minutes: 20);
taskCount = 2;
delayFactor = 10;
} else if (_updateInterval.inMinutes == 5) {
interval = Duration(minutes: 15);
taskCount = 3;
delayFactor = 5;
} else {
interval = _updateInterval;
taskCount = 1;
delayFactor = 0;
}
for (int i = 1; i <= taskCount; i++) {
int delay = i*delayFactor;
Logger.d("Scheduling location update task #$i for every ${interval.inMinutes} minutes in $delay minutes...");
await workManager.Workmanager.registerPeriodicTask(
"$backgroundTaskId$n",
"haClientLocationTracking-0$n",
tag: backgroundTaskTag,
inputData: {
"webhookId": webhookId,
"httpWebHost": httpWebHost
},
frequency: interval,
initialDelay: Duration(minutes: delay),
existingWorkPolicy: workManager.ExistingWorkPolicy.keep,
backoffPolicy: workManager.BackoffPolicy.linear,
backoffPolicyDelay: interval,
constraints: workManager.Constraints(
networkType: workManager.NetworkType.connected
)
);
}
2019-10-21 21:22:25 +03:00
}
2019-10-20 20:54:29 +03:00
}
2019-10-24 21:34:38 +03:00
_stopLocationService() async {
2019-10-20 20:54:29 +03:00
Logger.d("Canceling previous schedule if any...");
2019-10-21 21:22:25 +03:00
await workManager.Workmanager.cancelByTag(backgroundTaskTag);
2019-10-20 20:54:29 +03:00
}
updateDeviceLocation() async {
2019-11-10 23:53:28 +02:00
Logger.d("[Foreground location] Started");
Geolocator geolocator = Geolocator();
var battery = Battery();
String webhookId = ConnectionManager().webhookId;
String httpWebHost = ConnectionManager().httpWebHost;
if (webhookId != null && webhookId.isNotEmpty) {
2019-11-10 23:53:28 +02:00
Logger.d("[Foreground location] Getting battery level...");
int batteryLevel = await battery.batteryLevel;
Logger.d("[Foreground location] Getting device location...");
Position position = await geolocator.getCurrentPosition(
desiredAccuracy: LocationAccuracy.high,
locationPermissionLevel: GeolocationPermission.locationAlways
);
if (position != null) {
Logger.d("[Foreground location] Location: ${position.latitude} ${position.longitude}. Accuracy: ${position.accuracy}. (${position.timestamp})");
String url = "$httpWebHost/api/webhook/$webhookId";
Map data = {
"type": "update_location",
"data": {
"gps": [position.latitude, position.longitude],
"gps_accuracy": position.accuracy,
"battery": batteryLevel ?? 100
}
2019-11-10 23:53:28 +02:00
};
Logger.d("[Foreground location] Sending data home...");
var response = await http.post(
url,
headers: {"Content-Type": "application/json"},
body: json.encode(data)
);
Logger.d("[Foreground location] Got HTTP ${response.statusCode}");
} else {
Logger.d("[Foreground location] No location. Aborting.");
}
2019-10-20 20:54:29 +03:00
}
}
}
void updateDeviceLocationIsolate() {
2019-10-21 21:22:25 +03:00
workManager.Workmanager.executeTask((backgroundTask, data) {
print("[Background $backgroundTask] Started");
Geolocator geolocator = Geolocator();
2019-10-24 21:34:38 +03:00
var battery = Battery();
int batteryLevel = 100;
2019-10-21 21:22:25 +03:00
String webhookId = data["webhookId"];
String httpWebHost = data["httpWebHost"];
if (webhookId != null && webhookId.isNotEmpty) {
print("[Background $backgroundTask] hour=$battery");
2019-10-22 21:42:30 +03:00
String url = "$httpWebHost/api/webhook/$webhookId";
Map<String, String> headers = {};
headers["Content-Type"] = "application/json";
2019-10-24 21:34:38 +03:00
Map data = {
"type": "update_location",
"data": {
"gps": [],
"gps_accuracy": 0,
"battery": batteryLevel
}
};
print("[Background $backgroundTask] Getting battery level...");
2019-10-24 21:34:38 +03:00
battery.batteryLevel.then((val) => data["data"]["battery"] = val).whenComplete((){
print("[Background $backgroundTask] Getting device location...");
2019-11-01 15:44:51 +02:00
geolocator.getCurrentPosition(desiredAccuracy: LocationAccuracy.high, locationPermissionLevel: GeolocationPermission.locationAlways).then((location) {
2019-10-24 22:18:27 +03:00
if (location != null) {
print("[Background $backgroundTask] Got location: ${location.latitude} ${location.longitude}");
2019-10-24 21:34:38 +03:00
data["data"]["gps"] = [location.latitude, location.longitude];
data["data"]["gps_accuracy"] = location.accuracy;
print("[Background $backgroundTask] Sending data home.");
2019-10-24 21:34:38 +03:00
http.post(
2019-10-24 22:18:27 +03:00
url,
headers: headers,
body: json.encode(data)
2019-10-24 21:34:38 +03:00
);
} else {
print("[Background $backgroundTask] No location. Finishing.");
2019-10-24 22:18:27 +03:00
}
}).catchError((e) {
print("[Background $backgroundTask] Error getting current location: ${e.toString()}");
2019-10-22 21:42:30 +03:00
});
2019-10-20 20:54:29 +03:00
});
2019-10-21 21:22:25 +03:00
}
2019-10-20 20:54:29 +03:00
return Future.value(true);
});
}