25-9-8-1

lib/controller/functions/crud.dart

@@ -1,5 +1,6 @@
 import 'dart:convert';
 import 'package:jwt_decoder/jwt_decoder.dart';
+import 'package:sefer_driver/controller/functions/network/net_guard.dart';
 import 'package:secure_string_operations/secure_string_operations.dart';
 import 'package:sefer_driver/constant/box_name.dart';
 import 'package:sefer_driver/constant/links.dart';
@@ -12,11 +13,14 @@ import 'package:sefer_driver/env/env.dart';
 import '../../constant/api_key.dart';
 import '../../constant/char_map.dart';
 import '../../constant/info.dart';
+import '../../views/widgets/error_snakbar.dart';
 import '../../print.dart';
 import 'gemeni.dart';
 import 'upload_image.dart';
 
 class CRUD {
+  final NetGuard _netGuard = NetGuard();
+
   /// Stores the signature of the last logged error to prevent duplicates.
   static String _lastErrorSignature = '';
 
@@ -82,6 +86,17 @@ class CRUD {
     Map<String, dynamic>? payload,
     required Map<String, String> headers,
   }) async {
+    // ✅ 1. Check for internet connection before making any request.
+    if (!await _netGuard.hasInternet(mustReach: Uri.parse(link))) {
+      // ✅ 2. If no internet, show a notification to the user (only once every 15s).
+      _netGuard.notifyOnce((title, msg) {
+        mySnackeBarError(
+            msg); // Using your existing snackbar for notifications.
+      });
+      // ✅ 3. Return a specific status to indicate no internet.
+      return 'no_internet';
+    }
+
     var url = Uri.parse(link);
     try {
       var response = await http.post(
@@ -212,6 +227,78 @@ class CRUD {
     );
   }
 
+  Future<dynamic> postWalletMtn(
+      {required String link, Map<String, dynamic>? payload}) async {
+    final s = await LoginDriverController().getJwtWallet();
+    final hmac = box.read(BoxName.hmac);
+    final url = Uri.parse(link);
+
+    try {
+      final response = await http.post(
+        url,
+        body: payload, // form-urlencoded مناسب لـ filterRequest
+        headers: {
+          "Content-Type": "application/x-www-form-urlencoded",
+          "Authorization": "Bearer $s",
+          "X-HMAC-Auth": hmac.toString(),
+        },
+      );
+
+      print('req: ${response.request}');
+      print('status: ${response.statusCode}');
+      print('body: ${response.body}');
+      print('payload: $payload');
+
+      Map<String, dynamic> wrap(String status, {Object? message, int? code}) {
+        return {
+          'status': status,
+          'message': message,
+          'code': code ?? response.statusCode,
+        };
+      }
+
+      if (response.statusCode == 200) {
+        try {
+          final jsonData = jsonDecode(response.body);
+          // نتوقع الآن شكل موحّد من السيرفر: {status, message, data?}
+          return jsonData;
+        } catch (e) {
+          return wrap('failure',
+              message: 'JSON decode error', code: response.statusCode);
+        }
+      } else if (response.statusCode == 401) {
+        try {
+          final jsonData = jsonDecode(response.body);
+          if (jsonData is Map && jsonData['error'] == 'Token expired') {
+            await Get.put(LoginDriverController()).getJWT();
+            return {
+              'status': 'failure',
+              'message': 'token_expired',
+              'code': 401
+            };
+          }
+          return wrap('failure', message: jsonData);
+        } catch (_) {
+          return wrap('failure', message: response.body);
+        }
+      } else {
+        // غير 200 – ارجع التفاصيل
+        try {
+          final jsonData = jsonDecode(response.body);
+          return wrap('failure', message: jsonData);
+        } catch (_) {
+          return wrap('failure', message: response.body);
+        }
+      }
+    } catch (e) {
+      return {
+        'status': 'failure',
+        'message': 'HTTP request error: $e',
+        'code': -1
+      };
+    }
+  }
+
   Future<dynamic> get({
     required String link,
     Map<String, dynamic>? payload,
@@ -820,3 +907,32 @@ class CRUD {
     return json.decode(response.body);
   }
 }
+
+/// Custom exception for when there is no internet connection.
+class NoInternetException implements Exception {
+  final String message;
+  NoInternetException(
+      [this.message =
+          'No internet connection. Please check your network and try again.']);
+  @override
+  String toString() => message;
+}
+
+/// Custom exception for when the network is too slow (request times out).
+class WeakNetworkException implements Exception {
+  final String message;
+  WeakNetworkException(
+      [this.message =
+          'Your network connection is too slow. Please try again later.']);
+  @override
+  String toString() => message;
+}
+
+class ApiException implements Exception {
+  final String message;
+  final int? statusCode;
+  ApiException(this.message, [this.statusCode]);
+  @override
+  String toString() =>
+      "ApiException: $message (Status Code: ${statusCode ?? 'N/A'})";
+}

lib/controller/functions/network/connection_check.dart

@@ -0,0 +1,48 @@
+import 'dart:async';
+import 'dart:io';
+import 'package:http/http.dart' as http;
+
+import 'net_guard.dart';
+
+typedef BodyEncoder = Future<http.Response> Function();
+
+class HttpRetry {
+  /// ريتراي لـ network/transient errors فقط.
+  static Future<http.Response> sendWithRetry(
+    BodyEncoder send, {
+    int maxRetries = 3,
+    Duration baseDelay = const Duration(milliseconds: 400),
+    Duration timeout = const Duration(seconds: 12),
+  }) async {
+    // ✅ Pre-flight check for internet connection
+    if (!await NetGuard().hasInternet()) {
+      // Immediately throw a specific exception if there's no internet.
+      // This avoids pointless retries.
+      throw const SocketException("No internet connection");
+    }
+    int attempt = 0;
+    while (true) {
+      attempt++;
+      try {
+        final res = await send().timeout(timeout);
+        return res;
+      } on TimeoutException catch (_) {
+        if (attempt >= maxRetries) rethrow;
+      } on SocketException catch (_) {
+        if (attempt >= maxRetries) rethrow;
+      } on HandshakeException catch (_) {
+        if (attempt >= maxRetries) rethrow;
+      } on http.ClientException catch (e) {
+        // مثال: Connection reset by peer
+        final msg = e.message.toLowerCase();
+        final transient = msg.contains('connection reset') ||
+            msg.contains('broken pipe') ||
+            msg.contains('timed out');
+        if (!transient || attempt >= maxRetries) rethrow;
+      }
+      // backoff: 0.4s, 0.8s, 1.6s
+      final delay = baseDelay * (1 << (attempt - 1));
+      await Future.delayed(delay);
+    }
+  }
+}

lib/controller/functions/network/net_guard.dart

@@ -0,0 +1,48 @@
+import 'dart:async';
+import 'dart:io';
+import 'package:connectivity_plus/connectivity_plus.dart';
+import 'package:internet_connection_checker/internet_connection_checker.dart';
+
+class NetGuard {
+  static final NetGuard _i = NetGuard._();
+  NetGuard._();
+  factory NetGuard() => _i;
+
+  bool _notified = false;
+
+  /// فحص: (أ) فيه شبكة؟ (ب) فيه انترنت؟ (ج) السيرفر نفسه reachable؟
+  Future<bool> hasInternet({Uri? mustReach}) async {
+    final connectivity = await Connectivity().checkConnectivity();
+    if (connectivity == ConnectivityResult.none) return false;
+
+    final hasNet =
+        await InternetConnectionChecker.createInstance().hasConnection;
+    if (!hasNet) return false;
+
+    if (mustReach != null) {
+      try {
+        final host = mustReach.host;
+        final result = await InternetAddress.lookup(host);
+        if (result.isEmpty || result.first.rawAddress.isEmpty) return false;
+
+        // اختباري خفيف عبر TCP (80/443) — 400ms timeout
+        final port = mustReach.scheme == 'http' ? 80 : 443;
+        final socket = await Socket.connect(host, port,
+            timeout: const Duration(milliseconds: 400));
+        socket.destroy();
+      } catch (_) {
+        return false;
+      }
+    }
+    return true;
+  }
+
+  /// إظهار إشعار مرة واحدة ثم إسكات التكرارات
+  void notifyOnce(void Function(String title, String msg) show) {
+    if (_notified) return;
+    _notified = true;
+    show('لا يوجد اتصال بالإنترنت', 'تحقق من الشبكة ثم حاول مجددًا.');
+    // إعادة السماح بعد 15 ثانية
+    Future.delayed(const Duration(seconds: 15), () => _notified = false);
+  }
+}