apskel-pos-flutter/lib/data/datasources/product_remote_datasource.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);
    }
  }
}