added user invite service and uuid package

Author: appinteractive

package.json

@@ -100,6 +100,7 @@
     "shortid": "~2.2.8",
     "slug": "~0.9.1",
     "trunc-html": "^1.1.2",
+    "uuid": "^3.3.2",
     "valid-url": "^1.0.9",
     "winston": "~3.0.0-rc5"
   },

server/channels.js

@@ -47,6 +47,7 @@ module.exports = function (app) {
   // });
 
   app.service('contributions').publish('patched', () => app.channel('authenticated'));
+  app.service('settings').publish('patched', () => app.channel('anonymous', 'authenticated'));
 
   app.service('categories').publish(() => app.channel('anonymous', 'authenticated'));
   app.service('comments').publish(() => app.channel('authenticated'));

server/hooks/save-remote-images.js

@@ -8,9 +8,9 @@ const { isEmpty } = require('lodash');
 const fs = require('fs');
 const path = require('path');
 const request = require('request');
-const faker = require('faker');
 const mime = require('mime/lite');
 const validUrl = require('valid-url');
+const uuid = require('uuid/v1');
 
 function createUploadDirIfNeeded () {
   const uploadDir = path.resolve('public/uploads');
@@ -60,8 +60,7 @@ module.exports = function (options = []) { // eslint-disable-line no-unused-vars
           loading++;
           imgCount++;
           // TODO: fix that to use the data _id or somethink similar
-          let uuid = faker.fake('{{random.uuid}}');
-          const imgName = `${field}_${uuid}`;
+          const imgName = `${field}_${uuid()}`;
           let imgPath = path.resolve('public', 'uploads/' + imgName);
 
           if (typeof hook.data[field] === 'object') {

server/models/invites.model.js

@@ -1,5 +1,5 @@
 // invites-model.js - A mongoose model
-// 
+//
 // See http://mongoosejs.com/docs/models.html
 // for more of what you can do here.
 module.exports = function (app) {
@@ -12,6 +12,7 @@ module.exports = function (app) {
       enum: ['admin', 'moderator', 'manager', 'editor', 'user'],
       default: 'user'
     },
+    invitedByUserId: { type: String },
     language: { type: String },
     badgeIds: [],
     wasUsed: { type: Boolean },

server/services/index.js

@@ -22,6 +22,7 @@ const usersettings = require('./usersettings/usersettings.service.js');
 const pages = require('./pages/pages.service.js');
 const systemNotifications = require('./system-notifications/system-notifications.service.js');
 const settings = require('./settings/settings.service.js');
+const userInvites = require('./user-invites/user-invites.service.js');
 
 module.exports = function () {
   const app = this; // eslint-disable-line no-unused-vars
@@ -49,4 +50,5 @@ module.exports = function () {
   app.configure(pages);
   app.configure(systemNotifications);
   app.configure(settings);
+  app.configure(userInvites);
 };

server/services/settings/settings.hooks.js

@@ -1,4 +1,3 @@
-const { authenticate } = require('@feathersjs/authentication').hooks;
 const isAdmin = require('../../hooks/is-admin');
 const mapCreateToUpsert = require('../../hooks/map-create-to-upsert');
 

server/services/user-invites/user-invites.class.js

@@ -0,0 +1,84 @@
+/* eslint-disable no-unused-vars */
+const errors = require('@feathersjs/errors');
+const uuid = require('uuid/v1');
+const { genInviteCode } = require('../../helper/seed-helpers');
+
+class Service {
+  constructor (options) {
+    this.options = options || {};
+    if (!options.app) {
+      throw new Error('user-invites services missing option.app');
+    }
+    this.app = options.app;
+  }
+
+  async find (params) {
+    if (!params.user._id) {
+      throw new errors.Forbidden('no user id found');
+    }
+    const res = await this.app.service('invites').find(Object.assign(params.query || {}, {
+      query: {
+        $limit: 10,
+        invitedByUserId: params.user._id
+      }
+    }));
+    return res;
+  }
+
+  async get (id, params) {
+    throw new errors.NotImplemented();
+  }
+
+  async create (data, params) {
+    // 1. check user
+    if (!params.user._id) {
+      throw new errors.Forbidden('no used id found');
+    }
+    // 2. get system settings for max invite count
+    let settings = await this.app.service('settings').find({query: {key: 'system'}});
+    settings = settings.pop();
+    // do cancel of the settings prohibit it
+    if (!settings || !settings.invites || !settings.invites.userCanInvite || !settings.invites.maxInvitesByUser) {
+      throw new errors.Forbidden('system settings not valid');
+    }
+    // 3. get user invite count
+    const maxInvitesByUser = settings.invites.maxInvitesByUser;
+    // 4. check if the user has still free invites
+    const myInvites = await this.find(Object.assign(params, {query: { $limit: -1 }}));
+    let remainingInvites = maxInvitesByUser - myInvites.total;
+    if (remainingInvites <= 0) {
+      throw new errors.Forbidden('no invites left');
+    }
+    // 5. generate one remaining free invites
+    let output = [];
+    while (remainingInvites--) {
+      const res = await this.app.service('invites').create({
+        email: uuid(),
+        code: genInviteCode(),
+        invitedByUserId: params.user._id,
+        role: 'user'
+      });
+      output.push(res);
+    }
+
+    return output;
+  }
+
+  async update (id, data, params) {
+    throw new errors.NotImplemented();
+  }
+
+  async patch (id, data, params) {
+    throw new errors.NotImplemented();
+  }
+
+  async remove (id, params) {
+    throw new errors.NotImplemented();
+  }
+}
+
+module.exports = function (options) {
+  return new Service(options);
+};
+
+module.exports.Service = Service;

server/services/user-invites/user-invites.hooks.js

@@ -0,0 +1,35 @@
+const { authenticate } = require('@feathersjs/authentication').hooks;
+
+module.exports = {
+  before: {
+    all: [ authenticate('jwt') ],
+    find: [],
+    get: [],
+    create: [],
+    update: [],
+    patch: [],
+    remove: []
+  },
+
+  after: {
+    all: [
+
+    ],
+    find: [],
+    get: [],
+    create: [],
+    update: [],
+    patch: [],
+    remove: []
+  },
+
+  error: {
+    all: [],
+    find: [],
+    get: [],
+    create: [],
+    update: [],
+    patch: [],
+    remove: []
+  }
+};

server/services/user-invites/user-invites.service.js

@@ -0,0 +1,21 @@
+// Initializes the `user-invites` service on path `/user-invites`
+const createService = require('./user-invites.class.js');
+const hooks = require('./user-invites.hooks');
+
+module.exports = function (app) {
+
+  const paginate = app.get('paginate');
+
+  const options = {
+    paginate,
+    app
+  };
+
+  // Initialize our service with any options it requires
+  app.use('/user-invites', createService(options));
+
+  // Get our initialized service so that we can register hooks
+  const service = app.service('user-invites');
+
+  service.hooks(hooks);
+};

server/services/users/hooks/invite-code.js

@@ -5,18 +5,23 @@ module.exports = function (options = {}) { // eslint-disable-line no-unused-vars
   return {
     before: async function (hook) {
       // check the invite code for the given email / code combination
-      const query = {
+      let query = {
         query: {
           email: hook.data.email,
           code: hook.data.inviteCode
         }
       };
+      if (hook.data.invitedByUserId) {
+        // invite was created
+        delete query.query.email;
+        query.query.invitedByUserId = hook.data.invitedByUserId;
+      }
       const inviteRes = await hook.app.service('invites').find(query);
       // throw an error if the invite code does not match the one from the invite
       if (!inviteRes.data.length) {
         throw new errors.Forbidden('invite code is invalid');
       }
-      
+
       // set some user data from the invite like batches and roles
       hook.data.wasInvited = true;
       hook.data.inviteId = inviteRes.data[0]._id;