Class DevicesService

packages/core/src/services/devices/DevicesService.ts:16–72

@injectable()
@routerName('device')
export class DevicesService extends DBService<Device>
	implements IDeviceRouter, IService {
	public readonly DBObject: any = Device;

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

	@observableListener()
	get(id: string): Observable<Device | null> {
		return super.get(id).pipe(
			map(async (device) => {
				await this.throwIfNotExists(id);
				return device;
			}),
			switchMap((device) => device)
		);
	}

	async getMultipleDevices(
		ids: Array<Device['id']>
	): Promise<Observable<Device[]>> {
		const devices = await this.find({
			_id: { $in: ids },
			isDeleted: { $eq: false },
		});

		const devicesIds = devices.map((device) => device.id);

		return super.getMultiple(devicesIds);
	}

	@asyncListener()
	async create(device: IDeviceCreateObject): Promise<Device> {
		return super.create(device);
	}

	@asyncListener()
	async updateLanguage(
		deviceId: string,
		language: ILanguage
	): Promise<Device> {
		await this.throwIfNotExists(deviceId);

		return this.update(deviceId, {
			language,
		});
	}

	async throwIfNotExists(deviceId: string) {
		const device = await super.get(deviceId).pipe(first()).toPromise();

		if (!device || device.isDeleted) {
			throw Error(`Device with id '${deviceId}' does not exists!`);
		}
	}
}