25-2/24/1

lib/controller/functions/crud.dart

@@ -1,15 +1,23 @@
 import 'dart:convert';
 import 'package:Tripz/constant/box_name.dart';
 import 'package:Tripz/constant/links.dart';
+import 'package:Tripz/controller/auth/login_controller.dart';
+import 'package:Tripz/controller/functions/encrypt_decrypt.dart';
+import 'package:Tripz/controller/functions/package_info.dart';
 import 'package:Tripz/main.dart';
+import 'package:Tripz/views/widgets/mydialoug.dart';
 import 'package:get/get.dart';
 import 'package:http/http.dart' as http;
 import 'package:Tripz/env/env.dart';
+import 'package:secure_string_operations/secure_string_operations.dart';
 
 import '../../constant/api_key.dart';
 
+import '../../constant/char_map.dart';
+import '../../constant/info.dart';
 import '../../print.dart';
 import '../../views/widgets/elevated_btn.dart';
+import '../../views/widgets/error_snakbar.dart';
 import 'add_error.dart';
 import 'upload_image.dart';
 
@@ -27,25 +35,89 @@ class CRUD {
       headers: {
         "Content-Type": "application/x-www-form-urlencoded",
         'Authorization':
-            'Basic ${base64Encode(utf8.encode(AK.basicAuthCredentials.toString()))}',
+            // 'Bearer ${box.read(BoxName.firstTimeLoadKey) != null ? EncryptionHelper.instance.decryptData(box.read(BoxName.jwt).toString()) : box.read(BoxName.jwt).toString()}'
+            // 'Bearer ${box.read(BoxName.jwt).toString()}'
+            'Bearer ${X.r(X.r(X.r(box.read(BoxName.jwt), cn), cC), cs).toString().split(AppInformation.addd)[0]}'
       },
     );
-    // Log.print('req: ${response.request}');
-    // Log.print('response: ${response.body}');
-    // Log.print('payload: ${payload}');
-    // if (response.statusCode == 200) {
-    var jsonData = jsonDecode(response.body);
-    if (jsonData['status'] == 'success') {
-      return response.body;
-    }
+    Log.print('req: ${response.request}');
+    Log.print('response: ${response.body}');
+    Log.print('payload: ${payload}');
+    if (response.statusCode == 200) {
+      var jsonData = jsonDecode(response.body);
+      if (jsonData['status'] == 'success') {
+        return response.body;
+      }
 
-    return jsonData['status'];
+      return jsonData['status'];
+    } else if (response.statusCode == 401) {
+      // Specifically handle 401 Unauthorized
+      var jsonData = jsonDecode(response.body);
+
+      if (jsonData['error'] == 'Token expired') {
+        // Show snackbar prompting to re-login
+        await Get.put(LoginController()).getJWT();
+        mySnackbarSuccess('please order now'.tr);
+        return 'token_expired'; // Return a specific value for token expiration
+      } else {
+        // Other 401 errors
+        addError('Unauthorized: ${jsonData['error']}', 'crud().post - 401');
+        return 'failure';
+      }
+    } else {
+      addError('Non-200 response code: ${response.statusCode}',
+          'crud().post - Other');
+      return 'failure';
+    }
   }
 
