import 'dart:developer';

import 'package:dartz/dartz.dart';
import 'package:dio/dio.dart';
import 'package:enaklo_pos/core/network/dio_client.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 {
  final Dio dio = DioClient.instance;

  Future<Either<String, ProductResponseModel>> getProducts() async {
    try {
      final authData = await AuthLocalDataSource().getAuthData();
      final url = '${Variables.baseUrl}/api/v1/products';

      final response = await dio.get(
        url,
        options: Options(
          headers: {
            'Authorization': 'Bearer ${authData.token}',
            'Accept': 'application/json',
          },
        ),
      );

      if (response.statusCode == 200) {
        return Right(ProductResponseModel.fromMap(response.data));
      } else {
        return const Left('Failed to get products');
      }
    } on DioException catch (e) {
      log("Dio error: ${e.message}");
      return Left(e.response?.data['message'] ?? 'Gagal mengambil produk');
    } catch (e) {
      log("Unexpected error: $e");
      return const Left('Unexpected error occurred');
    }
  }

  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);
    }
  }
}