eatvio_app/lib/features/diary/repositories/diary_repository.dart

import 'dart:async';
import 'dart:io';
import 'package:eatvio_app/features/diary/models/consultant_comment_model.dart';
import 'package:eatvio_app/features/diary/models/consultant_review_model.dart';
import 'package:eatvio_app/features/diary/models/diary_day_model.dart';
import 'package:eatvio_app/features/diary/models/finish_diary_day_model.dart';
import 'package:eatvio_app/features/diary/models/nutrition_model.dart';
import 'package:eatvio_app/features/diary/models/product_moderation_model.dart';
import 'package:eatvio_app/features/diary/services/diary_service.dart';
import 'package:eatvio_app/features/glossary/models/glossary_model.dart';

class DiaryRepository {
  final DiaryService diaryService;
  final StreamController<String> _diaryForceFetchController = StreamController<String>.broadcast();

  Stream<String> get forceFetchStream => _diaryForceFetchController.stream;

  DiaryRepository({
    required this.diaryService,
  });

  Future<DiaryDayModel> getDiaryByDate(String date) async {
    try {
      return (await getDiaryIndexByDate(date)).last;
    } catch (e) {
      rethrow;
    }
  }

  Future<DiaryFutureDietDayModel> getDiaryByDateForDietOnly(String date) async {
    try {
      return (await diaryService.getDiaryIndexByDateForDietOnly(date: date)).last;
    } catch (e) {
      rethrow;
    }
  }

  Future<List<DiaryDayModel>> getDiaryIndexByDate(String date) async {
    return (await diaryService.getDiaryIndexByDate(date: date));
  }

  Future<DiaryDayModel> getDiaryDay(int diaryId) async {
    return (await diaryService.getDiaryDay(diary: diaryId)).diary;
  }

  Future<NutritionDataModel> getNutritionData(int index) async {
    return await diaryService.getNutrition(diary: index);
  }

  Future<void> addPortionToMeal({
    required int diaryId,
    required int mealId,
    required String productName,
    required String portion,
    required int quantity,
    int? productNutritionalValueId,
  }) async {
    return await diaryService.addProductToMeal(
      diary: diaryId,
      typeNo: mealId,
      productName: productName,
      portion: portion,
      quantity: quantity,
      productNutritionalValueId: productNutritionalValueId,
    );
  }

  Future<void> updateProductInMeal({
    required int diaryId,
    required int mealId,
    required int portionId,
    required String productName,
    required String portion,
    required int quantity,
    int? productNutritionalValueId,
    required PortionState portionState,
  }) async {
    Map<String, Object?> data = ProductInMeal(
      productName: productName,
      portion: portion,
      quantity: quantity,
    ).toJson();
    data['product_nutritional_value_id'] = productNutritionalValueId;
    data['state'] = portionState.name;
    return await diaryService.updateProductInMeal(
      diary: diaryId,
      typeNo: mealId,
      portionModel: portionId,
      productInMeal: data,
    );
  }

  Future<void> markEaten({
    required int diaryId,
    required int mealId,
    required int portionId,
  }) async {
    return await diaryService.markEaten(
      diary: diaryId,
      typeNo: mealId,
      portionModel: portionId,
    );
  }

  Future<void> unmarkEaten({
    required int diaryId,
    required int mealId,
    required int portionId,
  }) async {
    return await diaryService.unmarkEaten(
      diary: diaryId,
      typeNo: mealId,
      portionModel: portionId,
    );
  }

  Future<void> restore({
    required int diaryId,
    required int mealId,
    required int portionId,
  }) async {
    return await diaryService.restore(
      diary: diaryId,
      typeNo: mealId,
      portionModel: portionId,
    );
  }

  Future<void> deleteProductFromMeal({
    required int diaryId,
    required int mealId,
    required int portionId,
  }) async {
    return await diaryService.deleteProductFromMeal(
      diary: diaryId,
      typeNo: mealId,
      portionModel: portionId,
    );
  }

  Future<void> uploadPhotos({
    required int diaryId,
    required int mealId,
    required List<File> files,
  }) async {
    try {
      for (int i = 0; i < files.length; i++) {
        await diaryService.uploadPhotoOfMeal(
          diary: diaryId,
          typeNo: mealId,
          photo: files[i],
        );
      }
    } catch (e) {
      rethrow;
    }
  }

  Future<void> deletePhoto({
    required int diaryId,
    required int mealId,
    required DiaryPhotoModel photo,
  }) async {
    try {
      await diaryService.deletePhotoOfMeal(
        diaryId: diaryId,
        typeNo: mealId,
        userAttachment: photo.id,
      );
    } catch (e) {
      rethrow;
    }
  }

  Future<void> finishDiaryDay({
    required int diaryId,
    required String wakeUp,
    required String retire,
    String? comment,
  }) async {
    return await diaryService.finishDiaryDay(
      diary: diaryId,
      finishDiaryDayModel: FinishDiaryDayModel(wakeUp: wakeUp, retire: retire, comment: comment),
    );
  }

  Future<GlossaryModerationModel> sendProductToModeration({
    required String name,
    required double energy,
    required double proteins,
    required double fats,
    required double carbohydrates,
  }) async {
    return await diaryService.sendProductToModeration(
      data: ProductModerationModel(
        name: name,
        energy: energy,
        proteins: proteins,
        fats: fats,
        carbohydrates: carbohydrates,
      ).toJson(),
    );
  }

  Future<void> fillSatiety({
    required int diaryId,
    required int mealId,
    required int satiety,
  }) async {
    try {
      return await diaryService.fillSatiety(
        diary: diaryId,
        typeNo: mealId,
        satiety: satiety,
      );
    } catch (e) {
      rethrow;
    }
  }

  Future<void> fillMood({
    required int diaryId,
    required int mealId,
    required int mood,
  }) async {
    try {
      return await diaryService.fillMood(
        diary: diaryId,
        typeNo: mealId,
        mood: mood,
      );
    } catch (e) {
      rethrow;
    }
  }

  Future<void> fillTime({
    required int diaryId,
    required int mealId,
    required String time,
  }) async {
    try {
      return await diaryService.fillTime(
        diary: diaryId,
        typeNo: mealId,
        time: time,
      );
    } catch (e) {
      rethrow;
    }
  }

  Future<void> fillWakeup({
    required int diaryId,
    required String time,
  }) async {
    try {
      return await diaryService.fillWakeup(
        diary: diaryId,
        wakeUp: time,
      );
    } catch (e) {
      rethrow;
    }
  }

  Future<void> fillRetire({
    required int diaryId,
    required String time,
  }) async {
    try {
      return await diaryService.fillRetire(
        diary: diaryId,
        retire: time,
      );
    } catch (e) {
      rethrow;
    }
  }

  Future<void> commentUserDay({required int diaryId, required ConsultantCommentModel commentModel}) async {
    try {
      await diaryService.commentUserDay(id: diaryId, body: commentModel);
      _diaryForceFetchController.add('force');
    } catch (e) {
      rethrow;
    }
  }

  Future<ConsultantReviewModel> getDiaryComments({
    required int planId,
    required int diaryId,
  }) async {
    try {
      return await diaryService.getDiaryComments(planId: planId, diaryId: diaryId);
    } catch (e) {
      rethrow;
    }
  }
}