store dashboard evaluations

Author: vkarpov15

netlify/functions/completeDashboardEvaluate.js

@@ -0,0 +1,5 @@
+'use strict';
+
+const extrovert = require('extrovert');
+
+module.exports = extrovert.toNetlifyFunction(require('../../src/actions/completeDashboardEvaluate'));

netlify/functions/startDashboardEvaluate.js

@@ -0,0 +1,5 @@
+'use strict';
+
+const extrovert = require('extrovert');
+
+module.exports = extrovert.toNetlifyFunction(require('../../src/actions/startDashboardEvaluate'));

src/actions/completeDashboardEvaluate.js

@@ -0,0 +1,53 @@
+'use strict';
+
+const Archetype = require('archetype');
+const connect = require('../../src/db');
+
+const CompleteDashboardEvaluateParams = new Archetype({
+  authorization: {
+    $type: 'string'
+  },
+  dashboardResultId: {
+    $type: 'string'
+  },
+  workspaceId: {
+    $type: 'string'
+  },
+  finishedEvaluatingAt: {
+    $type: Date
+  },
+  result: {
+    $type: Archetype.Any
+  }
+}).compile('CompleteDashboardEvaluateParams');
+
+module.exports = async function completeDashboardEvaluate(params) {
+  const { authorization, dashboardResultId, workspaceId, finishedEvaluatingAt, result } = new CompleteDashboardEvaluateParams(params);
+
+  const db = await connect();
+  const { AccessToken, DashboardResult, Workspace } = db.models;
+
+  let userId = null;
+  if (authorization) {
+    const accessToken = await AccessToken.findById(authorization).orFail(new Error('Invalid access token'));
+    userId = accessToken.userId;
+  }
+
+  // Find the workspace and check user permissions
+  const workspace = await Workspace.findById(workspaceId).orFail(new Error('Workspace not found'));
+
+  const isAuthorized = workspace.members.some(member =>
+    member.userId.toString() === userId.toString() && member.roles.find(role => ['admin', 'owner', 'member'].includes(role))
+  );
+  if (!isAuthorized) {
+    throw new Error('Unauthorized');
+  }
+
+  const dashboardResult = await DashboardResult.findById(dashboardResultId).orFail();
+  dashboardResult.finishedEvaluatingAt = finishedEvaluatingAt;
+  dashboardResult.result = result;
+  dashboardResult.status = 'completed';
+  await dashboardResult.save();
+
+  return { dashboardResult };
+};

src/actions/startDashboardEvaluate.js

@@ -0,0 +1,52 @@
+'use strict';
+
+const Archetype = require('archetype');
+const connect = require('../../src/db');
+
+const StartDashboardEvaluateParams = new Archetype({
+  authorization: {
+    $type: 'string'
+  },
+  dashboardId: {
+    $type: 'string'
+  },
+  workspaceId: {
+    $type: 'string'
+  },
+  startedEvaluatingAt: {
+    $type: Date
+  }
+}).compile('StartDashboardEvaluateParams');
+
+module.exports = async function startDashboardEvaluate(params) {
+  const { authorization, dashboardId, workspaceId, startedEvaluatingAt } = new StartDashboardEvaluateParams(params);
+
+  const db = await connect();
+  const { AccessToken, DashboardResult, Workspace } = db.models;
+
+  let userId = null;
+  if (authorization) {
+    const accessToken = await AccessToken.findById(authorization).orFail(new Error('Invalid access token'));
+    userId = accessToken.userId;
+  }
+
+  // Find the workspace and check user permissions
+  const workspace = await Workspace.findById(workspaceId).orFail(new Error('Workspace not found'));
+
+  const isAuthorized = workspace.members.some(member =>
+    member.userId.toString() === userId.toString() && member.roles.find(role => ['admin', 'owner', 'member'].includes(role))
+  );
+  if (!isAuthorized) {
+    throw new Error('Unauthorized');
+  }
+
+  const dashboardResult = await DashboardResult.create({
+    dashboardId,
+    workspaceId,
+    userId,
+    startedEvaluatingAt,
+    status: 'in_progress'
+  });
+
+  return { dashboardResult };
+};

src/db/DashboardResult.js

@@ -0,0 +1,35 @@
+'use strict';
+
+const mongoose = require('mongoose');
+
+const dashboardResultSchema = new mongoose.Schema({
+  dashboardId: {
+    type: mongoose.ObjectId,
+    ref: 'Dashboard'
+  },
+  workspaceId: {
+    type: mongoose.ObjectId,
+    ref: 'Workspace'
+  },
+  userId: {
+    type: mongoose.ObjectId,
+    ref: 'User'
+  },
+  startedEvaluatingAt: {
+    type: Date
+  },
+  finishedEvaluatingAt: {
+    type: Date
+  },
+  status: {
+    type: String,
+    enum: ['in_progress', 'completed', 'failed']
+  },
+  error: new mongoose.Schema({
+    message: String,
+    extra: String
+  }),
+  result: 'Mixed'
+}, { timestamps: true });
+
+module.exports = dashboardResultSchema;

src/db/index.js

@@ -5,6 +5,7 @@ const mongoose = require('mongoose');
 let conn = null;
 
 const accessTokenSchema = require('./AccessToken');
+const dashboardResultSchema = require('./DashboardResult');
 const invitationSchema = require('./invitation');
 const jobSchema = require('./Job');
 const openCollectiveSponsorSchema = require('./OpenCollectiveSponsor');
@@ -22,6 +23,7 @@ module.exports = async function connect() {
     await conn.asPromise();
   }
   conn.model('AccessToken', accessTokenSchema, 'AccessToken');
+  conn.model('DashboardResult', dashboardResultSchema, 'DashboardResult');
   conn.model('Invitation', invitationSchema, 'Invitation');
   conn.model('Job', jobSchema, 'Job');
   conn.model('OpenCollectiveSponsor', openCollectiveSponsorSchema, 'OpenCollectiveSponsor');