Function create

packages/core/src/@pyro/db-server/db-service.ts:132–164

(createObject: CreateObject<T>)

	}

	async create(createObject: CreateObject<T>): Promise<T> {
		const callId = uuid();

		this.log.info({ callId, createObject }, '.create(createObject) called');

		let object;

		try {
			const document = await this.Model.create(createObject);

			object = this.parse(document.toObject() as RawObject<T>);
		} catch (error) {
			this.log.error(
				{ callId, createObject, error },
				'.create(createObject) thrown error!'
			);
			throw error;
		}

		this.existence.next({
			id: object.id,
			value: object,
			lastValue: null,
			type: ExistenceEventType.Created,
		});

		this.log.info(
			{ callId, createObject, object },
			'.create(createObject) created object'
		);

		return object;
	}

	/**
	 * Removes all records from the DB