answer.db.ts

import { Answer, IAnswer } from "../models";
import { model, Schema, Types } from "mongoose";

export const createAnswer = async (answer: IAnswer) => {
  const newQuestion = await Answer.create(answer);
  return newQuestion;
};

export const getAnswers = async (surveyId: string) => {
  const result = await Answer.aggregate([
    // surveyId에 해당하는 답변들 find
    { $match: { surveyId: new Types.ObjectId(surveyId) } },

    // 같은 question에 대한 답변들을 answers[]에 push
    // {surveyId,questionId,guestId,content} => {_id:questionId, surveyId, answers:[content,content]}
    {
      $group: {
        _id: "$questionId",
        surveyId: { $first: "$surveyId" },
        answers: { $push: "$content" },
      },
    },

    // question DB popluate
    {
      $lookup: {
        from: "questions",
        localField: "_id",
        foreignField: "_id",
        as: "questionInfo",
      },
    },
    {
      $unwind: "$questionInfo",
    },

    // 질문 순서대로 정렬
    { $sort: { "questionInfo.order": 1 } },

    // surveyId로 묶고 questions 내에 { questionInfo, answers }[]
    {
      $group: {
        _id: "$surveyId",
        questions: {
          $push: { questionInfo: "$questionInfo", answers: "$answers" },
        },
      },
    },

    // survey DB populate
    {
      $lookup: {
        from: "surveys",
        localField: "_id",
        foreignField: "_id",
        as: "survey",
      },
    },
    {
      $unwind: "$survey",
    },

    //밖에 있던 questions를 survey 내부로 이동시키고 survey를 가장 root로 변경
    { $set: { "survey.questions": "$questions" } },
    { $replaceRoot: { newRoot: "$survey" } },
  ]);
  return result[0];
};