124 lines
3.6 KiB
Dart
124 lines
3.6 KiB
Dart
import 'package:flutter_riverpod/flutter_riverpod.dart';
|
|
import '../api/types.dart';
|
|
import '../api/client.dart';
|
|
import '../api/openapi_config.dart';
|
|
import '../services/auth_service.dart';
|
|
import '../models/user_profile.dart';
|
|
import '../models/delivery_route.dart';
|
|
import '../models/delivery.dart';
|
|
import '../models/delivery_order.dart';
|
|
import '../models/delivery_address.dart';
|
|
import '../models/delivery_contact.dart';
|
|
|
|
final authServiceProvider = Provider<AuthService>((ref) {
|
|
return AuthService();
|
|
});
|
|
|
|
final apiClientProvider = Provider<CqrsApiClient>((ref) {
|
|
return CqrsApiClient(config: ApiClientConfig.production);
|
|
});
|
|
|
|
final isAuthenticatedProvider = FutureProvider<bool>((ref) async {
|
|
final authService = ref.watch(authServiceProvider);
|
|
return await authService.isAuthenticated();
|
|
});
|
|
|
|
final userProfileProvider = FutureProvider<UserProfile?>((ref) async {
|
|
final authService = ref.watch(authServiceProvider);
|
|
final token = await authService.getToken();
|
|
if (token == null) return null;
|
|
return authService.decodeToken(token);
|
|
});
|
|
|
|
final authTokenProvider = FutureProvider<String?>((ref) async {
|
|
final authService = ref.watch(authServiceProvider);
|
|
return await authService.getToken();
|
|
});
|
|
|
|
final deliveryRoutesProvider = FutureProvider<List<DeliveryRoute>>((ref) async {
|
|
final token = ref.watch(authTokenProvider).valueOrNull;
|
|
|
|
if (token == null) {
|
|
throw Exception('User not authenticated');
|
|
}
|
|
|
|
// Create a new client with auth token
|
|
final authClient = CqrsApiClient(
|
|
config: ApiClientConfig(
|
|
baseUrl: ApiClientConfig.production.baseUrl,
|
|
defaultHeaders: {'Authorization': 'Bearer $token'},
|
|
),
|
|
);
|
|
|
|
final result = await authClient.executeQuery<List<DeliveryRoute>>(
|
|
endpoint: 'simpleDeliveryRouteQueryItems',
|
|
query: _EmptyQuery(),
|
|
fromJson: (json) {
|
|
// API returns data wrapped in object with "data" field
|
|
if (json is Map<String, dynamic>) {
|
|
final data = json['data'];
|
|
if (data is List) {
|
|
return (data as List<dynamic>).map((r) => DeliveryRoute.fromJson(r as Map<String, dynamic>)).toList();
|
|
}
|
|
}
|
|
return [];
|
|
},
|
|
);
|
|
|
|
return result.whenSuccess((routes) => routes) ?? [];
|
|
});
|
|
|
|
final deliveriesProvider = FutureProvider.family<List<Delivery>, int>((ref, routeFragmentId) async {
|
|
final token = ref.watch(authTokenProvider).valueOrNull;
|
|
|
|
if (token == null) {
|
|
throw Exception('User not authenticated');
|
|
}
|
|
|
|
final authClient = CqrsApiClient(
|
|
config: ApiClientConfig(
|
|
baseUrl: ApiClientConfig.production.baseUrl,
|
|
defaultHeaders: {'Authorization': 'Bearer $token'},
|
|
),
|
|
);
|
|
|
|
final result = await authClient.executeQuery<List<Delivery>>(
|
|
endpoint: 'simpleDeliveriesQueryItems',
|
|
query: _DeliveriesQuery(routeFragmentId: routeFragmentId),
|
|
fromJson: (json) {
|
|
// API returns data wrapped in object with "data" field
|
|
if (json is Map<String, dynamic>) {
|
|
final data = json['data'];
|
|
if (data is List) {
|
|
return (data as List<dynamic>).map((d) => Delivery.fromJson(d as Map<String, dynamic>)).toList();
|
|
}
|
|
}
|
|
return [];
|
|
},
|
|
);
|
|
|
|
return result.whenSuccess((deliveries) => deliveries) ?? [];
|
|
});
|
|
|
|
final languageProvider = StateProvider<String>((ref) {
|
|
return 'fr';
|
|
});
|
|
|
|
class _EmptyQuery implements Serializable {
|
|
@override
|
|
Map<String, Object?> toJson() => {};
|
|
}
|
|
|
|
class _DeliveriesQuery implements Serializable {
|
|
final int routeFragmentId;
|
|
|
|
_DeliveriesQuery({required this.routeFragmentId});
|
|
|
|
@override
|
|
Map<String, Object?> toJson() => {
|
|
'params': {
|
|
'routeFragmentId': routeFragmentId,
|
|
},
|
|
};
|
|
}
|