Compare commits

...

4 Commits

Author SHA1 Message Date
94adf06726 add filter by network for legs, add full export for traction
All checks were successful
Release / meta (push) Successful in 1m45s
Release / linux-build (push) Successful in 1m48s
Release / web-build (push) Successful in 1m56s
Release / android-build (push) Successful in 7m33s
Release / release-dev (push) Successful in 30s
Release / release-master (push) Successful in 5s
2026-01-26 15:57:34 +00:00
8340501f37 make carousel more stable
All checks were successful
Release / meta (push) Successful in 4s
Release / linux-build (push) Successful in 1m14s
Release / web-build (push) Successful in 1m30s
Release / android-build (push) Successful in 5m52s
Release / release-dev (push) Successful in 7s
Release / release-master (push) Successful in 4s
2026-01-23 18:24:34 +00:00
a527ecdb17 add logo to login page 2026-01-23 18:04:40 +00:00
f3fcf07b05 add refresh token support 2026-01-23 17:55:55 +00:00
15 changed files with 857 additions and 370 deletions

View File

@@ -0,0 +1,27 @@
<?xml version="1.0" encoding="UTF-8" standalone="no"?>
<!-- Created with Inkscape (http://www.inkscape.org/) -->
<svg
width="120"
height="120"
viewBox="0 0 120 120"
version="1.1"
id="svg1"
xmlns="http://www.w3.org/2000/svg"
xmlns:svg="http://www.w3.org/2000/svg">
<defs
id="defs1" />
<g
id="layer1">
<path
style="fill:#00b7fd;stroke-width:4.40315"
d="M 42.563242,0 H 92.5 A 27.5,27.5 45 0 1 120,27.5 27.5,27.5 135 0 1 92.5,55 h -50 A 2.5,2.5 45 0 1 40,52.5 v -10 A 2.5,2.5 135 0 1 42.5,40 h 50 A 12.5,12.5 135 0 0 105,27.5 12.5,12.5 45 0 0 92.5,15 l -50,0 A 27.5,27.5 135 0 0 15,42.5 v 50 A 2.5,2.5 135 0 1 12.5,95 H 2.5 A 2.5,2.5 45 0 1 0,92.5 V 42.563242 A 42.563242,42.563242 135 0 1 42.563242,0 Z"
id="path1"
transform="translate(0,12.5)" />
<path
style="fill:#999999;stroke-width:4.40315"
d="m 42.5,60 h 60 A 17.5,17.5 45 0 1 120,77.5 17.5,17.5 135 0 1 102.5,95 h -60 A 22.5,22.5 45 0 1 20,72.5 v -30 A 22.5,22.5 135 0 1 42.5,20 h 50 a 7.5,7.5 45 0 1 7.5,7.5 7.5,7.5 135 0 1 -7.5,7.5 h -50 A 7.5,7.5 135 0 0 35,42.5 v 30 a 7.5,7.5 45 0 0 7.5,7.5 h 60 A 2.5,2.5 135 0 0 105,77.5 2.5,2.5 45 0 0 102.5,75 h -60 A 2.5,2.5 45 0 1 40,72.5 v -10 A 2.5,2.5 135 0 1 42.5,60 Z"
id="path2"
transform="translate(0,12.5)" />
</g>
</svg>

After

Width:  |  Height:  |  Size: 1.3 KiB

View File

@@ -3,6 +3,7 @@ import 'package:go_router/go_router.dart';
import 'package:provider/provider.dart'; import 'package:provider/provider.dart';
import 'package:mileograph_flutter/objects/objects.dart'; import 'package:mileograph_flutter/objects/objects.dart';
import 'package:mileograph_flutter/services/api_service.dart'; import 'package:mileograph_flutter/services/api_service.dart';
import 'package:mileograph_flutter/components/widgets/multi_select_filter.dart';
import 'package:mileograph_flutter/services/data_service.dart'; import 'package:mileograph_flutter/services/data_service.dart';
import './route_summary_widget.dart'; import './route_summary_widget.dart';
@@ -358,7 +359,7 @@ class _RouteCalculatorState extends State<RouteCalculator> {
runSpacing: 12, runSpacing: 12,
crossAxisAlignment: WrapCrossAlignment.center, crossAxisAlignment: WrapCrossAlignment.center,
children: [ children: [
_MultiSelectFilter( MultiSelectFilter(
label: 'Countries', label: 'Countries',
options: _countries, options: _countries,
selected: _selectedCountries, selected: _selectedCountries,
@@ -367,7 +368,7 @@ class _RouteCalculatorState extends State<RouteCalculator> {
_loadStations(); _loadStations();
}, },
), ),
_MultiSelectFilter( MultiSelectFilter(
label: 'Networks', label: 'Networks',
options: _networks, options: _networks,
selected: _selectedNetworks, selected: _selectedNetworks,
@@ -375,6 +376,16 @@ class _RouteCalculatorState extends State<RouteCalculator> {
setState(() => _selectedNetworks = vals); setState(() => _selectedNetworks = vals);
_loadStations(); _loadStations();
}, },
onRefresh: () async {
final data = context.read<DataService>();
await data.fetchStationFilters();
if (!mounted) return;
setState(() {
_networks = data.stationNetworks;
_countries = data.stationCountryNetworks.keys.toList();
});
await _loadStations();
},
), ),
if (_loadingStations) if (_loadingStations)
const Padding( const Padding(
@@ -573,159 +584,3 @@ Widget debugPanel(List<String> stations) {
), ),
); );
} }
class _MultiSelectFilter extends StatefulWidget {
const _MultiSelectFilter({
required this.label,
required this.options,
required this.selected,
required this.onChanged,
});
final String label;
final List<String> options;
final List<String> selected;
final ValueChanged<List<String>> onChanged;
@override
State<_MultiSelectFilter> createState() => _MultiSelectFilterState();
}
class _MultiSelectFilterState extends State<_MultiSelectFilter> {
late List<String> _tempSelected;
String _query = '';
@override
void initState() {
super.initState();
_tempSelected = List.from(widget.selected);
}
@override
void didUpdateWidget(covariant _MultiSelectFilter oldWidget) {
super.didUpdateWidget(oldWidget);
if (oldWidget.selected != widget.selected) {
_tempSelected = List.from(widget.selected);
}
}
void _openPicker() async {
_tempSelected = List.from(widget.selected);
_query = '';
await showModalBottomSheet<void>(
context: context,
isScrollControlled: true,
builder: (ctx) {
return StatefulBuilder(
builder: (ctx, setModalState) {
final filtered = widget.options
.where((opt) =>
_query.isEmpty || opt.toLowerCase().contains(_query.toLowerCase()))
.toList();
return SafeArea(
child: Padding(
padding: const EdgeInsets.all(16.0),
child: Column(
mainAxisSize: MainAxisSize.min,
crossAxisAlignment: CrossAxisAlignment.start,
children: [
Row(
children: [
Text(
'Select ${widget.label.toLowerCase()}',
style: Theme.of(context).textTheme.titleMedium?.copyWith(
fontWeight: FontWeight.w700,
),
),
const Spacer(),
TextButton(
onPressed: () {
setModalState(() {
_tempSelected.clear();
});
Navigator.of(ctx).pop();
widget.onChanged(const []);
},
child: const Text('Clear'),
),
],
),
const SizedBox(height: 8),
TextField(
decoration: const InputDecoration(
labelText: 'Search',
border: OutlineInputBorder(),
),
onChanged: (val) {
setModalState(() {
_query = val;
});
},
),
const SizedBox(height: 12),
SizedBox(
height: 320,
child: ListView.builder(
itemCount: filtered.length,
itemBuilder: (_, index) {
final option = filtered[index];
final selected = _tempSelected.contains(option);
return CheckboxListTile(
value: selected,
title: Text(option),
onChanged: (val) {
setModalState(() {
if (val == true) {
if (!_tempSelected.contains(option)) {
_tempSelected.add(option);
}
} else {
_tempSelected.removeWhere((e) => e == option);
}
});
widget.onChanged(List.from(_tempSelected.toSet()));
},
);
},
),
),
const SizedBox(height: 12),
Align(
alignment: Alignment.centerRight,
child: FilledButton.icon(
onPressed: () {
widget.onChanged(List.from(_tempSelected.toSet()));
Navigator.of(ctx).pop();
},
icon: const Icon(Icons.check),
label: const Text('Apply'),
),
),
],
),
),
);
},
);
},
);
}
@override
Widget build(BuildContext context) {
final hasSelection = widget.selected.isNotEmpty;
final display =
hasSelection ? widget.selected.join(', ') : 'Any ${widget.label.toLowerCase()}';
return OutlinedButton.icon(
onPressed: _openPicker,
icon: const Icon(Icons.filter_alt),
label: SizedBox(
width: 180,
child: Text(
'${widget.label}: $display',
overflow: TextOverflow.ellipsis,
),
),
);
}
}

