javascript 使用deepstream客户端的websocket实现

Posted 2021-05-04

//
//  websocket implementation using deepstream client
//
const db = new Db('testdb')

const ds = deepstream( '<DEEPSTREAM SERVER URL>' )
ds.login()

const userRepository = UserRepositoryMongo(db)

ds.rpc.provide( 'update-user', async ( data, response ) => {
  const { userId, userName, userEmail } = data
  
  try {
    await updateUser({
      userRepository,
      updateParams: {
        userId,
        userName,
        userEmai
      }
    })
  } catch (ex) {
    switch (ex.name) {
      case 'InvalidParamsException':
        response.error(ex.message)
        return
      case 'UserNotFoundException':
        response.error('User not found')
        return
      default:
        response.error('Unknown error')
        return
    }
  }
  res.send('User updated')
})