Как обнаружить исходную ошибку в среде микросервисов NestJS? ⇐ Javascript

[Anonymous]

Я использую пакет микросервисов NestJS ClientProxy с RabbitMQ в качестве транспортера. Я пытаюсь отправить сообщение от службы аутентификации в службу пользователя. Служба аутентификации запрашивает пользовательскую службу, существует ли пользователь, если нет, то она просит пользовательскую службу создать пользователя. Мой код работает, но я изо всех сил пытаюсь извлечь ошибку, которая выдается в репозитории пользователей, если пользователь уже существует. Я получаю ошибку 500 в ответе, и хотя это работает, я не понимаю, где я теряю исходную ошибку. Мне нужно придумать несколько шаблонов, поскольку это будет обычным делом. Мне не удалось изучить документацию NestJS. В их примерах не объявляются типы возвращаемых функций, поэтому мне не удалось увидеть ни одного законченного рабочего примера. Единственный способ преодолеть некоторые ошибки машинописного текста при возврате значения функции, вызывающей наблюдаемую, — это обернуть ответ в обещание. Хотя это похоже на взлом.
Будем благодарны за любую помощь. Заранее спасибо.
Служба аутентификации отправляет событие микросервису пользователя.:
Сначала он спрашивает, существует ли адрес электронной почты пользователя. и выдает ошибку. Я не могу заставить эту ошибку появиться в ответе.
public async register({
dto,
}: {
dto: UserRequestDto;
}): Promise {
return new Promise((resolve, reject) => {
this.usersController
.send(FIND_USER_BY_EMAIL, dto.email)
.pipe(
switchMap((res) => {
if (res === null) {
return this.usersController.send(CREATE_USER, dto);
}
}),
)
.subscribe({
next: (res) => {
resolve(res);
},
error: (e) => {
reject(e);
},
});
});
}

Пользовательский контроллер, прослушивающий событие:
@MessagePattern(FIND_USER_BY_EMAIL)
@Serialize(UserResponseDto)
public async findByEmail(@Payload() email: string): Promise {
try {
return await this.usersService.findByEmail({ email: email });
} catch (e) {
throw e;
}
}

Метод службы пользователя, вызываемый контроллером:
public async findByEmail({ email }: { email: string }): Promise {
try {
return await this.usersRepository.findByEmail({ email: email });
} catch (e) {
throw e;
}
}

Пользовательский репозиторий, вызываемый службой:
Здесь я выдаю ошибку. Эта ошибка не видна в результирующей наблюдаемой, где все это начинается. Метод error в наблюдаемом объекте знает, что произошла ошибка, но выдает мне пустой объект {}
public async findByEmail({ email }: { email: string }): Promise {
const repository = this.getRepository(UserEntity);

try {
const user = await repository.findOneBy({ email: email });

if (user) {
throw new UnprocessableEntityException("Email already exists.");
}

return user;
} catch (e) {
throw e;
}
}


Подробнее здесь: https://stackoverflow.com/questions/793 ... -framework