feature: populate game room with questions

backend/src/graphql/GameRoom/datasource.js

@@ -3,6 +3,7 @@ const { ApolloError, UserInputError } = require("apollo-server-core");
 const mongoose = require("mongoose");
 
 const ChatRoom = require("../../schemas/ChatRoom/ChatRoom");
+const Question = require("../../schemas/Question/Question");
 const GameRoom = require("../../schemas/GameRoom/GameRoom");
 
 const GameAnswerEnum = require("../../enum/GameAnswer");
@@ -34,9 +35,12 @@ class GameRoomAPI extends DataSource {
       ];
 
       // add 10 questions
+      const tenQuestions = await this.getQuestion();
+      const questions = tenQuestions.map((ques) => ques._id);
       const gameRoom = new GameRoom({
         _id,
         answers,
+        questions,
       });
 
       chatRoom.gameRoom = _id;
@@ -47,7 +51,7 @@ class GameRoomAPI extends DataSource {
       return _id;
     } catch (err) {
       console.error(err);
-      throw new ApolloError("Internal Server Error");
+      throw new ApolloError(err);
     }
   }
 
@@ -76,6 +80,32 @@ class GameRoomAPI extends DataSource {
       throw new ApolloError("Internal Server Error");
     }
   }
+
+  //for testing
+  async getGameRoomById(gameRoomId) {
+    try {
+      const gameRoom = await GameRoom.findById(gameRoomId);
+      return gameRoom;
+    } catch (err) {
+      throw new ApolloError("Internal Server Error");
+    }
+  }
+
+  async getQuestion() {
+    try {
+      let questions = [];
+      const limit = parseInt(process.env.QUESTION_LIMIT) || 10;
+      questions = await Question.aggregate([
+        {
+          $sample: { size: limit },
+        },
+      ]);
+      return questions;
+    } catch (err) {
+      console.log(err);
+      throw new ApolloError("Internal Server Error - get question");
+    }
+  }
 }
 
 module.exports.GameRoomAPI = GameRoomAPI;

backend/src/graphql/GameRoom/mutations.js

@@ -1,3 +1,5 @@
 module.exports.mutations = `
     submitAnswers(gameRoomId: String!, answers: [String!]!) : GeneralMutationResponse!
+    "this is for testing purposes"
+    createGameRoom(chatRoomId: ID!): GeneralMutationResponse
 `;

backend/src/graphql/GameRoom/queries.js

@@ -1,2 +1,3 @@
 module.exports.queries = `
+    getGameRoomById(gameRoomId: ID!): GameRoom
 `;

backend/src/graphql/GameRoom/resolvers.js

@@ -1,4 +1,4 @@
-const queries = {};
+const { AuthenticationError, ApolloError } = require("apollo-server-core");
 
 const mutations = {
   submitAnswers: async (_, args, { dataSources, req, userAuthentication }) => {
@@ -15,6 +15,41 @@ const mutations = {
       message: "Submit successfully",
     };
   },
+  createGameRoom: async (
+    _,
+    { chatRoomId },
+    { dataSources, req, userAuthentication }
+  ) => {
+    userAuthentication(req.user);
+    try {
+      userAuthentication(req.user);
+      const id = await dataSources.gameRoomAPI.createGameRoom(chatRoomId);
+      if (id) {
+        return {
+          success: true,
+          message: id,
+        };
+      }
+    } catch (err) {
+      throw new ApolloError(err);
+    }
+  },
+};
+
+const queries = {
+  getGameRoomById: async (
+    _,
+    { gameRoomId },
+    { dataSources, req, userAuthentication }
+  ) => {
+    userAuthentication(req.user);
+    try {
+      userAuthentication(req.user);
+      return await dataSources.gameRoomAPI.getGameRoomById(gameRoomId);
+    } catch (err) {
+      throw new ApolloError(err);
+    }
+  },
 };
 
 const subscriptions = {};

backend/src/graphql/GameRoom/types.js

@@ -1,3 +1,13 @@
 module.exports.types = `
+    type GameRoom {
+        id: ID!
+        questions: [ID]
+        answers: [GameAnswer]
+    }
 
+    type GameAnswer{
+        id: ID!
+        user: ID!
+        answers: [String]
+    }
 `;

backend/src/graphql/Question/datasource.js

@@ -0,0 +1,30 @@
+const { DataSource } = require("apollo-datasource");
+const { UserInputError, ApolloError } = require("apollo-server-core");
+
+const Question = require("../../schemas/Question/Question");
+
+class QuestionAPI extends DataSource {
+  constructor() {
+    super();
+  }
+  async getQuestion() {
+    try {
+      let questions = [];
+      const limit = parseInt(process.env.QUESTION_LIMIT) || 10;
+      questions = await Question.aggregate([
+        {
+          $sample: { size: limit },
+        },
+      ]);
+      return questions.map((obj) => ({
+        ...obj,
+        id: obj._id,
+      }));
+    } catch (err) {
+      console.log(err);
+      throw new ApolloError("Internal Server Error - get question");
+    }
+  }
+}
+
+module.exports.QuestionAPI = QuestionAPI;

