import { Types, isObjectIdOrHexString } from "mongoose";
import DataModule from "../DataModule";
import DataModuleJob from "./DataModuleJob";

export default abstract class FindByIdJob extends DataModuleJob {
	protected override async _validate() {
		if (typeof this._payload !== "object")
			throw new Error("Payload must be an object");

		if (!isObjectIdOrHexString(this._payload._id))
			throw new Error("_id is not an ObjectId");
	}

	protected async _execute({ _id }: { _id: Types.ObjectId }) {
		const model = await DataModule.getModel(this.getModelName());

		const query = model.findById(_id);

		return query.exec();
	}
}