View File

@@ -1,4 +1,6 @@
import 'package:flutter/material.dart'; import 'package:flutter/material.dart';
import 'package:flutter/services.dart';
import 'package:flutter_svg/flutter_svg.dart';
import 'package:go_router/go_router.dart'; import 'package:go_router/go_router.dart';
import 'package:mileograph_flutter/services/authservice.dart'; import 'package:mileograph_flutter/services/authservice.dart';
import 'package:mileograph_flutter/components/pages/settings.dart'; import 'package:mileograph_flutter/components/pages/settings.dart';
@@ -41,17 +43,29 @@ class _LoginScreenState extends State<LoginScreen> {
resizeToAvoidBottomInset: true, resizeToAvoidBottomInset: true,
body: Container( body: Container(
color: Theme.of(context).scaffoldBackgroundColor, color: Theme.of(context).scaffoldBackgroundColor,
child: SafeArea(
child: Column(
children: [
Expanded(
child: Center( child: Center(
child: Column( child: Column(
mainAxisAlignment: MainAxisAlignment.center, mainAxisAlignment: MainAxisAlignment.center,
children: [ children: [
Text.rich( LayoutBuilder(
builder: (context, constraints) {
return SizedBox(
width: constraints.maxWidth,
child: FittedBox(
fit: BoxFit.scaleDown,
child: Text.rich(
TextSpan( TextSpan(
children: [ children: [
TextSpan( TextSpan(
text: "Mile", text: "Mile",
style: TextStyle( style: TextStyle(
color: Theme.of(context).textTheme.bodyLarge?.color, color: Theme.of(
context,
).textTheme.bodyLarge?.color,
), ),
), ),
const TextSpan( const TextSpan(
@@ -61,7 +75,9 @@ class _LoginScreenState extends State<LoginScreen> {
TextSpan( TextSpan(
text: "graph", text: "graph",
style: TextStyle( style: TextStyle(
color: Theme.of(context).textTheme.bodyLarge?.color, color: Theme.of(
context,
).textTheme.bodyLarge?.color,
), ),
), ),
], ],
@@ -72,22 +88,14 @@ class _LoginScreenState extends State<LoginScreen> {
fontSize: 50, fontSize: 50,
), ),
), ),
softWrap: false,
overflow: TextOverflow.visible,
), ),
const SizedBox(height: 50),
const LoginPanel(),
const SizedBox(height: 16),
IconButton(
icon: const Icon(Icons.settings, color: Colors.grey),
tooltip: 'Settings',
onPressed: () {
Navigator.of(context).push(
MaterialPageRoute(
fullscreenDialog: true,
builder: (_) => const SettingsPage(),
), ),
); );
}, },
), ),
const SizedBox(height: 40),
if (_checkingSession) ...[ if (_checkingSession) ...[
const SizedBox(height: 12), const SizedBox(height: 12),
Row( Row(
@@ -105,15 +113,90 @@ class _LoginScreenState extends State<LoginScreen> {
), ),
], ],
), ),
] else ...[
const SizedBox(height: 10),
const LoginPanel(),
const SizedBox(height: 16),
IconButton(
icon: const Icon(Icons.settings, color: Colors.grey),
tooltip: 'Settings',
onPressed: () {
Navigator.of(context).push(
MaterialPageRoute(
fullscreenDialog: true,
builder: (_) => const SettingsPage(),
),
);
},
),
], ],
], ],
), ),
), ),
), ),
const Padding(
padding: EdgeInsets.only(bottom: 12),
child: _LoginLogo(),
),
],
),
),
),
); );
} }
} }
class _LoginLogo extends StatefulWidget {
const _LoginLogo();
@override
State<_LoginLogo> createState() => _LoginLogoState();
}
class _LoginLogoState extends State<_LoginLogo> {
late final Future<String> _svgFuture;
@override
void initState() {
super.initState();
_svgFuture = rootBundle.loadString('assets/logos/pg_logo_v2.svg');
}
@override
Widget build(BuildContext context) {
final accent = Theme.of(context).colorScheme.primary;
final grey = const Color(0xFF999999);
return SizedBox(
height: 42,
child: Opacity(
opacity: 0.75,
child: FutureBuilder<String>(
future: _svgFuture,
builder: (context, snapshot) {
final svg = snapshot.data;
if (svg == null) {
return const SizedBox.shrink();
}
final tinted = svg
.replaceAll('#00b7fd', _colorToHex(accent))
.replaceAll('#999999', _colorToHex(grey));
return SvgPicture.string(
tinted,
fit: BoxFit.contain,
semanticsLabel: 'Mileograph logo',
);
},
),
),
);
}
String _colorToHex(Color color) {
final hex = color.value.toRadixString(16).padLeft(8, '0');
return '#${hex.substring(2)}';
}
}
class LoginPanel extends StatefulWidget { class LoginPanel extends StatefulWidget {
const LoginPanel({super.key}); const LoginPanel({super.key});

View File

@@ -1,5 +1,6 @@
import 'package:flutter/material.dart'; import 'package:flutter/material.dart';
import 'package:mileograph_flutter/components/legs/leg_card.dart'; import 'package:mileograph_flutter/components/legs/leg_card.dart';
import 'package:mileograph_flutter/components/widgets/multi_select_filter.dart';
import 'package:mileograph_flutter/objects/objects.dart'; import 'package:mileograph_flutter/objects/objects.dart';
import 'package:mileograph_flutter/services/data_service.dart'; import 'package:mileograph_flutter/services/data_service.dart';
import 'package:mileograph_flutter/services/distance_unit_service.dart'; import 'package:mileograph_flutter/services/distance_unit_service.dart';
@@ -19,6 +20,9 @@ class _LegsPageState extends State<LegsPage> {
bool _initialised = false; bool _initialised = false;
bool _unallocatedOnly = false; bool _unallocatedOnly = false;
bool _showMoreFilters = false; bool _showMoreFilters = false;
bool _loadingNetworks = false;
List<String> _availableNetworks = [];
List<String> _selectedNetworks = [];
@override @override
void didChangeDependencies() { void didChangeDependencies() {
@@ -26,9 +30,21 @@ class _LegsPageState extends State<LegsPage> {
if (!_initialised) { if (!_initialised) {
_initialised = true; _initialised = true;
_refreshLegs(); _refreshLegs();
_loadNetworks();
} }
} }
Future<void> _loadNetworks() async {
setState(() => _loadingNetworks = true);
final data = context.read<DataService>();
await data.fetchStationNetworks();
if (!mounted) return;
setState(() {
_availableNetworks = data.stationNetworks;
_loadingNetworks = false;
});
}
Future<void> _refreshLegs() async { Future<void> _refreshLegs() async {
final data = context.read<DataService>(); final data = context.read<DataService>();
await data.fetchLegs( await data.fetchLegs(
@@ -36,6 +52,7 @@ class _LegsPageState extends State<LegsPage> {
dateRangeStart: _formatDate(_startDate), dateRangeStart: _formatDate(_startDate),
dateRangeEnd: _formatDate(_endDate), dateRangeEnd: _formatDate(_endDate),
unallocatedOnly: _unallocatedOnly, unallocatedOnly: _unallocatedOnly,
networkFilter: _selectedNetworks,
); );
} }
@@ -48,6 +65,7 @@ class _LegsPageState extends State<LegsPage> {
offset: data.legs.length, offset: data.legs.length,
append: true, append: true,
unallocatedOnly: _unallocatedOnly, unallocatedOnly: _unallocatedOnly,
networkFilter: _selectedNetworks,
); );
} }
@@ -90,6 +108,7 @@ class _LegsPageState extends State<LegsPage> {
_sortDirection = 0; _sortDirection = 0;
_unallocatedOnly = false; _unallocatedOnly = false;
_showMoreFilters = false; _showMoreFilters = false;
_selectedNetworks = [];
}); });
_refreshLegs(); _refreshLegs();
} }
@@ -209,6 +228,16 @@ class _LegsPageState extends State<LegsPage> {
spacing: 12, spacing: 12,
runSpacing: 12, runSpacing: 12,
children: [ children: [
MultiSelectFilter(
label: 'Networks',
options: _availableNetworks,
selected: _selectedNetworks,
onChanged: (vals) async {
setState(() => _selectedNetworks = vals);
await _refreshLegs();
},
onRefresh: _loadingNetworks ? null : _loadNetworks,
),
FilterChip( FilterChip(
avatar: const Icon(Icons.flash_off), avatar: const Icon(Icons.flash_off),
label: const Text('Unallocated only'), label: const Text('Unallocated only'),
@@ -218,6 +247,15 @@ class _LegsPageState extends State<LegsPage> {
await _refreshLegs(); await _refreshLegs();
}, },
), ),
if (_loadingNetworks)
const Padding(
padding: EdgeInsets.only(left: 8.0),
child: SizedBox(
height: 20,
width: 20,
child: CircularProgressIndicator(strokeWidth: 2),
),
),
], ],
), ),
), ),

