Add Insights API

Author: aayushgupta05

.env

@@ -1,3 +1,3 @@
 DATABASE_URL="mongodb://MongoAdminUser:SecretKey%231@cluster0-shard-00-00.t4hho.mongodb.net:27017,cluster0-shard-00-01.t4hho.mongodb.net:27017,cluster0-shard-00-02.t4hho.mongodb.net:27017/SpansberryDb?ssl=true&replicaSet=atlas-a80apd-shard-0&authSource=admin&retryWrites=true&w=majority"
 JWT_SECRET = "somesupersecretkey"
-PORT=8000
+PORT=8000

.env.travis

@@ -1,4 +1,4 @@
 NODE_ENV = "travis"
 DATABASE_URL="mongodb://127.0.0.1:27017"
 JWT_SECRET = "somesupersecretkey"
-PORT=8080
+PORT=8080

.travis.yml

@@ -8,4 +8,4 @@ install:
 before_script:
   - sleep 15
 script:
-  - npm run travisTest
+  - npm run travisTest

__tests__/category.spec.js

@@ -259,4 +259,4 @@ test("should delete a category with admin/moderator/creator access", async () =>
   expect(categories.length).toBe(0);
   const topics = await Topic.find().lean();
   expect(topics.length).toBe(0);
-});
+});

__tests__/organization.spec.js

@@ -337,7 +337,7 @@ test("demote provided moderator to user by another admin using Id", async () =>
   expect(demotedUser.isModerator).toBe(false);
 });
 
-test("get all admins and moderators", async () => {
+test("get all admins and moderators with admin authorization", async () => {
   const userLoginResponse = await testLoginUser(1);
   const token = userLoginResponse.body.data.login.token;
   const response = await request
@@ -369,3 +369,22 @@ test("get all admins and moderators", async () => {
   expect(response.body.data.getAdminModerators.moderators.length).toBe(0);
   expect(response.body.data.getAdminModerators.admins[0].isFirstAdmin).toBe(true);
 });
+
+test("get more organization details with admin authorization", async () => {
+  const userLoginResponse = await testLoginUser(1);
+  const token = userLoginResponse.body.data.login.token;
+  const response = await request
+    .post("/graphql")
+    .send({
+      query: `{ getOrganizationData {
+        categories
+        topics
+      }}`,
+    })
+    .set("Accept", "application/json")
+    .set("Authorization", `Bearer ${token}`);
+  expect(response.type).toBe("application/json");
+  expect(response.status).toBe(200);
+  expect(response.body.data.getOrganizationData.categories).toBe(0);
+  expect(response.body.data.getOrganizationData.topics).toBe(0);
+});

__tests__/user.spec.js

@@ -69,7 +69,7 @@ test("should signup new user", async () => {
   userId = response.body.data.createUser._id;
 });
 
-test("get all users via admin authorization", async () => {
+test("get all users", async () => {
   firstUserLoginResponse = await testLoginUser(1);
   firstUserToken = firstUserLoginResponse.body.data.login.token;
   const response = await request
@@ -336,4 +336,4 @@ test("current user should be able to get tasks assigned to him", async () => {
   expect(response.body.data.getAssignedTasks.length).toBe(1);
   expect(response.body.data.getAssignedTasks[0].description).toBe("Lorem Ipsum");
   expect(response.body.data.getAssignedTasks[0].userId).toBe(userId);
-});
+});

config/testVariables.js

@@ -23,6 +23,7 @@ module.exports = {
       .set("Accept", "application/json");
     return response;
   },
+  
   testCreateUser: async (userNo) => {
     const response = await request
       .post("/graphql")
@@ -64,6 +65,7 @@ module.exports = {
       .set("Accept", "application/json");
     return response;
   },
+
   testLoginUser: async (userNo) => {
     const response = await request
       .post("/graphql")
@@ -95,6 +97,7 @@ module.exports = {
       .set("Accept", "application/json");
     return response;
   },
+  
   testCreateCategory: async (token) => {
     const response = await request
       .post("/graphql")
@@ -120,6 +123,7 @@ module.exports = {
       .set("Authorization", `Bearer ${token}`);
     return response;
   },
+
   testCreateTopic: async (token, categoryId) => {
     const response = await request
       .post("/graphql")
@@ -152,6 +156,7 @@ module.exports = {
       .set("Authorization", `Bearer ${token}`);
     return response;
   },
+
   testCreateMessage: async (token, topicId) => {
     const response = await request
       .post("/graphql")
@@ -171,6 +176,7 @@ module.exports = {
       .set("Authorization", `Bearer ${token}`);
     return response;
   },
+
   testCreateTask: async (
     token,
     topicId,
@@ -273,4 +279,4 @@ module.exports = {
     }
     return response;
   },
-};
+};

example.env

@@ -1,4 +1,4 @@
 NODE_ENV = "development"
 DATABASE_URL="mongodb://<username>:<password>@cluster0-shard-00-00.t4hho.mongodb.net:27017,cluster0-shard-00-01.t4hho.mongodb.net:27017,cluster0-shard-00-02.t4hho.mongodb.net:27017/<dbname>?ssl=true&replicaSet=atlas-a80apd-shard-0&authSource=admin&retryWrites=true&w=majority"
 JWT_SECRET = "somesupersecretkey"
-PORT=8000
+PORT=8000

example.env.test

@@ -1,4 +1,4 @@
 NODE_ENV = "testing"
 DATABASE_URL="mongodb://<username>:<password>@cluster0-shard-00-00.t4hho.mongodb.net:27017,cluster0-shard-00-01.t4hho.mongodb.net:27017,cluster0-shard-00-02.t4hho.mongodb.net:27017/<dbname>?ssl=true&replicaSet=atlas-a80apd-shard-0&authSource=admin&retryWrites=true&w=majority"
 JWT_SECRET = "somesupersecretkey"
-PORT=8080
+PORT=8080

graphql/resolvers/organization.js

@@ -1,6 +1,9 @@
 require("dotenv").config();
 const User = require("../../models/user");
 const Organization = require("../../models/organization");
+const Category = require("../../models/category");
+const Topic = require("../../models/topic");
+
 const { 
   organizationCreatedResult, 
   madeAdminResult, 
@@ -292,7 +295,9 @@ module.exports = {
             options: { sort: { createdAt: -1 } },
           });
         let admins = organization.adminIds.filter(admin => !admin.isBlocked);
-        let moderators = organization.moderatorIds.filter(moderator => !moderator.isAdmin && !moderator.isBlocked);
+        let moderators = organization.moderatorIds.filter(
+          moderator => !moderator.isAdmin && !moderator.isBlocked
+        );
         return {
           admins,
           moderators,
@@ -305,4 +310,28 @@ module.exports = {
       throw err;
     }
   },
+
+  getOrganizationData: async (args, req) => {
+    if (!req.isAuth) {
+      throw new Error(authenticationError);
+    }
+    try {
+      if (req.currentUser.isAdmin) {
+        if (req.currentUser.isBlocked || req.currentUser.isRemoved) {
+          throw new Error(noAuthorizationError);
+        }
+        const categories = await Category.estimatedDocumentCount();
+        const topics = await Topic.estimatedDocumentCount();
+        return {
+          categories,
+          topics,
+        };
+      } else {
+        throw new Error(adminAccessError);
+      }
+    } catch (err) {
+      console.log(err);
+      throw err;
+    }
+  }
 };