-  Future<dynamic> post({
+  Future<dynamic> getWallet({
     required String link,
     Map<String, dynamic>? payload,
   }) async {
+    var s = await LoginController().getJwtWallet();
+    var url = Uri.parse(
+      link,
+    );
+    var response = await http.post(
+      url,
+      body: payload,
+      headers: {
+        "Content-Type": "application/x-www-form-urlencoded",
+        'Authorization': 'Bearer $s'
+      },
+    );
+
+    if (response.statusCode == 200) {
+      var jsonData = jsonDecode(response.body);
+      if (jsonData['status'] == 'success') {
+        return response.body;
+      }
+
+      return jsonData['status'];
+    } else if (response.statusCode == 401) {
+      // Specifically handle 401 Unauthorized
+      var jsonData = jsonDecode(response.body);
+
+      if (jsonData['error'] == 'Token expired') {
+        // Show snackbar prompting to re-login
+        await Get.put(LoginController()).getJwtWallet();
+
+        return 'token_expired'; // Return a specific value for token expiration
+      } else {
+        // Other 401 errors
+        addError('Unauthorized: ${jsonData['error']}', 'crud().post - 401');
+        return 'failure';
+      }
+    } else {
+      addError('Non-200 response code: ${response.statusCode}',
+          'crud().post - Other');
+      return 'failure';
+    }
+  }
+
+  Future<dynamic> post(
+      {required String link, Map<String, dynamic>? payload}) async {
     var url = Uri.parse(link);
     try {
       var response = await http.post(
@@ -54,34 +126,56 @@ class CRUD {
         headers: {
           "Content-Type": "application/x-www-form-urlencoded",
           'Authorization':
-              'Basic ${base64Encode(utf8.encode(AK.basicAuthCredentials))}',
+              'Bearer ${X.r(X.r(X.r(box.read(BoxName.jwt), cn), cC), cs).toString().split(AppInformation.addd)[0]}'
+          // 'Authorization': 'Bearer ${box.read(BoxName.jwt)}'
         },
       );
-
+      // Log.print('req: ${response.request}');
+      // Log.print('response: ${response.body}');
+      // Log.print('payload: ${payload}');
       if (response.statusCode == 200) {
         try {
-          // Log.print('req: ${response.request}');
-          // Log.print('response: ${response.body}');
-          // Log.print('payload: ${payload}');
           var jsonData = jsonDecode(response.body);
-
           if (jsonData['status'] == 'success') {
             return jsonData;
           } else {
             return jsonData['status'];
           }
         } catch (e) {
-          addError(e.toString(), 'crud().post');
-          return 'failure'; // Return a recognizable failure string for JSON errors
+          addError(e.toString(), 'crud().post - JSON decoding');
+          return 'failure';
+        }
+      } else if (response.statusCode == 401) {
+        // Specifically handle 401 Unauthorized
+        var jsonData = jsonDecode(response.body);
+
+        if (jsonData['error'] == 'Token expired') {
+          // Show snackbar prompting to re-login
+          await Get.put(LoginController()).getJWT();
+          // MyDialog().getDialog(
+          //   'Session expired. Please log in again.'.tr,
+          //   '',
+          //   () {
+          //     Get.put(LoginController()).loginUsingCredentials(
+          //         box.read(BoxName.passengerID), box.read(BoxName.email));
+          //     Get.back();
+          //   },
+          // );
+
+          return 'token_expired'; // Return a specific value for token expiration
+        } else {
+          // Other 401 errors
+          addError('Unauthorized: ${jsonData['error']}', 'crud().post - 401');
+          return 'failure';
         }
       } else {
-        addError(
-            'Non-200 response code: ${response.statusCode}', 'crud().post');
-        return 'failure'; // Handle unexpected status codes as failures
+        addError('Non-200 response code: ${response.statusCode}',
+            'crud().post - Other');
+        return 'failure';
       }
     } catch (e) {
-      addError('HTTP request error: $e', 'crud().post');
-      return 'failure'; // Handle HTTP request errors as failures
+      addError('HTTP request error: $e', 'crud().post - HTTP');
+      return 'failure';
     }
   }
 
@@ -509,24 +603,24 @@ class CRUD {
     }
   }
 
-  Future<dynamic> update({
-    required String endpoint,
-    required Map<String, dynamic> data,
-    required String id,
-  }) async {
-    // String? basicAuthCredentials =
-    //     await storage.read(key: BoxName.basicAuthCredentials);
-    var url = Uri.parse('$endpoint/$id');
-    var response = await http.put(
-      url,
-      body: json.encode(data),
-      headers: {
-        'Authorization':
-            'Basic ${base64Encode(utf8.encode(AK.basicAuthCredentials))}',
-      },
-    );
-    return json.decode(response.body);
-  }
+  // Future<dynamic> update({
+  //   required String endpoint,
+  //   required Map<String, dynamic> data,
+  //   required String id,
+  // }) async {
+  //   // String? basicAuthCredentials =
+  //   //     await storage.read(key: BoxName.basicAuthCredentials);
+  //   var url = Uri.parse('$endpoint/$id');
+  //   var response = await http.put(
+  //     url,
+  //     body: json.encode(data),
+  //     headers: {
+  //       'Authorization':
+  //           'Basic ${base64Encode(utf8.encode(AK.basicAuthCredentials))}',
+  //     },
+  //   );
+  //   return json.decode(response.body);
+  // }
 
   Future<dynamic> delete({
     required String endpoint,