Socketcluster implementation for VueJS
Added a new channel set so you can subscribe to channels as well. The following are some examples
sockets:{
connect(status) {
var vm = this
vm.authenticated = status.isAuthenticated
},
authenticate() {
this.authenticated = true
this.setUserData()
},
deauthenticate() {
this.authenticated = false
}
},
subscriptions:{
'crud>create':function(data) {
console.log(data)
}
}MVC-Example ( See MVC-Example README.md for more details )
- Scripts
1) Added NPM scripts, minify, and so on
- Server-Side
1) Added an ORM class (Called Lynchpin) that can be extended with any model
2) Added lots of extended functions for the ORM
3) Completed the basic MVC example. It now has login, user creation, and basic SPA.npm install gulp [email protected] -gnpm i3) copy config.json.sample and database.json.sample to config.json and database.json respectivily (only in mvc-example)
node server.jsnpm start<doctype html>
<html>
<head>
<title></title>
</head>
<body id='app'>
<script src='vue-socketcluster.js'></script>
</body>
</html>Vue.use(VueSocketcluster)
var vue = new Vue({
el:'#app',
data() {
return {
}
},
sockets:{
connect() {
console.log('Connected to server!')
},
ping() {
this.$sc.emit('pong')
}
}
})var router = new VueRouter()
Vue.use(VueRouter)
Vue.use(VueSocketcluster)
router.map({
'/session/create': {
component:Vue.extend({
template: '<p>Session Create</p>'
}),auth:false
}
})
router.redirect({
'*':'/session/create'
})
router.beforeEach(function(transition) {
router.app.loading = true
if (transition.to.auth && !router.app.authenticated) {
router.app.loading = false
transition.redirect('/session/create')
} else if (router.app.authenticated && !transition.to.auth) {
router.app.loading = false
transition.redirect('/')
} else {
transition.next()
}
})
router.afterEach(function(transition) {
setTimeout(function() {
router.app.loading = false
},20)
})
router.start(Vue.extend({
data() {
return {
loading:true,
authenticated:false
}
},
sockets:{
connect() {
console.log('Connected to server!')
var watcher = this.$sc.subscribe('broadcast')
watcher.watch(function(data) {
console.log(data)
})
},
ping() {
this.$sc.emit('pong')
this.$sc.emit('ping-with-response',{message:'Hello server!'},function(err,response) {
console.log(response)
})
}
}
}), '#app')scServer.on('connection', function (socket) {
console.log(' >> Client',socket.id,'connected at',new Date())
console.log('ping sent to',socket.id)
socket.emit('ping')
socket.on('pong',function() {
console.log('pong received from',socket.id)
})
socket.on('ping-with-response',function(data,respond) {
console.log(data)
worker.exchange.publish('broadcast',{message:'Hello from broadcast!'})
respond(null,{message:'responding..'})
})
})Vue.use(VueSocketcluster,{
hostname: String - Defaults to the current host (ready from the URL).
secure: Boolean - Defaults to false
port: Number - Defaults to 80 if !secure otherwise defaults to 443.
path: String - The URL which SC uses to make the initial handshake for the WebSocket. Defaults to '/socketcluster/'.
query: Object - A map of key-value pairs which will be used as query parameters for the initial HTTP handshake which will initiate the WebSocket connection.
ackTimeout: Number (milliseconds) - This is the timeout for getting a response to a SCSocket emit event (when a callback is provided).
autoReconnect: Boolean - Whether or not to automatically reconnect the socket when it loses the connection.
autoReconnectOptions: Object - Valid properties are: initialDelay (milliseconds), randomness (milliseconds), multiplier (decimal; default is 1.5) and maxDelay (milliseconds).
multiplex: Boolean - Defaults to true; multiplexing allows you to reuse a socket instead of creating a second socket to the same address.
timestampRequests: Boolean - Whether or not to add a timestamp to the WebSocket handshake request.
timestampParam: String - The query parameter name to use to hold the timestamp.
authEngine: Object - A custom engine to use for storing and loading JWT auth tokens on the client side.
authTokenName: String - The name of the JWT auth token (provided to the authEngine - By default this is the localStorage variable name); defaults to 'socketCluster.authToken'.
binaryType: String - The type to use to represent binary on the client. Defaults to 'arraybuffer'.
rejectUnauthorized: Boolean - Set this to false during debugging - Otherwise client connection will fail when using self-signed certificates.
})Vue.use(VueSocketcluster,{
hostname: 'securedomain.com',
secure: true,
port: 443,
rejectUnauthorized: false // Only necessary during debug if using a self-signed certificate
})The sockets attributes are essentially channels. If you name an attribute test and then emit to test, the function associated with test will fire.
Vue.component('my-component',Vue.extend({
data() {
return {
}
},
ready() {
this.$root.$sc.emit('pong')
}
}
}))