import 'dart:async';

import 'package:aitrainer_app/bloc/account/account_bloc.dart';
import 'package:aitrainer_app/model/cache.dart';
import 'package:aitrainer_app/repository/customer_repository.dart';
import 'package:aitrainer_app/repository/user_repository.dart';
import 'package:aitrainer_app/service/exercise_tree_service.dart';
import 'package:aitrainer_app/service/exercisetype_service.dart';
import 'package:aitrainer_app/util/common.dart';
import 'package:aitrainer_app/util/enums.dart';
import 'package:aitrainer_app/util/trans.dart';
import 'package:bloc/bloc.dart';
import 'package:equatable/equatable.dart';
import 'package:flurry/flurry.dart';
import 'package:flutter/material.dart';

part 'login_event.dart';
part 'login_state.dart';

class LoginBloc extends Bloc<LoginEvent, LoginState> with Trans {
  final AccountBloc accountBloc;
  final UserRepository userRepository;
  final CustomerRepository customerRepository = CustomerRepository();
  final BuildContext context;
  final bool isRegistration;
  bool dataPolicyAllowed = false;
  bool obscure = true;
  LoginBloc({this.accountBloc, this.userRepository, this.context, this.isRegistration}) : super(LoginInitial()) {
    if (isRegistration) {
      ExerciseTreeApi().getExerciseTree();
      ExerciseTypeApi().getExerciseTypes();
    }
  }

  @override
  Stream<LoginState> mapEventToState(
    LoginEvent event,
  ) async* {
    try {
      if (event is LoginEmailChange) {
        yield LoginLoading();
        final String email = event.email;
        userRepository.setEmail(email);
        yield LoginReady();
      } else if (event is LoginPasswordChange) {
        yield LoginLoading();
        final String password = event.password;
        userRepository.setPassword(password);
        yield LoginReady();
      } else if (event is LoginSubmit) {
        yield LoginLoading();
        await userRepository.getUser();
        accountBloc.add(AccountLogInFinished(customer: Cache().userLoggedIn));
        Flurry.logEvent("Login");
        Cache().setLoginType(LoginType.email);
        yield LoginSuccess();
      } else if (event is LoginFB) {
        yield LoginLoading();
        Cache().setLoginType(LoginType.fb);
        await userRepository.getUserByFB();
        accountBloc.add(AccountLogInFinished(customer: Cache().userLoggedIn));
        Flurry.logEvent("Login");
        Flurry.logEvent("LoginFB");
        yield LoginSuccess();
      } else if (event is LoginGoogle) {
        yield LoginLoading();
        Cache().setLoginType(LoginType.google);
        await userRepository.getUserByGoogle();
        accountBloc.add(AccountLogInFinished(customer: Cache().userLoggedIn));
        Flurry.logEvent("Login");
        Flurry.logEvent("LoginGoogle");
        yield LoginSuccess();
      } else if (event is LoginApple) {
        yield LoginLoading();
        Cache().setLoginType(LoginType.apple);
        await userRepository.getUserByApple();
        accountBloc.add(AccountLogInFinished(customer: Cache().userLoggedIn));
        Flurry.logEvent("Login");
        Flurry.logEvent("LoginApple");
        yield LoginSuccess();
      } else if (event is RegistrationSubmit) {
        yield LoginLoading();
        if (!this.dataPolicyAllowed) {
          yield LoginError();
          throw Exception("Please accept our data policy");
        }
        await userRepository.addUser();
        accountBloc.add(AccountLogInFinished(customer: Cache().userLoggedIn));
        await saveCustomer();
        Flurry.logEvent("Registration");
        Cache().setLoginType(LoginType.email);
        yield LoginSuccess();
      } else if (event is RegistrationFB) {
        yield LoginLoading();
        if (!this.dataPolicyAllowed) {
          yield LoginError();
          throw Exception("Please accept our data policy");
        }
        Cache().setLoginType(LoginType.fb);
        await userRepository.addUserFB();
        accountBloc.add(AccountLogInFinished(customer: Cache().userLoggedIn));
        await saveCustomer();
        Flurry.logEvent("RegistrationFB");
        Flurry.logEvent("Registration");
        yield LoginSuccess();
      } else if (event is RegistrationGoogle) {
        yield LoginLoading();
        if (!this.dataPolicyAllowed) {
          yield LoginError();
          throw Exception("Please accept our data policy");
        }
        Cache().setLoginType(LoginType.google);
        await userRepository.addUserGoogle();
        accountBloc.add(AccountLogInFinished(customer: Cache().userLoggedIn));
        await saveCustomer();
        Flurry.logEvent("RegistrationGoogle");
        Flurry.logEvent("Registration");
        yield LoginSuccess();
      } else if (event is RegistrationApple) {
        yield LoginLoading();
        if (!this.dataPolicyAllowed) {
          yield LoginError();
          throw Exception("Please accept our data policy");
        }
        Cache().setLoginType(LoginType.apple);
        await userRepository.addUserApple();
        accountBloc.add(AccountLogInFinished(customer: Cache().userLoggedIn));        
        await saveCustomer();
        Flurry.logEvent("RegistrationApple");
        Flurry.logEvent("Registration");
        yield LoginSuccess();
      } else if (event is DataProtectionClicked) {
        yield LoginLoading();
        this.dataPolicyAllowed = !dataPolicyAllowed;
        yield LoginReady();
      } else if (event is LoginPasswordChangeObscure) {
        yield LoginLoading();
        this.obscure = !this.obscure;
        yield LoginReady();
      }
    } on Exception catch (e) {
      yield LoginError(message: e.toString());
    }
  }

  Future<void> saveCustomer() async {
    customerRepository.customer = Cache().userLoggedIn;
    customerRepository.customer.dataPolicyAllowed = 1;
    await customerRepository.saveCustomer();
  }

  String emailValidation(String email) {
    String message = Common.emailValidation(email);
    if (message != null) {
      message = t(message);
    }
    return message;
  }

  String passwordValidation(String value) {
    String message = Common.passwordValidation(value);
    if (message != null) {
      message = t(message);
    }
    return message;
  }
}