Compare commits
4
Commits
v2.1
..
cfb551328b
| Author | SHA1 | Date | |
|---|---|---|---|
|
|
cfb551328b | ||
|
|
40366f0708 | ||
|
|
2e40786bcd | ||
|
|
38bcf01ae3 |
@@ -94,6 +94,8 @@ class HomeFilterWidget {
|
|||||||
this.showAmountIn = true,
|
this.showAmountIn = true,
|
||||||
this.showAmountOut = true,
|
this.showAmountOut = true,
|
||||||
this.showCount = true,
|
this.showCount = true,
|
||||||
|
this.updatedAt = 0,
|
||||||
|
this.deleted = false,
|
||||||
});
|
});
|
||||||
|
|
||||||
final String id;
|
final String id;
|
||||||
@@ -129,6 +131,12 @@ class HomeFilterWidget {
|
|||||||
final bool showAmountOut;
|
final bool showAmountOut;
|
||||||
final bool showCount;
|
final bool showCount;
|
||||||
|
|
||||||
|
/// Epoch ms; used for last-write-wins sync across devices.
|
||||||
|
final int updatedAt;
|
||||||
|
|
||||||
|
/// Soft-delete so removals propagate via sync instead of being recreated.
|
||||||
|
final bool deleted;
|
||||||
|
|
||||||
IconData get icon => HomeWidgetIcons.iconFor(iconId);
|
IconData get icon => HomeWidgetIcons.iconFor(iconId);
|
||||||
|
|
||||||
TransactionFilterSelection get filter => TransactionFilterSelection(
|
TransactionFilterSelection get filter => TransactionFilterSelection(
|
||||||
@@ -161,6 +169,9 @@ class HomeFilterWidget {
|
|||||||
bool? showAmountIn,
|
bool? showAmountIn,
|
||||||
bool? showAmountOut,
|
bool? showAmountOut,
|
||||||
bool? showCount,
|
bool? showCount,
|
||||||
|
int? updatedAt,
|
||||||
|
bool? deleted,
|
||||||
|
bool touchUpdatedAt = false,
|
||||||
}) {
|
}) {
|
||||||
return HomeFilterWidget(
|
return HomeFilterWidget(
|
||||||
id: id ?? this.id,
|
id: id ?? this.id,
|
||||||
@@ -183,6 +194,10 @@ class HomeFilterWidget {
|
|||||||
showAmountIn: showAmountIn ?? this.showAmountIn,
|
showAmountIn: showAmountIn ?? this.showAmountIn,
|
||||||
showAmountOut: showAmountOut ?? this.showAmountOut,
|
showAmountOut: showAmountOut ?? this.showAmountOut,
|
||||||
showCount: showCount ?? this.showCount,
|
showCount: showCount ?? this.showCount,
|
||||||
|
updatedAt: touchUpdatedAt
|
||||||
|
? DateTime.now().millisecondsSinceEpoch
|
||||||
|
: (updatedAt ?? this.updatedAt),
|
||||||
|
deleted: deleted ?? this.deleted,
|
||||||
);
|
);
|
||||||
}
|
}
|
||||||
|
|
||||||
@@ -208,6 +223,7 @@ class HomeFilterWidget {
|
|||||||
showAmountIn: showIn,
|
showAmountIn: showIn,
|
||||||
showAmountOut: showOut,
|
showAmountOut: showOut,
|
||||||
showCount: true,
|
showCount: true,
|
||||||
|
updatedAt: DateTime.now().millisecondsSinceEpoch,
|
||||||
);
|
);
|
||||||
}
|
}
|
||||||
|
|
||||||
@@ -236,6 +252,8 @@ class HomeFilterWidget {
|
|||||||
'showAmountIn': showAmountIn,
|
'showAmountIn': showAmountIn,
|
||||||
'showAmountOut': showAmountOut,
|
'showAmountOut': showAmountOut,
|
||||||
'showCount': showCount,
|
'showCount': showCount,
|
||||||
|
'updatedAt': updatedAt,
|
||||||
|
'deleted': deleted,
|
||||||
};
|
};
|
||||||
|
|
||||||
factory HomeFilterWidget.fromJson(Map<String, dynamic> json) {
|
factory HomeFilterWidget.fromJson(Map<String, dynamic> json) {
|
||||||
@@ -302,21 +320,31 @@ class HomeFilterWidget {
|
|||||||
showAmountIn: json['showAmountIn'] as bool? ?? true,
|
showAmountIn: json['showAmountIn'] as bool? ?? true,
|
||||||
showAmountOut: json['showAmountOut'] as bool? ?? true,
|
showAmountOut: json['showAmountOut'] as bool? ?? true,
|
||||||
showCount: json['showCount'] as bool? ?? true,
|
showCount: json['showCount'] as bool? ?? true,
|
||||||
|
updatedAt: asInt(json['updatedAt'] ?? json['updated_at'], 0),
|
||||||
|
deleted: json['deleted'] as bool? ?? false,
|
||||||
);
|
);
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
/// Union home widgets by id (local wins on conflict).
|
/// Union home widgets by id with last-write-wins on [HomeFilterWidget.updatedAt].
|
||||||
List<HomeFilterWidget> mergeHomeFilterWidgets(
|
List<HomeFilterWidget> mergeHomeFilterWidgets(
|
||||||
List<HomeFilterWidget> local,
|
List<HomeFilterWidget> local,
|
||||||
List<HomeFilterWidget> remote,
|
List<HomeFilterWidget> remote,
|
||||||
) {
|
) {
|
||||||
final byId = <String, HomeFilterWidget>{
|
final byId = <String, HomeFilterWidget>{};
|
||||||
for (final w in remote) w.id: w,
|
void put(HomeFilterWidget w) {
|
||||||
};
|
final existing = byId[w.id];
|
||||||
for (final w in local) {
|
if (existing == null || w.updatedAt >= existing.updatedAt) {
|
||||||
byId[w.id] = w;
|
byId[w.id] = w;
|
||||||
}
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
for (final w in remote) {
|
||||||
|
put(w);
|
||||||
|
}
|
||||||
|
for (final w in local) {
|
||||||
|
put(w);
|
||||||
|
}
|
||||||
final merged = byId.values.toList()
|
final merged = byId.values.toList()
|
||||||
..sort((a, b) => a.sortOrder.compareTo(b.sortOrder));
|
..sort((a, b) => a.sortOrder.compareTo(b.sortOrder));
|
||||||
return merged;
|
return merged;
|
||||||
|
|||||||
@@ -16,6 +16,8 @@ class OverviewFavourite {
|
|||||||
this.flow = TxFlowFilter.expense,
|
this.flow = TxFlowFilter.expense,
|
||||||
this.barStyle = LabelChartBarStyle.parallel,
|
this.barStyle = LabelChartBarStyle.parallel,
|
||||||
this.invertExpensePerspective = false,
|
this.invertExpensePerspective = false,
|
||||||
|
this.updatedAt = 0,
|
||||||
|
this.deleted = false,
|
||||||
});
|
});
|
||||||
|
|
||||||
final String id;
|
final String id;
|
||||||
@@ -34,6 +36,12 @@ class OverviewFavourite {
|
|||||||
final LabelChartBarStyle barStyle;
|
final LabelChartBarStyle barStyle;
|
||||||
final bool invertExpensePerspective;
|
final bool invertExpensePerspective;
|
||||||
|
|
||||||
|
/// Epoch ms; used for last-write-wins sync across devices.
|
||||||
|
final int updatedAt;
|
||||||
|
|
||||||
|
/// Soft-delete so removals propagate via sync instead of being recreated.
|
||||||
|
final bool deleted;
|
||||||
|
|
||||||
OverviewFavourite copyWith({
|
OverviewFavourite copyWith({
|
||||||
String? id,
|
String? id,
|
||||||
String? name,
|
String? name,
|
||||||
@@ -44,6 +52,9 @@ class OverviewFavourite {
|
|||||||
TxFlowFilter? flow,
|
TxFlowFilter? flow,
|
||||||
LabelChartBarStyle? barStyle,
|
LabelChartBarStyle? barStyle,
|
||||||
bool? invertExpensePerspective,
|
bool? invertExpensePerspective,
|
||||||
|
int? updatedAt,
|
||||||
|
bool? deleted,
|
||||||
|
bool touchUpdatedAt = false,
|
||||||
}) {
|
}) {
|
||||||
return OverviewFavourite(
|
return OverviewFavourite(
|
||||||
id: id ?? this.id,
|
id: id ?? this.id,
|
||||||
@@ -56,6 +67,10 @@ class OverviewFavourite {
|
|||||||
barStyle: barStyle ?? this.barStyle,
|
barStyle: barStyle ?? this.barStyle,
|
||||||
invertExpensePerspective:
|
invertExpensePerspective:
|
||||||
invertExpensePerspective ?? this.invertExpensePerspective,
|
invertExpensePerspective ?? this.invertExpensePerspective,
|
||||||
|
updatedAt: touchUpdatedAt
|
||||||
|
? DateTime.now().millisecondsSinceEpoch
|
||||||
|
: (updatedAt ?? this.updatedAt),
|
||||||
|
deleted: deleted ?? this.deleted,
|
||||||
);
|
);
|
||||||
}
|
}
|
||||||
|
|
||||||
@@ -69,9 +84,18 @@ class OverviewFavourite {
|
|||||||
'flow': flow.name,
|
'flow': flow.name,
|
||||||
'barStyle': barStyle.name,
|
'barStyle': barStyle.name,
|
||||||
'invertExpensePerspective': invertExpensePerspective,
|
'invertExpensePerspective': invertExpensePerspective,
|
||||||
|
'updatedAt': updatedAt,
|
||||||
|
'deleted': deleted,
|
||||||
};
|
};
|
||||||
|
|
||||||
factory OverviewFavourite.fromJson(Map<String, dynamic> json) {
|
factory OverviewFavourite.fromJson(Map<String, dynamic> json) {
|
||||||
|
final rawUpdated = json['updatedAt'] ?? json['updated_at'];
|
||||||
|
final updatedAt = switch (rawUpdated) {
|
||||||
|
int n => n,
|
||||||
|
num n => n.round(),
|
||||||
|
String s => int.tryParse(s) ?? 0,
|
||||||
|
_ => 0,
|
||||||
|
};
|
||||||
return OverviewFavourite(
|
return OverviewFavourite(
|
||||||
id: json['id'] as String? ?? 'fav_${DateTime.now().millisecondsSinceEpoch}',
|
id: json['id'] as String? ?? 'fav_${DateTime.now().millisecondsSinceEpoch}',
|
||||||
name: (json['name'] as String?)?.trim().isNotEmpty == true
|
name: (json['name'] as String?)?.trim().isNotEmpty == true
|
||||||
@@ -100,6 +124,8 @@ class OverviewFavourite {
|
|||||||
),
|
),
|
||||||
invertExpensePerspective:
|
invertExpensePerspective:
|
||||||
json['invertExpensePerspective'] as bool? ?? false,
|
json['invertExpensePerspective'] as bool? ?? false,
|
||||||
|
updatedAt: updatedAt,
|
||||||
|
deleted: json['deleted'] as bool? ?? false,
|
||||||
);
|
);
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
@@ -107,3 +133,25 @@ class OverviewFavourite {
|
|||||||
enum OverviewMetricMode { flow, labels }
|
enum OverviewMetricMode { flow, labels }
|
||||||
|
|
||||||
enum OverviewPeriodMode { monthly, yearly }
|
enum OverviewPeriodMode { monthly, yearly }
|
||||||
|
|
||||||
|
/// Union favourites by id with last-write-wins on [OverviewFavourite.updatedAt].
|
||||||
|
List<OverviewFavourite> mergeOverviewFavourites(
|
||||||
|
List<OverviewFavourite> local,
|
||||||
|
List<OverviewFavourite> remote,
|
||||||
|
) {
|
||||||
|
final byId = <String, OverviewFavourite>{};
|
||||||
|
void put(OverviewFavourite fav) {
|
||||||
|
final existing = byId[fav.id];
|
||||||
|
if (existing == null || fav.updatedAt >= existing.updatedAt) {
|
||||||
|
byId[fav.id] = fav;
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
for (final fav in remote) {
|
||||||
|
put(fav);
|
||||||
|
}
|
||||||
|
for (final fav in local) {
|
||||||
|
put(fav);
|
||||||
|
}
|
||||||
|
return byId.values.toList(growable: false);
|
||||||
|
}
|
||||||
|
|||||||
@@ -91,25 +91,6 @@ class BankController extends ChangeNotifier {
|
|||||||
return false;
|
return false;
|
||||||
}
|
}
|
||||||
|
|
||||||
/// Drop tombstones that match any of [txs] (fingerprint-aware).
|
|
||||||
void clearRemoteDeletesMatching(Iterable<BankTransaction> txs) {
|
|
||||||
final list = txs.toList(growable: false);
|
|
||||||
if (list.isEmpty) return;
|
|
||||||
final next = [
|
|
||||||
for (final tomb in _pendingRemoteDeletes)
|
|
||||||
if (!list.any(tomb.matchesForDelete)) tomb,
|
|
||||||
];
|
|
||||||
if (next.length == _pendingRemoteDeletes.length) return;
|
|
||||||
_pendingRemoteDeletes = next;
|
|
||||||
unawaited(_persistPendingDeletes());
|
|
||||||
}
|
|
||||||
|
|
||||||
void clearAllPendingRemoteDeletes() {
|
|
||||||
if (_pendingRemoteDeletes.isEmpty) return;
|
|
||||||
_pendingRemoteDeletes = const [];
|
|
||||||
unawaited(_persistPendingDeletes());
|
|
||||||
}
|
|
||||||
|
|
||||||
void requeueRemoteDeletes(Iterable<BankTransaction> txs) {
|
void requeueRemoteDeletes(Iterable<BankTransaction> txs) {
|
||||||
for (final tx in txs) {
|
for (final tx in txs) {
|
||||||
_queueRemoteDelete(tx, notify: false);
|
_queueRemoteDelete(tx, notify: false);
|
||||||
@@ -120,11 +101,54 @@ class BankController extends ChangeNotifier {
|
|||||||
void _queueRemoteDelete(BankTransaction tx, {bool notify = true}) {
|
void _queueRemoteDelete(BankTransaction tx, {bool notify = true}) {
|
||||||
if (tx.id.isEmpty) return;
|
if (tx.id.isEmpty) return;
|
||||||
if (_isTombstoned(tx)) return;
|
if (_isTombstoned(tx)) return;
|
||||||
_pendingRemoteDeletes = [..._pendingRemoteDeletes, tx];
|
_pendingRemoteDeletes = [
|
||||||
|
..._pendingRemoteDeletes,
|
||||||
|
tx.copyWith(isManual: true),
|
||||||
|
];
|
||||||
unawaited(_persistPendingDeletes());
|
unawaited(_persistPendingDeletes());
|
||||||
if (notify) onPendingRemoteDeletesChanged?.call();
|
if (notify) onPendingRemoteDeletesChanged?.call();
|
||||||
}
|
}
|
||||||
|
|
||||||
|
/// Merge delete tombstones from another device and strip matching local rows.
|
||||||
|
Future<void> applyRemoteDeletes(
|
||||||
|
List<BankTransaction> remote, {
|
||||||
|
bool notify = true,
|
||||||
|
}) async {
|
||||||
|
var tombsChanged = false;
|
||||||
|
for (final tomb in remote) {
|
||||||
|
if (_isTombstoned(tomb)) continue;
|
||||||
|
_pendingRemoteDeletes = [
|
||||||
|
..._pendingRemoteDeletes,
|
||||||
|
tomb.copyWith(isManual: true),
|
||||||
|
];
|
||||||
|
tombsChanged = true;
|
||||||
|
}
|
||||||
|
if (_pendingRemoteDeletes.isEmpty) return;
|
||||||
|
|
||||||
|
final beforeRemote = _remoteTransactions.length;
|
||||||
|
final beforeImported = _importedTransactions.length;
|
||||||
|
_remoteTransactions = [
|
||||||
|
for (final tx in _remoteTransactions)
|
||||||
|
if (!_isTombstoned(tx)) tx,
|
||||||
|
];
|
||||||
|
_importedTransactions = [
|
||||||
|
for (final tx in _importedTransactions)
|
||||||
|
if (!_isTombstoned(tx)) tx,
|
||||||
|
];
|
||||||
|
final stripped = beforeRemote != _remoteTransactions.length ||
|
||||||
|
beforeImported != _importedTransactions.length;
|
||||||
|
|
||||||
|
if (tombsChanged || stripped) {
|
||||||
|
_invalidateMerged();
|
||||||
|
if (tombsChanged) await _persistPendingDeletes();
|
||||||
|
if (stripped) {
|
||||||
|
await _persistCache();
|
||||||
|
await _persistImported();
|
||||||
|
}
|
||||||
|
if (notify) notifyListeners();
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
Future<void> _persistPendingDeletes() async {
|
Future<void> _persistPendingDeletes() async {
|
||||||
final storage = _storage;
|
final storage = _storage;
|
||||||
if (storage == null) return;
|
if (storage == null) return;
|
||||||
|
|||||||
@@ -42,26 +42,40 @@ class PreferencesController extends ChangeNotifier {
|
|||||||
);
|
);
|
||||||
|
|
||||||
List<OverviewFavourite> get overviewFavourites =>
|
List<OverviewFavourite> get overviewFavourites =>
|
||||||
|
List.unmodifiable([
|
||||||
|
for (final fav in _overviewFavourites)
|
||||||
|
if (!fav.deleted) fav,
|
||||||
|
]);
|
||||||
|
|
||||||
|
/// Full list including soft-deleted rows (for PocketBase push).
|
||||||
|
List<OverviewFavourite> get overviewFavouritesForSync =>
|
||||||
List.unmodifiable(_overviewFavourites);
|
List.unmodifiable(_overviewFavourites);
|
||||||
|
|
||||||
List<OverviewFavourite> get displayedOverviewFavourites => [
|
List<OverviewFavourite> get displayedOverviewFavourites => [
|
||||||
for (final fav in _overviewFavourites)
|
for (final fav in _overviewFavourites)
|
||||||
if (fav.display) fav,
|
if (!fav.deleted && fav.display) fav,
|
||||||
];
|
];
|
||||||
|
|
||||||
bool get hasDisplayedOverviewFavourites =>
|
bool get hasDisplayedOverviewFavourites =>
|
||||||
_overviewFavourites.any((f) => f.display);
|
_overviewFavourites.any((f) => !f.deleted && f.display);
|
||||||
|
|
||||||
List<HomeFilterWidget> get homeFilterWidgets =>
|
List<HomeFilterWidget> get homeFilterWidgets =>
|
||||||
|
List.unmodifiable([
|
||||||
|
for (final w in _homeFilterWidgets)
|
||||||
|
if (!w.deleted) w,
|
||||||
|
]);
|
||||||
|
|
||||||
|
/// Full list including soft-deleted rows (for PocketBase push).
|
||||||
|
List<HomeFilterWidget> get homeFilterWidgetsForSync =>
|
||||||
List.unmodifiable(_homeFilterWidgets);
|
List.unmodifiable(_homeFilterWidgets);
|
||||||
|
|
||||||
List<HomeFilterWidget> get displayedHomeFilterWidgets => [
|
List<HomeFilterWidget> get displayedHomeFilterWidgets => [
|
||||||
for (final w in _homeFilterWidgets)
|
for (final w in _homeFilterWidgets)
|
||||||
if (w.display) w,
|
if (!w.deleted && w.display) w,
|
||||||
];
|
];
|
||||||
|
|
||||||
bool get hasDisplayedHomeFilterWidgets =>
|
bool get hasDisplayedHomeFilterWidgets =>
|
||||||
_homeFilterWidgets.any((w) => w.display);
|
_homeFilterWidgets.any((w) => !w.deleted && w.display);
|
||||||
|
|
||||||
HomeBuiltInSections get homeBuiltInSections => _homeBuiltInSections;
|
HomeBuiltInSections get homeBuiltInSections => _homeBuiltInSections;
|
||||||
|
|
||||||
@@ -118,7 +132,10 @@ class PreferencesController extends ChangeNotifier {
|
|||||||
}
|
}
|
||||||
|
|
||||||
Future<void> addOverviewFavourite(OverviewFavourite favourite) async {
|
Future<void> addOverviewFavourite(OverviewFavourite favourite) async {
|
||||||
_overviewFavourites = [..._overviewFavourites, favourite];
|
final stamped = favourite.updatedAt == 0
|
||||||
|
? favourite.copyWith(touchUpdatedAt: true)
|
||||||
|
: favourite;
|
||||||
|
_overviewFavourites = [..._overviewFavourites, stamped];
|
||||||
notifyListeners();
|
notifyListeners();
|
||||||
await _persistFavourites();
|
await _persistFavourites();
|
||||||
}
|
}
|
||||||
@@ -127,18 +144,19 @@ class PreferencesController extends ChangeNotifier {
|
|||||||
final index = _overviewFavourites.indexWhere((f) => f.id == favourite.id);
|
final index = _overviewFavourites.indexWhere((f) => f.id == favourite.id);
|
||||||
if (index < 0) return;
|
if (index < 0) return;
|
||||||
final next = [..._overviewFavourites];
|
final next = [..._overviewFavourites];
|
||||||
next[index] = favourite;
|
next[index] = favourite.copyWith(touchUpdatedAt: true);
|
||||||
_overviewFavourites = next;
|
_overviewFavourites = next;
|
||||||
notifyListeners();
|
notifyListeners();
|
||||||
await _persistFavourites();
|
await _persistFavourites();
|
||||||
}
|
}
|
||||||
|
|
||||||
Future<void> removeOverviewFavourite(String id) async {
|
Future<void> removeOverviewFavourite(String id) async {
|
||||||
final next = [
|
final index = _overviewFavourites.indexWhere((f) => f.id == id);
|
||||||
for (final fav in _overviewFavourites)
|
if (index < 0) return;
|
||||||
if (fav.id != id) fav,
|
final current = _overviewFavourites[index];
|
||||||
];
|
if (current.deleted) return;
|
||||||
if (next.length == _overviewFavourites.length) return;
|
final next = [..._overviewFavourites];
|
||||||
|
next[index] = current.copyWith(deleted: true, touchUpdatedAt: true);
|
||||||
_overviewFavourites = next;
|
_overviewFavourites = next;
|
||||||
notifyListeners();
|
notifyListeners();
|
||||||
await _persistFavourites();
|
await _persistFavourites();
|
||||||
@@ -148,7 +166,7 @@ class PreferencesController extends ChangeNotifier {
|
|||||||
final index = _overviewFavourites.indexWhere((f) => f.id == id);
|
final index = _overviewFavourites.indexWhere((f) => f.id == id);
|
||||||
if (index < 0) return;
|
if (index < 0) return;
|
||||||
final current = _overviewFavourites[index];
|
final current = _overviewFavourites[index];
|
||||||
if (current.display == display) return;
|
if (current.deleted || current.display == display) return;
|
||||||
await updateOverviewFavourite(current.copyWith(display: display));
|
await updateOverviewFavourite(current.copyWith(display: display));
|
||||||
}
|
}
|
||||||
|
|
||||||
@@ -164,16 +182,20 @@ class PreferencesController extends ChangeNotifier {
|
|||||||
}
|
}
|
||||||
|
|
||||||
Future<void> addHomeFilterWidget(HomeFilterWidget widget) async {
|
Future<void> addHomeFilterWidget(HomeFilterWidget widget) async {
|
||||||
final order = _homeFilterWidgets.isEmpty
|
final order = _homeFilterWidgets.where((w) => !w.deleted).isEmpty
|
||||||
? 0
|
? 0
|
||||||
: _homeFilterWidgets
|
: _homeFilterWidgets
|
||||||
|
.where((w) => !w.deleted)
|
||||||
.map((w) => w.sortOrder)
|
.map((w) => w.sortOrder)
|
||||||
.reduce((a, b) => a > b ? a : b) +
|
.reduce((a, b) => a > b ? a : b) +
|
||||||
1;
|
1;
|
||||||
_homeFilterWidgets = [
|
final stamped = (widget.updatedAt == 0
|
||||||
..._homeFilterWidgets,
|
? widget.copyWith(touchUpdatedAt: true)
|
||||||
widget.copyWith(sortOrder: widget.sortOrder == 0 ? order : widget.sortOrder),
|
: widget)
|
||||||
];
|
.copyWith(
|
||||||
|
sortOrder: widget.sortOrder == 0 ? order : widget.sortOrder,
|
||||||
|
);
|
||||||
|
_homeFilterWidgets = [..._homeFilterWidgets, stamped];
|
||||||
notifyListeners();
|
notifyListeners();
|
||||||
await _persistHomeWidgets();
|
await _persistHomeWidgets();
|
||||||
}
|
}
|
||||||
@@ -182,7 +204,7 @@ class PreferencesController extends ChangeNotifier {
|
|||||||
final index = _homeFilterWidgets.indexWhere((w) => w.id == widget.id);
|
final index = _homeFilterWidgets.indexWhere((w) => w.id == widget.id);
|
||||||
if (index < 0) return;
|
if (index < 0) return;
|
||||||
final next = [..._homeFilterWidgets];
|
final next = [..._homeFilterWidgets];
|
||||||
next[index] = widget;
|
next[index] = widget.copyWith(touchUpdatedAt: true);
|
||||||
next.sort((a, b) => a.sortOrder.compareTo(b.sortOrder));
|
next.sort((a, b) => a.sortOrder.compareTo(b.sortOrder));
|
||||||
_homeFilterWidgets = next;
|
_homeFilterWidgets = next;
|
||||||
notifyListeners();
|
notifyListeners();
|
||||||
@@ -190,11 +212,12 @@ class PreferencesController extends ChangeNotifier {
|
|||||||
}
|
}
|
||||||
|
|
||||||
Future<void> removeHomeFilterWidget(String id) async {
|
Future<void> removeHomeFilterWidget(String id) async {
|
||||||
final next = [
|
final index = _homeFilterWidgets.indexWhere((w) => w.id == id);
|
||||||
for (final w in _homeFilterWidgets)
|
if (index < 0) return;
|
||||||
if (w.id != id) w,
|
final current = _homeFilterWidgets[index];
|
||||||
];
|
if (current.deleted) return;
|
||||||
if (next.length == _homeFilterWidgets.length) return;
|
final next = [..._homeFilterWidgets];
|
||||||
|
next[index] = current.copyWith(deleted: true, touchUpdatedAt: true);
|
||||||
_homeFilterWidgets = next;
|
_homeFilterWidgets = next;
|
||||||
notifyListeners();
|
notifyListeners();
|
||||||
await _persistHomeWidgets();
|
await _persistHomeWidgets();
|
||||||
@@ -204,19 +227,32 @@ class PreferencesController extends ChangeNotifier {
|
|||||||
final index = _homeFilterWidgets.indexWhere((w) => w.id == id);
|
final index = _homeFilterWidgets.indexWhere((w) => w.id == id);
|
||||||
if (index < 0) return;
|
if (index < 0) return;
|
||||||
final current = _homeFilterWidgets[index];
|
final current = _homeFilterWidgets[index];
|
||||||
if (current.display == display) return;
|
if (current.deleted || current.display == display) return;
|
||||||
await updateHomeFilterWidget(current.copyWith(display: display));
|
await updateHomeFilterWidget(current.copyWith(display: display));
|
||||||
}
|
}
|
||||||
|
|
||||||
Future<void> reorderHomeFilterWidgets(int oldIndex, int newIndex) async {
|
Future<void> reorderHomeFilterWidgets(int oldIndex, int newIndex) async {
|
||||||
if (oldIndex == newIndex) return;
|
if (oldIndex == newIndex) return;
|
||||||
final next = [..._homeFilterWidgets];
|
final visible = [
|
||||||
final item = next.removeAt(oldIndex);
|
for (final w in _homeFilterWidgets)
|
||||||
final target = newIndex.clamp(0, next.length);
|
if (!w.deleted) w,
|
||||||
next.insert(target, item);
|
|
||||||
_homeFilterWidgets = [
|
|
||||||
for (var i = 0; i < next.length; i++) next[i].copyWith(sortOrder: i),
|
|
||||||
];
|
];
|
||||||
|
if (oldIndex < 0 || oldIndex >= visible.length) return;
|
||||||
|
final nextVisible = [...visible];
|
||||||
|
final item = nextVisible.removeAt(oldIndex);
|
||||||
|
final target = newIndex.clamp(0, nextVisible.length);
|
||||||
|
nextVisible.insert(target, item);
|
||||||
|
final orderById = <String, int>{
|
||||||
|
for (var i = 0; i < nextVisible.length; i++) nextVisible[i].id: i,
|
||||||
|
};
|
||||||
|
final now = DateTime.now().millisecondsSinceEpoch;
|
||||||
|
_homeFilterWidgets = [
|
||||||
|
for (final w in _homeFilterWidgets)
|
||||||
|
if (w.deleted)
|
||||||
|
w
|
||||||
|
else
|
||||||
|
w.copyWith(sortOrder: orderById[w.id] ?? w.sortOrder, updatedAt: now),
|
||||||
|
]..sort((a, b) => a.sortOrder.compareTo(b.sortOrder));
|
||||||
notifyListeners();
|
notifyListeners();
|
||||||
await _persistHomeWidgets();
|
await _persistHomeWidgets();
|
||||||
}
|
}
|
||||||
|
|||||||
@@ -274,23 +274,42 @@ class SyncController extends ChangeNotifier {
|
|||||||
_armPushDebounce();
|
_armPushDebounce();
|
||||||
}
|
}
|
||||||
|
|
||||||
/// Removes tombstoned bank txs from PocketBase before pull/push can resurrect them.
|
/// Pull shared delete tombstones, then remove matching local bank rows.
|
||||||
|
Future<void> _pullAndApplyTxDeletes(PbSyncService service) async {
|
||||||
|
try {
|
||||||
|
final remote = await service.pullTxDeletes(onStatus: _setStatus);
|
||||||
|
await _bank.applyRemoteDeletes(remote, notify: false);
|
||||||
|
} catch (error) {
|
||||||
|
debugPrint('SyncController: tx_deletes pull skipped ($error)');
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
/// Removes tombstoned bank txs from the transactions collection.
|
||||||
|
///
|
||||||
|
/// Tombstones themselves stay local + synced via `tx_deletes` so other
|
||||||
|
/// devices learn about the delete and do not push the row back.
|
||||||
Future<void> _flushPendingTxDeletes(PbSyncService service) async {
|
Future<void> _flushPendingTxDeletes(PbSyncService service) async {
|
||||||
final pending = List<BankTransaction>.of(_bank.pendingRemoteDeletes);
|
final pending = List<BankTransaction>.of(_bank.pendingRemoteDeletes);
|
||||||
if (pending.isEmpty) return;
|
if (pending.isEmpty) return;
|
||||||
_setStatus('Removing deleted bank txs…');
|
_setStatus('Removing deleted bank txs…');
|
||||||
try {
|
try {
|
||||||
final matched = await service.deleteTransactionsMatching(pending);
|
await service.deleteTransactionsMatching(pending);
|
||||||
if (matched.isNotEmpty) {
|
// Keep tombstones — they must remain until every device has seen them.
|
||||||
_bank.clearRemoteDeletesMatching(matched);
|
|
||||||
}
|
|
||||||
// Do NOT clear unmatched tombstones — they still block pull resurrection
|
|
||||||
// until pushTransactions GC removes the remote rows.
|
|
||||||
} catch (error) {
|
} catch (error) {
|
||||||
debugPrint('SyncController: tx deletes failed ($error)');
|
debugPrint('SyncController: tx deletes failed ($error)');
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
|
Future<void> _pushTxDeletes(PbSyncService service) async {
|
||||||
|
final tombs = List<BankTransaction>.of(_bank.pendingRemoteDeletes);
|
||||||
|
if (tombs.isEmpty) return;
|
||||||
|
try {
|
||||||
|
await service.pushTxDeletes(tombs, onStatus: _setStatus);
|
||||||
|
} catch (error) {
|
||||||
|
debugPrint('SyncController: tx_deletes push skipped ($error)');
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
void _armPushDebounce() {
|
void _armPushDebounce() {
|
||||||
if (!_auth.isLoggedIn) return;
|
if (!_auth.isLoggedIn) return;
|
||||||
if (_syncing) {
|
if (_syncing) {
|
||||||
@@ -323,7 +342,8 @@ class SyncController extends ChangeNotifier {
|
|||||||
|
|
||||||
try {
|
try {
|
||||||
final service = PbSyncService(_auth.client);
|
final service = PbSyncService(_auth.client);
|
||||||
// Delete first — otherwise pull re-merges the row and push recreates it.
|
// Learn deletes from other devices before merging bank txs / pushing.
|
||||||
|
await _pullAndApplyTxDeletes(service);
|
||||||
await _flushPendingTxDeletes(service);
|
await _flushPendingTxDeletes(service);
|
||||||
final remoteMeta = await service.pull(
|
final remoteMeta = await service.pull(
|
||||||
onProgress: (p) {
|
onProgress: (p) {
|
||||||
@@ -352,7 +372,7 @@ class SyncController extends ChangeNotifier {
|
|||||||
);
|
);
|
||||||
}
|
}
|
||||||
final mergedFavourites = mergeOverviewFavourites(
|
final mergedFavourites = mergeOverviewFavourites(
|
||||||
_prefs.overviewFavourites,
|
_prefs.overviewFavouritesForSync,
|
||||||
remoteFavourites,
|
remoteFavourites,
|
||||||
);
|
);
|
||||||
List<HomeFilterWidget> remoteHomeWidgets = const [];
|
List<HomeFilterWidget> remoteHomeWidgets = const [];
|
||||||
@@ -366,7 +386,7 @@ class SyncController extends ChangeNotifier {
|
|||||||
);
|
);
|
||||||
}
|
}
|
||||||
final mergedHomeWidgets = mergeHomeFilterWidgets(
|
final mergedHomeWidgets = mergeHomeFilterWidgets(
|
||||||
_prefs.homeFilterWidgets,
|
_prefs.homeFilterWidgetsForSync,
|
||||||
remoteHomeWidgets,
|
remoteHomeWidgets,
|
||||||
);
|
);
|
||||||
AppCloudPrefs? remoteAppPrefs;
|
AppCloudPrefs? remoteAppPrefs;
|
||||||
@@ -438,6 +458,7 @@ class SyncController extends ChangeNotifier {
|
|||||||
}
|
}
|
||||||
// Retry deletes in case any were queued during the pull/merge window.
|
// Retry deletes in case any were queued during the pull/merge window.
|
||||||
await _flushPendingTxDeletes(service);
|
await _flushPendingTxDeletes(service);
|
||||||
|
await _pushTxDeletes(service);
|
||||||
_pushBankPending = false;
|
_pushBankPending = false;
|
||||||
final tombs = List<BankTransaction>.of(_bank.pendingRemoteDeletes);
|
final tombs = List<BankTransaction>.of(_bank.pendingRemoteDeletes);
|
||||||
final bankSummary = await service.pushTransactions(
|
final bankSummary = await service.pushTransactions(
|
||||||
@@ -448,8 +469,6 @@ class SyncController extends ChangeNotifier {
|
|||||||
onProgress: _setProgress,
|
onProgress: _setProgress,
|
||||||
onStatus: _setStatus,
|
onStatus: _setStatus,
|
||||||
);
|
);
|
||||||
// Push GC removes orphan admin test rows; tombstones are done.
|
|
||||||
_bank.clearAllPendingRemoteDeletes();
|
|
||||||
_lastSyncedAt = DateTime.now();
|
_lastSyncedAt = DateTime.now();
|
||||||
_lastError = null;
|
_lastError = null;
|
||||||
_lastSyncSummary = '$metaSummary\n$bankSummary';
|
_lastSyncSummary = '$metaSummary\n$bankSummary';
|
||||||
@@ -557,7 +576,7 @@ class SyncController extends ChangeNotifier {
|
|||||||
_setStatus('Pushing favourites…');
|
_setStatus('Pushing favourites…');
|
||||||
try {
|
try {
|
||||||
await service.pushOverviewFavourites(
|
await service.pushOverviewFavourites(
|
||||||
_prefs.overviewFavourites,
|
_prefs.overviewFavouritesForSync,
|
||||||
onStatus: _setStatus,
|
onStatus: _setStatus,
|
||||||
);
|
);
|
||||||
parts.add('Favourites updated');
|
parts.add('Favourites updated');
|
||||||
@@ -565,6 +584,7 @@ class SyncController extends ChangeNotifier {
|
|||||||
debugPrint(
|
debugPrint(
|
||||||
'SyncController: overview_favourites push skipped ($error)',
|
'SyncController: overview_favourites push skipped ($error)',
|
||||||
);
|
);
|
||||||
|
_pushFavouritesPending = true;
|
||||||
}
|
}
|
||||||
bump();
|
bump();
|
||||||
}
|
}
|
||||||
@@ -572,7 +592,7 @@ class SyncController extends ChangeNotifier {
|
|||||||
_setStatus('Pushing home widgets…');
|
_setStatus('Pushing home widgets…');
|
||||||
try {
|
try {
|
||||||
await service.pushHomeFilterWidgets(
|
await service.pushHomeFilterWidgets(
|
||||||
_prefs.homeFilterWidgets,
|
_prefs.homeFilterWidgetsForSync,
|
||||||
onStatus: _setStatus,
|
onStatus: _setStatus,
|
||||||
);
|
);
|
||||||
parts.add('Home widgets updated');
|
parts.add('Home widgets updated');
|
||||||
@@ -580,6 +600,7 @@ class SyncController extends ChangeNotifier {
|
|||||||
debugPrint(
|
debugPrint(
|
||||||
'SyncController: home_filter_widgets push skipped ($error)',
|
'SyncController: home_filter_widgets push skipped ($error)',
|
||||||
);
|
);
|
||||||
|
_pushHomeWidgetsPending = true;
|
||||||
}
|
}
|
||||||
bump();
|
bump();
|
||||||
}
|
}
|
||||||
@@ -601,7 +622,10 @@ class SyncController extends ChangeNotifier {
|
|||||||
}
|
}
|
||||||
if (pushBank) {
|
if (pushBank) {
|
||||||
_setStatus('Updating bank txs…');
|
_setStatus('Updating bank txs…');
|
||||||
|
// Other devices may have deleted test txs — learn that before push.
|
||||||
|
await _pullAndApplyTxDeletes(service);
|
||||||
await _flushPendingTxDeletes(service);
|
await _flushPendingTxDeletes(service);
|
||||||
|
await _pushTxDeletes(service);
|
||||||
try {
|
try {
|
||||||
final tombs = List<BankTransaction>.of(_bank.pendingRemoteDeletes);
|
final tombs = List<BankTransaction>.of(_bank.pendingRemoteDeletes);
|
||||||
final summary = await service.pushTransactions(
|
final summary = await service.pushTransactions(
|
||||||
@@ -612,7 +636,6 @@ class SyncController extends ChangeNotifier {
|
|||||||
onProgress: _setProgress,
|
onProgress: _setProgress,
|
||||||
onStatus: _setStatus,
|
onStatus: _setStatus,
|
||||||
);
|
);
|
||||||
_bank.clearAllPendingRemoteDeletes();
|
|
||||||
parts.add(summary);
|
parts.add(summary);
|
||||||
} catch (error) {
|
} catch (error) {
|
||||||
debugPrint('SyncController: bank tx push skipped ($error)');
|
debugPrint('SyncController: bank tx push skipped ($error)');
|
||||||
|
|||||||
@@ -474,7 +474,29 @@ class _OverviewScreenState extends State<OverviewScreen> {
|
|||||||
),
|
),
|
||||||
);
|
);
|
||||||
},
|
},
|
||||||
onMonthTap: (month) => _openPeriod(context, month),
|
onMonthTap: (month, {labelId, flow}) => _openPeriod(
|
||||||
|
context,
|
||||||
|
month,
|
||||||
|
labelId: labelId,
|
||||||
|
labelIds: {
|
||||||
|
for (final id in favourite.labelIds) id,
|
||||||
|
},
|
||||||
|
flow: flow ??
|
||||||
|
(favourite.metric == OverviewMetricMode.labels
|
||||||
|
? favourite.flow
|
||||||
|
: null),
|
||||||
|
periodMode: favourite.period,
|
||||||
|
),
|
||||||
|
onChartTap: () => _openChartFilter(
|
||||||
|
context,
|
||||||
|
labelIds: {
|
||||||
|
for (final id in favourite.labelIds) id,
|
||||||
|
},
|
||||||
|
flow: favourite.metric == OverviewMetricMode.labels
|
||||||
|
? favourite.flow
|
||||||
|
: null,
|
||||||
|
periodMode: favourite.period,
|
||||||
|
),
|
||||||
);
|
);
|
||||||
}
|
}
|
||||||
|
|
||||||
@@ -590,7 +612,17 @@ class _OverviewScreenState extends State<OverviewScreen> {
|
|||||||
),
|
),
|
||||||
);
|
);
|
||||||
},
|
},
|
||||||
onMonthTap: (month) => _openPeriod(context, month),
|
onMonthTap: (month, {labelId, flow}) => _openPeriod(
|
||||||
|
context,
|
||||||
|
month,
|
||||||
|
labelId: labelId,
|
||||||
|
flow: flow ??
|
||||||
|
(_metric == OverviewMetricMode.labels ? _labelFlow : null),
|
||||||
|
),
|
||||||
|
onChartTap: () => _openChartFilter(
|
||||||
|
context,
|
||||||
|
flow: _metric == OverviewMetricMode.labels ? _labelFlow : null,
|
||||||
|
),
|
||||||
),
|
),
|
||||||
const SizedBox(height: 14),
|
const SizedBox(height: 14),
|
||||||
if (_metric == OverviewMetricMode.flow) ...[
|
if (_metric == OverviewMetricMode.flow) ...[
|
||||||
@@ -739,23 +771,57 @@ class _OverviewScreenState extends State<OverviewScreen> {
|
|||||||
BuildContext context,
|
BuildContext context,
|
||||||
DateTime period, {
|
DateTime period, {
|
||||||
String? labelId,
|
String? labelId,
|
||||||
|
Set<String>? labelIds,
|
||||||
|
TxFlowFilter? flow,
|
||||||
|
OverviewPeriodMode? periodMode,
|
||||||
}) {
|
}) {
|
||||||
final yearly = _period == OverviewPeriodMode.yearly;
|
final mode = periodMode ?? _period;
|
||||||
|
final yearly = mode == OverviewPeriodMode.yearly;
|
||||||
final initial = yearly ? DateTime(period.year, 12) : period;
|
final initial = yearly ? DateTime(period.year, 12) : period;
|
||||||
final labelIds = labelId != null
|
final resolvedLabelIds = labelId != null
|
||||||
? {labelId}
|
? {labelId}
|
||||||
: {
|
: (labelIds ??
|
||||||
|
{
|
||||||
// Open with the same labels currently shown on the chart.
|
// Open with the same labels currently shown on the chart.
|
||||||
for (final id in _includedLabelIds) id,
|
for (final id in _includedLabelIds) id,
|
||||||
|
});
|
||||||
|
Navigator.of(context).push(
|
||||||
|
MaterialPageRoute<void>(
|
||||||
|
builder: (_) => TransactionsScreen(
|
||||||
|
initialMonth: initial,
|
||||||
|
initialLabelIds: resolvedLabelIds,
|
||||||
|
initialLabelMatch: LabelMatchMode.or,
|
||||||
|
initialFlow: flow,
|
||||||
|
initialSearchInMonthOnly: !yearly && resolvedLabelIds.isNotEmpty,
|
||||||
|
initialYear: yearly ? period.year : null,
|
||||||
|
),
|
||||||
|
),
|
||||||
|
);
|
||||||
|
}
|
||||||
|
|
||||||
|
/// Open Transactions with this chart's filters (no specific bar/column).
|
||||||
|
void _openChartFilter(
|
||||||
|
BuildContext context, {
|
||||||
|
Set<String>? labelIds,
|
||||||
|
TxFlowFilter? flow,
|
||||||
|
OverviewPeriodMode? periodMode,
|
||||||
|
}) {
|
||||||
|
final mode = periodMode ?? _period;
|
||||||
|
final yearly = mode == OverviewPeriodMode.yearly;
|
||||||
|
final resolvedLabelIds = labelIds ??
|
||||||
|
{
|
||||||
|
for (final id in _includedLabelIds) id,
|
||||||
};
|
};
|
||||||
Navigator.of(context).push(
|
Navigator.of(context).push(
|
||||||
MaterialPageRoute<void>(
|
MaterialPageRoute<void>(
|
||||||
builder: (_) => TransactionsScreen(
|
builder: (_) => TransactionsScreen(
|
||||||
initialMonth: initial,
|
// Monthly charts show a year — open that whole year with the chart filter.
|
||||||
initialLabelIds: labelIds,
|
initialMonth: yearly ? null : DateTime(_cursor.year, 12),
|
||||||
|
initialYear: yearly ? null : _cursor.year,
|
||||||
|
initialLabelIds: resolvedLabelIds,
|
||||||
initialLabelMatch: LabelMatchMode.or,
|
initialLabelMatch: LabelMatchMode.or,
|
||||||
initialSearchInMonthOnly: !yearly && labelIds.isNotEmpty,
|
initialFlow: flow,
|
||||||
initialYear: yearly ? period.year : null,
|
initialSearchInMonthOnly: false,
|
||||||
),
|
),
|
||||||
),
|
),
|
||||||
);
|
);
|
||||||
@@ -1159,6 +1225,7 @@ class _ChartCard extends StatelessWidget {
|
|||||||
required this.availableLabelCount,
|
required this.availableLabelCount,
|
||||||
required this.onLabelTap,
|
required this.onLabelTap,
|
||||||
required this.onMonthTap,
|
required this.onMonthTap,
|
||||||
|
required this.onChartTap,
|
||||||
this.onPeriodModeChanged,
|
this.onPeriodModeChanged,
|
||||||
this.onEdit,
|
this.onEdit,
|
||||||
});
|
});
|
||||||
@@ -1182,7 +1249,12 @@ class _ChartCard extends StatelessWidget {
|
|||||||
final int? includedLabelCount;
|
final int? includedLabelCount;
|
||||||
final int availableLabelCount;
|
final int availableLabelCount;
|
||||||
final void Function(TxLabel label) onLabelTap;
|
final void Function(TxLabel label) onLabelTap;
|
||||||
final void Function(DateTime month) onMonthTap;
|
final void Function(
|
||||||
|
DateTime month, {
|
||||||
|
String? labelId,
|
||||||
|
TxFlowFilter? flow,
|
||||||
|
}) onMonthTap;
|
||||||
|
final VoidCallback onChartTap;
|
||||||
final ValueChanged<OverviewPeriodMode>? onPeriodModeChanged;
|
final ValueChanged<OverviewPeriodMode>? onPeriodModeChanged;
|
||||||
final VoidCallback? onEdit;
|
final VoidCallback? onEdit;
|
||||||
|
|
||||||
@@ -1277,7 +1349,7 @@ class _ChartCard extends StatelessWidget {
|
|||||||
runSpacing: 2,
|
runSpacing: 2,
|
||||||
alignment: WrapAlignment.end,
|
alignment: WrapAlignment.end,
|
||||||
children: [
|
children: [
|
||||||
for (final row in labelSpend.take(compact ? 3 : 5))
|
for (final row in labelSpend.take(6))
|
||||||
GestureDetector(
|
GestureDetector(
|
||||||
onTap: () => onLabelTap(row.label),
|
onTap: () => onLabelTap(row.label),
|
||||||
child: _LegendDot(
|
child: _LegendDot(
|
||||||
@@ -1286,7 +1358,7 @@ class _ChartCard extends StatelessWidget {
|
|||||||
compact: compact,
|
compact: compact,
|
||||||
),
|
),
|
||||||
),
|
),
|
||||||
if (labelSpend.length > (compact ? 3 : 5))
|
if (labelSpend.length > 6)
|
||||||
_LegendDot(
|
_LegendDot(
|
||||||
color: colors.outline,
|
color: colors.outline,
|
||||||
label: 'Other',
|
label: 'Other',
|
||||||
@@ -1523,12 +1595,16 @@ class _ChartCard extends StatelessWidget {
|
|||||||
],
|
],
|
||||||
SizedBox(
|
SizedBox(
|
||||||
height: chartHeight,
|
height: chartHeight,
|
||||||
|
child: _TappableChartArea(
|
||||||
|
onChartTap: onChartTap,
|
||||||
child: metric == OverviewMetricMode.flow
|
child: metric == OverviewMetricMode.flow
|
||||||
? _FlowBars(
|
? _FlowBars(
|
||||||
months: months,
|
months: months,
|
||||||
monthly: monthly,
|
monthly: monthly,
|
||||||
currency: currency,
|
currency: currency,
|
||||||
period: period,
|
period: period,
|
||||||
|
onMonthTap: onMonthTap,
|
||||||
|
onChartTap: onChartTap,
|
||||||
)
|
)
|
||||||
: _LabelMonthBars(
|
: _LabelMonthBars(
|
||||||
months: months,
|
months: months,
|
||||||
@@ -1539,6 +1615,8 @@ class _ChartCard extends StatelessWidget {
|
|||||||
barStyle: labelBarStyle,
|
barStyle: labelBarStyle,
|
||||||
invertChart: invertChart,
|
invertChart: invertChart,
|
||||||
onMonthTap: onMonthTap,
|
onMonthTap: onMonthTap,
|
||||||
|
onChartTap: onChartTap,
|
||||||
|
),
|
||||||
),
|
),
|
||||||
),
|
),
|
||||||
],
|
],
|
||||||
@@ -1548,18 +1626,89 @@ class _ChartCard extends StatelessWidget {
|
|||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
|
/// Lets empty-chart taps open the chart filter without double-firing when a bar
|
||||||
|
/// was just selected (fl_chart + parent [GestureDetector] both see the tap).
|
||||||
|
class _TappableChartArea extends StatefulWidget {
|
||||||
|
const _TappableChartArea({
|
||||||
|
required this.onChartTap,
|
||||||
|
required this.child,
|
||||||
|
});
|
||||||
|
|
||||||
|
final VoidCallback onChartTap;
|
||||||
|
final Widget child;
|
||||||
|
|
||||||
|
@override
|
||||||
|
State<_TappableChartArea> createState() => _TappableChartAreaState();
|
||||||
|
}
|
||||||
|
|
||||||
|
class _TappableChartAreaState extends State<_TappableChartArea> {
|
||||||
|
var _handling = false;
|
||||||
|
|
||||||
|
void _runExclusive(VoidCallback action) {
|
||||||
|
if (_handling) return;
|
||||||
|
_handling = true;
|
||||||
|
action();
|
||||||
|
Future<void>.delayed(const Duration(milliseconds: 400), () {
|
||||||
|
if (mounted) _handling = false;
|
||||||
|
});
|
||||||
|
}
|
||||||
|
|
||||||
|
void openChartFilter() => _runExclusive(widget.onChartTap);
|
||||||
|
|
||||||
|
void openBar(VoidCallback action) => _runExclusive(action);
|
||||||
|
|
||||||
|
@override
|
||||||
|
Widget build(BuildContext context) {
|
||||||
|
return GestureDetector(
|
||||||
|
behavior: HitTestBehavior.opaque,
|
||||||
|
onTap: openChartFilter,
|
||||||
|
child: _ChartTapScope(
|
||||||
|
openChartFilter: openChartFilter,
|
||||||
|
openBar: openBar,
|
||||||
|
child: widget.child,
|
||||||
|
),
|
||||||
|
);
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
class _ChartTapScope extends InheritedWidget {
|
||||||
|
const _ChartTapScope({
|
||||||
|
required this.openChartFilter,
|
||||||
|
required this.openBar,
|
||||||
|
required super.child,
|
||||||
|
});
|
||||||
|
|
||||||
|
final VoidCallback openChartFilter;
|
||||||
|
final void Function(VoidCallback action) openBar;
|
||||||
|
|
||||||
|
static _ChartTapScope? maybeOf(BuildContext context) {
|
||||||
|
return context.getInheritedWidgetOfExactType<_ChartTapScope>();
|
||||||
|
}
|
||||||
|
|
||||||
|
@override
|
||||||
|
bool updateShouldNotify(_ChartTapScope oldWidget) => false;
|
||||||
|
}
|
||||||
|
|
||||||
class _FlowBars extends StatelessWidget {
|
class _FlowBars extends StatelessWidget {
|
||||||
const _FlowBars({
|
const _FlowBars({
|
||||||
required this.months,
|
required this.months,
|
||||||
required this.monthly,
|
required this.monthly,
|
||||||
required this.currency,
|
required this.currency,
|
||||||
required this.period,
|
required this.period,
|
||||||
|
required this.onMonthTap,
|
||||||
|
required this.onChartTap,
|
||||||
});
|
});
|
||||||
|
|
||||||
final List<DateTime> months;
|
final List<DateTime> months;
|
||||||
final Map<DateTime, _MonthBucket> monthly;
|
final Map<DateTime, _MonthBucket> monthly;
|
||||||
final String currency;
|
final String currency;
|
||||||
final OverviewPeriodMode period;
|
final OverviewPeriodMode period;
|
||||||
|
final void Function(
|
||||||
|
DateTime month, {
|
||||||
|
String? labelId,
|
||||||
|
TxFlowFilter? flow,
|
||||||
|
}) onMonthTap;
|
||||||
|
final VoidCallback onChartTap;
|
||||||
|
|
||||||
@override
|
@override
|
||||||
Widget build(BuildContext context) {
|
Widget build(BuildContext context) {
|
||||||
@@ -1578,7 +1727,10 @@ class _FlowBars extends StatelessWidget {
|
|||||||
});
|
});
|
||||||
|
|
||||||
if (empty) {
|
if (empty) {
|
||||||
return Center(
|
return GestureDetector(
|
||||||
|
behavior: HitTestBehavior.opaque,
|
||||||
|
onTap: onChartTap,
|
||||||
|
child: Center(
|
||||||
child: Text(
|
child: Text(
|
||||||
period == OverviewPeriodMode.yearly
|
period == OverviewPeriodMode.yearly
|
||||||
? 'No income or expenses in these years'
|
? 'No income or expenses in these years'
|
||||||
@@ -1586,6 +1738,7 @@ class _FlowBars extends StatelessWidget {
|
|||||||
style: theme.textTheme.bodyMedium,
|
style: theme.textTheme.bodyMedium,
|
||||||
textAlign: TextAlign.center,
|
textAlign: TextAlign.center,
|
||||||
),
|
),
|
||||||
|
),
|
||||||
);
|
);
|
||||||
}
|
}
|
||||||
|
|
||||||
@@ -1594,6 +1747,29 @@ class _FlowBars extends StatelessWidget {
|
|||||||
maxY: safeMax,
|
maxY: safeMax,
|
||||||
groupsSpace: period == OverviewPeriodMode.yearly ? 16 : 10,
|
groupsSpace: period == OverviewPeriodMode.yearly ? 16 : 10,
|
||||||
barTouchData: BarTouchData(
|
barTouchData: BarTouchData(
|
||||||
|
touchCallback: (event, response) {
|
||||||
|
if (event is! FlTapUpEvent) return;
|
||||||
|
final spot = response?.spot;
|
||||||
|
final index = spot?.touchedBarGroupIndex;
|
||||||
|
if (spot == null ||
|
||||||
|
index == null ||
|
||||||
|
index < 0 ||
|
||||||
|
index >= months.length) {
|
||||||
|
// Parent GestureDetector also handles empty-area taps.
|
||||||
|
return;
|
||||||
|
}
|
||||||
|
final rodIndex = spot.touchedRodDataIndex;
|
||||||
|
// Rods: 0 = expense, 1 = income.
|
||||||
|
final flow = rodIndex == 1
|
||||||
|
? TxFlowFilter.income
|
||||||
|
: TxFlowFilter.expense;
|
||||||
|
final scope = _ChartTapScope.maybeOf(context);
|
||||||
|
if (scope != null) {
|
||||||
|
scope.openBar(() => onMonthTap(months[index], flow: flow));
|
||||||
|
} else {
|
||||||
|
onMonthTap(months[index], flow: flow);
|
||||||
|
}
|
||||||
|
},
|
||||||
touchTooltipData: BarTouchTooltipData(
|
touchTooltipData: BarTouchTooltipData(
|
||||||
getTooltipItem: (group, groupIndex, rod, rodIndex) {
|
getTooltipItem: (group, groupIndex, rod, rodIndex) {
|
||||||
final month = months[group.x.toInt()];
|
final month = months[group.x.toInt()];
|
||||||
@@ -1707,9 +1883,10 @@ class _LabelMonthBars extends StatelessWidget {
|
|||||||
required this.barStyle,
|
required this.barStyle,
|
||||||
required this.invertChart,
|
required this.invertChart,
|
||||||
required this.onMonthTap,
|
required this.onMonthTap,
|
||||||
|
required this.onChartTap,
|
||||||
});
|
});
|
||||||
|
|
||||||
static const _maxSeriesLabels = 5;
|
static const _maxSeriesLabels = 6;
|
||||||
|
|
||||||
final List<DateTime> months;
|
final List<DateTime> months;
|
||||||
final List<_LabelSpend> labelSpend;
|
final List<_LabelSpend> labelSpend;
|
||||||
@@ -1718,7 +1895,12 @@ class _LabelMonthBars extends StatelessWidget {
|
|||||||
final OverviewPeriodMode period;
|
final OverviewPeriodMode period;
|
||||||
final LabelChartBarStyle barStyle;
|
final LabelChartBarStyle barStyle;
|
||||||
final bool invertChart;
|
final bool invertChart;
|
||||||
final void Function(DateTime month) onMonthTap;
|
final void Function(
|
||||||
|
DateTime month, {
|
||||||
|
String? labelId,
|
||||||
|
TxFlowFilter? flow,
|
||||||
|
}) onMonthTap;
|
||||||
|
final VoidCallback onChartTap;
|
||||||
|
|
||||||
double _plot(double value) => invertChart ? -value : value;
|
double _plot(double value) => invertChart ? -value : value;
|
||||||
|
|
||||||
@@ -1727,12 +1909,16 @@ class _LabelMonthBars extends StatelessWidget {
|
|||||||
final theme = Theme.of(context);
|
final theme = Theme.of(context);
|
||||||
final colors = theme.colorScheme;
|
final colors = theme.colorScheme;
|
||||||
if (labelSpend.isEmpty) {
|
if (labelSpend.isEmpty) {
|
||||||
return Center(
|
return GestureDetector(
|
||||||
|
behavior: HitTestBehavior.opaque,
|
||||||
|
onTap: onChartTap,
|
||||||
|
child: Center(
|
||||||
child: Text(
|
child: Text(
|
||||||
'No labeled activity in this period.\nTag transactions to see them here.',
|
'No labeled activity in this period.\nTag transactions to see them here.',
|
||||||
style: theme.textTheme.bodyMedium,
|
style: theme.textTheme.bodyMedium,
|
||||||
textAlign: TextAlign.center,
|
textAlign: TextAlign.center,
|
||||||
),
|
),
|
||||||
|
),
|
||||||
);
|
);
|
||||||
}
|
}
|
||||||
|
|
||||||
@@ -1789,12 +1975,16 @@ class _LabelMonthBars extends StatelessWidget {
|
|||||||
}
|
}
|
||||||
}
|
}
|
||||||
if (maxY == 0 && minY == 0) {
|
if (maxY == 0 && minY == 0) {
|
||||||
return Center(
|
return GestureDetector(
|
||||||
|
behavior: HitTestBehavior.opaque,
|
||||||
|
onTap: onChartTap,
|
||||||
|
child: Center(
|
||||||
child: Text(
|
child: Text(
|
||||||
'No labeled activity in this period.\nTag transactions to see them here.',
|
'No labeled activity in this period.\nTag transactions to see them here.',
|
||||||
style: theme.textTheme.bodyMedium,
|
style: theme.textTheme.bodyMedium,
|
||||||
textAlign: TextAlign.center,
|
textAlign: TextAlign.center,
|
||||||
),
|
),
|
||||||
|
),
|
||||||
);
|
);
|
||||||
}
|
}
|
||||||
final span = (maxY - minY).abs();
|
final span = (maxY - minY).abs();
|
||||||
@@ -1805,12 +1995,12 @@ class _LabelMonthBars extends StatelessWidget {
|
|||||||
final rodWidth = stacked
|
final rodWidth = stacked
|
||||||
? (period == OverviewPeriodMode.yearly ? 18.0 : 14.0)
|
? (period == OverviewPeriodMode.yearly ? 18.0 : 14.0)
|
||||||
: period == OverviewPeriodMode.yearly
|
: period == OverviewPeriodMode.yearly
|
||||||
? (seriesCount <= 3 ? 12.0 : 8.0)
|
? (seriesCount <= 3 ? 12.0 : seriesCount <= 6 ? 8.0 : 6.0)
|
||||||
: (seriesCount <= 3
|
: (seriesCount <= 3
|
||||||
? 7.0
|
? 7.0
|
||||||
: seriesCount <= 5
|
: seriesCount <= 6
|
||||||
? 5.0
|
? 4.5
|
||||||
: 4.0);
|
: 3.5);
|
||||||
|
|
||||||
List<BarChartRodData> rodsFor(DateTime month) {
|
List<BarChartRodData> rodsFor(DateTime month) {
|
||||||
final bucket =
|
final bucket =
|
||||||
@@ -1896,9 +2086,36 @@ class _LabelMonthBars extends StatelessWidget {
|
|||||||
barTouchData: BarTouchData(
|
barTouchData: BarTouchData(
|
||||||
touchCallback: (event, response) {
|
touchCallback: (event, response) {
|
||||||
if (event is! FlTapUpEvent) return;
|
if (event is! FlTapUpEvent) return;
|
||||||
final index = response?.spot?.touchedBarGroupIndex;
|
final spot = response?.spot;
|
||||||
if (index == null || index < 0 || index >= months.length) return;
|
final index = spot?.touchedBarGroupIndex;
|
||||||
onMonthTap(months[index]);
|
if (spot == null ||
|
||||||
|
index == null ||
|
||||||
|
index < 0 ||
|
||||||
|
index >= months.length) {
|
||||||
|
// Parent GestureDetector also handles empty-area taps.
|
||||||
|
return;
|
||||||
|
}
|
||||||
|
String? labelId;
|
||||||
|
if (stacked) {
|
||||||
|
final stackIdx = spot.touchedStackItemIndex;
|
||||||
|
if (stackIdx >= 0 && stackIdx < topLabels.length) {
|
||||||
|
labelId = topLabels[stackIdx].label.id;
|
||||||
|
}
|
||||||
|
} else {
|
||||||
|
final rodIdx = spot.touchedRodDataIndex;
|
||||||
|
if (rodIdx >= 0 && rodIdx < topLabels.length) {
|
||||||
|
labelId = topLabels[rodIdx].label.id;
|
||||||
|
}
|
||||||
|
// Last rod may be "Other" — open month with chart labels only.
|
||||||
|
}
|
||||||
|
final scope = _ChartTapScope.maybeOf(context);
|
||||||
|
if (scope != null) {
|
||||||
|
scope.openBar(
|
||||||
|
() => onMonthTap(months[index], labelId: labelId),
|
||||||
|
);
|
||||||
|
} else {
|
||||||
|
onMonthTap(months[index], labelId: labelId);
|
||||||
|
}
|
||||||
},
|
},
|
||||||
touchTooltipData: BarTouchTooltipData(
|
touchTooltipData: BarTouchTooltipData(
|
||||||
getTooltipItem: (group, groupIndex, rod, rodIndex) {
|
getTooltipItem: (group, groupIndex, rod, rodIndex) {
|
||||||
|
|||||||
@@ -25,20 +25,6 @@ List<BankTransaction> mergeBankTransactionLists(
|
|||||||
return mergeTransactions(local, remote);
|
return mergeTransactions(local, remote);
|
||||||
}
|
}
|
||||||
|
|
||||||
/// Union Overview favourites by client id (local wins on conflict).
|
|
||||||
List<OverviewFavourite> mergeOverviewFavourites(
|
|
||||||
List<OverviewFavourite> local,
|
|
||||||
List<OverviewFavourite> remote,
|
|
||||||
) {
|
|
||||||
final byId = <String, OverviewFavourite>{
|
|
||||||
for (final fav in remote) fav.id: fav,
|
|
||||||
};
|
|
||||||
for (final fav in local) {
|
|
||||||
byId[fav.id] = fav;
|
|
||||||
}
|
|
||||||
return byId.values.toList(growable: false);
|
|
||||||
}
|
|
||||||
|
|
||||||
/// Union-merge so neither device loses annotations on first sync.
|
/// Union-merge so neither device loses annotations on first sync.
|
||||||
TxMetaStoreData mergeTxMetaStores(TxMetaStoreData a, TxMetaStoreData b) {
|
TxMetaStoreData mergeTxMetaStores(TxMetaStoreData a, TxMetaStoreData b) {
|
||||||
final byId = <String, TxMeta>{...a.byId};
|
final byId = <String, TxMeta>{...a.byId};
|
||||||
@@ -485,6 +471,8 @@ class PbSyncService {
|
|||||||
),
|
),
|
||||||
invertExpensePerspective:
|
invertExpensePerspective:
|
||||||
r.getBoolValue('invert_expense_perspective'),
|
r.getBoolValue('invert_expense_perspective'),
|
||||||
|
updatedAt: _recordUpdatedAtMs(r),
|
||||||
|
deleted: r.getBoolValue('deleted'),
|
||||||
),
|
),
|
||||||
);
|
);
|
||||||
}
|
}
|
||||||
@@ -544,6 +532,8 @@ class PbSyncService {
|
|||||||
'showAmountIn': r.getBoolValue('show_amount_in', true),
|
'showAmountIn': r.getBoolValue('show_amount_in', true),
|
||||||
'showAmountOut': r.getBoolValue('show_amount_out', true),
|
'showAmountOut': r.getBoolValue('show_amount_out', true),
|
||||||
'showCount': r.getBoolValue('show_count', true),
|
'showCount': r.getBoolValue('show_count', true),
|
||||||
|
'updatedAt': _recordUpdatedAtMs(r),
|
||||||
|
'deleted': r.getBoolValue('deleted'),
|
||||||
}),
|
}),
|
||||||
);
|
);
|
||||||
}
|
}
|
||||||
@@ -804,6 +794,70 @@ class PbSyncService {
|
|||||||
return matchedTombs;
|
return matchedTombs;
|
||||||
}
|
}
|
||||||
|
|
||||||
|
/// Pull synced delete tombstones for admin test transactions.
|
||||||
|
Future<List<BankTransaction>> pullTxDeletes({
|
||||||
|
void Function(String message)? onStatus,
|
||||||
|
}) async {
|
||||||
|
final userId = _userId;
|
||||||
|
final filter = 'user="$userId"';
|
||||||
|
onStatus?.call('Pulling deleted test txs…');
|
||||||
|
final records = await _fullList('tx_deletes', filter);
|
||||||
|
final out = <BankTransaction>[];
|
||||||
|
for (final r in records) {
|
||||||
|
final tx = _bankTxFromRecord(r);
|
||||||
|
if (tx == null) continue;
|
||||||
|
out.add(tx.copyWith(isManual: true));
|
||||||
|
}
|
||||||
|
debugPrint('PbSyncService pull: tx_deletes=${out.length}');
|
||||||
|
return out;
|
||||||
|
}
|
||||||
|
|
||||||
|
/// Upsert local delete tombstones. Never removes remote-only rows (union).
|
||||||
|
Future<String> pushTxDeletes(
|
||||||
|
List<BankTransaction> tombs, {
|
||||||
|
void Function(String message)? onStatus,
|
||||||
|
}) async {
|
||||||
|
if (tombs.isEmpty) return 'Tx deletes: nothing to push';
|
||||||
|
final userId = _userId;
|
||||||
|
final filter = 'user="$userId"';
|
||||||
|
onStatus?.call('Syncing deleted test txs…');
|
||||||
|
final existing = {
|
||||||
|
for (final r in await _fullList('tx_deletes', filter))
|
||||||
|
r.getStringValue('tx_id'): r,
|
||||||
|
};
|
||||||
|
|
||||||
|
final ops = <_BatchOp>[];
|
||||||
|
var skipped = 0;
|
||||||
|
final seen = <String>{};
|
||||||
|
for (final tomb in tombs) {
|
||||||
|
final syncId = _clip(tomb.id, 2000);
|
||||||
|
if (syncId.isEmpty || !seen.add(syncId)) continue;
|
||||||
|
final body = <String, dynamic>{
|
||||||
|
'user': userId,
|
||||||
|
'tx_id': syncId,
|
||||||
|
'date': _clip(tomb.date, 32),
|
||||||
|
'description': _clip(
|
||||||
|
tomb.description.isEmpty ? 'Unknown' : tomb.description,
|
||||||
|
4000,
|
||||||
|
),
|
||||||
|
'amount': tomb.amount,
|
||||||
|
'currency': _clip(
|
||||||
|
tomb.currency.isEmpty ? 'EUR' : tomb.currency.toUpperCase(),
|
||||||
|
8,
|
||||||
|
),
|
||||||
|
};
|
||||||
|
final remote = existing[syncId];
|
||||||
|
if (remote == null) {
|
||||||
|
ops.add(_BatchOp.create(body));
|
||||||
|
} else {
|
||||||
|
skipped++;
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
await _runWriteOps('tx_deletes', ops, onStatus: onStatus);
|
||||||
|
return 'Tx deletes: local ${tombs.length} (+${ops.length} · $skipped exist)';
|
||||||
|
}
|
||||||
|
|
||||||
Future<void> _runOne(String collection, _BatchOp op) {
|
Future<void> _runOne(String collection, _BatchOp op) {
|
||||||
final col = _pb.collection(collection);
|
final col = _pb.collection(collection);
|
||||||
final Future<dynamic> future;
|
final Future<dynamic> future;
|
||||||
@@ -968,6 +1022,12 @@ class PbSyncService {
|
|||||||
filter =
|
filter =
|
||||||
'user="$userId" && tx_id="${key.replaceAll('"', '\\"')}"';
|
'user="$userId" && tx_id="${key.replaceAll('"', '\\"')}"';
|
||||||
}
|
}
|
||||||
|
case 'tx_deletes':
|
||||||
|
final key = body['tx_id'];
|
||||||
|
if (userId != null && key is String) {
|
||||||
|
filter =
|
||||||
|
'user="$userId" && tx_id="${key.replaceAll('"', '\\"')}"';
|
||||||
|
}
|
||||||
}
|
}
|
||||||
if (filter == null) {
|
if (filter == null) {
|
||||||
throw StateError('Cannot upsert $collection without filter');
|
throw StateError('Cannot upsert $collection without filter');
|
||||||
@@ -1294,6 +1354,8 @@ class PbSyncService {
|
|||||||
'flow': fav.flow.name,
|
'flow': fav.flow.name,
|
||||||
'bar_style': fav.barStyle.name,
|
'bar_style': fav.barStyle.name,
|
||||||
'invert_expense_perspective': fav.invertExpensePerspective,
|
'invert_expense_perspective': fav.invertExpensePerspective,
|
||||||
|
'updated_at': fav.updatedAt,
|
||||||
|
'deleted': fav.deleted,
|
||||||
};
|
};
|
||||||
final remote = existing[clientId];
|
final remote = existing[clientId];
|
||||||
if (remote == null) {
|
if (remote == null) {
|
||||||
@@ -1358,6 +1420,8 @@ class PbSyncService {
|
|||||||
'show_amount_in': w.showAmountIn,
|
'show_amount_in': w.showAmountIn,
|
||||||
'show_amount_out': w.showAmountOut,
|
'show_amount_out': w.showAmountOut,
|
||||||
'show_count': w.showCount,
|
'show_count': w.showCount,
|
||||||
|
'updated_at': w.updatedAt,
|
||||||
|
'deleted': w.deleted,
|
||||||
};
|
};
|
||||||
final remote = existing[clientId];
|
final remote = existing[clientId];
|
||||||
if (remote == null) {
|
if (remote == null) {
|
||||||
@@ -1463,7 +1527,9 @@ class PbSyncService {
|
|||||||
remote.getStringValue('flow') == fav.flow.name &&
|
remote.getStringValue('flow') == fav.flow.name &&
|
||||||
remote.getStringValue('bar_style') == fav.barStyle.name &&
|
remote.getStringValue('bar_style') == fav.barStyle.name &&
|
||||||
remote.getBoolValue('invert_expense_perspective') ==
|
remote.getBoolValue('invert_expense_perspective') ==
|
||||||
fav.invertExpensePerspective;
|
fav.invertExpensePerspective &&
|
||||||
|
remote.getBoolValue('deleted') == fav.deleted &&
|
||||||
|
_recordUpdatedAtMs(remote) == fav.updatedAt;
|
||||||
}
|
}
|
||||||
|
|
||||||
bool _homeFilterWidgetUnchanged(RecordModel remote, HomeFilterWidget w) {
|
bool _homeFilterWidgetUnchanged(RecordModel remote, HomeFilterWidget w) {
|
||||||
@@ -1502,7 +1568,9 @@ class PbSyncService {
|
|||||||
remote.getBoolValue('month_only') == w.monthOnly &&
|
remote.getBoolValue('month_only') == w.monthOnly &&
|
||||||
remote.getBoolValue('show_amount_in', true) == w.showAmountIn &&
|
remote.getBoolValue('show_amount_in', true) == w.showAmountIn &&
|
||||||
remote.getBoolValue('show_amount_out', true) == w.showAmountOut &&
|
remote.getBoolValue('show_amount_out', true) == w.showAmountOut &&
|
||||||
remote.getBoolValue('show_count', true) == w.showCount;
|
remote.getBoolValue('show_count', true) == w.showCount &&
|
||||||
|
remote.getBoolValue('deleted') == w.deleted &&
|
||||||
|
_recordUpdatedAtMs(remote) == w.updatedAt;
|
||||||
}
|
}
|
||||||
|
|
||||||
bool _appPrefsUnchanged(RecordModel remote, AppCloudPrefs prefs) {
|
bool _appPrefsUnchanged(RecordModel remote, AppCloudPrefs prefs) {
|
||||||
@@ -1515,6 +1583,20 @@ class PbSyncService {
|
|||||||
remote.getIntValue('look_ahead_max_years', 5) ==
|
remote.getIntValue('look_ahead_max_years', 5) ==
|
||||||
prefs.lookAheadMaxYears.clamp(1, 30);
|
prefs.lookAheadMaxYears.clamp(1, 30);
|
||||||
}
|
}
|
||||||
|
|
||||||
|
/// Prefer custom `updated_at`, else PocketBase system `updated`.
|
||||||
|
int _recordUpdatedAtMs(RecordModel r) {
|
||||||
|
final raw = r.get<dynamic>('updated_at');
|
||||||
|
final custom = switch (raw) {
|
||||||
|
int n => n,
|
||||||
|
num n => n.round(),
|
||||||
|
String s => int.tryParse(s) ?? 0,
|
||||||
|
_ => 0,
|
||||||
|
};
|
||||||
|
if (custom > 0) return custom;
|
||||||
|
final system = DateTime.tryParse(r.getStringValue('updated'));
|
||||||
|
return system?.millisecondsSinceEpoch ?? 0;
|
||||||
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
RecurringTemplateSource _parseTemplateSource(String raw) {
|
RecurringTemplateSource _parseTemplateSource(String raw) {
|
||||||
|
|||||||
@@ -288,19 +288,14 @@ class _StatsBody extends StatelessWidget {
|
|||||||
final spentOnly = widgetConfig.showAmountOut &&
|
final spentOnly = widgetConfig.showAmountOut &&
|
||||||
!widgetConfig.showAmountIn &&
|
!widgetConfig.showAmountIn &&
|
||||||
!widgetConfig.showCount;
|
!widgetConfig.showCount;
|
||||||
|
final half = widgetConfig.halfWidth;
|
||||||
|
|
||||||
// Avoid LayoutBuilder/Spacer/Expanded here: half-width rows use
|
Widget metricsBlock({required bool alignEnd}) {
|
||||||
// IntrinsicHeight, which cannot measure those widgets.
|
if (spentOnly) {
|
||||||
return Column(
|
return Column(
|
||||||
crossAxisAlignment: CrossAxisAlignment.start,
|
crossAxisAlignment:
|
||||||
|
alignEnd ? CrossAxisAlignment.end : CrossAxisAlignment.start,
|
||||||
children: [
|
children: [
|
||||||
_CardHeader(
|
|
||||||
icon: widgetConfig.icon,
|
|
||||||
title: widgetConfig.name,
|
|
||||||
subtitle: _subtitleFor(widgetConfig),
|
|
||||||
),
|
|
||||||
if (spentOnly) ...[
|
|
||||||
const SizedBox(height: 32),
|
|
||||||
Text(
|
Text(
|
||||||
'Spent',
|
'Spent',
|
||||||
style: theme.textTheme.labelMedium?.copyWith(
|
style: theme.textTheme.labelMedium?.copyWith(
|
||||||
@@ -316,11 +311,13 @@ class _StatsBody extends StatelessWidget {
|
|||||||
height: 1.15,
|
height: 1.15,
|
||||||
),
|
),
|
||||||
),
|
),
|
||||||
] else ...[
|
],
|
||||||
const SizedBox(height: 14),
|
);
|
||||||
Wrap(
|
}
|
||||||
|
return Wrap(
|
||||||
spacing: 16,
|
spacing: 16,
|
||||||
runSpacing: 8,
|
runSpacing: 8,
|
||||||
|
alignment: alignEnd ? WrapAlignment.end : WrapAlignment.start,
|
||||||
children: [
|
children: [
|
||||||
if (widgetConfig.showAmountIn)
|
if (widgetConfig.showAmountIn)
|
||||||
_Metric(
|
_Metric(
|
||||||
@@ -336,13 +333,45 @@ class _StatsBody extends StatelessWidget {
|
|||||||
),
|
),
|
||||||
if (widgetConfig.showCount)
|
if (widgetConfig.showCount)
|
||||||
_Metric(
|
_Metric(
|
||||||
label: 'Txs',
|
label: 'Transactions',
|
||||||
value: '${metrics.count}',
|
value: '${metrics.count}',
|
||||||
color: colors.primary,
|
color: colors.primary,
|
||||||
),
|
),
|
||||||
],
|
],
|
||||||
|
);
|
||||||
|
}
|
||||||
|
|
||||||
|
// Avoid LayoutBuilder/Spacer/Expanded here: half-width rows use
|
||||||
|
// IntrinsicHeight, which cannot measure those widgets.
|
||||||
|
if (!half) {
|
||||||
|
return Row(
|
||||||
|
crossAxisAlignment: CrossAxisAlignment.start,
|
||||||
|
children: [
|
||||||
|
Expanded(
|
||||||
|
child: _CardHeader(
|
||||||
|
icon: widgetConfig.icon,
|
||||||
|
title: widgetConfig.name,
|
||||||
|
subtitle: _subtitleFor(widgetConfig),
|
||||||
|
),
|
||||||
|
),
|
||||||
|
const SizedBox(width: 12),
|
||||||
|
Flexible(
|
||||||
|
child: metricsBlock(alignEnd: true),
|
||||||
),
|
),
|
||||||
],
|
],
|
||||||
|
);
|
||||||
|
}
|
||||||
|
|
||||||
|
return Column(
|
||||||
|
crossAxisAlignment: CrossAxisAlignment.start,
|
||||||
|
children: [
|
||||||
|
_CardHeader(
|
||||||
|
icon: widgetConfig.icon,
|
||||||
|
title: widgetConfig.name,
|
||||||
|
subtitle: _subtitleFor(widgetConfig),
|
||||||
|
),
|
||||||
|
SizedBox(height: spentOnly ? 32 : 14),
|
||||||
|
metricsBlock(alignEnd: false),
|
||||||
],
|
],
|
||||||
);
|
);
|
||||||
}
|
}
|
||||||
|
|||||||
@@ -0,0 +1,83 @@
|
|||||||
|
/// PocketBase migration: `tx_deletes` — synced tombstones for deleted admin
|
||||||
|
/// test transactions so another device cannot push them back into `transactions`.
|
||||||
|
///
|
||||||
|
/// Apply on the server:
|
||||||
|
///
|
||||||
|
/// sudo cp this_file /opt/pocketbase/pb_migrations/
|
||||||
|
/// sudo chown pocketbase:pocketbase /opt/pocketbase/pb_migrations/*.js
|
||||||
|
/// sudo -u pocketbase /opt/pocketbase/pocketbase migrate up
|
||||||
|
/// sudo systemctl restart pocketbase
|
||||||
|
migrate((app) => {
|
||||||
|
const users = app.findCollectionByNameOrId("usersapp");
|
||||||
|
|
||||||
|
try {
|
||||||
|
app.findCollectionByNameOrId("tx_deletes");
|
||||||
|
return;
|
||||||
|
} catch (_) {}
|
||||||
|
|
||||||
|
const ownerRules = {
|
||||||
|
listRule: "user = @request.auth.id",
|
||||||
|
viewRule: "user = @request.auth.id",
|
||||||
|
createRule: "@request.auth.id != '' && user = @request.auth.id",
|
||||||
|
updateRule: "user = @request.auth.id",
|
||||||
|
deleteRule: "user = @request.auth.id",
|
||||||
|
};
|
||||||
|
|
||||||
|
const txDeletes = new Collection({
|
||||||
|
type: "base",
|
||||||
|
name: "tx_deletes",
|
||||||
|
...ownerRules,
|
||||||
|
fields: [
|
||||||
|
{
|
||||||
|
type: "relation",
|
||||||
|
name: "user",
|
||||||
|
required: true,
|
||||||
|
collectionId: users.id,
|
||||||
|
cascadeDelete: true,
|
||||||
|
maxSelect: 1,
|
||||||
|
},
|
||||||
|
{
|
||||||
|
// Clipped BankTransaction.id
|
||||||
|
type: "text",
|
||||||
|
name: "tx_id",
|
||||||
|
required: true,
|
||||||
|
min: 1,
|
||||||
|
max: 2000,
|
||||||
|
},
|
||||||
|
{
|
||||||
|
type: "text",
|
||||||
|
name: "date",
|
||||||
|
required: true,
|
||||||
|
min: 1,
|
||||||
|
max: 32,
|
||||||
|
},
|
||||||
|
{
|
||||||
|
type: "text",
|
||||||
|
name: "description",
|
||||||
|
required: true,
|
||||||
|
min: 1,
|
||||||
|
max: 4000,
|
||||||
|
},
|
||||||
|
{
|
||||||
|
type: "number",
|
||||||
|
name: "amount",
|
||||||
|
required: true,
|
||||||
|
},
|
||||||
|
{
|
||||||
|
type: "text",
|
||||||
|
name: "currency",
|
||||||
|
required: true,
|
||||||
|
min: 1,
|
||||||
|
max: 8,
|
||||||
|
},
|
||||||
|
],
|
||||||
|
indexes: [
|
||||||
|
"CREATE UNIQUE INDEX idx_tx_deletes_user_tx ON tx_deletes (user, tx_id)",
|
||||||
|
],
|
||||||
|
});
|
||||||
|
app.save(txDeletes);
|
||||||
|
}, (app) => {
|
||||||
|
try {
|
||||||
|
app.delete(app.findCollectionByNameOrId("tx_deletes"));
|
||||||
|
} catch (_) {}
|
||||||
|
});
|
||||||
@@ -0,0 +1,48 @@
|
|||||||
|
/// PocketBase migration: `updated_at` + `deleted` on overview favourites and
|
||||||
|
/// home filter widgets for cross-device last-write-wins sync.
|
||||||
|
///
|
||||||
|
/// Apply on the server:
|
||||||
|
///
|
||||||
|
/// sudo cp this_file /opt/pocketbase/pb_migrations/
|
||||||
|
/// sudo chown pocketbase:pocketbase /opt/pocketbase/pb_migrations/*.js
|
||||||
|
/// sudo -u pocketbase /opt/pocketbase/pocketbase migrate up
|
||||||
|
/// sudo systemctl restart pocketbase
|
||||||
|
migrate((app) => {
|
||||||
|
function addSyncFields(collectionName) {
|
||||||
|
const col = app.findCollectionByNameOrId(collectionName);
|
||||||
|
let changed = false;
|
||||||
|
if (!col.fields.getByName("updated_at")) {
|
||||||
|
col.fields.add(new Field({
|
||||||
|
type: "number",
|
||||||
|
name: "updated_at",
|
||||||
|
required: false,
|
||||||
|
}));
|
||||||
|
changed = true;
|
||||||
|
}
|
||||||
|
if (!col.fields.getByName("deleted")) {
|
||||||
|
col.fields.add(new Field({
|
||||||
|
type: "bool",
|
||||||
|
name: "deleted",
|
||||||
|
required: false,
|
||||||
|
}));
|
||||||
|
changed = true;
|
||||||
|
}
|
||||||
|
if (changed) app.save(col);
|
||||||
|
}
|
||||||
|
|
||||||
|
addSyncFields("overview_favourites");
|
||||||
|
addSyncFields("home_filter_widgets");
|
||||||
|
}, (app) => {
|
||||||
|
function removeSyncFields(collectionName) {
|
||||||
|
try {
|
||||||
|
const col = app.findCollectionByNameOrId(collectionName);
|
||||||
|
const updated = col.fields.getByName("updated_at");
|
||||||
|
if (updated) col.fields.removeById(updated.id);
|
||||||
|
const deleted = col.fields.getByName("deleted");
|
||||||
|
if (deleted) col.fields.removeById(deleted.id);
|
||||||
|
app.save(col);
|
||||||
|
} catch (_) {}
|
||||||
|
}
|
||||||
|
removeSyncFields("overview_favourites");
|
||||||
|
removeSyncFields("home_filter_widgets");
|
||||||
|
});
|
||||||
@@ -1,7 +1,6 @@
|
|||||||
import 'package:flutter_test/flutter_test.dart';
|
import 'package:flutter_test/flutter_test.dart';
|
||||||
import 'package:myapp/models/overview_favourite.dart';
|
import 'package:myapp/models/overview_favourite.dart';
|
||||||
import 'package:myapp/models/transaction_meta.dart';
|
import 'package:myapp/models/transaction_meta.dart';
|
||||||
import 'package:myapp/services/pb_sync_service.dart';
|
|
||||||
import 'package:myapp/widgets/label_filter_dialog.dart';
|
import 'package:myapp/widgets/label_filter_dialog.dart';
|
||||||
|
|
||||||
void main() {
|
void main() {
|
||||||
@@ -16,6 +15,8 @@ void main() {
|
|||||||
flow: TxFlowFilter.expense,
|
flow: TxFlowFilter.expense,
|
||||||
barStyle: LabelChartBarStyle.stacked,
|
barStyle: LabelChartBarStyle.stacked,
|
||||||
invertExpensePerspective: false,
|
invertExpensePerspective: false,
|
||||||
|
updatedAt: 100,
|
||||||
|
deleted: false,
|
||||||
);
|
);
|
||||||
|
|
||||||
final restored = OverviewFavourite.fromJson(fav.toJson());
|
final restored = OverviewFavourite.fromJson(fav.toJson());
|
||||||
@@ -27,35 +28,53 @@ void main() {
|
|||||||
expect(restored.labelIds, ['groceries', 'custom_ah']);
|
expect(restored.labelIds, ['groceries', 'custom_ah']);
|
||||||
expect(restored.flow, TxFlowFilter.expense);
|
expect(restored.flow, TxFlowFilter.expense);
|
||||||
expect(restored.barStyle, LabelChartBarStyle.stacked);
|
expect(restored.barStyle, LabelChartBarStyle.stacked);
|
||||||
|
expect(restored.updatedAt, 100);
|
||||||
|
expect(restored.deleted, isFalse);
|
||||||
});
|
});
|
||||||
|
|
||||||
test('mergeOverviewFavourites unions by id with local wins', () {
|
test('mergeOverviewFavourites unions by id with last-write-wins', () {
|
||||||
const local = OverviewFavourite(
|
const local = OverviewFavourite(
|
||||||
id: 'fav_1',
|
id: 'fav_1',
|
||||||
name: 'Local name',
|
name: 'Local name',
|
||||||
display: true,
|
display: true,
|
||||||
|
updatedAt: 200,
|
||||||
);
|
);
|
||||||
const remoteOnly = OverviewFavourite(
|
const remoteOnly = OverviewFavourite(
|
||||||
id: 'fav_2',
|
id: 'fav_2',
|
||||||
name: 'Remote only',
|
name: 'Remote only',
|
||||||
display: false,
|
display: false,
|
||||||
metric: OverviewMetricMode.labels,
|
metric: OverviewMetricMode.labels,
|
||||||
|
updatedAt: 50,
|
||||||
);
|
);
|
||||||
const remoteConflict = OverviewFavourite(
|
const remoteConflictOlder = OverviewFavourite(
|
||||||
id: 'fav_1',
|
id: 'fav_1',
|
||||||
name: 'Remote name',
|
name: 'Remote name',
|
||||||
display: false,
|
display: false,
|
||||||
|
updatedAt: 100,
|
||||||
|
);
|
||||||
|
const remoteConflictNewer = OverviewFavourite(
|
||||||
|
id: 'fav_3',
|
||||||
|
name: 'Remote newer',
|
||||||
|
display: true,
|
||||||
|
updatedAt: 300,
|
||||||
|
);
|
||||||
|
const localOlder = OverviewFavourite(
|
||||||
|
id: 'fav_3',
|
||||||
|
name: 'Local older',
|
||||||
|
display: false,
|
||||||
|
updatedAt: 10,
|
||||||
);
|
);
|
||||||
|
|
||||||
final merged = mergeOverviewFavourites(
|
final merged = mergeOverviewFavourites(
|
||||||
[local],
|
[local, localOlder],
|
||||||
[remoteConflict, remoteOnly],
|
[remoteConflictOlder, remoteOnly, remoteConflictNewer],
|
||||||
);
|
);
|
||||||
|
|
||||||
expect(merged.length, 2);
|
expect(merged.length, 3);
|
||||||
final byId = {for (final f in merged) f.id: f};
|
final byId = {for (final f in merged) f.id: f};
|
||||||
expect(byId['fav_1']!.name, 'Local name');
|
expect(byId['fav_1']!.name, 'Local name');
|
||||||
expect(byId['fav_1']!.display, isTrue);
|
expect(byId['fav_1']!.display, isTrue);
|
||||||
expect(byId['fav_2']!.name, 'Remote only');
|
expect(byId['fav_2']!.name, 'Remote only');
|
||||||
|
expect(byId['fav_3']!.name, 'Remote newer');
|
||||||
});
|
});
|
||||||
}
|
}
|
||||||
|
|||||||
Reference in New Issue
Block a user