|
@@ -2,6 +2,7 @@ import defRegistry from './flow/default-registry'
|
|
|
import flowMut from './flow/mutation-types'
|
|
|
import chatMut from './chat/mutation-types'
|
|
|
import flowService from '@/services/flowservice'
|
|
|
+import utils from '@/utils/utils'
|
|
|
|
|
|
let flow = {}
|
|
|
let chat = {}
|
|
@@ -55,11 +56,11 @@ export default store => {
|
|
|
flowService.sessionLoad(undefined, sessId)
|
|
|
})
|
|
|
})
|
|
|
-
|
|
|
flowService.on('document', (v) => {
|
|
|
store.commit(flow.DOCUMENT_UPDATE, v.data)
|
|
|
})
|
|
|
flowService.on('nodeUpdate', (v) => {
|
|
|
+ utils.activity()
|
|
|
store.commit(flow.NODE_UPDATE, v.data)
|
|
|
})
|
|
|
|
|
@@ -80,13 +81,15 @@ export default store => {
|
|
|
store.commit(flow.REGISTRY_UPDATE, Object.assign({}, defRegistry, res))
|
|
|
})
|
|
|
flowService.on('nodeActivity', (v) => {
|
|
|
+ utils.activity()
|
|
|
store.commit(flow.ACTIVITY_UPDATE, v.data || {nodes: {}})
|
|
|
})
|
|
|
flowService.on('sessionNotify', (v) => {
|
|
|
- // ACTION
|
|
|
- store.dispatch(flow.NOTIFICATION_ADD, v.data)
|
|
|
+ utils.activity()
|
|
|
+ store.commit(flow.NOTIFICATION_ADD, v.data)
|
|
|
})
|
|
|
flowService.on('sessionJoin', (v) => {
|
|
|
+ utils.activity()
|
|
|
// store.dispatch(flow.NOTIFICATION_ADD, 'Connected')
|
|
|
const sessId = v.id
|
|
|
store.dispatch(chat.CHAT_JOIN, {
|
|
@@ -99,9 +102,11 @@ export default store => {
|
|
|
|
|
|
/// // CHAT //////
|
|
|
flowService.on('chatUserList', (v) => {
|
|
|
+ utils.activity()
|
|
|
store.commit(chat.USERLIST_UPDATE, v.data)
|
|
|
})
|
|
|
flowService.on('chatEvent', (v) => {
|
|
|
+ utils.activity()
|
|
|
store.commit(chat.EVENT_ADD, v.data)
|
|
|
})
|
|
|
}
|