tsacdop-podcast-app-android/lib/state/podcast_group.dart

import 'dart:core';
import 'dart:developer' as developer;
import 'dart:io';
import 'dart:isolate';
import 'dart:math' as math;
import 'dart:ui';

import 'package:color_thief_flutter/color_thief_flutter.dart';
import 'package:dio/dio.dart';
import 'package:equatable/equatable.dart';
import 'package:flutter/foundation.dart';
import 'package:flutter/material.dart';
import 'package:flutter_isolate/flutter_isolate.dart';
import 'package:image/image.dart' as img;
import 'package:path_provider/path_provider.dart';
import 'package:uuid/uuid.dart';
import 'package:webfeed/webfeed.dart';
import 'package:workmanager/workmanager.dart';

import '../local_storage/key_value_storage.dart';
import '../local_storage/sqflite_localpodcast.dart';
import '../service/gpodder_api.dart';
import '../type/fireside_data.dart';
import '../type/podcastlocal.dart';

void callbackDispatcher() {
  if (Platform.isAndroid) {
    Workmanager.executeTask((task, inputData) async {
      final gpodder = Gpodder();
      final status = await gpodder.getChanges();
      if (status == 200) {
        await gpodder.updateChange();
        developer.log('Gpodder sync successfully');
      }
      return Future.value(true);
    });
  }
}

class GroupEntity {
  final String name;
  final String id;
  final String color;
  final List<String> podcastList;

  GroupEntity(this.name, this.id, this.color, this.podcastList);

  Map<String, Object> toJson() {
    return {'name': name, 'id': id, 'color': color, 'podcastList': podcastList};
  }

  static GroupEntity fromJson(Map<String, Object> json) {
    var list = List<String>.from(json['podcastList']);
    return GroupEntity(json['name'] as String, json['id'] as String,
        json['color'] as String, list);
  }
}

class PodcastGroup extends Equatable {
  /// Group name.
  final String name;

  final String id;

  /// Group theme color, not used.
  final String color;

  /// Id lists of podcasts in group.
  final List<String> podcastList;

  final List<PodcastLocal> podcasts;

  PodcastGroup(this.name,
      {this.color = '#000000',
      String id,
      List<String> podcastList,
      List<PodcastLocal> podcasts})
      : id = id ?? Uuid().v4(),
        podcastList = podcastList ?? [],
        podcasts = podcasts ?? [];

  final _dbHelper = DBHelper();

  Future<void> getPodcasts() async {
    podcasts.clear();
    if (podcastList.isNotEmpty) {
      try {
        var result = await _dbHelper.getPodcastLocal(podcastList);
        if (podcasts.isEmpty) podcasts.addAll(result);
      } catch (e) {
        await Future.delayed(Duration(milliseconds: 200));
        try {
          var result = await _dbHelper.getPodcastLocal(podcastList);
          if (podcasts.isEmpty) podcasts.addAll(result);
        } catch (e) {
          developer.log(e.toString());
        }
      }
    }
  }

  Future<PodcastGroup> updatePodcast(PodcastLocal podcast) async {
    var count = await _dbHelper.getPodcastCounts(podcast.id);
    var list = [
      for (var p in podcasts)
        p == podcast ? podcast.copyWith(updateCount: count) : p
    ];
    return PodcastGroup(name,
        id: id, color: color, podcastList: podcastList, podcasts: list);
  }

  void reorderGroup(int oldIndex, int newIndex) {
    if (newIndex > oldIndex) {
      newIndex -= 1;
    }
    final podcast = podcasts.removeAt(oldIndex);
    podcasts.insert(newIndex, podcast);
    podcastList.removeAt(oldIndex);
    podcastList.insert(newIndex, podcast.id);
  }

  void addToGroup(PodcastLocal podcast) {
    if (!podcasts.contains(podcast)) {
      podcasts.add(podcast);
      podcastList.add(podcast.id);
    }
  }

  void addToGroupAt(PodcastLocal podcast, {int index = 0}) {
    if (!podcasts.contains(podcast)) {
      podcasts.insert(index, podcast);
      podcastList.insert(index, podcast.id);
    }
  }

  void deleteFromGroup(PodcastLocal podcast) {
    podcasts.remove(podcast);
    podcastList.remove(podcast.id);
  }

