seepur/app/Middleware/WsCallAuth.js

'use strict'
/** @typedef {import('@adonisjs/framework/src/Request')} Request */
/** @typedef {import('@adonisjs/framework/src/Response')} Response */
/** @typedef {import('@adonisjs/framework/src/View')} View */

const Call = use('App/Models/Call');

class WsCallAuth {
  /**
   * @param {object} ctx
   * @param {Request} ctx.request
   * @param {Function} next
   */
  async wsHandle(ctx, next) {
    const {request, auth, socket} = ctx;
    const callId = Number(socket.topic.split(':')[1]);
    const user = auth.user;
    const call = await Call.find(callId);
    if (!call) {
      throw new Error('Call not found');
    }
    if (call.state === 'ENDED') throw new Error('This call has ended');
    if (user.id === call.user_1 || user.id === call.user_2) {
      ctx.call = call;
      await next()
    }
    // call next to advance the request
    else
      throw new Error('Not allowed');
  }
}

module.exports = WsCallAuth