25-7-28-2

2025-07-28 12:21:28 +03:00
parent 660d60e1f5
commit 83a97baed1
549 changed files with 109870 additions and 0 deletions
--- a/lib/controller/functions/crud.dart
+++ b/lib/controller/functions/crud.dart
@@ -0,0 +1,624 @@
+import 'dart:convert';
+import 'package:jwt_decoder/jwt_decoder.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';
+import 'package:sefer_driver/controller/auth/captin/login_captin_controller.dart';
+import 'package:sefer_driver/main.dart';
+import 'package:get/get.dart';
+import 'package:http/http.dart' as http;
+import 'package:sefer_driver/env/env.dart';
+
+import '../../constant/api_key.dart';
+import '../../constant/char_map.dart';
+import '../../constant/info.dart';
+import '../../print.dart';
+import 'gemeni.dart';
+import 'upload_image.dart';
+
+class CRUD {
+  Future<dynamic> get({
+    required String link,
+    Map<String, dynamic>? payload,
+  }) async {
+    bool isTokenExpired = JwtDecoder.isExpired(X
+        .r(X.r(X.r(box.read(BoxName.jwt), cn), cC), cs)
+        .toString()
+        .split(AppInformation.addd)[0]);
+    // Log.print('isTokenExpired: ${isTokenExpired}');
+
+    if (isTokenExpired) {
+      await LoginDriverController().getJWT();
+    }
+    // await Get.put(LoginDriverController()).getJWT();
+    var url = Uri.parse(
+      link,
+    );
+    var response = await http.post(
+      url,
+      body: payload,
+      headers: {
+        "Content-Type": "application/x-www-form-urlencoded",
+        'Authorization':
+            'Bearer ${X.r(X.r(X.r(box.read(BoxName.jwt), cn), cC), cs).toString().split(AppInformation.addd)[0]}'
+      },
+    );
+    print(response.request);
+    Log.print('response.body: ${response.body}');
+    print(payload);
+    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(LoginDriverController()).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> getWallet({
+    required String link,
+    Map<String, dynamic>? payload,
+  }) async {
+    var s = await LoginDriverController().getJwtWallet();
+    final hmac = box.read(BoxName.hmac);
+    // Log.print('hmac: ${hmac}');
+    var url = Uri.parse(
+      link,
+    );
+    var response = await http.post(
+      url,
+      body: payload,
+      headers: {
+        "Content-Type": "application/x-www-form-urlencoded",
+        'Authorization': 'Bearer $s',
+        'X-HMAC-Auth': hmac.toString(),
+      },
+    );
+    Log.print('response.request: ${response.request}');
+    Log.print('response.body: ${response.body}');
+    print(payload);
+    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(LoginDriverController()).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> postWallet(
+      {required String link, Map<String, dynamic>? payload}) async {
+    var s = await LoginDriverController().getJwtWallet();
+    // Log.print('jwt: ${s}');
+    final hmac = box.read(BoxName.hmac);
+    // Log.print('hmac: ${hmac}');
+    var url = Uri.parse(link);
+    // Log.print('url: ${url}');
+    try {
+      // await LoginDriverController().getJWT();
+
+      var response = await http.post(
+        url,
+        body: payload,
+        headers: {
+          "Content-Type": "application/x-www-form-urlencoded",
+          'Authorization': 'Bearer $s',
+          'X-HMAC-Auth': hmac.toString(),
+        },
+      );
+      Log.print('response.request:${response.request}');
+      Log.print('response.body: ${response.body}');
+      Log.print('payload:$payload');
+      if (response.statusCode == 200) {
+        try {
+          var jsonData = jsonDecode(response.body);
+          if (jsonData['status'] == 'success') {
+            return jsonData;
+          } else {
+            return jsonData['status'];
+          }
+        } catch (e) {
+          // 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') {
+          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';
+      }
+    } catch (e) {
+      // addError('HTTP request error: $e', 'crud().post - HTTP');
+      return 'failure';
+    }
+  }
+
+  Future<dynamic> post(
+      {required String link, Map<String, dynamic>? payload}) async {
+    var url = Uri.parse(link);
+    try {
+      bool isTokenExpired = JwtDecoder.isExpired(X
+          .r(X.r(X.r(box.read(BoxName.jwt), cn), cC), cs)
+          .toString()
+          .split(AppInformation.addd)[0]);
+      if (isTokenExpired) {
+        await LoginDriverController().getJWT();
+      }
+      var response = await http.post(
+        url,
+        body: payload,
+        headers: {
+          "Content-Type": "application/x-www-form-urlencoded",
+          'Authorization':
+              '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)}'
+        },
+      );
+      print(response.request);
+      Log.print('response.body: ${response.body}');
+      print(payload);
+      if (response.statusCode == 200) {
+        try {
+          var jsonData = jsonDecode(response.body);
+          if (jsonData['status'] == 'success') {
+            return jsonData;
+          } else {
+            return jsonData['status'];
+          }
+        } catch (e) {
+          // addError(e.toString(), url);
+          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(LoginDriverController()).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 - Other');
+        return 'failure';
+      }
+    } catch (e) {
+      // addError('HTTP request error: $e', 'crud().post - HTTP');
+      return 'failure';
+    }
+  }
+
+  Future<dynamic> getAgoraToken({
+    required String channelName,
+    required String uid,
+  }) async {
+    var uid = box.read(BoxName.phone) ?? box.read(BoxName.phoneDriver);
+    var res = await http.get(Uri.parse(
+            // 'https://repulsive-pig-rugby-shirt.cyclic.app/token?channelName=$channelName'),
+            'https://orca-app-b2i85.ondigitalocean.app/token?channelName=$channelName'),
+        headers: {'Authorization': 'Bearer ${AK.agoraAppCertificate}'});
+
+    if (res.statusCode == 200) {
+      var response = jsonDecode(res.body);
+      return response['token'];
+    } else {}
+  }
+
+  Future<dynamic> getLlama({
+    required String link,
+    required String payload,
+    required String prompt,
+  }) async {
+    var url = Uri.parse(
+      link,
+    );
+    var headers = {
+      'Content-Type': 'application/json',
+      'Authorization':
+          'Bearer LL-X5lJ0Px9CzKK0HTuVZ3u2u4v3tGWkImLTG7okGRk4t25zrsLqJ0qNoUzZ2x4ciPy'
+      // 'Authorization': 'Bearer ${Env.llamaKey}'
+    };
+    var data = json.encode({
+      "model": "Llama-3-70b-Inst-FW",
+      // "model": "llama-13b-chat",
+      "messages": [
+        {
+          "role": "user",
+          "content":
+              "Extract the desired information from the following passage as json decoded like $prompt just in this:\n\n$payload"
+        }
+      ],
+      "temperature": 0.9
+    });
+    var response = await http.post(
+      url,
+      body: data,
+      headers: headers,
+    );
+
+    if (response.statusCode == 200) {
+      return response.body;
+    }
+    return response.statusCode;
+  }
+
+  Future allMethodForAI(String prompt, linkPHP, imagePath) async {
+    await ImageController().choosImage(linkPHP, imagePath);
+    Future.delayed(const Duration(seconds: 2));
+    var extractedString =
+        await arabicTextExtractByVisionAndAI(imagePath: imagePath);
+    var json = jsonDecode(extractedString);
+
+    var textValues = extractTextFromLines(json);
+    // await Get.put(AI()).geminiAiExtraction(prompt, textValues);
+    await Get.put(AI()).anthropicAI(textValues, prompt, imagePath);
+  }
+
+  String extractTextFromLines(Map<String, dynamic> jsonData) {
+    final readResult = jsonData['readResult'];
+    final blocks = readResult['blocks'];
+
+    final StringBuffer buffer = StringBuffer();
+
+    for (final block in blocks) {
+      final lines = block['lines'];
+      for (final line in lines) {
+        final text = line['text'];
+        buffer.write(text);
+        buffer.write('\n');
+      }
+    }
+
+    return buffer.toString().trim();
+  }
+
+  Future<dynamic> arabicTextExtractByVisionAndAI({
+    required String imagePath,
+  }) async {
+    var headers = {
+      'Content-Type': 'application/json',
+      'Ocp-Apim-Subscription-Key': AK.ocpApimSubscriptionKey
+    };
+
+    String imagePathFull =
+        '${AppLink.server}/card_image/$imagePath-${box.read(BoxName.driverID)}.jpg';
+    var request = http.Request('POST', Uri.parse(
+        // 'https://ocrhamza.cognitiveservices.azure.com/vision/v2.1/ocr?language=ar'));
+        // 'https://eastus.api.cognitive.microsoft.com/vision/v3.2/ocr'
+        'https://eastus.api.cognitive.microsoft.com/computervision/imageanalysis:analyze?features=caption,read&model-version=latest&language=en&api-version=2024-02-01'));
+    request.body = json.encode({"url": imagePathFull});
+    // request.body = json.encode({"url": imagePathFull});
+    request.headers.addAll(headers);
+
+    http.StreamedResponse response = await request.send();
+
+    if (response.statusCode == 200) {
+      //     'response.stream.bytesToString(): ${await response.stream.bytesToString()}');
+      return await response.stream.bytesToString();
+    } else {}
+  }
+
+  Future<dynamic> getChatGPT({
+    required String link,
+    required String payload,
+  }) async {
+    var url = Uri.parse(
+      link,
+    );
+    var headers = {
+      'Content-Type': 'application/json',
+      'Authorization': 'Bearer ${Env.chatGPTkeySeferNew}'
+    };
+    var data = json.encode({
+      "model": "gpt-3.5-turbo",
+      "messages": [
+        {
+          "role": "user",
+          "content":
+              "Extract the desired information from the following passage as json decoded like vin,make,made,year,expiration_date,color,owner,registration_date just in this:\n\n$payload"
+        }
+      ],
+      "temperature": 0.9
+    });
+    var response = await http.post(
+      url,
+      body: data,
+      headers: headers,
+    );
+
+    if (response.statusCode == 200) {
+      return response.body;
+    }
+    return response.statusCode;
+  }
+
+  Future<dynamic> postStripe({
+    required String link,
+    Map<String, dynamic>? payload,
+  }) async {
+    // String? secretKey = await storage.read(key: BoxName.secretKey);
+    var url = Uri.parse(
+      link,
+    );
+    var response = await http.post(
+      url,
+      body: payload,
+      headers: {
+        "Content-Type": "application/x-www-form-urlencoded",
+        'Authorization': 'Bearer ${AK.secretKeyStripe}',
+      },
+    );
+    if (response.statusCode == 200) {
+      return response.body;
+    } else {}
+  }
+
+  Future<dynamic> postPayMob({
+    required String link,
+    Map<String, dynamic>? payload,
+  }) async {
+    // String? basicAuthCredentials =
+    //     await storage.read(key: BoxName.basicAuthCredentials);
+    var url = Uri.parse(
+      link,
+    );
+    var response = await http.post(url,
+        body: payload, headers: {'Content-Type': 'application/json'});
+
+    var jsonData = jsonDecode(response.body);
+    if (response.statusCode == 200) {
+      if (jsonData['status'] == 'success') {
+        return response.body;
+      } else {
+        return (jsonData['status']);
+      }
+    } else {
+      return response.statusCode;
+    }
+  }
+
+  Future<void> sendEmail(String link, Map<String, String>? payload) async {
+    // التحقق من صلاحية التوكن
+    String rawJwt = box.read(BoxName.jwt);
+    String token = X
+        .r(X.r(X.r(rawJwt, cn), cC), cs)
+        .toString()
+        .split(AppInformation.addd)[0];
+
+    bool isTokenExpired = JwtDecoder.isExpired(token);
+    if (isTokenExpired) {
+      await LoginDriverController().getJWT();
+      rawJwt = box.read(BoxName.jwt); // تحديث التوكن بعد التجديد
+      token = X
+          .r(X.r(X.r(rawJwt, cn), cC), cs)
+          .toString()
+          .split(AppInformation.addd)[0];
+    }
+
+    // إعداد الهيدر
+    final headers = {
+      "Content-Type": "application/x-www-form-urlencoded",
+      "Authorization": "Bearer $token",
+    };
+
+    // إعداد الطلب
+    final request = http.Request('POST', Uri.parse(link));
+    request.bodyFields = payload ?? {};
+    request.headers.addAll(headers);
+
+    // إرسال الطلب
+    final response = await request.send();
+
+    // التحقق من النتيجة
+    if (response.statusCode == 200) {
+      print("✅ Email sent successfully.");
+    } else {
+      print("❌ Failed to send email. Status: ${response.statusCode}");
+      final responseBody = await response.stream.bytesToString();
+      print("Response body: $responseBody");
+    }
+  }
+
+  Future<dynamic> postFromDialogue({
+    required String link,
+    Map<String, dynamic>? payload,
+  }) async {
+    // String? basicAuthCredentials =
+    //     await storage.read(key: BoxName.basicAuthCredentials);
+    var url = Uri.parse(
+      link,
+    );
+    var response = await http.post(
+      url,
+      body: payload,
+      headers: {
+        "Content-Type": "application/x-www-form-urlencoded",
+        'Authorization':
+            'Basic ${base64Encode(utf8.encode(AK.basicAuthCredentials))}',
+      },
+    );
+
+    if (response.body.isNotEmpty) {
+      var jsonData = jsonDecode(response.body);
+      if (response.statusCode == 200) {
+        if (jsonData['status'] == 'success') {
+          Get.back();
+          // Get.snackbar(
+          //   jsonData['status'],
+          //   jsonData['message'],
+          // );
+
+          return response.body;
+        }
+      }
+      return (jsonData['status']);
+    }
+  }
+
+  Future<void> sendVerificationRequest(String phoneNumber) async {
+    final accountSid = AK.accountSIDTwillo;
+    final authToken = AK.authTokenTwillo;
+    final verifySid = AK.twilloRecoveryCode;
+
+    final Uri verificationUri = Uri.parse(
+        'https://verify.twilio.com/v2/Services/$verifySid/Verifications');
+
+    // Send the verification request
+    final response = await http.post(
+      verificationUri,
+      headers: {
+        'Authorization':
+            'Basic ' + base64Encode(utf8.encode('$accountSid:$authToken')),
+        'Content-Type': 'application/x-www-form-urlencoded',
+      },
+      body: {
+        'To': phoneNumber,
+        'Channel': 'sms',
+      },
+    );
+
+    if (response.statusCode == 201) {
+    } else {}
+
+    // Prompt the user to enter the OTP
+    final otpCode = "123456"; // Replace with user input
+
+    // Check the verification code
+    final checkUri = Uri.parse(
+        'https://verify.twilio.com/v2/Services/$verifySid/VerificationCheck');
+
+    final checkResponse = await http.post(
+      checkUri,
+      headers: {
+        'Authorization':
+            'Basic ' + base64Encode(utf8.encode('$accountSid:$authToken')),
+        'Content-Type': 'application/x-www-form-urlencoded',
+      },
+      body: {
+        'To': phoneNumber,
+        'Code': otpCode,
+      },
+    );
+
+    if (checkResponse.statusCode == 201) {
+    } else {}
+  }
+
+  Future<dynamic> getGoogleApi({
+    required String link,
+    Map<String, dynamic>? payload,
+  }) async {
+    var url = Uri.parse(
+      link,
+    );
+    var response = await http.post(
+      url,
+      body: payload,
+    );
+    var jsonData = jsonDecode(response.body);
+    if (jsonData['status'] == 'OK') {
+      return jsonData;
+    }
+    return (jsonData['status']);
+  }
+
+  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,
+    required String id,
+  }) async {
+    // String? basicAuthCredentials =
+    //     await storage.read(key: BoxName.basicAuthCredentials);
+    var url = Uri.parse('$endpoint/$id');
+    var response = await http.delete(
+      url,
+      headers: {
+        'Authorization':
+            'Basic ${base64Encode(utf8.encode(AK.basicAuthCredentials))}',
+      },
+    );
+    return json.decode(response.body);
+  }
+}