Hope that the official support request response communication model

[dengzhaofun]

I realized the simple request reponse communication model by myself, and I hope that the official can support it, so that the development will be faster and easier.

client

import { nanoid } from '../plugin/nanoid'
import * as _ from '../plugin/lodash'

export abstract class BaseRoom {
  respFuncs = {}
  constructor(protected readonly room) {
    this.room.onMessage('*', (type, message) => {
      console.log("BaseRoom -> constructor -> message", type, message)
    })
    this.room.onMessage('response', (message) => {
      if (_.isObject(message) && _.isFunction(this.respFuncs[message.respId])) {
        this.respFuncs[message.respId](message)
        delete this.respFuncs[message.respId]
      }
    })
  }

  async request(type: string, message: any, delay: boolean = false, callback: (message) => void) {
    const respId = nanoid()
    this.room.send('request', {type, message, respId, delay})
    if (_.isFunction(callback)) {
      this.respFuncs[respId] = callback
    }
  }
}

server

  async onCreate(options: any) {
    this.onMessage('*', (client: Client, type: string | number, message: any) => {
      const func = this[`${type}_socket`]
      if (_.isFunction(func)) {
        func.call(this, client, message)
      }
    })
  }

  async request_socket(client: Client, wrapMessage: any) {
    const { type, message, respId, delay } = wrapMessage
    if (type && message) {
      const func = this[`${type}_socket`]
      if (_.isFunction(func)) {
        const data = await func.call(this, client, message)
        if (_.isString(respId)) {
          if (delay) {
            this.delaySend(client, 'response', data)
          } else {
            client.send('response', data)
          }
        }
      }
    }
  }

[github-actions]

This issue is stale because it has been open 30 days with no activity. Remove stale label or comment or this will be closed in 7 days.

[github-actions]

This issue was closed because it has been stalled for 7 days with no activity.