601 lines
18 KiB
Dart
Executable File
601 lines
18 KiB
Dart
Executable File
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/controller/functions/add_error.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(),
|
|
},
|
|
);
|
|
// print(response.request);
|
|
// 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();
|
|
final hmac = box.read(BoxName.hmac);
|
|
Log.print('hmac: ${hmac}');
|
|
var url = Uri.parse(link);
|
|
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(),
|
|
},
|
|
);
|
|
// 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(), '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;
|
|
}
|
|
}
|
|
|
|
sendEmail(
|
|
String link,
|
|
Map<String, String>? payload,
|
|
) async {
|
|
var headers = {
|
|
"Content-Type": "application/x-www-form-urlencoded",
|
|
'Authorization':
|
|
'Basic ${base64Encode(utf8.encode(AK.basicAuthCredentials))}',
|
|
};
|
|
var request = http.Request('POST', Uri.parse(link));
|
|
request.bodyFields = payload!;
|
|
request.headers.addAll(headers);
|
|
|
|
http.StreamedResponse response = await request.send();
|
|
if (response.statusCode == 200) {
|
|
} else {}
|
|
}
|
|
|
|
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);
|
|
}
|
|
}
|