adding websockets

Author: diegogit03

.gitignore

@@ -1,6 +1,8 @@
 node_modules
 package-lock.json
 
+public/uploads
+
 tmp
 
 .env

app/Controllers/Http/Auth/AuthController.js

@@ -1,9 +1,12 @@
 'use strict'
 
 const Database = use('Database')
+
 const User = use('App/Models/User')
 const Role = use('Role')
 
+const Ws = use('Ws')
+
 class AuthController {
 
   async register({ request, response }) {
@@ -25,6 +28,12 @@ class AuthController {
       await user.roles().attach([ userRole.id ], null, trx)
 
       await trx.commit()
+
+      const topic = await Ws.getChannel('notifications').topic('notifications')
+      if (topic) {
+        topic.broadcast('new:user')
+      }
+
       return response.status(201).send({ data: user })
 
     } catch(error) {
@@ -64,7 +73,7 @@ class AuthController {
       refresh_token = request.header('refresh_token')
     }
 
-    const loggedOut = await auth
+    await auth
       .authenticator('jwt')
       .revokeTokens([refresh_token], true)
 

app/Controllers/Ws/NotificationController.js

@@ -0,0 +1,18 @@
+'use strict'
+
+class NotificationController {
+  constructor ({ socket, request }) {
+    this.socket = socket
+    this.request = request
+  }
+
+  onMessage (message) {
+    this.socket.broadcast('message', message)
+  }
+
+  onClose () {
+    this.socket.broadcastToAll('drop:connection')
+  }
+}
+
+module.exports = NotificationController

app/Helpers/index.js

@@ -37,7 +37,7 @@ const manage_single_upload = async (file, path = null) => {
   path = path ? path : Helpers.publicPath('uploads')
   // gera um nome aleatorio
   const random_name = await str_random(30)
-  let filename = `${new Date().getTime()}-${randomName}.${file.subtype}`
+  let filename = `${new Date().getTime()}-${random_name}.${file.subtype}`
 
   // renomeia o arquivo e move ele para o path
   await file.move(path, {
@@ -55,7 +55,7 @@ const manage_single_upload = async (file, path = null) => {
  * @return { Object }
  */
 const manage_multiple_uploads = async (fileJar, path = null) => {
-  const path = path ? path : Helpers.publicPath('uploads')
+  path = path ? path : Helpers.publicPath('uploads')
   let success = [],
     errors = []
 

app/Models/Hooks/OrderHook.js

@@ -3,9 +3,9 @@
 const OrderHook = exports = module.exports = {}
 
 OrderHook.updateValues = async (model) => {
-    model.SsideLoaded.subtotal = await model.items().getSum('subtotal')
-    model.SsideLoaded.qty_items = await model.items().getSum('quantity')
-    model.SsideLoaded.discount = await model.discounts().getSum('discount')
+    model.$sideLoaded.subtotal = await model.items().getSum('subtotal')
+    model.$sideLoaded.qty_items = await model.items().getSum('quantity')
+    model.$sideLoaded.discount = await model.discounts().getSum('discount')
     model.total = model.$sideLoaded.subtotal - model.$sideLoaded.discount
 }
 

app/Models/Image.js

@@ -12,7 +12,7 @@ class Image extends Model {
 
     getUrl({ path }){
 
-      return `${Env.get('APP_URL')}/images/${path}`
+      return `${Env.get('APP_URL')}/uploads/${path}`
 
     }
 

app/Validators/Admin/StoreCategory.js

@@ -4,7 +4,7 @@ class StoreCategory {
   get rules () {
     return {
       title: 'required',
-      description: 'description'
+      description: 'required'
     }
   }
 }

config/cors.js

@@ -16,7 +16,7 @@ module.exports = {
   | Function - Receives the current origin and should return one of the above values.
   |
   */
-  origin: false,
+  origin: true,
 
   /*
   |--------------------------------------------------------------------------

database/migrations/1597874686212_coupon_schema.js

@@ -12,6 +12,7 @@ class CouponSchema extends Schema {
       table.dateTime('valid_until')
       table.integer('quantity').defaultTo(1)
       table.enu('can_use_for', ['product', 'client', 'product_client', 'all'])
+      table.decimal('discount', 12, 2).defaultTo(0.0)
 
       table.enu('type', ['free', 'percent', 'currency']).defaultTo('currency')
       table.boolean('recursive').defaultTo(false)

server.js

@@ -21,5 +21,6 @@ const { Ignitor } = require('@adonisjs/ignitor')
 
 new Ignitor(require('@adonisjs/fold'))
   .appRoot(__dirname)
+  .wsServer()
   .fireHttpServer()
   .catch(console.error)