  Color getColor() {
    if (color != '#000000') {
      var colorInt = int.parse('FF${color.toUpperCase()}', radix: 16);
      return Color(colorInt).withOpacity(1.0);
    } else {
      return Colors.blue[400];
    }
  }

  ///Ordered podcast list.
  //List<PodcastLocal> _orderedPodcasts;
  //List<PodcastLocal> get orderedPodcasts => _orderedPodcasts;

  //set orderedPodcasts(list) => _orderedPodcasts = list;

  GroupEntity toEntity() {
    return GroupEntity(name, id, color, podcastList);
  }

  static PodcastGroup fromEntity(GroupEntity entity) {
    return PodcastGroup(
      entity.name,
      id: entity.id,
      color: entity.color,
      podcastList: entity.podcastList.toSet().toList(),
    );
  }

  @override
  List<Object> get props => [id, name];
}

enum SubscribeState { none, start, subscribe, fetch, stop, exist, error }

class SubscribeItem {
  ///Rss url.
  String url;

  ///Rss title.
  String title;

  /// Subscribe status.
  SubscribeState subscribeState;

  /// Podcast id.
  String id;

  ///Avatar image link.
  String imgUrl;

  ///Podcast group, default Home.
  String group;

  SubscribeItem(
    this.url,
    this.title, {
    this.subscribeState = SubscribeState.none,
    this.id = '',
    this.imgUrl = '',
    this.group = '',
  });
}

class GroupList extends ChangeNotifier {
  /// List of all gourps.
  List<PodcastGroup> _groups = [];
  List<PodcastGroup> get groups => _groups;

  List<PodcastGroup> _orderChanged = [];
  List<PodcastGroup> get orderChanged => _orderChanged;
  //GroupList({List<PodcastGroup> groups}) : _groups = groups ?? [];

  /// Subscribe worker isolate
  FlutterIsolate subIsolate;
  ReceivePort receivePort;
  SendPort subSendPort;

  /// Current subsribe item from isolate.
  SubscribeItem _currentSubscribeItem = SubscribeItem('', '');
  SubscribeItem get currentSubscribeItem => _currentSubscribeItem;

  /// Default false, true if subscribe isolate is created.
  bool _created = false;
  bool get created => _created;

  final DBHelper _dbHelper = DBHelper();

  /// Groups save in shared_prefrences.
  final KeyValueStorage _groupStorage = KeyValueStorage(groupsKey);

  @override
  void addListener(VoidCallback listener) {
    if (_groups.isEmpty) {
      loadGroups().then((value) => super.addListener(listener));
      gpodderSyncNow();
    }
  }

  @override
  void dispose() {
    subIsolate?.kill();
    subIsolate = null;
    super.dispose();
  }

  /// Subscribe podcast via isolate.
  /// Add subsribe item
  SubscribeItem _subscribeItem;
  setSubscribeItem(SubscribeItem item, {bool syncGpodder = true}) async {
    _subscribeItem = item;
    if (syncGpodder) _syncAdd(item.url);
    await _start();
  }

  _setCurrentSubscribeItem(SubscribeItem item) {
    _currentSubscribeItem = item;
    notifyListeners();
  }

  Future<void> _syncAdd(String rssUrl) async {
    final check = await _checkGpodderLoggedin();
    if (check) {
      await _addStorage.addList([rssUrl]);
    }
  }

  Future<void> _start() async {
    if (!_created) {
      await _createIsolate();
      _created = true;
      listen();
    } else {
      subSendPort.send([
        _subscribeItem.url,
        _subscribeItem.title,
        _subscribeItem.imgUrl,
        _subscribeItem.group,
      ]);
    }
  }

  Future<void> _createIsolate() async {
    receivePort = ReceivePort();
    subIsolate =
        await FlutterIsolate.spawn(subIsolateEntryPoint, receivePort.sendPort);
  }

  /// Isolate listener to get subscrribe status.
  void listen() {
    receivePort.distinct().listen((message) {
      if (message is SendPort) {
        subSendPort = message;
        subSendPort.send([
          _subscribeItem.url,
          _subscribeItem.title,
          _subscribeItem.imgUrl,
          _subscribeItem.group,
        ]);
      } else if (message is List) {
        _setCurrentSubscribeItem(SubscribeItem(
          message[1],
          message[0],
          subscribeState: SubscribeState.values[message[2]],
        ));
        if (message.length == 5) {
          _subscribeNewPodcast(id: message[3], groupName: message[4]);
        }
      } else if (message is String && message == "done") {
        subIsolate.kill();
        subIsolate = null;
        _currentSubscribeItem = SubscribeItem('', '');
        _created = false;
        notifyListeners();
      }
    });
  }

