trcr/lib/push_service.dart

import 'dart:developer' as developer;
import 'dart:io';

import 'package:firebase_crashlytics/firebase_crashlytics.dart';
import 'package:firebase_messaging/firebase_messaging.dart';
import 'package:flutter_background_geolocation/flutter_background_geolocation.dart' as bg;
import 'package:traccar_client/password_service.dart';

import 'preferences.dart';

class PushService {
  static Future<void> init() async {
    await FirebaseMessaging.instance.requestPermission();
    FirebaseMessaging.onBackgroundMessage(pushServiceBackgroundHandler);
    FirebaseMessaging.onMessage.listen(_onMessage);
    FirebaseMessaging.instance.onTokenRefresh.listen(_uploadToken);
    bg.BackgroundGeolocation.onEnabledChange((enabled) async {
      if (enabled) {
        try {
          _uploadToken(await FirebaseMessaging.instance.getToken());
        } catch (error) {
          developer.log('Failed to get notificaion token', error: error);
        }
      }
    });
  }

  static Future<void> _onMessage(RemoteMessage message) async {
    final command = message.data['command'];
    FirebaseCrashlytics.instance.log('push_command: $command');
    switch (command) {
      case 'positionSingle':
        try {
          await bg.BackgroundGeolocation.getCurrentPosition(samples: 1, persist: true, extras: {'remote': true});
        } catch (error) {
          developer.log('Failed to get position', error: error);
        }
      case 'positionPeriodic':
        await bg.BackgroundGeolocation.start();
      case 'positionStop':
        await bg.BackgroundGeolocation.stop();
      case 'factoryReset':
        await PasswordService.setPassword('');
    }
  }

  static Future<void> _uploadToken(String? token) async {
    if (token == null) return;
    final id = Preferences.instance.getString(Preferences.id);
    final url = Preferences.instance.getString(Preferences.url);
    if (id == null || url == null) return;
    try {
      final request = await HttpClient().postUrl(Uri.parse(url));
      request.headers.contentType = ContentType.parse('application/x-www-form-urlencoded');
      request.write('id=${Uri.encodeComponent(id)}&notificationToken=${Uri.encodeComponent(token)}');
      await request.close();
    } catch (error) {
      developer.log('Failed to upload token', error: error);
    }
  }
}

@pragma('vm:entry-point')
Future<void> pushServiceBackgroundHandler(RemoteMessage message) async {
  await Preferences.init();
  await bg.BackgroundGeolocation.ready(Preferences.geolocationConfig());
  FirebaseCrashlytics.instance.log('push_background_handler');
  await PushService._onMessage(message);
}