Class UsersService

packages/core/src/services/users/UsersService.ts:68–584

@injectable()
@routerName('user')
export class UsersService
	extends DBService<User>
	implements IUserRouter, IService
{
	public readonly DBObject: any = User;

	// TODO: this and other Stripe related things should be inside separate Payments Service
	private stripe = new Stripe(env.STRIPE_SECRET_KEY, {
		apiVersion: '2020-08-27',
	});

	protected readonly log: Logger = createEverLogger({
		name: 'usersService',
	});

	public watchedFiles: IWatchedFiles;

	constructor(
		@inject(new LazyServiceIdentifer(() => InvitesService))
		protected invitesService: InvitesService,
		@inject(new LazyServiceIdentifer(() => DevicesService))
		protected devicesService: DevicesService,
		@inject(new LazyServiceIdentifer(() => WarehousesService))
		protected _storesService: WarehousesService
	) {
		super();
		// TODO: too many hardcoded constants used below. Refactor!
		this.watchedFiles = _.zipObject(
			['aboutUs', 'privacy', 'termsOfUse', 'help'],
			_.map(['about_us', 'privacy', 'terms_of_use', 'help'], (folder) =>
				_.zipObject(
					['en-US', 'he-IL', 'ru-RU', 'bg-BG', 'fr-FR'],
					_.map(
						['en-US', 'he-IL', 'ru-RU', 'bg-BG', 'fr-FR'],
						(language) =>
							observeFile(
								`${path.resolve(
									__dirname,
									'../../../',
									...['res', 'templates']
								)}/${folder}/${language}.hbs`
							).pipe(
								tap({ error: (err) => this.log.error(err) }),
								publishReplay(1),
								refCount<string>()
							)
					)
				)
			)
		) as any;
	}

	/**
	 * Verify if customer with given email already exists
	 *
	 * @param {string} email
	 * @returns {Promise<boolean>}
	 * @memberof UsersService