8 files changed, 206 insertions, 0 deletions
diff --git a/src/app.hooks.js b/src/app.hooks.js
new file mode 100644
index 0000000..20ce4bf
--- /dev/null
+++ b/src/app.hooks.js
@@ -0,0 +1,34 @@
+// Application hooks that run for every service
+const log = require('./hooks/log');
+
+module.exports = {
+  before: {
+    all: [ log() ],
+    find: [],
+    get: [],
+    create: [],
+    update: [],
+    patch: [],
+    remove: []
+  },
+
+  after: {
+    all: [ log() ],
+    find: [],
+    get: [],
+    create: [],
+    update: [],
+    patch: [],
+    remove: []
+  },
+
+  error: {
+    all: [ log() ],
+    find: [],
+    get: [],
+    create: [],
+    update: [],
+    patch: [],
+    remove: []
+  }
+};
diff --git a/src/app.js b/src/app.js
new file mode 100644
index 0000000..2a8636f
--- /dev/null
+++ b/src/app.js
@@ -0,0 +1,50 @@
+const path = require('path');
+const favicon = require('serve-favicon');
+const compress = require('compression');
+const helmet = require('helmet');
+const cors = require('cors');
+const logger = require('./logger');
+
+const feathers = require('@feathersjs/feathers');
+const configuration = require('@feathersjs/configuration');
+const express = require('@feathersjs/express');
+const socketio = require('@feathersjs/socketio');
+
+
+const middleware = require('./middleware');
+const services = require('./services');
+const appHooks = require('./app.hooks');
+const channels = require('./channels');
+
+const app = express(feathers());
+
+// Load app configuration
+app.configure(configuration());
+// Enable security, CORS, compression, favicon and body parsing
+app.use(helmet());
+app.use(cors());
+app.use(compress());
+app.use(express.json());
+app.use(express.urlencoded({ extended: true }));
+app.use(favicon(path.join(app.get('public'), 'favicon.ico')));
+// Host the public folder
+app.use('/', express.static(app.get('public')));
+
+// Set up Plugins and providers
+app.configure(express.rest());
+app.configure(socketio());
+
+// Configure other middleware (see `middleware/index.js`)
+app.configure(middleware);
+// Set up our services (see `services/index.js`)
+app.configure(services);
+// Set up event channels (see channels.js)
+app.configure(channels);
+
+// Configure a middleware for 404s and the error handler
+app.use(express.notFound());
+app.use(express.errorHandler({ logger }));
+
+app.hooks(appHooks);
+
+module.exports = app;
diff --git a/src/channels.js b/src/channels.js
new file mode 100644
index 0000000..fb88a0f
--- /dev/null
+++ b/src/channels.js
@@ -0,0 +1,61 @@
+module.exports = function(app) {
+  if(typeof app.channel !== 'function') {
+    // If no real-time functionality has been configured just return
+    return;
+  }
+
+  app.on('connection', connection => {
+    // On a new real-time connection, add it to the anonymous channel
+    app.channel('anonymous').join(connection);
+  });
+
+  app.on('login', (authResult, { connection }) => {
+    // connection can be undefined if there is no
+    // real-time connection, e.g. when logging in via REST
+    if(connection) {
+      // Obtain the logged in user from the connection
+      // const user = connection.user;
+      
+      // The connection is no longer anonymous, remove it
+      app.channel('anonymous').leave(connection);
+
+      // Add it to the authenticated user channel
+      app.channel('authenticated').join(connection);
+
+      // Channels can be named anything and joined on any condition 
+      
+      // E.g. to send real-time events only to admins use
+      // if(user.isAdmin) { app.channel('admins').join(connection); }
+
+      // If the user has joined e.g. chat rooms
+      // if(Array.isArray(user.rooms)) user.rooms.forEach(room => app.channel(`rooms/${room.id}`).join(channel));
+      
+      // Easily organize users by email and userid for things like messaging
+      // app.channel(`emails/${user.email}`).join(channel);
+      // app.channel(`userIds/$(user.id}`).join(channel);
+    }
+  });
+
+  // eslint-disable-next-line no-unused-vars
+  app.publish((data, hook) => {
+    // Here you can add event publishers to channels set up in `channels.js`
+    // To publish only for a specific event use `app.publish(eventname, () => {})`
+
+    console.log('Publishing all events to all authenticated users. See `channels.js` and https://docs.feathersjs.com/api/channels.html for more information.'); // eslint-disable-line
+
+    // e.g. to publish all service events to all authenticated users use
+    return app.channel('authenticated');
+  });
+
+  // Here you can also add service specific event publishers
+  // e.g. the publish the `users` service `created` event to the `admins` channel
+  // app.service('users').publish('created', () => app.channel('admins'));
+  
+  // With the userid and email organization from above you can easily select involved users
+  // app.service('messages').publish(() => {
+  //   return [
+  //     app.channel(`userIds/${data.createdBy}`),
+  //     app.channel(`emails/${data.recipientEmail}`)
+  //   ];
+  // });
+};
diff --git a/src/hooks/log.js b/src/hooks/log.js
new file mode 100644
index 0000000..37e9403
--- /dev/null
+++ b/src/hooks/log.js
@@ -0,0 +1,24 @@
+// A hook that logs service method before, after and error
+// See https://github.com/winstonjs/winston for documentation
+// about the logger.
+const logger = require('../logger');
+const util = require('util');
+
+// To see more detailed messages, uncomment the following line:
+// logger.level = 'debug';
+
+module.exports = function () {
+  return context => {
+    // This debugs the service call and a stringified version of the hook context
+    // You can customize the message (and logger) to your needs
+    logger.debug(`${context.type} app.service('${context.path}').${context.method}()`);
+    
+    if(typeof context.toJSON === 'function' && logger.level === 'debug') {
+      logger.debug('Hook Context', util.inspect(context, {colors: false}));
+    }
+    
+    if(context.error && !context.result) {
+      logger.error(context.error.stack);
+    }
+  };
+};
diff --git a/src/index.js b/src/index.js
new file mode 100644
index 0000000..d68605b
--- /dev/null
+++ b/src/index.js
@@ -0,0 +1,13 @@
+/* eslint-disable no-console */
+const logger = require('./logger');
+const app = require('./app');
+const port = app.get('port');
+const server = app.listen(port);
+
+process.on('unhandledRejection', (reason, p) =>
+  logger.error('Unhandled Rejection at: Promise ', p, reason)
+);
+
+server.on('listening', () =>
+  logger.info('Feathers application started on http://%s:%d', app.get('host'), port)
+);
diff --git a/src/logger.js b/src/logger.js
new file mode 100644
index 0000000..b9aba0d
--- /dev/null
+++ b/src/logger.js
@@ -0,0 +1,16 @@
+const { createLogger, format, transports } = require('winston');
+
+// Configure the Winston logger. For the complete documentation see https://github.com/winstonjs/winston
+const logger = createLogger({
+  // To see more detailed errors, change this to 'debug'
+  level: 'info',
+  format: format.combine(
+    format.splat(),
+    format.simple()
+  ),
+  transports: [
+    new transports.Console()
+  ],
+});
+
+module.exports = logger;
diff --git a/src/middleware/index.js b/src/middleware/index.js
new file mode 100644
index 0000000..49ad533
--- /dev/null
+++ b/src/middleware/index.js
@@ -0,0 +1,5 @@
+// eslint-disable-next-line no-unused-vars
+module.exports = function (app) {
+  // Add your custom middleware here. Remember that
+  // in Express, the order matters.
+};
diff --git a/src/services/index.js b/src/services/index.js
new file mode 100644
index 0000000..791edad
--- /dev/null
+++ b/src/services/index.js
@@ -0,0 +1,3 @@
+// eslint-disable-next-line no-unused-vars
+module.exports = function (app) {
+};