cake_wallet/lib/utils/mobx.dart

import 'dart:async';
import 'package:hive/hive.dart';
import 'package:mobx/mobx.dart';

mixin Keyable {
  dynamic keyIndex;
}

void connectDifferent<T extends Keyable, Y extends Keyable>(
    ObservableList<T> source, ObservableList<Y> dest, Y Function(T) transform,
    {bool Function(T) filter}) {
  source.observe((ListChange<T> change) {
    change.elementChanges.forEach((change) {
      switch (change.type) {
        case OperationType.add:
          if (filter?.call(change.newValue as T) ?? true) {
            dest.add(transform(change.newValue as T));
          }
          break;
        case OperationType.remove:
          // Hive could has equal index and key
          dest.removeWhere(
              (elem) => elem.keyIndex == (change.oldValue.key ?? change.index));
          break;
        case OperationType.update:
          for (var i = 0; i < dest.length; i++) {
            final item = dest[i];

            if (item.keyIndex == change.newValue.key) {
              dest[i] = transform(change.newValue as T);
            }
          }
          break;
      }
    });
  });
}

void connect<T extends Keyable>(
    ObservableList<T> source, ObservableList<T> dest) {
  source.observe((ListChange<T> change) {
    source.observe((ListChange<T> change) {
      change.elementChanges.forEach((change) {
        switch (change.type) {
          case OperationType.add:
            // if (filter?.call(change.newValue as T) ?? true) {
            dest.add(change.newValue as T);
            // }
            break;
          case OperationType.remove:
            // Hive could has equal index and key
            dest.removeWhere((elem) =>
                elem.keyIndex == (change.oldValue.key ?? change.index));
            break;
          case OperationType.update:
            for (var i = 0; i < dest.length; i++) {
              final item = dest[i];

              if (item.keyIndex == change.newValue.key) {
                dest[i] = change.newValue as T;
              }
            }
            break;
        }
      });
    });
  });
}

StreamSubscription<BoxEvent> bindBox<T extends Keyable>(
    Box<T> source, ObservableList<T> dest) {
  return source.watch().listen((event) {
    if (event.deleted) {
      dest.removeWhere((el) => el.keyIndex == event.key);
    }

    final dynamic value = event.value;

    if (value is T) {
      final elIndex = dest.indexWhere((el) => el.keyIndex == value.keyIndex);

      if (elIndex > -1) {
        dest[elIndex] = value;
      } else {
        dest.add(value);
      }
    }
  });
}