Open
Description
@jondubois Hey man, if I do this would it cause any issues? I've tested it locally and it works fine. Basically, I'm trying to wrap promises around emit and publish for the client.
Thanks!
import * as SC from 'socketcluster-client'
import * as Emitter from 'component-emitter'
export function install (_Vue,options) {
function vue2SocketclusterInit() {
var opts = this.$options
if (opts.socket) {
this.$socket = opts.socket
} else if (opts.parent && opts.parent.$socket) {
this.$socket = opts.parent.$socket
} else {
let soc = SC.connect(options)
soc.emit = function(event,data,callback) {
return new Promise((resolve,reject) => {
if (soc._localEvents[event] == null) {
return soc._emit(event,data,(err,res) => {
callback && callback(err,res)
if (err) return reject(err)
return resolve(res)
})
}
Emitter.prototype.emit.call(soc, event, data)
})
}
soc.publish = function(channelName,data,callback) {
return new Promise((resolve,reject) => {
let pubData = {
channel:soc._decorateChannelName(channelName),
data
}
soc._emit('#publish',pubData,(err,res) => {
callback && callback(err,res)
if (err) return reject(err)
return resolve(res)
})
})
}
this.$socket = soc
}
}
var usesInit = _Vue.config._lifecycleHooks.indexOf('init') > -1
_Vue.mixin(usesInit ? { init: vue2SocketclusterInit } : { beforeCreate: vue2SocketclusterInit })
}