Skip to content
New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Jump to bottom

refactor-email bloc #29

Open
wants to merge 1 commit into
base: main
Choose a base branch
from
Open

refactor-email bloc #29

Changes from all commits
Commits
Show all changes
1 commit
Select commit
File filter

Filter by extension

Filter by extension
Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
191 changes: 108 additions & 83 deletions lib/src/app/feature/email_authentication/presentation/bloc/email_bloc.dart
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -10,7 +10,16 @@ part 'email_event.dart';
part 'email_state.dart';

class AuthenticationBloc extends Bloc<AuthEvent, AuthState> {
AuthenticationBloc({this.userRepository}) : super(AuthInitial());
AuthenticationBloc({this.userRepository}) : super(AuthInitial()) {
on<SignInButtonPressed>(_signInButtonPressed);
on<SignUpButtonPressed>(_signUpButtonPressed);
on<AuthenticationStarted>(_authenticationStarted);
on<AuthenticationStateChanged>(_authenticationStateChanges);
on<AuthenticationGoogleStarted>(_authenticationGoogleStarted);
on<AuthenticationExited>(_authenticationExited);
on<VerificationMailSent>(_verificationMailSent);
on<GetUser>(_getUser);
}

final UserRepository? userRepository;
final logger = Logger();
Expand All @@ -22,93 +31,109 @@ class AuthenticationBloc extends Bloc<AuthEvent, AuthState> {
return super.close();
}

@override
Stream<AuthState> mapEventToState(
AuthEvent event,
) async* {
if (event is SignInButtonPressed) {
yield AuthLoading();
try {
final user = await userRepository?.signIn(event.email, event.password);
yield AuthSucceed(user: user);
} catch (e) {
yield AuthFailed(message: e.toString());
}
} else if (event is SignUpButtonPressed) {
yield AuthLoading();
try {
add(VerificationMailSent());
await userRepository?.signUp(event.email, event.password);
} catch (e) {
if (e is FirebaseAuthException) {
if (e.code == 'ERROR_EMAIL_ALREADY_IN_USE') {
logger.w("Account Already exists");
} else if (e.code == 'weak-password') {
logger.w("Password Provided is too Weak");
}
FutureOr<void> _signInButtonPressed(
SignInButtonPressed event, Emitter<AuthState> emit) async {
emit(AuthLoading());
try {
final user = await userRepository?.signIn(event.email, event.password);
emit(AuthSucceed(user: user));
} catch (e) {
emit(AuthFailed(message: e.toString()));
}
}

FutureOr<void> _signUpButtonPressed(
SignUpButtonPressed event, Emitter<AuthState> emit) async {
emit(AuthLoading());
try {
add(VerificationMailSent());
await userRepository?.signUp(event.email, event.password);
} catch (e) {
if (e is FirebaseAuthException) {
if (e.code == 'ERROR_EMAIL_ALREADY_IN_USE') {
logger.w("Account Already exists");
} else if (e.code == 'weak-password') {
logger.w("Password Provided is too Weak");
}
yield AuthFailed(message: e.toString());
}
} else if (event is AuthenticationStarted) {
try {
yield AuthLoading();
authStreamSub =
userRepository!.getAuthDetailStream().listen((authDetail) {
add(AuthenticationStateChanged(authenticationDetail: authDetail));
});
} catch (error) {
logger.d(
'Error occured while fetching authentication detail : ${error.toString()}');
yield const AuthFailed(
message: 'Error occrued while fetching auth detail');
}
} else if (event is AuthenticationStateChanged) {
if (event.authenticationDetail.isValid!) {
yield AuthSucceed(authenticationDetail: event.authenticationDetail);
emit(AuthFailed(message: e.toString()));
}
}

FutureOr<void> _authenticationStarted(
AuthenticationStarted event, Emitter<AuthState> emit) {
try {
emit(AuthLoading());
authStreamSub =
userRepository!.getAuthDetailStream().listen((authDetail) {
add(AuthenticationStateChanged(authenticationDetail: authDetail));
});
} catch (error) {
logger.d(
'Error occured while fetching authentication detail : ${error.toString()}');
emit(const AuthFailed(
message: 'Error occrued while fetching auth detail'));
}
}

FutureOr<void> _authenticationStateChanges(
AuthenticationStateChanged event, Emitter<AuthState> emit) {
if (event.authenticationDetail.isValid!) {
emit(AuthSucceed(authenticationDetail: event.authenticationDetail));
} else {
emit(const AuthFailed(message: 'User has logged out'));
}
}

FutureOr<void> _authenticationGoogleStarted(
AuthenticationGoogleStarted event, Emitter<AuthState> emit) async {
try {
emit(AuthLoading());
AuthenticationDetail authenticationDetail =
await userRepository!.authenticateWithGoogle();

if (authenticationDetail.isValid!) {
emit(AuthSucceed(authenticationDetail: authenticationDetail));
} else {
yield const AuthFailed(message: 'User has logged out');
emit(const AuthFailed(message: 'User detail not found.'));
}
} else if (event is AuthenticationGoogleStarted) {
try {
yield AuthLoading();
AuthenticationDetail authenticationDetail =
await userRepository!.authenticateWithGoogle();
} catch (error) {
logger.d('Error occured while login with Google ${error.toString()}');
emit(const AuthFailed(
message: 'Unable to login with Google. Try again.',
));
}
}

if (authenticationDetail.isValid!) {
yield AuthSucceed(authenticationDetail: authenticationDetail);
} else {
yield const AuthFailed(message: 'User detail not found.');
}
} catch (error) {
logger.d('Error occured while login with Google ${error.toString()}');
yield const AuthFailed(
message: 'Unable to login with Google. Try again.',
);
}
} else if (event is AuthenticationExited) {
try {
yield AuthLoading();
await userRepository!.unAuthenticate();
} catch (error) {
logger.d('Error occured while logging out. : ${error.toString()}');
yield const AuthFailed(message: 'Unable to logout. Please try again.');
}
} else if (event is VerificationMailSent) {
try {
await userRepository?.sendVerificationEmail();
yield MailVerificationSent();
} catch (e) {
logger.d('Unable to send mail. Try again.');
yield const AuthFailed(message: 'Unable to logout. Please try again.');
}
} else if (event is GetUser) {
try {
await userRepository!.getCurrentUser();
yield CurrentUser();
} catch (e) {
logger.d(e);
yield AuthFailed(message: e.toString());
}
FutureOr<void> _authenticationExited(
AuthenticationExited event, Emitter<AuthState> emit) async {
try {
emit(AuthLoading());
await userRepository!.unAuthenticate();
} catch (error) {
logger.d('Error occured while logging out. : ${error.toString()}');
emit(const AuthFailed(message: 'Unable to logout. Please try again.'));
}
}

FutureOr<void> _verificationMailSent(
VerificationMailSent event, Emitter<AuthState> emit) async {
try {
await userRepository?.sendVerificationEmail();
emit(MailVerificationSent());
} catch (e) {
logger.d('Unable to send mail. Try again.');
emit(const AuthFailed(message: 'Unable to logout. Please try again.'));
}
}

FutureOr<void> _getUser(GetUser event, Emitter<AuthState> emit) async {
try {
await userRepository!.getCurrentUser();
emit(CurrentUser());
} catch (e) {
logger.d(e);
emit(AuthFailed(message: e.toString()));
}
}
}