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/util/common.dart';
import 'package:aitrainer_app/util/enums.dart';
import 'package:aitrainer_app/util/track.dart';
import 'package:aitrainer_app/util/trans.dart';
import 'package:bloc/bloc.dart';
import 'package:equatable/equatable.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());

  @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));
        Track().track(TrackingEvent.login, eventValue: "email");
        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));
        Track().track(TrackingEvent.login, eventValue: "FB");
        yield LoginSuccess();
      } else if (event is LoginGoogle) {
        yield LoginLoading();
        Cache().setLoginType(LoginType.google);
        await userRepository.getUserByGoogle();
        accountBloc.add(AccountLogInFinished(customer: Cache().userLoggedIn));
        Track().track(TrackingEvent.login, eventValue: "Google");
        yield LoginSuccess();
      } else if (event is LoginApple) {
        yield LoginLoading();
        Cache().setLoginType(LoginType.apple);
        await userRepository.getUserByApple();
        accountBloc.add(AccountLogInFinished(customer: Cache().userLoggedIn));
        Track().track(TrackingEvent.login, eventValue: "Apple");
        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();
        Track().track(TrackingEvent.registration, eventValue: "email");
        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();
        Track().track(TrackingEvent.registration, eventValue: "FB");
        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();
        Track().track(TrackingEvent.registration, eventValue: "Google");
        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();
        Track().track(TrackingEvent.registration, eventValue: "Apple");

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