95 lines
3.7 KiB
Dart
95 lines
3.7 KiB
Dart
import 'dart:developer';
|
|
|
|
import 'package:dartz/dartz.dart';
|
|
import 'package:enaklo_pos/data/models/request/product_request_model.dart';
|
|
import 'package:enaklo_pos/data/models/response/add_product_response_model.dart';
|
|
import 'package:enaklo_pos/data/models/response/product_response_model.dart';
|
|
import 'package:http/http.dart' as http;
|
|
|
|
import '../../core/constants/variables.dart';
|
|
import 'auth_local_datasource.dart';
|
|
|
|
class ProductRemoteDatasource {
|
|
Future<Either<String, ProductResponseModel>> getProducts() async {
|
|
final url = Uri.parse('${Variables.baseUrl}/api/products');
|
|
final authData = await AuthLocalDataSource().getAuthData();
|
|
final response = await http.get(url, headers: {
|
|
'Authorization': 'Bearer ${authData.token}',
|
|
'Accept': 'application/json',
|
|
});
|
|
log("Status Code: ${response.statusCode}");
|
|
log("Body: ${response.body}");
|
|
if (response.statusCode == 200) {
|
|
return Right(ProductResponseModel.fromJson(response.body));
|
|
} else {
|
|
return const Left('Failed to get products');
|
|
}
|
|
}
|
|
|
|
Future<Either<String, AddProductResponseModel>> addProduct(
|
|
ProductRequestModel productRequestModel) async {
|
|
final authData = await AuthLocalDataSource().getAuthData();
|
|
final Map<String, String> headers = {
|
|
'Authorization': 'Bearer ${authData.token}',
|
|
};
|
|
var request = http.MultipartRequest(
|
|
'POST', Uri.parse('${Variables.baseUrl}/api/products'));
|
|
request.fields.addAll(productRequestModel.toMap());
|
|
request.files.add(await http.MultipartFile.fromPath(
|
|
'image', productRequestModel.image!.path));
|
|
request.headers.addAll(headers);
|
|
|
|
http.StreamedResponse response = await request.send();
|
|
|
|
final String body = await response.stream.bytesToString();
|
|
log(response.stream.toString());
|
|
log(response.statusCode.toString());
|
|
if (response.statusCode == 201) {
|
|
return right(AddProductResponseModel.fromJson(body));
|
|
} else {
|
|
return left(body);
|
|
}
|
|
}
|
|
|
|
Future<Either<String, AddProductResponseModel>> updateProduct(
|
|
ProductRequestModel productRequestModel) async {
|
|
final authData = await AuthLocalDataSource().getAuthData();
|
|
final Map<String, String> headers = {
|
|
'Authorization': 'Bearer ${authData.token}',
|
|
};
|
|
|
|
log("Update Product Request Data: ${productRequestModel.toMap()}");
|
|
log("Update Product ID: ${productRequestModel.id}");
|
|
log("Update Product Name: ${productRequestModel.name}");
|
|
log("Update Product Price: ${productRequestModel.price}");
|
|
log("Update Product Stock: ${productRequestModel.stock}");
|
|
log("Update Product Category ID: ${productRequestModel.categoryId}");
|
|
log("Update Product Is Best Seller: ${productRequestModel.isBestSeller}");
|
|
log("Update Product Printer Type: ${productRequestModel.printerType}");
|
|
log("Update Product Has Image: ${productRequestModel.image != null}");
|
|
|
|
var request = http.MultipartRequest(
|
|
'POST', Uri.parse('${Variables.baseUrl}/api/products/edit'));
|
|
request.fields.addAll(productRequestModel.toMap());
|
|
if (productRequestModel.image != null) {
|
|
request.files.add(await http.MultipartFile.fromPath(
|
|
'image', productRequestModel.image!.path));
|
|
}
|
|
request.headers.addAll(headers);
|
|
|
|
log("Update Product Request Fields: ${request.fields}");
|
|
log("Update Product Request Files: ${request.files.length}");
|
|
|
|
http.StreamedResponse response = await request.send();
|
|
|
|
final String body = await response.stream.bytesToString();
|
|
log("Update Product Status Code: ${response.statusCode}");
|
|
log("Update Product Body: $body");
|
|
if (response.statusCode == 200) {
|
|
return right(AddProductResponseModel.fromJson(body));
|
|
} else {
|
|
return left(body);
|
|
}
|
|
}
|
|
}
|