patchEstimateHandler.js

export const patchEstimateHandler = async (req, res) => {
  const {
    body: { canStartToday },
    params: { estimateId },
    userId
  } = req;

  const originalEstimate = await getEstimateById(estimateId);
  if (!originalEstimate) {
    return responseService.createErrorResponse(res, createError.NotFound());
  }

  const updates = {};
  if (typeof canStartToday === 'boolean') {
    updates.canStartToday = canStartToday;
  }

  const trx = await BaseModel.getTransactionObject();

  const latestEstimateRevision = await JobEstimateRevision.query().findById(
    originalEstimate.latestEstimateRevisionId
  );

  if (
    latestEstimateRevision.revisedById !== userId ||
    latestEstimateRevision.status !== REVISION_STATUS.draft
  ) {
    const { providerId } = await getJobByEstimateId(estimateId);

    const status = providerId === userId ? REVISION_STATUS.published : REVISION_STATUS.suggested;

    const jobEstimateRevision = await JobEstimateRevision.query(trx).insertAndFetch({
      changedFromId: latestEstimateRevision.id,
      status,
      revisedById: userId,
      expiration: latestEstimateRevision.expiration,
      canStartToday: latestEstimateRevision.canStartToday,
      ...updates
    });
    await originalEstimate.$query(trx).patch({
      latestEstimateRevisionId: jobEstimateRevision.id
    });
  } else {
    await latestEstimateRevision.$query(trx).patch(updates);
  }

  let estimate;
  try {
    estimate = await getEstimate(estimateId);
  } catch (e) {
    return e.status
      ? responseService.createErrorResponse(res, e)
      : responseService.createErrorResponse(res, createError.BadRequest(e.message));
  }

  return responseService.createSuccessResponse(res, 200, estimate);
};