  ///Set gpodder sync
  final _loginInfp = KeyValueStorage(gpodderApiKey);
  final _addStorage = KeyValueStorage(gpodderAddKey);
  final _removeStorage = KeyValueStorage(gpodderRemoveKey);
  final _remoteAddStorage = KeyValueStorage(gpodderRemoteAddKey);
  final _remoteRemoveStorage = KeyValueStorage(gpodderRemoteRemoveKey);

  Future<bool> _checkGpodderLoggedin() async {
    final loginInfo = await _loginInfp.getStringList();
    return loginInfo.isNotEmpty;
  }

  Future<void> gpodderSyncNow() async {
    final addList = await _remoteAddStorage.getStringList();
    final removeList = await _remoteRemoveStorage.getStringList();

    if (removeList.isNotEmpty) {
      for (var rssLink in removeList) {
        final exist = await _dbHelper.checkPodcast(rssLink);
        if (exist != '') {
          var podcast = await _dbHelper.getPodcastWithUrl(rssLink);
          await _unsubscribe(podcast);
        }
      }
      await _remoteAddStorage.clearList();
    }
    if (addList.isNotEmpty) {
      for (var rssLink in addList) {
        final exist = await _dbHelper.checkPodcast(rssLink);
        if (exist == '') {
          var item = SubscribeItem(rssLink, rssLink, group: 'Home');
          _subscribeItem = item;
          await _start();

          await Future.delayed(Duration(milliseconds: 200));
        }
      }
      await _remoteRemoveStorage.clearList();
    }
  }

  void setWorkManager() {
    Workmanager.initialize(
      callbackDispatcher,
      isInDebugMode: false,
    );
    Workmanager.registerPeriodicTask("2", "gpodder_sync",
        frequency: Duration(hours: 4),
        initialDelay: Duration(seconds: 10),
        constraints: Constraints(
          networkType: NetworkType.connected,
        ));
    developer.log('work manager init done + (gpodder sync)');
  }

  Future cancelWork() async {
    await Workmanager.cancelByUniqueName('2');
    developer.log('work job cancelled');
  }

  /// Mange groups states in app.
  /// Load groups from storage at start.
  Future<void> loadGroups() async {
    _groupStorage.getGroups().then((loadgroups) async {
      _groups.addAll(loadgroups.map(PodcastGroup.fromEntity));
      for (var group in _groups) {
        await group.getPodcasts();
      }
      _groups = [...groups];
      notifyListeners();
    });
  }

  void addToOrderChanged(PodcastGroup group) {
    if (_orderChanged.contains(group)) {
      _orderChanged = [for (var g in _orderChanged) g == group ? group : g];
    } else {
      _orderChanged = [..._orderChanged, group];
    }
    notifyListeners();
  }

  void drlFromOrderChanged(String name) {
    _orderChanged = [
      for (var group in _orderChanged)
        if (group.name != name) group
    ];
    notifyListeners();
  }

  void clearOrderChanged() {
    _orderChanged.clear();
  }

  /// Update podcasts of each group
  Future<void> updateGroups() async {
    for (var group in _groups) {
      await group.getPodcasts();
    }
    _groups = [..._groups];
    notifyListeners();
  }

  /// Add new group.
  Future<void> addGroup(PodcastGroup podcastGroup) async {
    _groups = [..._groups, podcastGroup];
    notifyListeners();
    await _saveGroup();
  }

  /// Remove group.
  Future<void> delGroup(PodcastGroup podcastGroup) async {
    for (var podcast in podcastGroup.podcasts) {
      if (!_groups.first.podcasts.contains(podcast)) {
        _groups.first.addToGroup(podcast);
      }
    }
    _groups = [
      for (var group in _groups)
        if (group.id != podcastGroup.id) group
    ];
    notifyListeners();
    await _saveGroup();
  }

  Future<void> updateGroup(PodcastGroup podcastGroup) async {
    _groups = [
      for (var group in _groups) group == podcastGroup ? podcastGroup : group
    ];
    notifyListeners();
    _saveGroup();
  }

  Future<void> _updateGroups() async {
    _groups = [..._groups];
    notifyListeners();
    await _saveGroup();
  }