backend/src/graphql/Question/index.js

@@ -0,0 +1,13 @@
+const { queries } = require("./queries");
+const { mutations } = require("./mutations");
+const { resolvers } = require("./resolvers");
+const { types } = require("./types");
+const { QuestionAPI } = require("./datasource");
+
+module.exports.Question = {
+  queries,
+  mutations,
+  resolvers,
+  types,
+  QuestionAPI,
+};

backend/src/graphql/Question/mutations.js

@@ -0,0 +1,3 @@
+module.exports.mutations = `
+
+`;

backend/src/graphql/Question/queries.js

@@ -0,0 +1,4 @@
+module.exports.queries = `
+    "get 10 questions to populate game room"
+    getQuestion: [Question!]!
+`;

backend/src/graphql/Question/resolvers.js

@@ -0,0 +1,19 @@
+const { AuthenticationError, ApolloError } = require("apollo-server-core");
+
+const queries = {
+  getQuestion: async (_, __, { dataSources, req, userAuthentication }) => {
+    try {
+      userAuthentication(req.user);
+      return await dataSources.questionAPI.getQuestion();
+    } catch (err) {
+      throw new ApolloError(err);
+    }
+  },
+};
+
+const mutations = {};
+
+module.exports.resolvers = {
+  queries,
+  mutations,
+};

backend/src/graphql/Question/types.js

@@ -0,0 +1,7 @@
+module.exports.types = `
+    type Question{
+        id: ID!
+        question: String!,
+        topics: [String!]!
+    }
+`;

backend/src/graphql/datasources.js

@@ -11,6 +11,7 @@ const { UserStatus } = require("./UserStatus");
 const { PlayingStatus } = require("./PlayingStatus");
 const { OpeningLine } = require("./OpeningLine");
 const { Image } = require("./Image");
+const { Question } = require("./Question");
 
 module.exports = {
   UserAPI: User.UserAPI,
@@ -26,4 +27,5 @@ module.exports = {
   PlayingStatusAPI: PlayingStatus.PlayingStatusAPI,
   OpeningLineAPI: OpeningLine.OpeningLineAPI,
   ImageAPI: Image.ImageAPI,
+  QuestionAPI: Question.QuestionAPI,
 };

backend/src/graphql/resolvers.js

@@ -12,6 +12,7 @@ const { UserStatus } = require("./UserStatus");
 const { OpeningLine } = require("./OpeningLine");
 const { Upload } = require("./Upload");
 const { Image } = require("./Image");
+const { Question } = require("./Question");
 
 const resolvers = {
   Upload: GraphQLUpload,
@@ -29,6 +30,7 @@ const resolvers = {
     ...OpeningLine.resolvers.queries,
     ...Upload.resolvers.queries,
     ...Image.resolvers.queries,
+    ...Question.resolvers.queries,
   },
   Mutation: {
     ...User.resolvers.mutations,
@@ -43,6 +45,7 @@ const resolvers = {
     ...OpeningLine.resolvers.mutations,
     ...Upload.resolvers.mutations,
     ...Image.resolvers.mutations,
+    ...Question.resolvers.mutations,
   },
   Subscription: {
     ...ChatRoom.resolvers.subscriptions,

backend/src/graphql/typeDefs.js

@@ -18,6 +18,7 @@ const { SharedType } = require("./SharedType");
 const { GameRoom } = require("./GameRoom");
 const { GameRequest } = require("./GameRequest");
 const { Upload } = require("./Upload");
+const { Question } = require("./Question");
 
 const typeDefs = gql`
   ${interfaces.types}
@@ -37,6 +38,7 @@ const typeDefs = gql`
   ${UserStatus.types}
   ${OpeningLine.types}
   ${Upload.types}
+  ${Question.types}
 
   type Query {
     ${User.queries}
@@ -52,6 +54,7 @@ const typeDefs = gql`
     ${OpeningLine.queries}
     ${Upload.queries}
     ${Image.queries}
+    ${Question.queries}
   }
 
   type Mutation {
@@ -67,6 +70,7 @@ const typeDefs = gql`
     ${OpeningLine.mutations}
     ${Upload.mutations}
     ${Image.mutations}
+    ${Question.mutations}
   }
 
   type Subscription {

backend/src/index.js

@@ -30,6 +30,7 @@ const dataSources = () => ({
   playingStatusAPI: new datasources.PlayingStatusAPI(),
   openingLineAPI: new datasources.OpeningLineAPI(),
   imageAPI: new datasources.ImageAPI(),
+  questionAPI: new datasources.QuestionAPI(),
 });
 
 cloudinary.config({