diff options
Diffstat (limited to 'src')
| -rw-r--r-- | src/app.js | 7 | ||||
| -rw-r--r-- | src/authentication.js | 27 | ||||
| -rw-r--r-- | src/models/posts.model.js | 28 | ||||
| -rw-r--r-- | src/models/users.model.js | 36 | ||||
| -rw-r--r-- | src/sequelize.js | 70 | ||||
| -rw-r--r-- | src/services/index.js | 4 | ||||
| -rw-r--r-- | src/services/posts/posts.hooks.js | 33 | ||||
| -rw-r--r-- | src/services/posts/posts.service.js | 22 | ||||
| -rw-r--r-- | src/services/users/users.hooks.js | 41 | ||||
| -rw-r--r-- | src/services/users/users.service.js | 22 |
10 files changed, 290 insertions, 0 deletions
@@ -16,6 +16,10 @@ const services = require('./services'); const appHooks = require('./app.hooks'); const channels = require('./channels'); +const sequelize = require('./sequelize'); + +const authentication = require('./authentication'); + const app = express(feathers()); // Load app configuration @@ -34,8 +38,11 @@ app.use('/', express.static(app.get('public'))); app.configure(express.rest()); app.configure(socketio()); +app.configure(sequelize); + // Configure other middleware (see `middleware/index.js`) app.configure(middleware); +app.configure(authentication); // Set up our services (see `services/index.js`) app.configure(services); // Set up event channels (see channels.js) diff --git a/src/authentication.js b/src/authentication.js new file mode 100644 index 0000000..3312a46 --- /dev/null +++ b/src/authentication.js @@ -0,0 +1,27 @@ +const authentication = require('@feathersjs/authentication'); +const jwt = require('@feathersjs/authentication-jwt'); +const local = require('@feathersjs/authentication-local'); + + +module.exports = function (app) { + const config = app.get('authentication'); + + // Set up authentication with the secret + app.configure(authentication(config)); + app.configure(jwt()); + app.configure(local()); + + // The `authentication` service is used to create a JWT. + // The before `create` hook registers strategies that can be used + // to create a new valid JWT (e.g. local or oauth2) + app.service('authentication').hooks({ + before: { + create: [ + authentication.hooks.authenticate(config.strategies) + ], + remove: [ + authentication.hooks.authenticate('jwt') + ] + } + }); +}; diff --git a/src/models/posts.model.js b/src/models/posts.model.js new file mode 100644 index 0000000..e46117c --- /dev/null +++ b/src/models/posts.model.js @@ -0,0 +1,28 @@ +// See http://docs.sequelizejs.com/en/latest/docs/models-definition/ +// for more of what you can do here. +const Sequelize = require('sequelize'); +const DataTypes = Sequelize.DataTypes; + +module.exports = function (app) { + const sequelizeClient = app.get('sequelizeClient'); + const posts = sequelizeClient.define('posts', { + text: { + type: DataTypes.STRING, + allowNull: false + } + }, { + hooks: { + beforeCount(options) { + options.raw = true; + } + } + }); + + // eslint-disable-next-line no-unused-vars + posts.associate = function (models) { + // Define associations here + // See http://docs.sequelizejs.com/en/latest/docs/associations/ + }; + + return posts; +}; diff --git a/src/models/users.model.js b/src/models/users.model.js new file mode 100644 index 0000000..407e712 --- /dev/null +++ b/src/models/users.model.js @@ -0,0 +1,36 @@ +// See http://docs.sequelizejs.com/en/latest/docs/models-definition/ +// for more of what you can do here. +const Sequelize = require('sequelize'); +const DataTypes = Sequelize.DataTypes; + +module.exports = function (app) { + const sequelizeClient = app.get('sequelizeClient'); + const users = sequelizeClient.define('users', { + + email: { + type: DataTypes.STRING(126), + allowNull: false, + unique: true + }, + password: { + type: DataTypes.STRING(126), + allowNull: false + }, + + + }, { + hooks: { + beforeCount(options) { + options.raw = true; + } + } + }); + + // eslint-disable-next-line no-unused-vars + users.associate = function (models) { + // Define associations here + // See http://docs.sequelizejs.com/en/latest/docs/associations/ + }; + + return users; +}; diff --git a/src/sequelize.js b/src/sequelize.js new file mode 100644 index 0000000..5afa78a --- /dev/null +++ b/src/sequelize.js @@ -0,0 +1,70 @@ +const Sequelize = require('sequelize'); +const { Op } = Sequelize; +const operatorsAliases = { + $eq: Op.eq, + $ne: Op.ne, + $gte: Op.gte, + $gt: Op.gt, + $lte: Op.lte, + $lt: Op.lt, + $not: Op.not, + $in: Op.in, + $notIn: Op.notIn, + $is: Op.is, + $like: Op.like, + $notLike: Op.notLike, + $iLike: Op.iLike, + $notILike: Op.notILike, + $regexp: Op.regexp, + $notRegexp: Op.notRegexp, + $iRegexp: Op.iRegexp, + $notIRegexp: Op.notIRegexp, + $between: Op.between, + $notBetween: Op.notBetween, + $overlap: Op.overlap, + $contains: Op.contains, + $contained: Op.contained, + $adjacent: Op.adjacent, + $strictLeft: Op.strictLeft, + $strictRight: Op.strictRight, + $noExtendRight: Op.noExtendRight, + $noExtendLeft: Op.noExtendLeft, + $and: Op.and, + $or: Op.or, + $any: Op.any, + $all: Op.all, + $values: Op.values, + $col: Op.col +}; + +module.exports = function (app) { + const connectionString = app.get('mysql'); + const sequelize = new Sequelize(connectionString, { + dialect: 'mysql', + logging: false, + operatorsAliases, + define: { + freezeTableName: true + } + }); + const oldSetup = app.setup; + + app.set('sequelizeClient', sequelize); + + app.setup = function (...args) { + const result = oldSetup.apply(this, args); + + // Set up data relationships + const models = sequelize.models; + Object.keys(models).forEach(name => { + if ('associate' in models[name]) { + models[name].associate(models); + } + }); + + // Sync to the database + sequelize.sync(); + + return result; + }; +}; diff --git a/src/services/index.js b/src/services/index.js index 791edad..ccbb889 100644 --- a/src/services/index.js +++ b/src/services/index.js @@ -1,3 +1,7 @@ +const posts = require('./posts/posts.service.js'); +const users = require('./users/users.service.js'); // eslint-disable-next-line no-unused-vars module.exports = function (app) { + app.configure(posts); + app.configure(users); }; diff --git a/src/services/posts/posts.hooks.js b/src/services/posts/posts.hooks.js new file mode 100644 index 0000000..39ac996 --- /dev/null +++ b/src/services/posts/posts.hooks.js @@ -0,0 +1,33 @@ +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: [] + } +}; diff --git a/src/services/posts/posts.service.js b/src/services/posts/posts.service.js new file mode 100644 index 0000000..cacde6e --- /dev/null +++ b/src/services/posts/posts.service.js @@ -0,0 +1,22 @@ +// Initializes the `posts` service on path `/posts` +const createService = require('feathers-sequelize'); +const createModel = require('../../models/posts.model'); +const hooks = require('./posts.hooks'); + +module.exports = function (app) { + const Model = createModel(app); + const paginate = app.get('paginate'); + + const options = { + Model, + paginate + }; + + // Initialize our service with any options it requires + app.use('/posts', createService(options)); + + // Get our initialized service so that we can register hooks + const service = app.service('posts'); + + service.hooks(hooks); +}; diff --git a/src/services/users/users.hooks.js b/src/services/users/users.hooks.js new file mode 100644 index 0000000..613676b --- /dev/null +++ b/src/services/users/users.hooks.js @@ -0,0 +1,41 @@ +const { authenticate } = require('@feathersjs/authentication').hooks; + +const { + hashPassword, protect +} = require('@feathersjs/authentication-local').hooks; + +module.exports = { + before: { + all: [], + find: [ authenticate('jwt') ], + get: [ authenticate('jwt') ], + create: [ hashPassword() ], + update: [ hashPassword(), authenticate('jwt') ], + patch: [ hashPassword(), authenticate('jwt') ], + remove: [ authenticate('jwt') ] + }, + + after: { + all: [ + // Make sure the password field is never sent to the client + // Always must be the last hook + protect('password') + ], + find: [], + get: [], + create: [], + update: [], + patch: [], + remove: [] + }, + + error: { + all: [], + find: [], + get: [], + create: [], + update: [], + patch: [], + remove: [] + } +}; diff --git a/src/services/users/users.service.js b/src/services/users/users.service.js new file mode 100644 index 0000000..3cb0535 --- /dev/null +++ b/src/services/users/users.service.js @@ -0,0 +1,22 @@ +// Initializes the `users` service on path `/users` +const createService = require('feathers-sequelize'); +const createModel = require('../../models/users.model'); +const hooks = require('./users.hooks'); + +module.exports = function (app) { + const Model = createModel(app); + const paginate = app.get('paginate'); + + const options = { + Model, + paginate + }; + + // Initialize our service with any options it requires + app.use('/users', createService(options)); + + // Get our initialized service so that we can register hooks + const service = app.service('users'); + + service.hooks(hooks); +}; |