Secure your code as it's written. Use Snyk Code to scan source code in minutes - no build needed - and fix issues immediately.
dragonKilled = (events$: Observable): Observable => {
return events$
.pipe(
ofType(HeroKilledDragonEvent),
delay(1000),
map(event => {
console.log(clc.redBright('Inside [HeroesGameSagas] Saga'));
return new DropAncientItemCommand(event.heroId, itemId);
}),
);
}
}
userLoggedIn = (events$: Observable): Observable => {
return events$
.pipe(
ofType(UserLoggedInEvent),
delay(1000),
map( event => {
Logger.log('Inside [AuthSagas] Saga', JSON.stringify(event.user));
if (event.user) { this.queue.add('UserLoggedIn', event.user); }
return null;
}),
);
}
userRegistered = (events$: Observable): Observable => {
return events$
.pipe(
ofType(UserRegisteredEvent),
delay(1000),
map( event => {
Logger.log('Inside [AuthSagas] Saga', JSON.stringify(event.user));
this.queue.add('UserRegistered', event.user);
return null;
}),
);
}
emailVerified = (events$: Observable): Observable => {
return events$
.pipe(
ofType(EmailVerifiedEvent),
delay(1000),
map( event => {
Logger.log('Inside [AuthSagas] Saga', JSON.stringify(event.user));
this.queue.add('EmailVerified', event.user);
return null;
}),
);
}
}
authCreated = (events$: Observable): Observable => {
return events$
.pipe(
ofType(UserLoggedInEvent),
delay(1000),
map(event => {
Logger.log('Inside [AuthSagas] Saga', JSON.stringify(event.user));
return null;
}),
);
}
}