load projects and samples

src/api/route-services/projects.js

@@ -7,9 +7,10 @@ const logger = require('../../utils/logging');
 const { OK, NotFoundError } = require('../../utils/responses');
 
 const SamplesService = require('./samples');
+const ExperimentService = require('./experiment');
 
 const samplesService = new SamplesService();
-
+const experimentService = new ExperimentService();
 class ProjectsService {
   constructor() {
     this.tableName = `projects-${config.clusterEnv}`;
@@ -28,13 +29,13 @@ class ProjectsService {
 
     const dynamodb = createDynamoDbInstance();
     const response = await dynamodb.getItem(params).promise();
-
     if (response.Item) {
       const prettyResponse = convertToJsObject(response.Item);
       return prettyResponse.projects;
     }
 
-    throw new NotFoundError('Project not found');
+    logger.log('Project not found');
+    return response;
   }
 
   async updateProject(projectUuid, project) {
@@ -65,6 +66,80 @@ class ProjectsService {
     }
   }
 
+  /**
+   * Finds all projects referenced in experiments.
+   */
+  async getProjects() {
+    // Get project data from the experiments table. Only return
+    // those tables that have a project ID associated with them.
+    const params = {
+      TableName: experimentService.experimentsTableName,
+      ExpressionAttributeNames: {
+        '#pid': 'projectId',
+      },
+      FilterExpression: 'attribute_exists(projectId)',
+      ProjectionExpression: '#pid',
+    };
+
+    const dynamodb = createDynamoDbInstance();
+    const response = await dynamodb.scan(params).promise();
+
+    if (!response.Items) {
+      throw new NotFoundError('No projects available!');
+    }
+
+    const projectIds = response.Items.map((entry) => convertToJsObject(entry).projectId);
+    return this.getProjectsFromIds(new Set(projectIds));
+  }
+
+  /**
+   * Returns information about a group of projects.
+   *
+   * @param {Set} projectIds A Set of projectId values that are to be queried.
+   * @returns An object containing descriptions of projects.
+   */
+  async getProjectsFromIds(projectIds) {
+    const dynamodb = createDynamoDbInstance();
+    const params = {
+      RequestItems: {
+        [this.tableName]: {
+          Keys: [...projectIds].map((projectUuid) => convertToDynamoDbRecord({ projectUuid })),
+        },
+      },
+    };
+
+    const data = await dynamodb.batchGetItem(params).promise();
+    const existingProjectIds = new Set(data.Responses[this.tableName].map((entry) => {
+      const newData = convertToJsObject(entry);
+      return newData.projects.uuid;
+    }));
+
+    // Build up projects that do not exist in Dynamo yet.
+    const projects = [...projectIds]
+      .filter((entry) => (
+        !existingProjectIds.has(entry)
+      ))
+      .map((emptyProject) => {
+        const newProject = {};
+
+        const id = emptyProject;
+        newProject.name = id;
+        newProject.uuid = id;
+        newProject.samples = [];
+        newProject.metadataKeys = [];
+        newProject.experiments = [id];
+
+        return newProject;
+      });
+
+    data.Responses[this.tableName].forEach((entry) => {
+      const newData = convertToJsObject(entry);
+      projects.push(newData.projects);
+    });
+
+    return projects;
+  }
+
   async deleteProject(projectUuid) {
     logger.log(`Deleting project with id ${projectUuid}`);
     const marshalledKey = convertToDynamoDbRecord({

src/api/route-services/samples.js

@@ -27,15 +27,17 @@ class SamplesService {
     const dynamodb = createDynamoDbInstance();
 
     const response = await dynamodb.query(params).promise();
+    const items = response.Items;
 
-    if (response.Items) {
+    if (items) {
       const prettyResponse = response.Items.map((item) => convertToJsObject(item));
       return prettyResponse;
     }
 
-    throw new NotFoundError('Samples not found');
+    throw new NotFoundError('Samples not found!');
   }
 
+
   async getSamplesByExperimentId(experimentId) {
     logger.log(`Gettings samples using experimentId : ${experimentId}`);
     const marshalledKey = convertToDynamoDbRecord({

src/api/routes/projects.js

@@ -13,4 +13,9 @@ module.exports = {
       .then((data) => res.json(data))
       .catch(next);
   },
+
+  'projects#get': (req, res, next) => {
+    projectsService.getProjects().then((response) => res.json(response)).catch(next);
+  },
+
 };

src/specs/api.yaml

@@ -589,4 +589,20 @@ paths:
                   experimentId:
                     type: string
                   samples:
-                    $ref: ./models/api-body-schemas/Samples.v1.yaml
+                    $ref: ./models/api-body-schemas/Samples.v1.yaml
+  '/projects':
+    get:
+      summary: ''
+      operationId: getProjects
+      x-eov-operation-id: projects#get
+      x-eov-operation-handler: routes/projects
+      responses:
+        '200':
+          description: OK
+          content:
+            application/json:
+              schema:
+                type: array
+                items:
+                  $ref: ./models/api-body-schemas/Project.v1.yaml
+      description: Get the projects