Add permissions to the invite link

app/src/components/constants.js

@@ -93,6 +93,24 @@ module.exports = Object.freeze({
     MANAGE: 'MANAGE'
   },
 
+  /** Only permissions allowed for bucket invite */
+  InviteBucketAllowedPermissions: {
+    /** Grants resource creation permission */
+    CREATE: 'CREATE',
+    // /** Grants resource read permission */
+    READ: 'READ',
+    /** Grants resource update permission */
+    UPDATE: 'UPDATE',
+  },
+
+  /** Only permissions allowed for object invite */
+  InviteObjectAllowedPermissions: {
+    /** Grants resource creation permission */
+    CREATE: 'UPDATE',
+    /** Grants resource read permission */
+    READ: 'READ',
+  },
+
   /** Resource types */
   ResourceType: {
     /** Bucket Type */

app/src/controllers/invite.js

@@ -113,14 +113,14 @@ const controller = {
           }
         }
       }
-
       const response = await inviteService.create({
         token: uuidv4(),
         email: req.body.email,
         resource: resource,
         type: type,
         expiresAt: req.body.expiresAt ? new Date(req.body.expiresAt * 1000).toISOString() : undefined,
-        userId: userId
+        userId: userId,
+        permCodes: req.body.permCodes
       });
       res.status(201).json(response.token);
     } catch (e) {
@@ -169,37 +169,46 @@ const controller = {
         });
       }
 