  Future<void> _saveGroup() async {
    await _groupStorage.saveGroup(_groups.map((it) => it.toEntity()).toList());
  }

  /// Subscribe podcast from search result.
  Future subscribe(PodcastLocal podcast) async {
    await _dbHelper.savePodcastLocal(podcast);
    _groups.first.addToGroupAt(podcast);
    _updateGroups();
  }

  /// Subscribe podcast from OPML.
  Future<bool> _subscribeNewPodcast(
      {String id, String groupName = 'Home'}) async {
    //List<String> groupNames = _groups.map((e) => e.name).toList();
    var podcasts = await _dbHelper.getPodcastLocal([id]);
    for (var group in _groups) {
      if (group.name == groupName) {
        if (group.podcastList.contains(id)) {
          return true;
        } else {
          group.addToGroupAt(podcasts.first);
          _updateGroups();
          return true;
        }
      }
    }
    _groups = [
      ..._groups,
      PodcastGroup(groupName, podcastList: [id], podcasts: podcasts)
    ];
    notifyListeners();
    await _saveGroup();
    return true;
  }

  List<PodcastGroup> getPodcastGroup(String id) {
    var result = <PodcastGroup>[];
    for (var group in _groups) {
      if (group.podcastList.contains(id)) {
        result.add(group);
      }
    }
    return result;
  }

  //Change podcast groups
  Future<void> changeGroup(
      PodcastLocal podcast, List<PodcastGroup> list) async {
    for (var group in getPodcastGroup(podcast.id)) {
      if (list.contains(group)) {
        list.remove(group);
      } else {
        group.deleteFromGroup(podcast);
      }
    }
    for (var s in list) {
      s.addToGroup(podcast);
    }
    _updateGroups();
  }

  /// Unsubscribe podcast
  Future<void> _syncRemove(String rssUrl) async {
    final check = await _checkGpodderLoggedin();
    if (check) {
      await _removeStorage.addList([rssUrl]);
    }
  }

  Future<void> _unsubscribe(PodcastLocal podcast) async {
    for (var group in _groups) {
      group.deleteFromGroup(podcast);
    }
    _updateGroups();
    await _dbHelper.delPodcastLocal(podcast.id);
  }

  /// Delete podcsat from device.
  Future<void> removePodcast(
    PodcastLocal podcast,
  ) async {
    _syncRemove(podcast.rssUrl);
    await _unsubscribe(podcast);
    await File(podcast.imagePath)?.delete();
  }

  Future<void> saveOrder(PodcastGroup group) async {
    // group.podcastList = group.orderedPodcasts.map((e) => e.id).toList();
    var orderedGroup;
    for (var g in _orderChanged) {
      if (g == group) orderedGroup = g;
    }
    _groups = [for (var g in _groups) g == orderedGroup ? orderedGroup : g];
    notifyListeners();
    await _saveGroup();
  }
}

