ha_client/lib/managers/location_manager.class.dart

part of '../main.dart';

class LocationManager {

  static final LocationManager _instance = LocationManager
      ._internal();

  factory LocationManager() {
    return _instance;
  }

  LocationManager._internal() {
    init();
  }

  final String backgroundTaskId = "haclocationtask0";
  final String backgroundTaskTag = "haclocation";

  void init() async {
    if (AppSettings().locationTrackingEnabled) {
      await _startLocationService();
    }
  }

  setSettings(bool enabled, int interval) async {
    if (interval != AppSettings().locationUpdateInterval.inMinutes) {
      await _stopLocationService();
    }
    AppSettings().save({
      'location-interval': interval,
      'location-enabled': enabled
    });
    AppSettings().locationUpdateInterval = Duration(minutes: interval);
    AppSettings().locationTrackingEnabled = enabled;
    if (enabled && !AppSettings().locationTrackingEnabled) {
      Logger.d("Starting location tracking");
      await _startLocationService();
    } else if (!enabled && AppSettings().locationTrackingEnabled) {
      Logger.d("Stopping location tracking...");
      await _stopLocationService();
    }
  }

  _startLocationService() async {
    String webhookId = AppSettings().webhookId;
    String httpWebHost = AppSettings().httpWebHost;
    if (webhookId != null && webhookId.isNotEmpty) {
      Duration interval;
      int delayFactor;
      int taskCount;
      Logger.d("Starting location update for every ${AppSettings().locationUpdateInterval
        .inMinutes} minutes...");
      if (AppSettings().locationUpdateInterval.inMinutes == 10) {
        interval = Duration(minutes: 20);
        taskCount = 2;
        delayFactor = 10;
      } else if (AppSettings().locationUpdateInterval.inMinutes == 5) {
        interval = Duration(minutes: 15);
        taskCount = 3;
        delayFactor = 5;
      } else {
        interval = AppSettings().locationUpdateInterval;
        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$i",
          "haClientLocationTracking-0$i",
          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,
          ),
        );
      }
    }
  }

  _stopLocationService() async {
    Logger.d("Canceling previous schedule if any...");
    await workManager.Workmanager.cancelAll();
  }

  updateDeviceLocation() async {
    try {
      Logger.d("[Foreground location] Started");
      Geolocator geolocator = Geolocator();
      var battery = Battery();
      String webhookId = AppSettings().webhookId;
      String httpWebHost = AppSettings().httpWebHost;
      if (webhookId != null && webhookId.isNotEmpty) {
          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
              }
            };
            Logger.d("[Foreground location] Sending data home...");
            http.Response response = await http.post(
              url,
              headers: {"Content-Type": "application/json"},
              body: json.encode(data)
            );
            if (response.statusCode >= 300) {
              Logger.e('Foreground location update error: ${response.body}');
            }
            Logger.d("[Foreground location] Got HTTP ${response.statusCode}");
          } else {
            Logger.d("[Foreground location] No location. Aborting.");
          }
      }
    } catch (e, stack) {
      Logger.e('Foreground location error: ${e.toSTring()}', stacktrace: stack);
    }
  }

}

void updateDeviceLocationIsolate() {
  workManager.Workmanager.executeTask((backgroundTask, data) async {
    //print("[Background $backgroundTask] Started");
    Geolocator geolocator = Geolocator();
    var battery = Battery();
    String webhookId = data["webhookId"];
    String httpWebHost = data["httpWebHost"];
    //String logData = '==> ${DateTime.now()} [Background $backgroundTask]:';
    //print("[Background $backgroundTask] Getting path for log file...");
    //final logFileDirectory = await getExternalStorageDirectory();
    //print("[Background $backgroundTask] Opening log file...");
    //File logFile = File('${logFileDirectory.path}/ha-client-background-log.txt');
    //print("[Background $backgroundTask] Log file path: ${logFile.path}");
    if (webhookId != null && webhookId.isNotEmpty) {
      String url = "$httpWebHost/api/webhook/$webhookId";
      Map<String, String> headers = {};
      headers["Content-Type"] = "application/json";
      Map data = {
        "type": "update_location",
        "data": {
          "gps": [],
          "gps_accuracy": 0,
          "battery": 100
        }
      };
      //print("[Background $backgroundTask] Getting battery level...");
      int batteryLevel;
      try {
        batteryLevel = await battery.batteryLevel;
        //print("[Background $backgroundTask] Got battery level: $batteryLevel");
      } catch(e) {
        //print("[Background $backgroundTask] Error getting battery level: $e. Setting zero");
        batteryLevel = 0;
        //logData += 'Battery: error, $e';
      }
      if (batteryLevel != null) {
        data["data"]["battery"] = batteryLevel;
        //logData += 'Battery: success, $batteryLevel';
      }/* else {
        logData += 'Battery: error, level is null';
      }*/
      Position location;
      try {
        location = await geolocator.getCurrentPosition(desiredAccuracy: LocationAccuracy.high, locationPermissionLevel: GeolocationPermission.locationAlways);
        if (location != null && location.latitude != null) {
          //logData += ' || Location: success, ${location.latitude} ${location.longitude} (${location.timestamp})';
          data["data"]["gps"] = [location.latitude, location.longitude];
          data["data"]["gps_accuracy"] = location.accuracy;
          try {
            http.Response response = await http.post(
                url,
                headers: headers,
                body: json.encode(data)
            );
            /*if (response.statusCode >= 200 && response.statusCode < 300) {
              logData += ' || Post: success, ${response.statusCode}';
            } else {
              logData += ' || Post: error, ${response.statusCode}';
            }*/
          } catch(e) {
            //logData += ' || Post: error, $e';
          }
        }/* else {
          logData += ' || Location: error, location is null';
        }*/
      } catch (e) {
        //print("[Background $backgroundTask] Location error: $e");
        //logData += ' || Location: error, $e';
      }
    }/* else {
      logData += 'Not configured';
    }*/
    //print("[Background $backgroundTask] Writing log data...");
    /*try {
      var fileMode;
      if (logFile.existsSync() && logFile.lengthSync() < 5000000) {
        fileMode = FileMode.append;
      } else {
        fileMode = FileMode.write;
      }
      await logFile.writeAsString('$logData\n', mode: fileMode);
    } catch (e) {
      print("[Background $backgroundTask] Error writing log: $e");
    }
    print("[Background $backgroundTask] Finished.");*/
    return true;
  });
}