baublet/w8mngr

import { dbService } from "../../config/db";
import { Context } from "../../createContext";
import { FoodInput } from "../../generated";
import { foodMeasurementDataService } from "../foodMeasurement";
import { rootService } from "./rootService";

export async function saveMutation(
  context: Context,
  { input, userId }: { input: FoodInput; userId: string }
) {
  const db = await context.services.get(dbService);
  await db.transact();
  try {
    const { measurements, ...foodProperties } = input;

    const upsertResults = await rootService.upsert(
      context,
      [{ ...foodProperties, userId }],
      (q) => q.where("userId", "=", userId)
    );
    const foodId = upsertResults[0].id;

    if (!foodId) {
      throw new Error(
        `Unknown error upserting food. Expected an upsert result. Instead received ${JSON.stringify(
          upsertResults
        )}`
      );
    }

    if (measurements) {
      await foodMeasurementDataService.upsert(
        context,
        measurements.map((measurement) => ({
          ...measurement,
          userId,
          foodId,
        }))
      );
    }

    await db.commit();
    return {
      food: rootService.findOneOrFail(context, (q) =>
        q.where("id", "=", foodId).andWhere("userId", "=", userId)
      ),
    };
  } catch (error) {
    await db.rollback(error);
    return {
      food: undefined,
      errors: [error],
    };
  }
}