Future<void> subIsolateEntryPoint(SendPort sendPort) async {
  var items = <SubscribeItem>[];
  var _running = false;
  final listColor = <String>[
    '388E3C',
    '1976D2',
    'D32F2F',
    '00796B',
  ];
  var subReceivePort = ReceivePort();
  sendPort.send(subReceivePort.sendPort);

  Future<String> _getColor(File file) async {
    final imageProvider = FileImage(file);
    var colorImage = await getImageFromProvider(imageProvider);
    var color = await getColorFromImage(colorImage);
    var primaryColor = color.toString();
    return primaryColor;
  }

  Future<void> _subscribe(SubscribeItem item) async {
    var dbHelper = DBHelper();
    var rss = item.url;
    sendPort.send([item.title, item.url, 1]);
    var options = BaseOptions(
      connectTimeout: 30000,
      receiveTimeout: 90000,
    );

    try {
      var response = await Dio(options).get(rss);
      RssFeed p;
      try {
        p = RssFeed.parse(response.data);
      } catch (e) {
        developer.log('Parse error', error: e);
        sendPort.send([item.title, item.url, 6]);
        await Future.delayed(Duration(seconds: 2));
        sendPort.send([item.title, item.url, 4]);
        items.removeWhere((element) => element.url == item.url);
        if (items.isNotEmpty) {
          await _subscribe(items.first);
        } else {
          sendPort.send("done");
        }
      }

      var dir = await getApplicationDocumentsDirectory();

      var realUrl =
          response.redirects.isEmpty ? rss : response.realUri.toString();

      var checkUrl = await dbHelper.checkPodcast(realUrl);

      /// If url not existe in database.
      if (checkUrl == '') {
        img.Image thumbnail;
        String imageUrl;
        try {
          var imageResponse = await Dio().get<List<int>>(p.itunes.image.href,
              options: Options(
                responseType: ResponseType.bytes,
                receiveTimeout: 90000,
              ));
          imageUrl = p.itunes.image.href;
          var image = img.decodeImage(imageResponse.data);
          thumbnail = img.copyResize(image, width: 300);
        } catch (e) {
          try {
            var imageResponse = await Dio().get<List<int>>(item.imgUrl,
                options: Options(
                  responseType: ResponseType.bytes,
                  receiveTimeout: 90000,
                ));
            imageUrl = item.imgUrl;
            var image = img.decodeImage(imageResponse.data);
            thumbnail = img.copyResize(image, width: 300);
          } catch (e) {
            developer.log(e.toString(), name: 'Download image error');
            try {
              var index = math.Random().nextInt(3);
              var imageResponse = await Dio().get<List<int>>(
                  "https://ui-avatars.com/api/?size=300&background="
                  "${listColor[index]}&color=fff&name=${item.title}&length=2&bold=true",
                  options: Options(responseType: ResponseType.bytes));
              imageUrl = "https://ui-avatars.com/api/?size=300&background="
                  "${listColor[index]}&color=fff&name=${item.title}&length=2&bold=true";
              thumbnail = img.decodeImage(imageResponse.data);
            } catch (e) {
              developer.log(e.toString(), name: 'Donwload image error');
              sendPort.send([item.title, item.url, 6]);
              await Future.delayed(Duration(seconds: 2));
              sendPort.send([item.title, item.url, 4]);
              items.removeWhere((element) => element.url == item.url);
              if (items.length > 0) {
                await _subscribe(items.first);
              } else {
                sendPort.send("done");
              }
            }
          }
        }
        var uuid = Uuid().v4();
        File("${dir.path}/$uuid.png")..writeAsBytesSync(img.encodePng(thumbnail));
        var imagePath = "${dir.path}/$uuid.png";
        var primaryColor = await _getColor(File(imagePath));
        var author = p.itunes.author ?? p.author ?? '';
        var provider = p.generator ?? '';
        var link = p.link ?? '';
        var funding = p.podcastFunding.isNotEmpty
            ? [for (var f in p.podcastFunding) f.url]
            : <String>[];
        var podcastLocal = PodcastLocal(p.title, imageUrl, realUrl,
            primaryColor, author, uuid, imagePath, provider, link, funding,
            description: p.description);

        await dbHelper.savePodcastLocal(podcastLocal);

        sendPort.send([item.title, item.url, 2, uuid, item.group]);

        if (provider.contains('fireside')) {
          var data = FiresideData(uuid, link);
          try {
            await data.fatchData();
          } catch (e) {
            developer.log(e.toString(), name: 'Fatch fireside data error');
          }
        }
        await dbHelper.savePodcastRss(p, uuid);

        sendPort.send([item.title, item.url, 3, uuid]);

        await Future.delayed(Duration(seconds: 2));

        sendPort.send([item.title, item.url, 4]);
        items.removeAt(0);
        if (items.length > 0) {
          await _subscribe(items.first);
        } else {
          sendPort.send("done");
        }
      } else {
        sendPort.send([item.title, realUrl, 5, checkUrl, item.group]);
        await Future.delayed(Duration(seconds: 2));
        sendPort.send([item.title, item.url, 4]);
        items.removeAt(0);
        if (items.length > 0) {
          await _subscribe(items.first);
        } else {
          sendPort.send("done");
        }
      }
    } catch (e) {
      developer.log('$e confirm');
      sendPort.send([item.title, item.url, 6]);
      await Future.delayed(Duration(seconds: 2));
      sendPort.send([item.title, item.url, 4]);
      items.removeWhere((element) => element.url == item.url);
      if (items.length > 0) {
        await _subscribe(items.first);
      } else {
        sendPort.send("done");
      }
    }
  }

  subReceivePort.distinct().listen((message) {
    if (message is List<dynamic>) {
      items.add(SubscribeItem(message[0], message[1],
          imgUrl: message[2], group: message[3]));
      if (!_running) {
        _subscribe(items.first);
        _running = true;
      }
    }
  });
}