// import 'dart:async';
import 'package:bytedesk_kefu/model/jsonResult.dart';
import 'package:bytedesk_kefu/model/user.dart';
import 'package:bytedesk_kefu/repositories/user_repository.dart';
import 'package:bloc/bloc.dart';
import './bloc.dart';

class ProfileBloc extends Bloc<ProfileEvent, ProfileState> {
  //
  final UserRepository userRepository = new UserRepository();

  ProfileBloc() : super(InitialProfileState()) {
    on<GetProfileEvent>(_mapProfileState);
    on<UploadImageEvent>(_mapUploadImageToState);
    on<UpdateAvatarEvent>(_mapUpdateAvatarToState);
    on<UpdateNicknameEvent>(_mapUpdateNicknameToState);
    on<UpdateDescriptionEvent>(_mapUpdateDescriptionToState);
    on<UpdateMobileEvent>(_mapUpdateMobileToState);

    on<UpdateSexEvent>(_mapUpdateSexToState);
    on<UpdateLocationEvent>(_mapUpdateLocationToState);
    on<UpdateBirthdayEvent>(_mapUpdateBirthdayToState);
    on<QueryFollowEvent>(_mapQueryFollowToState);
    on<UserFollowEvent>(_mapUserFollowToState);

    on<UserUnfollowEvent>(_mapUserUnfollowToState);

  }

  // @override
  // void mapEventToState(ProfileEvent event, Emitter<ProfileState> emit) async {
  //   //
  //   if (event is GetProfileEvent) {
  //     yield* _mapProfileState();
  //   } else if (event is UploadImageEvent) {
  //     yield* _mapUploadImageToState(event);
  //   } else if (event is UpdateAvatarEvent) {
  //     yield* _mapUpdateAvatarToState(event);
  //   } else if (event is UpdateNicknameEvent) {
  //     yield* _mapUpdateNicknameToState(event);
  //   } else if (event is UpdateDescriptionEvent) {
  //     yield* _mapUpdateDescriptionToState(event);
  //   } else if (event is UpdateMobileEvent) {
  //     yield* _mapUpdateMobileToState(event);
  //   } else if (event is UpdateSexEvent) {
  //     yield* _mapUpdateSexToState(event);
  //   } else if (event is UpdateLocationEvent) {
  //     yield* _mapUpdateLocationToState(event);
  //   } else if (event is UpdateBirthdayEvent) {
  //     yield* _mapUpdateBirthdayToState(event);
  //   } else if (event is QueryFollowEvent) {
  //     yield* _mapQueryFollowToState(event);
  //   } else if (event is UserFollowEvent) {
  //     yield* _mapUserFollowToState(event);
  //   } else if (event is UserUnfollowEvent) {
  //     yield* _mapUserUnfollowToState(event);
  //   }
  // }

  void _mapProfileState(GetProfileEvent event, Emitter<ProfileState> emit) async {
    emit(ProfileInProgress());
    try {
      User user = await userRepository.getProfile();
      emit(ProfileSuccess(user: user));
    } catch (error) {
      // 网络或其他错误
      emit(ProfileFailure(error: error.toString()));
    }
  }

  void _mapUploadImageToState(UploadImageEvent event, Emitter<ProfileState> emit) async {
    emit(ProfileInProgress());
    try {
      final String url = await userRepository.upload(event.filePath);
      emit(UploadImageSuccess(url));
    } catch (error) {
      print(error);
      emit(UpLoadImageError());
    }
  }

  void _mapUpdateAvatarToState(UpdateAvatarEvent event, Emitter<ProfileState> emit) async {
    emit(ProfileInProgress());
    try {
      final User user = await userRepository.updateAvatar(event.avatar);
      emit(UpdateAvatarSuccess(user));
    } catch (error) {
      print(error);
      emit(UpLoadImageError());
    }
  }

  void _mapUpdateNicknameToState(UpdateNicknameEvent event, Emitter<ProfileState> emit) async {
    emit(ProfileInProgress());
    try {
      final User user = await userRepository.updateNickname(event.nickname);
      emit(UpdateNicknameSuccess(user));
    } catch (error) {
      print(error);
      emit(UpLoadImageError());
    }
  }

  void _mapUpdateDescriptionToState(UpdateDescriptionEvent event, Emitter<ProfileState> emit) async {
    emit(ProfileInProgress());
    try {
      final User user =
          await userRepository.updateDescription(event.description);
      emit(UpdateDescriptionSuccess(user));
    } catch (error) {
      print(error);
      emit(UpLoadImageError());
    }
  }

  void _mapUpdateMobileToState(UpdateMobileEvent event, Emitter<ProfileState> emit) async {
    emit(ProfileInProgress());
    try {
      final User user = await userRepository.updateMobile(event.mobile);
      emit(UpdateMobileSuccess(user));
    } catch (error) {
      print(error);
      emit(UpLoadImageError());
    }
  }

  void _mapUpdateSexToState(UpdateSexEvent event, Emitter<ProfileState> emit) async {
    emit(ProfileInProgress());
    try {
      final User user = await userRepository.updateSex(event.sex);
      emit(UpdateSexSuccess(user));
    } catch (error) {
      print(error);
      emit(UpLoadImageError());
    }
  }

  void _mapUpdateLocationToState(UpdateLocationEvent event, Emitter<ProfileState> emit) async {
    emit(ProfileInProgress());
    try {
      final User user = await userRepository.updateLocation(event.location);
      emit(UpdateLocationSuccess(user));
    } catch (error) {
      print(error);
      emit(UpLoadImageError());
    }
  }

  void _mapUpdateBirthdayToState(UpdateBirthdayEvent event, Emitter<ProfileState> emit) async {
    emit(ProfileInProgress());
    try {
      final User user = await userRepository.updateBirthday(event.birthday);
      emit(UpdateBirthdaySuccess(user));
    } catch (error) {
      print(error);
      emit(UpLoadImageError());
    }
  }

  void _mapQueryFollowToState(QueryFollowEvent event, Emitter<ProfileState> emit) async {
    emit(QueryFollowing());
    try {
      final bool isFollowed = await userRepository.isFollowed(event.uid);
      emit(QueryFollowSuccess(isFollowed));
    } catch (error) {
      print(error);
      emit(QueryFollowError());
    }
  }

  void _mapUserFollowToState(UserFollowEvent event, Emitter<ProfileState> emit) async {
    emit(Following());
    try {
      final JsonResult jsonResult = await userRepository.follow(event.uid);
      emit(FollowResultSuccess(jsonResult));
    } catch (error) {
      print(error);
      emit(FollowError());
    }
  }

  void _mapUserUnfollowToState(UserUnfollowEvent event, Emitter<ProfileState> emit) async {
    emit(Following());
    try {
      final JsonResult jsonResult = await userRepository.unfollow(event.uid);
      emit(UnfollowResultSuccess(jsonResult));
    } catch (error) {
      print(error);
      emit(UnFollowError());
    }
  }
}