mirror of
https://github.com/DeviceFarmer/stf.git
synced 2026-04-25 18:25:15 +02:00
72 lines
1.8 KiB
JavaScript
72 lines
1.8 KiB
JavaScript
define(['./_module', 'lodash'], function(app, _) {
|
|
function GroupServiceFactory($rootScope, $http, socket, userService) {
|
|
var groupService = {
|
|
}
|
|
|
|
groupService.group = (function() {
|
|
var groupPromise = $http.get('/api/v1/group')
|
|
.then(function(response) {
|
|
return response.data.group
|
|
})
|
|
return function() {
|
|
return groupPromise
|
|
}
|
|
})()
|
|
|
|
userService.user().then(function(user) {
|
|
function ownerFilter(listener) {
|
|
return function(data) {
|
|
if (data.owner.email === user.email) {
|
|
listener()
|
|
}
|
|
}
|
|
}
|
|
|
|
socket.on('group.join', ownerFilter(function(data) {
|
|
groupService.group().then(function(group) {
|
|
group.members.push(data.serial)
|
|
console.log('group.join', data)
|
|
$rootScope.$digest()
|
|
})
|
|
}))
|
|
|
|
socket.on('group.leave', ownerFilter(function(data) {
|
|
groupService.group().then(function(group) {
|
|
_.pull(group.members, data.serial)
|
|
console.log('group.leave', data)
|
|
$rootScope.$digest()
|
|
})
|
|
}))
|
|
|
|
socket.on('device.absent', /* unfiltered */ function(data) {
|
|
groupService.group().then(function(group) {
|
|
_.pull(group.members, data.serial)
|
|
$rootScope.$digest()
|
|
})
|
|
})
|
|
})
|
|
|
|
groupService.invite = function(requirements) {
|
|
userService.user().then(function(user) {
|
|
socket.emit('group.invite', requirements)
|
|
})
|
|
}
|
|
|
|
groupService.kick = function(requirements) {
|
|
userService.user().then(function(user) {
|
|
socket.emit('group.kick', requirements)
|
|
})
|
|
}
|
|
|
|
return groupService
|
|
}
|
|
|
|
app.factory('GroupService'
|
|
, [ '$rootScope'
|
|
, '$http'
|
|
, 'SocketService'
|
|
, 'UserService'
|
|
, GroupServiceFactory
|
|
])
|
|
})
|