View File

@@ -1,6 +1,7 @@
part of 'traction.dart'; part of 'traction.dart';
enum _TractionMoreAction { enum _TractionMoreAction {
exportResults,
classStats, classStats,
classLeaderboard, classLeaderboard,
adminPending, adminPending,
@@ -68,14 +69,14 @@ class _TractionPageState extends State<TractionPage> {
_ClassLeaderboardScope _classLeaderboardScope = _ClassLeaderboardScope.global; _ClassLeaderboardScope _classLeaderboardScope = _ClassLeaderboardScope.global;
final Map<String, TextEditingController> _dynamicControllers = {}; final Map<String, TextEditingController> _dynamicControllers = {};
final Map<String, String?> _enumSelections = {}; final Map<String, dynamic> _enumSelections = {};
bool _restoredFromPrefs = false; bool _restoredFromPrefs = false;
static const int _pageSize = 100; static const int _pageSize = 100;
int _lastTractionOffset = 0; int _lastTractionOffset = 0;
String? _lastQuerySignature; String? _lastQuerySignature;
String? _transferFromLabel; String? _transferFromLabel;
bool _isSearching = false; bool _isSearching = false;
bool _classExporting = false; bool _exporting = false;
@override @override
void initState() { void initState() {
@@ -169,12 +170,7 @@ class _TractionPageState extends State<TractionPage> {
].join(';'); ].join(';');
} }
Future<void> _refreshTraction({ Map<String, dynamic> _buildTractionFilters() {
bool append = false,
bool preservePosition = true,
}) async {
_setState(() => _isSearching = true);
final data = context.read<DataService>();
final filters = <String, dynamic>{}; final filters = <String, dynamic>{};
final name = _nameController.text.trim(); final name = _nameController.text.trim();
if (name.isNotEmpty) filters['name'] = name; if (name.isNotEmpty) filters['name'] = name;
@@ -187,6 +183,16 @@ class _TractionPageState extends State<TractionPage> {
filters[key] = value; filters[key] = value;
} }
}); });
return filters;
}
Future<void> _refreshTraction({
bool append = false,
bool preservePosition = true,
}) async {
_setState(() => _isSearching = true);
final data = context.read<DataService>();
final filters = _buildTractionFilters();
final hadOnly = !_hasFilters; final hadOnly = !_hasFilters;
final signature = _tractionQuerySignature(filters, hadOnly); final signature = _tractionQuerySignature(filters, hadOnly);
final queryChanged = final queryChanged =
@@ -673,23 +679,6 @@ class _TractionPageState extends State<TractionPage> {
); );
final hasClassActions = _hasClassQuery; final hasClassActions = _hasClassQuery;
final classLabel = _currentClassLabel;
final exportClassButton = !hasClassActions
? null
: FilledButton.tonalIcon(
onPressed: _classExporting ? null : _exportSelectedClass,
icon: _classExporting
? const SizedBox(
height: 16,
width: 16,
child: CircularProgressIndicator(strokeWidth: 2),
)
: const Icon(Icons.download),
label: Text(
_classExporting ? 'Exporting...' : 'Export $classLabel',
),
);
final newTractionButton = FilledButton.icon( final newTractionButton = FilledButton.icon(
onPressed: () async { onPressed: () async {
@@ -710,7 +699,7 @@ class _TractionPageState extends State<TractionPage> {
); );
final hasAdminActions = isElevated; final hasAdminActions = isElevated;
final hasMoreMenu = hasClassActions || hasAdminActions; final hasMoreMenu = true;
final moreButton = !hasMoreMenu final moreButton = !hasMoreMenu
? null ? null
@@ -718,6 +707,9 @@ class _TractionPageState extends State<TractionPage> {
tooltip: 'More options', tooltip: 'More options',
onSelected: (action) async { onSelected: (action) async {
switch (action) { switch (action) {
case _TractionMoreAction.exportResults:
await _exportTractionResults();
break;
case _TractionMoreAction.classStats: case _TractionMoreAction.classStats:
_toggleClassStatsPanel(); _toggleClassStatsPanel();
break; break;
@@ -759,6 +751,25 @@ class _TractionPageState extends State<TractionPage> {
}, },
itemBuilder: (context) { itemBuilder: (context) {
final items = <PopupMenuEntry<_TractionMoreAction>>[]; final items = <PopupMenuEntry<_TractionMoreAction>>[];
items.add(
PopupMenuItem(
value: _TractionMoreAction.exportResults,
child: Row(
children: [
if (_exporting)
const SizedBox(
height: 16,
width: 16,
child: CircularProgressIndicator(strokeWidth: 2),
)
else
const Icon(Icons.download, size: 18),
const SizedBox(width: 8),
Text(_exporting ? 'Exporting...' : 'Export'),
],
),
),
);
if (hasClassActions) { if (hasClassActions) {
items.add( items.add(
PopupMenuItem( PopupMenuItem(
@@ -847,14 +858,12 @@ class _TractionPageState extends State<TractionPage> {
final desktopActions = [ final desktopActions = [
refreshButton, refreshButton,
if (exportClassButton != null) exportClassButton,
newTractionButton, newTractionButton,
if (moreButton != null) moreButton, if (moreButton != null) moreButton,
]; ];
final mobileActions = [ final mobileActions = [
if (moreButton != null) moreButton, if (moreButton != null) moreButton,
if (exportClassButton != null) exportClassButton,
newTractionButton, newTractionButton,
refreshButton, refreshButton,
]; ];
@@ -882,23 +891,36 @@ class _TractionPageState extends State<TractionPage> {
); );
} }
Future<void> _exportSelectedClass() async { Future<void> _exportTractionResults() async {
if (_classExporting) return; if (_exporting) return;
final classLabel = _currentClassLabel; setState(() => _exporting = true);
if (classLabel.isEmpty) return;
setState(() => _classExporting = true);
final messenger = ScaffoldMessenger.of(context); final messenger = ScaffoldMessenger.of(context);
try { try {
final data = context.read<DataService>(); final data = context.read<DataService>();
final encodedClass = Uri.encodeComponent(classLabel); final filters = _buildTractionFilters();
final response = await data.api.getBytes( final hadOnly = !_hasFilters;
'/loco/class/export/$encodedClass', final limit = data.traction.length;
final params = StringBuffer('?limit=$limit&offset=0');
if (hadOnly) params.write('&had_only=true');
if (!_mileageFirst) params.write('&mileage_first=false');
final payload = <String, dynamic>{};
final classLabel = (_selectedClass ?? _classController.text).trim();
if (classLabel.isNotEmpty) payload['class'] = classLabel;
final numberLabel = _numberController.text.trim();
if (numberLabel.isNotEmpty) payload['number'] = numberLabel;
filters.forEach((key, value) {
if (value == null) return;
if (value is String && value.trim().isEmpty) return;
payload[key] = value;
});
final response = await data.api.postBytes(
'/locos/search/v2/export${params.toString()}',
payload.isEmpty ? null : payload,
headers: const {'accept': '*/*'}, headers: const {'accept': '*/*'},
); );
final safeClassName = final filename = response.filename ?? 'traction-export.xlsx';
classLabel.replaceAll(RegExp(r'[^a-zA-Z0-9-_]+'), '_');
final fallbackName = 'traction-${safeClassName.isEmpty ? 'class' : safeClassName}.xlsx';
final filename = response.filename ?? fallbackName;
final saveResult = await saveBytes( final saveResult = await saveBytes(
Uint8List.fromList(response.bytes), Uint8List.fromList(response.bytes),
filename, filename,
@@ -932,7 +954,7 @@ class _TractionPageState extends State<TractionPage> {
SnackBar(content: Text('Export failed: $e')), SnackBar(content: Text('Export failed: $e')),
); );
} finally { } finally {
if (mounted) setState(() => _classExporting = false); if (mounted) setState(() => _exporting = false);
} }
} }
@@ -1847,13 +1869,44 @@ class _TractionPageState extends State<TractionPage> {
bool isMobile, bool isMobile,
) { ) {
final width = isMobile ? double.infinity : 220.0; final width = isMobile ? double.infinity : 220.0;
final type = field.type?.toLowerCase() ?? '';
final isBooleanField =
type == 'bool' || type == 'boolean' || type.contains('bool');
if (isBooleanField) {
final currentValue = _enumSelections[field.name];
final safeValue = currentValue is bool ? currentValue : null;
return SizedBox(
width: width,
child: DropdownButtonFormField<bool?>(
value: safeValue,
decoration: InputDecoration(
labelText: field.display,
border: const OutlineInputBorder(),
),
items: const [
DropdownMenuItem(value: null, child: Text('Any')),
DropdownMenuItem(value: true, child: Text('Yes')),
DropdownMenuItem(value: false, child: Text('No')),
],
onChanged: (val) {
setState(() {
_enumSelections[field.name] = val;
});
_refreshTraction();
},
),
);
}
if (field.enumValues != null && field.enumValues!.isNotEmpty) { if (field.enumValues != null && field.enumValues!.isNotEmpty) {
final options = field.enumValues! final options = field.enumValues!
.map((e) => e.toString()) .map((e) => e.toString())
.toSet() .toSet()
.toList(); .toList();
final currentValue = _enumSelections[field.name]; final currentValue = _enumSelections[field.name];
final safeValue = options.contains(currentValue) ? currentValue : null; final safeValue =
currentValue is String && options.contains(currentValue)
? currentValue
: null;
return SizedBox( return SizedBox(
width: width, width: width,
child: DropdownButtonFormField<String?>( child: DropdownButtonFormField<String?>(
@@ -1883,7 +1936,6 @@ class _TractionPageState extends State<TractionPage> {
_dynamicControllers[field.name] = controller; _dynamicControllers[field.name] = controller;
TextInputType? inputType; TextInputType? inputType;
if (field.type != null) { if (field.type != null) {
final type = field.type!.toLowerCase();
if (type.contains('int') || if (type.contains('int') ||
type.contains('num') || type.contains('num') ||
type.contains('double')) { type.contains('double')) {

View File

@@ -0,0 +1,166 @@
import 'package:flutter/material.dart';
class MultiSelectFilter extends StatefulWidget {
const MultiSelectFilter({
super.key,
required this.label,
required this.options,
required this.selected,
required this.onChanged,
this.onRefresh,
});
final String label;
final List<String> options;
final List<String> selected;
final ValueChanged<List<String>> onChanged;
final VoidCallback? onRefresh;
@override
State<MultiSelectFilter> createState() => _MultiSelectFilterState();
}
class _MultiSelectFilterState extends State<MultiSelectFilter> {
late List<String> _tempSelected;
String _query = '';
@override
void initState() {
super.initState();
_tempSelected = List.from(widget.selected);
}
@override
void didUpdateWidget(covariant MultiSelectFilter oldWidget) {
super.didUpdateWidget(oldWidget);
if (oldWidget.selected != widget.selected) {
_tempSelected = List.from(widget.selected);
}
}
void _openPicker() async {
_tempSelected = List.from(widget.selected);
_query = '';
await showModalBottomSheet<void>(
context: context,
isScrollControlled: true,
builder: (ctx) {
return StatefulBuilder(
builder: (ctx, setModalState) {
final filtered = widget.options
.where((opt) =>
_query.isEmpty || opt.toLowerCase().contains(_query.toLowerCase()))
.toList();
return SafeArea(
child: Padding(
padding: const EdgeInsets.all(16.0),
child: Column(
mainAxisSize: MainAxisSize.min,
crossAxisAlignment: CrossAxisAlignment.start,
children: [
Row(
children: [
Text(
'Select ${widget.label.toLowerCase()}',
style: Theme.of(context).textTheme.titleMedium?.copyWith(
fontWeight: FontWeight.w700,
),
),
const Spacer(),
if (widget.onRefresh != null)
IconButton(
tooltip: 'Refresh',
onPressed: widget.onRefresh,
icon: const Icon(Icons.refresh),
),
TextButton(
onPressed: () {
setModalState(() {
_tempSelected.clear();
});
Navigator.of(ctx).pop();
widget.onChanged(const []);
},
child: const Text('Clear'),
),
],
),
const SizedBox(height: 8),
TextField(
decoration: const InputDecoration(
labelText: 'Search',
border: OutlineInputBorder(),
),
onChanged: (val) {
setModalState(() {
_query = val;
});
},
),
const SizedBox(height: 12),
SizedBox(
height: 320,
child: ListView.builder(
itemCount: filtered.length,
itemBuilder: (_, index) {
final option = filtered[index];
final selected = _tempSelected.contains(option);
return CheckboxListTile(
value: selected,
title: Text(option),
onChanged: (val) {
setModalState(() {
if (val == true) {
if (!_tempSelected.contains(option)) {
_tempSelected.add(option);
}
} else {
_tempSelected.removeWhere((e) => e == option);
}
});
widget.onChanged(List.from(_tempSelected.toSet()));
},
);
},
),
),
const SizedBox(height: 12),
Align(
alignment: Alignment.centerRight,
child: FilledButton.icon(
onPressed: () {
widget.onChanged(List.from(_tempSelected.toSet()));
Navigator.of(ctx).pop();
},
icon: const Icon(Icons.check),
label: const Text('Apply'),
),
),
],
),
),
);
},
);
},
);
}
@override
Widget build(BuildContext context) {
final hasSelection = widget.selected.isNotEmpty;
final display =
hasSelection ? widget.selected.join(', ') : 'Any ${widget.label.toLowerCase()}';
return OutlinedButton.icon(
onPressed: _openPicker,
icon: const Icon(Icons.filter_alt),
label: SizedBox(
width: 180,
child: Text(
'${widget.label}: $display',
overflow: TextOverflow.ellipsis,
),
),
);
}
}

View File

@@ -2,7 +2,7 @@ import 'dart:convert';
import 'package:http/http.dart' as http; import 'package:http/http.dart' as http;
typedef TokenProvider = String? Function(); typedef TokenProvider = String? Function();
typedef UnauthorizedHandler = Future<void> Function(); typedef UnauthorizedHandler = Future<bool> Function();
class ApiService { class ApiService {
String _baseUrl; String _baseUrl;
@@ -36,35 +36,47 @@ class ApiService {
_client.close(); _client.close();
} }
Map<String, String> _buildHeaders(Map<String, String>? extra) { Map<String, String> _buildHeaders(
Map<String, String>? extra, {
bool includeAuth = true,
}) {
final token = _getToken?.call(); final token = _getToken?.call();
final headers = {'accept': 'application/json', ...?extra}; final headers = {'accept': 'application/json', ...?extra};
if (token != null && token.isNotEmpty) { if (includeAuth && token != null && token.isNotEmpty) {
headers['Authorization'] = 'Bearer $token'; headers['Authorization'] = 'Bearer $token';
} }
return headers; return headers;
} }
Future<dynamic> get(String endpoint, {Map<String, String>? headers}) async { Future<dynamic> get(
final response = await _client String endpoint, {
.get( Map<String, String>? headers,
bool includeAuth = true,
bool allowRetry = true,
}) async {
final response = await _sendWithRetry(
() => _client.get(
Uri.parse('$baseUrl$endpoint'), Uri.parse('$baseUrl$endpoint'),
headers: _buildHeaders(headers), headers: _buildHeaders(headers, includeAuth: includeAuth),
) ),
.timeout(timeout); allowRetry: allowRetry,
);
return _processResponse(response); return _processResponse(response);
} }
Future<ApiBinaryResponse> getBytes( Future<ApiBinaryResponse> getBytes(
String endpoint, { String endpoint, {
Map<String, String>? headers, Map<String, String>? headers,
bool includeAuth = true,
bool allowRetry = true,
}) async { }) async {
final response = await _client final response = await _sendWithRetry(
.get( () => _client.get(
Uri.parse('$baseUrl$endpoint'), Uri.parse('$baseUrl$endpoint'),
headers: _buildHeaders(headers), headers: _buildHeaders(headers, includeAuth: includeAuth),
) ),
.timeout(timeout); allowRetry: allowRetry,
);
if (response.statusCode >= 200 && response.statusCode < 300) { if (response.statusCode >= 200 && response.statusCode < 300) {
final contentDisposition = response.headers['content-disposition']; final contentDisposition = response.headers['content-disposition'];
@@ -76,10 +88,6 @@ class ApiService {
); );
} }
if (response.statusCode == 401 && _onUnauthorized != null) {
await _onUnauthorized!();
}
final body = _decodeBody(response); final body = _decodeBody(response);
final message = _extractErrorMessage(body); final message = _extractErrorMessage(body);
throw ApiException( throw ApiException(
@@ -93,18 +101,63 @@ class ApiService {
String endpoint, String endpoint,
dynamic data, { dynamic data, {
Map<String, String>? headers, Map<String, String>? headers,
bool includeAuth = true,
bool allowRetry = true,
}) async { }) async {
final hasBody = data != null; final hasBody = data != null;
final response = await _client final response = await _sendWithRetry(
.post( () => _client.post(
Uri.parse('$baseUrl$endpoint'), Uri.parse('$baseUrl$endpoint'),
headers: _buildHeaders(hasBody ? _jsonHeaders(headers) : headers), headers: _buildHeaders(
hasBody ? _jsonHeaders(headers) : headers,
includeAuth: includeAuth,
),
body: hasBody ? jsonEncode(data) : null, body: hasBody ? jsonEncode(data) : null,
) ),
.timeout(timeout); allowRetry: allowRetry,
);
return _processResponse(response); return _processResponse(response);
} }
Future<ApiBinaryResponse> postBytes(
String endpoint,
dynamic data, {
Map<String, String>? headers,
bool includeAuth = true,
bool allowRetry = true,
}) async {
final hasBody = data != null;
final response = await _sendWithRetry(
() => _client.post(
Uri.parse('$baseUrl$endpoint'),
headers: _buildHeaders(
hasBody ? _jsonHeaders(headers) : headers,
includeAuth: includeAuth,
),
body: hasBody ? jsonEncode(data) : null,
),
allowRetry: allowRetry,
);
if (response.statusCode >= 200 && response.statusCode < 300) {
final contentDisposition = response.headers['content-disposition'];
return ApiBinaryResponse(
bytes: response.bodyBytes,
statusCode: response.statusCode,
contentType: response.headers['content-type'],
filename: _extractFilename(contentDisposition),
);
}
final body = _decodeBody(response);
final message = _extractErrorMessage(body);
throw ApiException(
statusCode: response.statusCode,
message: message,
body: body,
);
}
Future<dynamic> postMultipartFile( Future<dynamic> postMultipartFile(
String endpoint, { String endpoint, {
required List<int> bytes, required List<int> bytes,
@@ -112,12 +165,15 @@ class ApiService {
String fieldName = 'file', String fieldName = 'file',
Map<String, String>? fields, Map<String, String>? fields,
Map<String, String>? headers, Map<String, String>? headers,
bool includeAuth = true,
bool allowRetry = true,
}) async { }) async {
Future<http.Response> send() async {
final request = http.MultipartRequest( final request = http.MultipartRequest(
'POST', 'POST',
Uri.parse('$baseUrl$endpoint'), Uri.parse('$baseUrl$endpoint'),
); );
request.headers.addAll(_buildHeaders(headers)); request.headers.addAll(_buildHeaders(headers, includeAuth: includeAuth));
if (fields != null && fields.isNotEmpty) { if (fields != null && fields.isNotEmpty) {
request.fields.addAll(fields); request.fields.addAll(fields);
} }
@@ -128,22 +184,34 @@ class ApiService {
filename: filename, filename: filename,
), ),
); );
final streamed = await _client.send(request).timeout(timeout); final streamed = await _client.send(request);
final response = await http.Response.fromStream(streamed); return http.Response.fromStream(streamed);
}
final response = await _sendWithRetry(send, allowRetry: allowRetry);
return _processResponse(response); return _processResponse(response);
} }
Future<dynamic> postForm(String endpoint, Map<String, String> data) async { Future<dynamic> postForm(
final response = await _client String endpoint,
.post( Map<String, String> data, {
bool includeAuth = true,
bool allowRetry = true,
}) async {
final response = await _sendWithRetry(
() => _client.post(
Uri.parse('$baseUrl$endpoint'), Uri.parse('$baseUrl$endpoint'),
headers: _buildHeaders({ headers: _buildHeaders(
{
'Content-Type': 'application/x-www-form-urlencoded', 'Content-Type': 'application/x-www-form-urlencoded',
'accept': 'application/json', 'accept': 'application/json',
}), },
includeAuth: includeAuth,
),
body: data, // http package handles form-encoding for Map<String, String> body: data, // http package handles form-encoding for Map<String, String>
) ),
.timeout(timeout); allowRetry: allowRetry,
);
return _processResponse(response); return _processResponse(response);
} }
@@ -151,28 +219,37 @@ class ApiService {
String endpoint, String endpoint,
dynamic data, { dynamic data, {
Map<String, String>? headers, Map<String, String>? headers,
bool includeAuth = true,
bool allowRetry = true,
}) async { }) async {
final hasBody = data != null; final hasBody = data != null;
final response = await _client final response = await _sendWithRetry(
.put( () => _client.put(
Uri.parse('$baseUrl$endpoint'), Uri.parse('$baseUrl$endpoint'),
headers: _buildHeaders(hasBody ? _jsonHeaders(headers) : headers), headers: _buildHeaders(
hasBody ? _jsonHeaders(headers) : headers,
includeAuth: includeAuth,
),
body: hasBody ? jsonEncode(data) : null, body: hasBody ? jsonEncode(data) : null,
) ),
.timeout(timeout); allowRetry: allowRetry,
);
return _processResponse(response); return _processResponse(response);
} }
Future<dynamic> delete( Future<dynamic> delete(
String endpoint, { String endpoint, {
Map<String, String>? headers, Map<String, String>? headers,
bool includeAuth = true,
bool allowRetry = true,
}) async { }) async {
final response = await _client final response = await _sendWithRetry(
.delete( () => _client.delete(
Uri.parse('$baseUrl$endpoint'), Uri.parse('$baseUrl$endpoint'),
headers: _buildHeaders(headers), headers: _buildHeaders(headers, includeAuth: includeAuth),
) ),
.timeout(timeout); allowRetry: allowRetry,
);
return _processResponse(response); return _processResponse(response);
} }
@@ -186,10 +263,6 @@ class ApiService {
return body; return body;
} }
if (res.statusCode == 401 && _onUnauthorized != null) {
await _onUnauthorized!();
}
final message = _extractErrorMessage(body); final message = _extractErrorMessage(body);
throw ApiException( throw ApiException(
statusCode: res.statusCode, statusCode: res.statusCode,
@@ -239,6 +312,20 @@ class ApiService {
return body.toString(); return body.toString();
} }
Future<http.Response> _sendWithRetry(
Future<http.Response> Function() send, {
required bool allowRetry,
}) async {
var response = await send().timeout(timeout);
if (response.statusCode == 401 && allowRetry && _onUnauthorized != null) {
final refreshed = await _onUnauthorized!();
if (refreshed) {
response = await send().timeout(timeout);
}
}
return response;
}
String? _extractFilename(String? contentDisposition) { String? _extractFilename(String? contentDisposition) {
if (contentDisposition == null || contentDisposition.isEmpty) return null; if (contentDisposition == null || contentDisposition.isEmpty) return null;
final utf8Match = final utf8Match =

View File

@@ -6,18 +6,20 @@ import 'package:mileograph_flutter/services/token_storage_service.dart';
class AuthService extends ChangeNotifier { class AuthService extends ChangeNotifier {
final ApiService api; final ApiService api;
bool _restoring = false; bool _restoring = false;
String? _accessToken;
Future<bool>? _refreshFuture;
final TokenStorageService _tokenStorage = TokenStorageService(); final TokenStorageService _tokenStorage = TokenStorageService();
AuthService({required this.api}) { AuthService({required this.api}) {
api.setTokenProvider(() => token); api.setTokenProvider(() => token);
api.setUnauthorizedHandler(handleTokenExpired); api.setUnauthorizedHandler(_handleUnauthorized);
} }
AuthenticatedUserData? _user; AuthenticatedUserData? _user;
bool get isLoggedIn => _user != null; bool get isLoggedIn => _user != null;
String? get token => _user?.accessToken; String? get token => _accessToken;
String? get userId => _user?.userId; String? get userId => _user?.userId;
String? get username => _user?.username; String? get username => _user?.username;
String? get fullName => _user?.fullName; String? get fullName => _user?.fullName;
@@ -33,11 +35,13 @@ class AuthService extends ChangeNotifier {
required String fullName, required String fullName,
required String accessToken, required String accessToken,
required String email, required String email,
String? refreshToken,
String entriesVisibility = 'private', String entriesVisibility = 'private',
String mileageVisibility = 'private', String mileageVisibility = 'private',
bool isElevated = false, bool isElevated = false,
bool isDisabled = false, bool isDisabled = false,
}) { }) {
_accessToken = accessToken;
_user = AuthenticatedUserData( _user = AuthenticatedUserData(
userId: userId, userId: userId,
username: username, username: username,
@@ -49,7 +53,7 @@ class AuthService extends ChangeNotifier {
isElevated: isElevated, isElevated: isElevated,
disabled: isDisabled, disabled: isDisabled,
); );
_persistToken(accessToken); _persistTokens(accessToken, refreshToken);
notifyListeners(); notifyListeners();
} }
@@ -64,8 +68,9 @@ class AuthService extends ChangeNotifier {
}; };
// 1. Get token // 1. Get token
final tokenResponse = await api.postForm('/token', formData); final tokenResponse = await api.postForm('/token', formData, includeAuth: false);
final accessToken = tokenResponse['access_token']; final accessToken = tokenResponse['access_token'];
final refreshToken = tokenResponse['refresh_token'];
// 2. Get user details // 2. Get user details
final userResponse = await api.get( final userResponse = await api.get(
@@ -83,6 +88,7 @@ class AuthService extends ChangeNotifier {
fullName: userResponse['full_name'], fullName: userResponse['full_name'],
accessToken: accessToken, accessToken: accessToken,
email: userResponse['email'], email: userResponse['email'],
refreshToken: refreshToken,
entriesVisibility: _parseVisibility( entriesVisibility: _parseVisibility(
userResponse['user_entries_visibility'] ?? userResponse['entries_visibility'], userResponse['user_entries_visibility'] ?? userResponse['entries_visibility'],
'private', 'private',
@@ -103,20 +109,18 @@ class AuthService extends ChangeNotifier {
// read token from secure storage (with fallback) // read token from secure storage (with fallback)
final token = await _tokenStorage.getToken(); final token = await _tokenStorage.getToken();
if (token == null || token.isEmpty) return; if (token == null || token.isEmpty) return;
_accessToken = token;
final userResponse = await api.get( final userResponse = await api.get(
'/users/me', '/users/me',
headers: {
'Authorization': 'Bearer $token',
'accept': 'application/json',
},
); );
final restoredAccessToken = _accessToken ?? token;
setLoginData( setLoginData(
userId: userResponse['user_id'], userId: userResponse['user_id'],
username: userResponse['username'], username: userResponse['username'],
fullName: userResponse['full_name'], fullName: userResponse['full_name'],
accessToken: token, accessToken: restoredAccessToken,
email: userResponse['email'], email: userResponse['email'],
entriesVisibility: _parseVisibility( entriesVisibility: _parseVisibility(
userResponse['user_entries_visibility'] ?? userResponse['entries_visibility'], userResponse['user_entries_visibility'] ?? userResponse['entries_visibility'],
@@ -140,12 +144,9 @@ class AuthService extends ChangeNotifier {
final token = await _tokenStorage.getToken(); final token = await _tokenStorage.getToken();
if (token == null || token.isEmpty) return false; if (token == null || token.isEmpty) return false;
try { try {
_accessToken = token;
await api.get( await api.get(
'/validate', '/validate',
headers: {
'Authorization': 'Bearer $token',
'accept': 'application/json',
},
); );
return true; return true;
} catch (_) { } catch (_) {
@@ -154,11 +155,15 @@ class AuthService extends ChangeNotifier {
} }
} }
Future<void> _persistToken(String token) async { Future<void> _persistTokens(String accessToken, String? refreshToken) async {
await _tokenStorage.setToken(token); await _tokenStorage.setToken(accessToken);
if (refreshToken != null && refreshToken.isNotEmpty) {
await _tokenStorage.setRefreshToken(refreshToken);
}
} }
Future<void> _clearToken() async { Future<void> _clearToken() async {
_accessToken = null;
await _tokenStorage.clearToken(); await _tokenStorage.clearToken();
} }
@@ -181,6 +186,61 @@ class AuthService extends ChangeNotifier {
await api.postForm('/register', formData); await api.postForm('/register', formData);
} }
Future<bool> _handleUnauthorized() async {
if (_refreshFuture != null) {
return _refreshFuture!;
}
_refreshFuture = _refreshTokens();
final refreshed = await _refreshFuture!;
_refreshFuture = null;
return refreshed;
}
Future<bool> _refreshTokens() async {
final refreshToken = await _tokenStorage.getRefreshToken();
if (refreshToken == null || refreshToken.isEmpty) {
await handleTokenExpired();
return false;
}
try {
final response = await api.post(
'/token/refresh',
{'refresh_token': refreshToken},
includeAuth: false,
allowRetry: false,
);
final accessToken = response['access_token'];
final newRefreshToken = response['refresh_token'];
if (accessToken is! String ||
accessToken.isEmpty ||
newRefreshToken is! String ||
newRefreshToken.isEmpty) {
await handleTokenExpired();
return false;
}
_accessToken = accessToken;
await _persistTokens(accessToken, newRefreshToken);
if (_user != null) {
_user = AuthenticatedUserData(
userId: _user!.userId,
username: _user!.username,
fullName: _user!.fullName,
accessToken: accessToken,
email: _user!.email,
entriesVisibility: _user!.entriesVisibility,
mileageVisibility: _user!.mileageVisibility,
isElevated: _user!.isElevated,
isDisabled: _user!.disabled,
);
}
notifyListeners();
return true;
} catch (_) {
await handleTokenExpired();
return false;
}
}
Future<void> handleTokenExpired() async { Future<void> handleTokenExpired() async {
_user = null; _user = null;
await _clearToken(); await _clearToken();

View File

@@ -55,7 +55,6 @@ extension DataServiceBadges on DataService {
bool onlyIncomplete = false, bool onlyIncomplete = false,
}) async { }) async {
_isClassClearanceProgressLoading = true; _isClassClearanceProgressLoading = true;
if (!append) _classClearanceProgress = [];
try { try {
final onlyIncompleteParam = final onlyIncompleteParam =
onlyIncomplete ? '&only_incomplete=true' : ''; onlyIncomplete ? '&only_incomplete=true' : '';
@@ -84,7 +83,6 @@ extension DataServiceBadges on DataService {
_classClearanceHasMore = items.length >= limit; _classClearanceHasMore = items.length >= limit;
} catch (e) { } catch (e) {
debugPrint('Failed to fetch class clearance progress: $e'); debugPrint('Failed to fetch class clearance progress: $e');
if (!append) _classClearanceProgress = [];
_classClearanceHasMore = false; _classClearanceHasMore = false;
} finally { } finally {
_isClassClearanceProgressLoading = false; _isClassClearanceProgressLoading = false;

View File

@@ -7,6 +7,7 @@ class _LegFetchOptions {
final String? dateRangeStart; final String? dateRangeStart;
final String? dateRangeEnd; final String? dateRangeEnd;
final bool unallocatedOnly; final bool unallocatedOnly;
final List<String> networkFilter;
const _LegFetchOptions({ const _LegFetchOptions({
this.limit = 100, this.limit = 100,
@@ -15,6 +16,7 @@ class _LegFetchOptions {
this.dateRangeStart, this.dateRangeStart,
this.dateRangeEnd, this.dateRangeEnd,
this.unallocatedOnly = false, this.unallocatedOnly = false,
this.networkFilter = const [],
}); });
} }
@@ -118,6 +120,7 @@ class DataService extends ChangeNotifier {
List<String> _stationNetworks = []; List<String> _stationNetworks = [];
Map<String, List<String>> _stationCountryNetworks = {}; Map<String, List<String>> _stationCountryNetworks = {};
DateTime? _stationFiltersFetchedAt; DateTime? _stationFiltersFetchedAt;
DateTime? _stationNetworksFetchedAt;
List<String> get stationNetworks => _stationNetworks; List<String> get stationNetworks => _stationNetworks;
Map<String, List<String>> get stationCountryNetworks => Map<String, List<String>> get stationCountryNetworks =>
_stationCountryNetworks; _stationCountryNetworks;
@@ -391,9 +394,14 @@ class DataService extends ChangeNotifier {
String? dateRangeEnd, String? dateRangeEnd,
bool append = false, bool append = false,
bool unallocatedOnly = false, bool unallocatedOnly = false,
List<String> networkFilter = const [],
}) async { }) async {
_isLegsLoading = true; _isLegsLoading = true;
if (!append) { if (!append) {
final normalizedNetworks = networkFilter
.map((network) => network.trim())
.where((network) => network.isNotEmpty)
.toList();
_lastLegsFetch = _LegFetchOptions( _lastLegsFetch = _LegFetchOptions(
limit: limit, limit: limit,
sortBy: sortBy, sortBy: sortBy,
@@ -401,6 +409,7 @@ class DataService extends ChangeNotifier {
dateRangeStart: dateRangeStart, dateRangeStart: dateRangeStart,
dateRangeEnd: dateRangeEnd, dateRangeEnd: dateRangeEnd,
unallocatedOnly: unallocatedOnly, unallocatedOnly: unallocatedOnly,
networkFilter: normalizedNetworks,
); );
} }
final buffer = StringBuffer( final buffer = StringBuffer(
@@ -415,6 +424,13 @@ class DataService extends ChangeNotifier {
if (unallocatedOnly) { if (unallocatedOnly) {
buffer.write('&unallocated_only=true'); buffer.write('&unallocated_only=true');
} }
final networks = networkFilter
.map((network) => network.trim())
.where((network) => network.isNotEmpty)
.toList();
for (final network in networks) {
buffer.write('&network_filter=${Uri.encodeQueryComponent(network)}');
}
try { try {
final json = await api.get('/user/legs${buffer.toString()}'); final json = await api.get('/user/legs${buffer.toString()}');
@@ -444,6 +460,7 @@ class DataService extends ChangeNotifier {
dateRangeStart: _lastLegsFetch.dateRangeStart, dateRangeStart: _lastLegsFetch.dateRangeStart,
dateRangeEnd: _lastLegsFetch.dateRangeEnd, dateRangeEnd: _lastLegsFetch.dateRangeEnd,
unallocatedOnly: _lastLegsFetch.unallocatedOnly, unallocatedOnly: _lastLegsFetch.unallocatedOnly,
networkFilter: _lastLegsFetch.networkFilter,
); );
} }
@@ -669,6 +686,7 @@ class DataService extends ChangeNotifier {
_stationNetworks = []; _stationNetworks = [];
_stationCountryNetworks = {}; _stationCountryNetworks = {};
_stationFiltersFetchedAt = null; _stationFiltersFetchedAt = null;
_stationNetworksFetchedAt = null;
_notifications = []; _notifications = [];
_isNotificationsLoading = false; _isNotificationsLoading = false;
_userEntriesVisibility = 'private'; _userEntriesVisibility = 'private';
@@ -736,6 +754,9 @@ class DataService extends ChangeNotifier {
final networks = (map['networks'] as List? ?? const []) final networks = (map['networks'] as List? ?? const [])
.whereType<String>() .whereType<String>()
.toList(); .toList();
networks.sort(
(a, b) => a.toLowerCase().compareTo(b.toLowerCase()),
);
final countryNetworksRaw = final countryNetworksRaw =
map['country_networks'] as Map? ?? const <String, dynamic>{}; map['country_networks'] as Map? ?? const <String, dynamic>{};
final countryNetworks = <String, List<String>>{}; final countryNetworks = <String, List<String>>{};
@@ -753,6 +774,31 @@ class DataService extends ChangeNotifier {
} }
} }
Future<void> fetchStationNetworks() async {
final now = DateTime.now();
final recent = _stationNetworks.isNotEmpty &&
((_stationNetworksFetchedAt != null &&
now.difference(_stationNetworksFetchedAt!) <
const Duration(minutes: 30)) ||
(_stationFiltersFetchedAt != null &&
now.difference(_stationFiltersFetchedAt!) <
const Duration(minutes: 30)));
if (recent) return;
try {
final response = await api.get('/stations/networks');
if (response is List) {
final networks = response.whereType<String>().toList();
networks.sort(
(a, b) => a.toLowerCase().compareTo(b.toLowerCase()),
);
_stationNetworks = networks;
_stationNetworksFetchedAt = now;
}
} catch (e) {
debugPrint('Failed to fetch station networks: $e');
}
}
String _stationKey(List<String> countries, List<String> networks) { String _stationKey(List<String> countries, List<String> networks) {
final c = countries..sort(); final c = countries..sort();
final n = networks..sort(); final n = networks..sort();

View File

@@ -10,7 +10,8 @@ class TokenStorageService {
factory TokenStorageService() => _instance; factory TokenStorageService() => _instance;
static const _tokenKey = 'auth_token'; static const _accessTokenKey = 'auth_token';
static const _refreshTokenKey = 'refresh_token';
final FlutterSecureStorage _secureStorage = const FlutterSecureStorage(); final FlutterSecureStorage _secureStorage = const FlutterSecureStorage();
Future<SharedPreferences> get _prefs async => Future<SharedPreferences> get _prefs async =>
@@ -18,17 +19,17 @@ class TokenStorageService {
Future<void> setToken(String token) async { Future<void> setToken(String token) async {
try { try {
await _secureStorage.write(key: _tokenKey, value: token); await _secureStorage.write(key: _accessTokenKey, value: token);
} catch (_) { } catch (_) {
// ignore secure storage failures in debug/unsupported environments // ignore secure storage failures in debug/unsupported environments
} }
final prefs = await _prefs; final prefs = await _prefs;
await prefs.setString(_tokenKey, token); await prefs.setString(_accessTokenKey, token);
} }
Future<String?> getToken() async { Future<String?> getToken() async {
try { try {
final secured = await _secureStorage.read(key: _tokenKey); final secured = await _secureStorage.read(key: _accessTokenKey);
if (secured != null && secured.isNotEmpty) { if (secured != null && secured.isNotEmpty) {
return secured; return secured;
} }
@@ -36,22 +37,48 @@ class TokenStorageService {
// ignore and fall back // ignore and fall back
} }
final prefs = await _prefs; final prefs = await _prefs;
final token = prefs.getString(_tokenKey); final token = prefs.getString(_accessTokenKey);
return (token == null || token.isEmpty) ? null : token; return (token == null || token.isEmpty) ? null : token;
} }
Future<void> clearToken() async { Future<void> clearToken() async {
try { try {
await _secureStorage.delete(key: _tokenKey); await _secureStorage.delete(key: _accessTokenKey);
await _secureStorage.delete(key: _refreshTokenKey);
} catch (_) { } catch (_) {
// ignore // ignore
} }
final prefs = await _prefs; final prefs = await _prefs;
await prefs.remove(_tokenKey); await prefs.remove(_accessTokenKey);
await prefs.remove(_refreshTokenKey);
} }
Future<bool> hasToken() async { Future<bool> hasToken() async {
final token = await getToken(); final token = await getToken();
return token != null && token.isNotEmpty; return token != null && token.isNotEmpty;
} }
Future<void> setRefreshToken(String token) async {
try {
await _secureStorage.write(key: _refreshTokenKey, value: token);
} catch (_) {
// ignore secure storage failures in debug/unsupported environments
}
final prefs = await _prefs;
await prefs.setString(_refreshTokenKey, token);
}
Future<String?> getRefreshToken() async {
try {
final secured = await _secureStorage.read(key: _refreshTokenKey);
if (secured != null && secured.isNotEmpty) {
return secured;
}
} catch (_) {
// ignore and fall back
}
final prefs = await _prefs;
final token = prefs.getString(_refreshTokenKey);
return (token == null || token.isEmpty) ? null : token;
}
} }

View File

@@ -262,6 +262,14 @@ packages:
url: "https://pub.dev" url: "https://pub.dev"
source: hosted source: hosted
version: "4.1.0" version: "4.1.0"
flutter_svg:
dependency: "direct main"
description:
name: flutter_svg
sha256: "87fbd7c534435b6c5d9d98b01e1fd527812b82e68ddd8bd35fc45ed0fa8f0a95"
url: "https://pub.dev"
source: hosted
version: "2.2.3"
flutter_test: flutter_test:
dependency: "direct dev" dependency: "direct dev"
description: flutter description: flutter
@@ -400,6 +408,14 @@ packages:
url: "https://pub.dev" url: "https://pub.dev"
source: hosted source: hosted
version: "1.9.1" version: "1.9.1"
path_parsing:
dependency: transitive
description:
name: path_parsing
sha256: "883402936929eac138ee0a45da5b0f2c80f89913e6dc3bf77eb65b84b409c6ca"
url: "https://pub.dev"
source: hosted
version: "1.1.0"
path_provider: path_provider:
dependency: transitive dependency: transitive
description: description:
@@ -605,6 +621,30 @@ packages:
url: "https://pub.dev" url: "https://pub.dev"
source: hosted source: hosted
version: "1.4.0" version: "1.4.0"
vector_graphics:
dependency: transitive
description:
name: vector_graphics
sha256: a4f059dc26fc8295b5921376600a194c4ec7d55e72f2fe4c7d2831e103d461e6
url: "https://pub.dev"
source: hosted
version: "1.1.19"
vector_graphics_codec:
dependency: transitive
description:
name: vector_graphics_codec
sha256: "99fd9fbd34d9f9a32efd7b6a6aae14125d8237b10403b422a6a6dfeac2806146"
url: "https://pub.dev"
source: hosted
version: "1.1.13"
vector_graphics_compiler:
dependency: transitive
description:
name: vector_graphics_compiler
sha256: d354a7ec6931e6047785f4db12a1f61ec3d43b207fc0790f863818543f8ff0dc
url: "https://pub.dev"
source: hosted
version: "1.1.19"
vector_math: vector_math:
dependency: transitive dependency: transitive
description: description:

View File

@@ -16,7 +16,7 @@ publish_to: "none" # Remove this line if you wish to publish to pub.dev
# https://developer.apple.com/library/archive/documentation/General/Reference/InfoPlistKeyReference/Articles/CoreFoundationKeys.html # https://developer.apple.com/library/archive/documentation/General/Reference/InfoPlistKeyReference/Articles/CoreFoundationKeys.html
# In Windows, build-name is used as the major, minor, and patch parts # In Windows, build-name is used as the major, minor, and patch parts
# of the product and file versions while build-number is used as the build suffix. # of the product and file versions while build-number is used as the build suffix.
version: 0.7.6+14 version: 0.7.8+16
environment: environment:
sdk: ^3.8.1 sdk: ^3.8.1
@@ -42,6 +42,7 @@ dependencies:
file_selector_macos: ^0.9.4 file_selector_macos: ^0.9.4
file_selector_windows: ^0.9.3 file_selector_windows: ^0.9.3
file_selector_web: ^0.9.4 file_selector_web: ^0.9.4
flutter_svg: ^2.0.10
# The following adds the Cupertino Icons font to your application. # The following adds the Cupertino Icons font to your application.
# Use with the CupertinoIcons class for iOS style icons. # Use with the CupertinoIcons class for iOS style icons.
@@ -73,6 +74,8 @@ flutter:
- family: Tomatoes - family: Tomatoes
fonts: fonts:
- asset: lib/assets/fonts/Tomatoes-O8L8.ttf - asset: lib/assets/fonts/Tomatoes-O8L8.ttf
assets:
- assets/logos/pg_logo_v2.svg
# To add assets to your application, add an assets section, like this: # To add assets to your application, add an assets section, like this:
# assets: # assets:
# - images/a_dot_burr.jpeg # - images/a_dot_burr.jpeg

View File

@@ -201,6 +201,7 @@ class FakeDataService extends DataService {
String? dateRangeEnd, String? dateRangeEnd,
bool append = false, bool append = false,
bool unallocatedOnly = false, bool unallocatedOnly = false,
List<String> networkFilter = const [],
}) async {} }) async {}
@override @override
@@ -231,6 +232,9 @@ class FakeDataService extends DataService {
@override @override
Future<void> fetchPendingLocoCount() async {} Future<void> fetchPendingLocoCount() async {}
@override
Future<void> fetchStationNetworks() async {}
@override @override
Future<Map<String, dynamic>?> fetchClassStats(String locoClass) async { Future<Map<String, dynamic>?> fetchClassStats(String locoClass) async {
return TestData.classStats; return TestData.classStats;

View File

@@ -1,3 +1,4 @@
import 'package:flutter/material.dart';
import 'package:flutter_test/flutter_test.dart'; import 'package:flutter_test/flutter_test.dart';
import 'package:go_router/go_router.dart'; import 'package:go_router/go_router.dart';
import 'package:shared_preferences/shared_preferences.dart'; import 'package:shared_preferences/shared_preferences.dart';