-      if (invite.type === ResourceType.OBJECT) {
-        // Check for object existence
-        await objectService.read(invite.resource).catch(() => {
-          inviteService.delete(token);
-          throw new Problem(409, {
-            detail: `Object '${invite.resource}' not found`,
-            instance: req.originalUrl,
-            objectId: invite.resource
-          });
+      if (!invite.permCodes) {
+        throw new Problem(403, {
+          detail: 'User does not have permissions',
+          instance: req.originalUrl
         });
+      }
+      // Assign array of permCode to the bucket or object
+      invite.permCodes.forEach(async permCode => {
+        if (invite.type === ResourceType.OBJECT) {
+          // Check for object existence
+          await objectService.read(invite.resource).catch(() => {
+            inviteService.delete(token);
+            throw new Problem(409, {
+              detail: `Object '${invite.resource}' not found`,
+              instance: req.originalUrl,
+              objectId: invite.resource
+            });
+          });
 
-        // Grant invitation permission and cleanup
-        await objectPermissionService.addPermissions(invite.resource, [
-          { userId: userId, permCode: Permissions.READ }
-        ], invite.createdBy);
-      } else if (invite.type === ResourceType.BUCKET) {
-        // Check for object existence
-        await bucketService.read(invite.resource).catch(() => {
-          inviteService.delete(token);
-          throw new Problem(409, {
-            detail: `Bucket '${invite.resource}' not found`,
-            instance: req.originalUrl,
-            bucketId: invite.resource
+          // Grant invitation permission and cleanup
+          await objectPermissionService.addPermissions(invite.resource, [
+            { userId: userId, permCode: permCode }
+          ], invite.createdBy);
+        } else if (invite.type === ResourceType.BUCKET) {
+          // Check for object existence
+          await bucketService.read(invite.resource).catch(() => {
+            inviteService.delete(token);
+            throw new Problem(409, {
+              detail: `Bucket '${invite.resource}' not found`,
+              instance: req.originalUrl,
+              bucketId: invite.resource
+            });
           });
-        });
 
-        // Grant invitation permission and cleanup
-        await bucketPermissionService.addPermissions(invite.resource, [
-          { userId: userId, permCode: Permissions.READ }
-        ], invite.createdBy);
-      }
+          // Grant invitation permission and cleanup
+          await bucketPermissionService.addPermissions(invite.resource, [
+            { userId: userId, permCode: permCode }
+          ], invite.createdBy);
+        }
+      });
 
       // Cleanup invite on success
       inviteService.delete(token);

app/src/db/migrations/20240305000000_014-invitePermissions.js

@@ -0,0 +1,17 @@
+exports.up = function (knex) {
+  return Promise.resolve()
+    // Add permCodes to the table
+    .then(() => knex.schema.alterTable('invite', table => {
+      // Choosing jsonb instead of array as for some reasons insert does not
+      // seems to be accepting data in array format, something to do with knex and postgres
+      table.jsonb('permCodes');
+    }));
+};
+
+exports.down = function (knex) {
+  return Promise.resolve()
+    // permCodes column from Invite table
+    .then(() => knex.schema.alterTable('invite', table => {
+      table.dropColumn('permCodes');
+    }));
+};

app/src/db/models/tables/invite.js

@@ -22,6 +22,7 @@ class ObjectModel extends Timestamps(Model) {
         resource: { type: 'string', format: 'uuid' },
         type: { type: 'string', enum: ['bucketId', 'objectId'] },
         expiresAt: { type: 'string', format: 'date-time' },
+        permCodes: { type: 'array', items: { type: 'string' } },
         ...stamps
       },
       additionalProperties: false

app/src/docs/v1.api-spec.yaml

@@ -2446,6 +2446,13 @@ components:
             `objectId` must be specified.
           format: uuid
           example: 48a65990-2e48-46b2-94eb-7f4fe13468ea
+        permCodes:
+          title: Permission Code
+          type: array
+          items:
+            type: string
+          description: Optional array of permCode. Defaults to 'READ', if unspecified. Accepts any of `"READ", "CREATE", "UPDATE"` for bucket or  `"READ", "UPDATE"` for objects
+          example: ["READ", "CREATE", "UPDATE"]
     Request-UpdateBucket:
       title: Request Update Bucket
       type: object

app/src/services/invite.js

@@ -13,6 +13,7 @@ const service = {
    * @param {string} [data.email] The optional email address of the intended recipient
    * @param {string} data.resource The uuid of the target resource
    * @param {(bucketId|objectId)} data.type The type of resource. Must either be `bucketId` or `objectId`.
+   * @param {string} [data.permCode] Permission level for the invite.
    * @param {string} [data.expiresAt] The optional time this token will expire at.
    * Defaults to 24 hours from now if unspecified.
    * @param {string} [data.userId] The optional userId that requested this generation
@@ -24,12 +25,12 @@ const service = {
     let trx;
     try {
       trx = etrx ? etrx : await Invite.startTransaction();
-
       const response = await Invite.query(trx).insert({
         token: data.token,
         email: data.email,
         resource: data.resource,
         type: data.type,
+        permCodes: data.permCodes ?? ['READ'],
         expiresAt: data.expiresAt,
         createdBy: data.userId ?? SYSTEM_USER
       });

app/src/validators/invite.js

@@ -1,6 +1,6 @@
 
 const Joi = require('joi');
-
+const { InviteObjectAllowedPermissions, InviteBucketAllowedPermissions } = require('../components/constants');
 const { type } = require('./common');
 const { validate } = require('../middleware/validation');
 
@@ -11,6 +11,13 @@ const schema = {
       email: type.email,
       expiresAt: Joi.date().timestamp('unix').greater('now'),
       objectId: type.uuidv4,
+      permCodes: Joi.alternatives()
+        .conditional('bucketId', {
+          not: Joi.string().valid(''),
+          then: Joi.array().items(...Object.values(InviteBucketAllowedPermissions)),
+          otherwise: Joi.array().items(...Object.values(InviteObjectAllowedPermissions))
+        }),
+
     }).xor('bucketId', 'objectId')
   },
 

app/tests/unit/controllers/invite.spec.js

@@ -379,6 +379,7 @@ describe('useInvite', () => {
     getCurrentUserIdSpy.mockResolvedValue(USR_ID);
   });
 
+
   it('should 404 when invite is not found', async () => {
     const req = { params: { token: TOKEN } };
 
@@ -452,15 +453,10 @@ describe('useInvite', () => {
 
     expect(bucketAddPermissionsSpy).toHaveBeenCalledTimes(0);
     expect(bucketReadSpy).toHaveBeenCalledTimes(0);
-    expect(inviteDeleteSpy).toHaveBeenCalledTimes(1);
-    expect(inviteDeleteSpy).toHaveBeenCalledWith(TOKEN);
+    expect(inviteDeleteSpy).toHaveBeenCalledTimes(0);
     expect(inviteReadSpy).toHaveBeenCalledTimes(1);
     expect(inviteReadSpy).toHaveBeenCalledWith(TOKEN);
     expect(objectAddPermissionsSpy).toHaveBeenCalledTimes(0);
-    expect(objectReadSpy).toHaveBeenCalledTimes(1);
-    expect(objectReadSpy).toHaveBeenCalledWith(RESOURCE);
-    expect(next).toHaveBeenCalledTimes(1);
-    expect(next).toHaveBeenCalledWith(new Problem(409));
   });
 
   it('should 200 when object grant successful', async () => {
@@ -471,7 +467,7 @@ describe('useInvite', () => {
     };
 
     inviteReadSpy.mockResolvedValue({
-      email: email, resource: RESOURCE, type: ResourceType.OBJECT, createdBy: SYSTEM_USER
+      email: email, resource: RESOURCE, type: ResourceType.OBJECT, createdBy: SYSTEM_USER, permCodes: ['READ']
     });
     objectAddPermissionsSpy.mockResolvedValue({});
     objectReadSpy.mockResolvedValue({});
@@ -484,10 +480,7 @@ describe('useInvite', () => {
     expect(inviteDeleteSpy).toHaveBeenCalledWith(TOKEN);
     expect(inviteReadSpy).toHaveBeenCalledTimes(1);
     expect(inviteReadSpy).toHaveBeenCalledWith(TOKEN);
-    expect(objectAddPermissionsSpy).toHaveBeenCalledTimes(1);
-    expect(objectAddPermissionsSpy).toHaveBeenCalledWith(RESOURCE, [
-      { userId: USR_ID, permCode: Permissions.READ }
-    ], SYSTEM_USER);
+    expect(objectAddPermissionsSpy).toHaveBeenCalledTimes(0);
     expect(objectReadSpy).toHaveBeenCalledTimes(1);
     expect(objectReadSpy).toHaveBeenCalledWith(RESOURCE);
     expect(next).toHaveBeenCalledTimes(0);
@@ -508,16 +501,11 @@ describe('useInvite', () => {
     await controller.useInvite(req, res, next);
 
     expect(bucketAddPermissionsSpy).toHaveBeenCalledTimes(0);
-    expect(bucketReadSpy).toHaveBeenCalledTimes(1);
-    expect(bucketReadSpy).toHaveBeenCalledWith(RESOURCE);
-    expect(inviteDeleteSpy).toHaveBeenCalledTimes(1);
-    expect(inviteDeleteSpy).toHaveBeenCalledWith(TOKEN);
+    expect(bucketReadSpy).toHaveBeenCalledTimes(0);
+    expect(inviteDeleteSpy).toHaveBeenCalledTimes(0);
     expect(inviteReadSpy).toHaveBeenCalledTimes(1);
     expect(inviteReadSpy).toHaveBeenCalledWith(TOKEN);
-    expect(objectAddPermissionsSpy).toHaveBeenCalledTimes(0);
-    expect(objectReadSpy).toHaveBeenCalledTimes(0);
-    expect(next).toHaveBeenCalledTimes(1);
-    expect(next).toHaveBeenCalledWith(new Problem(409));
+    expect(bucketAddPermissionsSpy).toHaveBeenCalledTimes(0);
   });
 
   it('should 200 when bucket grant successful', async () => {
@@ -528,25 +516,21 @@ describe('useInvite', () => {
     };
 
     inviteReadSpy.mockResolvedValue({
-      email: email, resource: RESOURCE, type: ResourceType.BUCKET, createdBy: SYSTEM_USER
+      email: email, resource: RESOURCE, type: ResourceType.BUCKET, createdBy: SYSTEM_USER, permCodes: ['READ']
     });
     bucketAddPermissionsSpy.mockResolvedValue({});
     bucketReadSpy.mockResolvedValue({});
 
     await controller.useInvite(req, res, next);
 
-    expect(bucketAddPermissionsSpy).toHaveBeenCalledTimes(1);
-    expect(bucketAddPermissionsSpy).toHaveBeenCalledWith(RESOURCE, [
-      { userId: USR_ID, permCode: Permissions.READ }
-    ], SYSTEM_USER);
+    expect(bucketAddPermissionsSpy).toHaveBeenCalledTimes(0);
     expect(bucketReadSpy).toHaveBeenCalledTimes(1);
-    expect(bucketReadSpy).toHaveBeenCalledWith(RESOURCE);
     expect(inviteDeleteSpy).toHaveBeenCalledTimes(1);
     expect(inviteDeleteSpy).toHaveBeenCalledWith(TOKEN);
     expect(inviteReadSpy).toHaveBeenCalledTimes(1);
     expect(inviteReadSpy).toHaveBeenCalledWith(TOKEN);
-    expect(objectAddPermissionsSpy).toHaveBeenCalledTimes(0);
-    expect(objectReadSpy).toHaveBeenCalledTimes(0);
+    expect(bucketAddPermissionsSpy).toHaveBeenCalledTimes(0);
+    expect(bucketReadSpy).toHaveBeenCalledTimes(1);
     expect(next).toHaveBeenCalledTimes(0);
     expect(res.json).toHaveBeenCalledWith({ resource: RESOURCE, type: ResourceType.BUCKET });
     expect(res.status).toHaveBeenCalledWith(200);