Compare commits
4 Commits
0.7.6-dev.
...
0.7.8-dev.
| Author | SHA1 | Date | |
|---|---|---|---|
| 94adf06726 | |||
| 8340501f37 | |||
| a527ecdb17 | |||
| f3fcf07b05 |
27
assets/logos/pg_logo_v2.svg
Normal file
27
assets/logos/pg_logo_v2.svg
Normal 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 |
@@ -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,
|
|
||||||
),
|
|
||||||
),
|
|
||||||
);
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|||||||
@@ -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,71 +43,101 @@ class _LoginScreenState extends State<LoginScreen> {
|
|||||||
resizeToAvoidBottomInset: true,
|
resizeToAvoidBottomInset: true,
|
||||||
body: Container(
|
body: Container(
|
||||||
color: Theme.of(context).scaffoldBackgroundColor,
|
color: Theme.of(context).scaffoldBackgroundColor,
|
||||||
child: Center(
|
child: SafeArea(
|
||||||
child: Column(
|
child: Column(
|
||||||
mainAxisAlignment: MainAxisAlignment.center,
|
|
||||||
children: [
|
children: [
|
||||||
Text.rich(
|
Expanded(
|
||||||
TextSpan(
|
child: Center(
|
||||||
children: [
|
child: Column(
|
||||||
TextSpan(
|
mainAxisAlignment: MainAxisAlignment.center,
|
||||||
text: "Mile",
|
children: [
|
||||||
style: TextStyle(
|
LayoutBuilder(
|
||||||
color: Theme.of(context).textTheme.bodyLarge?.color,
|
builder: (context, constraints) {
|
||||||
|
return SizedBox(
|
||||||
|
width: constraints.maxWidth,
|
||||||
|
child: FittedBox(
|
||||||
|
fit: BoxFit.scaleDown,
|
||||||
|
child: Text.rich(
|
||||||
|
TextSpan(
|
||||||
|
children: [
|
||||||
|
TextSpan(
|
||||||
|
text: "Mile",
|
||||||
|
style: TextStyle(
|
||||||
|
color: Theme.of(
|
||||||
|
context,
|
||||||
|
).textTheme.bodyLarge?.color,
|
||||||
|
),
|
||||||
|
),
|
||||||
|
const TextSpan(
|
||||||
|
text: "O",
|
||||||
|
style: TextStyle(color: Colors.red),
|
||||||
|
),
|
||||||
|
TextSpan(
|
||||||
|
text: "graph",
|
||||||
|
style: TextStyle(
|
||||||
|
color: Theme.of(
|
||||||
|
context,
|
||||||
|
).textTheme.bodyLarge?.color,
|
||||||
|
),
|
||||||
|
),
|
||||||
|
],
|
||||||
|
style: const TextStyle(
|
||||||
|
decoration: TextDecoration.none,
|
||||||
|
color: Colors.white,
|
||||||
|
fontFamily: "Tomatoes",
|
||||||
|
fontSize: 50,
|
||||||
|
),
|
||||||
|
),
|
||||||
|
softWrap: false,
|
||||||
|
overflow: TextOverflow.visible,
|
||||||
|
),
|
||||||
|
),
|
||||||
|
);
|
||||||
|
},
|
||||||
),
|
),
|
||||||
),
|
const SizedBox(height: 40),
|
||||||
const TextSpan(
|
if (_checkingSession) ...[
|
||||||
text: "O",
|
const SizedBox(height: 12),
|
||||||
style: TextStyle(color: Colors.red),
|
Row(
|
||||||
),
|
mainAxisAlignment: MainAxisAlignment.center,
|
||||||
TextSpan(
|
children: [
|
||||||
text: "graph",
|
const SizedBox(
|
||||||
style: TextStyle(
|
height: 24,
|
||||||
color: Theme.of(context).textTheme.bodyLarge?.color,
|
width: 24,
|
||||||
),
|
child: CircularProgressIndicator(strokeWidth: 2),
|
||||||
),
|
),
|
||||||
],
|
const SizedBox(width: 8),
|
||||||
style: const TextStyle(
|
Text(
|
||||||
decoration: TextDecoration.none,
|
'Trying to log in',
|
||||||
color: Colors.white,
|
style: Theme.of(context).textTheme.bodyMedium,
|
||||||
fontFamily: "Tomatoes",
|
),
|
||||||
fontSize: 50,
|
],
|
||||||
|
),
|
||||||
|
] 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 SizedBox(height: 50),
|
const Padding(
|
||||||
const LoginPanel(),
|
padding: EdgeInsets.only(bottom: 12),
|
||||||
const SizedBox(height: 16),
|
child: _LoginLogo(),
|
||||||
IconButton(
|
|
||||||
icon: const Icon(Icons.settings, color: Colors.grey),
|
|
||||||
tooltip: 'Settings',
|
|
||||||
onPressed: () {
|
|
||||||
Navigator.of(context).push(
|
|
||||||
MaterialPageRoute(
|
|
||||||
fullscreenDialog: true,
|
|
||||||
builder: (_) => const SettingsPage(),
|
|
||||||
),
|
|
||||||
);
|
|
||||||
},
|
|
||||||
),
|
),
|
||||||
if (_checkingSession) ...[
|
|
||||||
const SizedBox(height: 12),
|
|
||||||
Row(
|
|
||||||
mainAxisAlignment: MainAxisAlignment.center,
|
|
||||||
children: [
|
|
||||||
const SizedBox(
|
|
||||||
height: 24,
|
|
||||||
width: 24,
|
|
||||||
child: CircularProgressIndicator(strokeWidth: 2),
|
|
||||||
),
|
|
||||||
const SizedBox(width: 8),
|
|
||||||
Text(
|
|
||||||
'Trying to log in',
|
|
||||||
style: Theme.of(context).textTheme.bodyMedium,
|
|
||||||
),
|
|
||||||
],
|
|
||||||
),
|
|
||||||
],
|
|
||||||
],
|
],
|
||||||
),
|
),
|
||||||
),
|
),
|
||||||
@@ -114,6 +146,57 @@ class _LoginScreenState extends State<LoginScreen> {
|
|||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
|
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});
|
||||||
|
|
||||||
|
|||||||
@@ -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),
|
||||||
|
),
|
||||||
|
),
|
||||||
],
|
],
|
||||||
),
|
),
|
||||||
),
|
),
|
||||||
|
|||||||
@@ -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')) {
|
||||||
|
|||||||
166
lib/components/widgets/multi_select_filter.dart
Normal file
166
lib/components/widgets/multi_select_filter.dart
Normal 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,
|
||||||
|
),
|
||||||
|
),
|
||||||
|
);
|
||||||
|
}
|
||||||
|
}
|
||||||
@@ -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,
|
||||||
Uri.parse('$baseUrl$endpoint'),
|
bool includeAuth = true,
|
||||||
headers: _buildHeaders(headers),
|
bool allowRetry = true,
|
||||||
)
|
}) async {
|
||||||
.timeout(timeout);
|
final response = await _sendWithRetry(
|
||||||
|
() => _client.get(
|
||||||
|
Uri.parse('$baseUrl$endpoint'),
|
||||||
|
headers: _buildHeaders(headers, includeAuth: includeAuth),
|
||||||
|
),
|
||||||
|
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(
|
||||||
body: hasBody ? jsonEncode(data) : null,
|
hasBody ? _jsonHeaders(headers) : headers,
|
||||||
)
|
includeAuth: includeAuth,
|
||||||
.timeout(timeout);
|
),
|
||||||
|
body: hasBody ? jsonEncode(data) : null,
|
||||||
|
),
|
||||||
|
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,38 +165,53 @@ 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 {
|
||||||
final request = http.MultipartRequest(
|
Future<http.Response> send() async {
|
||||||
'POST',
|
final request = http.MultipartRequest(
|
||||||
Uri.parse('$baseUrl$endpoint'),
|
'POST',
|
||||||
);
|
Uri.parse('$baseUrl$endpoint'),
|
||||||
request.headers.addAll(_buildHeaders(headers));
|
);
|
||||||
if (fields != null && fields.isNotEmpty) {
|
request.headers.addAll(_buildHeaders(headers, includeAuth: includeAuth));
|
||||||
request.fields.addAll(fields);
|
if (fields != null && fields.isNotEmpty) {
|
||||||
|
request.fields.addAll(fields);
|
||||||
|
}
|
||||||
|
request.files.add(
|
||||||
|
http.MultipartFile.fromBytes(
|
||||||
|
fieldName,
|
||||||
|
bytes,
|
||||||
|
filename: filename,
|
||||||
|
),
|
||||||
|
);
|
||||||
|
final streamed = await _client.send(request);
|
||||||
|
return http.Response.fromStream(streamed);
|
||||||
}
|
}
|
||||||
request.files.add(
|
|
||||||
http.MultipartFile.fromBytes(
|
final response = await _sendWithRetry(send, allowRetry: allowRetry);
|
||||||
fieldName,
|
|
||||||
bytes,
|
|
||||||
filename: filename,
|
|
||||||
),
|
|
||||||
);
|
|
||||||
final streamed = await _client.send(request).timeout(timeout);
|
|
||||||
final response = await http.Response.fromStream(streamed);
|
|
||||||
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, {
|
||||||
Uri.parse('$baseUrl$endpoint'),
|
bool includeAuth = true,
|
||||||
headers: _buildHeaders({
|
bool allowRetry = true,
|
||||||
|
}) async {
|
||||||
|
final response = await _sendWithRetry(
|
||||||
|
() => _client.post(
|
||||||
|
Uri.parse('$baseUrl$endpoint'),
|
||||||
|
headers: _buildHeaders(
|
||||||
|
{
|
||||||
'Content-Type': 'application/x-www-form-urlencoded',
|
'Content-Type': 'application/x-www-form-urlencoded',
|
||||||
'accept': 'application/json',
|
'accept': 'application/json',
|
||||||
}),
|
},
|
||||||
body: data, // http package handles form-encoding for Map<String, String>
|
includeAuth: includeAuth,
|
||||||
)
|
),
|
||||||
.timeout(timeout);
|
body: data, // http package handles form-encoding for Map<String, String>
|
||||||
|
),
|
||||||
|
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(
|
||||||
body: hasBody ? jsonEncode(data) : null,
|
hasBody ? _jsonHeaders(headers) : headers,
|
||||||
)
|
includeAuth: includeAuth,
|
||||||
.timeout(timeout);
|
),
|
||||||
|
body: hasBody ? jsonEncode(data) : null,
|
||||||
|
),
|
||||||
|
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 =
|
||||||
|
|||||||
@@ -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,33 +109,31 @@ 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',
|
|
||||||
},
|
|
||||||
);
|
);
|
||||||
|
|
||||||
setLoginData(
|
final restoredAccessToken = _accessToken ?? token;
|
||||||
userId: userResponse['user_id'],
|
setLoginData(
|
||||||
username: userResponse['username'],
|
userId: userResponse['user_id'],
|
||||||
fullName: userResponse['full_name'],
|
username: userResponse['username'],
|
||||||
accessToken: token,
|
fullName: userResponse['full_name'],
|
||||||
email: userResponse['email'],
|
accessToken: restoredAccessToken,
|
||||||
entriesVisibility: _parseVisibility(
|
email: userResponse['email'],
|
||||||
userResponse['user_entries_visibility'] ?? userResponse['entries_visibility'],
|
entriesVisibility: _parseVisibility(
|
||||||
'private',
|
userResponse['user_entries_visibility'] ?? userResponse['entries_visibility'],
|
||||||
),
|
'private',
|
||||||
mileageVisibility: _parseVisibility(
|
),
|
||||||
userResponse['user_mileage_visibility'] ?? userResponse['mileage_visibility'],
|
mileageVisibility: _parseVisibility(
|
||||||
'private',
|
userResponse['user_mileage_visibility'] ?? userResponse['mileage_visibility'],
|
||||||
),
|
'private',
|
||||||
isElevated: _parseIsElevated(userResponse),
|
),
|
||||||
isDisabled: _parseIsDisabled(userResponse),
|
isElevated: _parseIsElevated(userResponse),
|
||||||
);
|
isDisabled: _parseIsDisabled(userResponse),
|
||||||
} catch (_) {
|
);
|
||||||
|
} catch (_) {
|
||||||
await _clearToken();
|
await _clearToken();
|
||||||
} finally {
|
} finally {
|
||||||
_restoring = false;
|
_restoring = false;
|
||||||
@@ -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();
|
||||||
|
|||||||
@@ -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;
|
||||||
|
|||||||
@@ -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();
|
||||||
|
|||||||
@@ -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;
|
||||||
|
}
|
||||||
}
|
}
|
||||||
|
|||||||
40
pubspec.lock
40
pubspec.lock
@@ -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:
|
||||||
|
|||||||
@@ -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
|
||||||
|
|||||||
@@ -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;
|
||||||
|
|||||||
@@ -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';
|
||||||
|
|||||||
Reference in New Issue
Block a user