task locking
parent
cc3758c8d3
commit
6cb469fdb3
|
@ -23,32 +23,34 @@ const (
|
|||
|
||||
// commands sent to web clients
|
||||
const (
|
||||
SentCmdInitUserSocketConnection = 1
|
||||
SentCmdUpdateConnectedUsers = 2
|
||||
SentCmdNewGroupTaskStarted = 3
|
||||
SentCmdNewGroupTaskStep = 4
|
||||
SentCmdUpdateGroupTaskStep = 5
|
||||
SentCmdUpdateGroupTask = 6
|
||||
SentCmdReloadingGroupTasks = 7
|
||||
SentCmdGroupTasksReloaded = 8
|
||||
SentCmdUpdateUserSessions = 9
|
||||
SentCmdUpdateAllUsersUserAvatar = 10
|
||||
SentCmdNewScanner = 11
|
||||
SentCmdDeleteScanner = 12
|
||||
SentCmdUpdateScannerUsedBy = 13
|
||||
SentCmdScanResult = 14
|
||||
SentCmdUpdateScannerLastUsed = 15
|
||||
SentCmdTaskLocked = 16
|
||||
SentCmdTaskUnlocked = 17
|
||||
SentCmdInitUserSocketConnection = 1
|
||||
SentCmdUpdateConnectedUsers = 2
|
||||
SentCmdNewGroupTaskStarted = 3
|
||||
SentCmdNewGroupTaskStep = 4
|
||||
SentCmdUpdateGroupTaskStep = 5
|
||||
SentCmdUpdateGroupTask = 6
|
||||
SentCmdReloadingGroupTasks = 7
|
||||
SentCmdGroupTasksReloaded = 8
|
||||
SentCmdUpdateUserSessions = 9
|
||||
SentCmdUpdateAllUsersUserAvatar = 10
|
||||
SentCmdNewScanner = 11
|
||||
SentCmdDeleteScanner = 12
|
||||
SentCmdUpdateScannerUsedBy = 13
|
||||
SentCmdScanResult = 14
|
||||
SentCmdUpdateScannerLastUsed = 15
|
||||
SentCmdTaskLocked = 16
|
||||
SentCmdTaskUnlocked = 17
|
||||
SentCmdUpdateGroupTaskStepUserInputValue = 18
|
||||
)
|
||||
|
||||
// commands received from web clients
|
||||
const (
|
||||
ReceivedCmdStartGroupTasks = 1
|
||||
ReceivedCmdTaskFailedTryAgainRunTaskStep = 2
|
||||
ReceivedCmdTaskContinueTaskStep = 3
|
||||
ReceivedCmdReloadGroupTasks = 4
|
||||
ReceivedCmdTaskLocking = 5
|
||||
ReceivedCmdStartGroupTasks = 1
|
||||
ReceivedCmdTaskFailedTryAgainRunTaskStep = 2
|
||||
ReceivedCmdTaskContinueTaskStep = 3
|
||||
ReceivedCmdReloadGroupTasks = 4
|
||||
ReceivedCmdTaskLocking = 5
|
||||
ReceivedCmdUpdateGroupTaskStepUserInputValue = 6
|
||||
)
|
||||
|
||||
var (
|
||||
|
|
|
@ -173,6 +173,12 @@ func RunHub() {
|
|||
}
|
||||
|
||||
break
|
||||
case utils.ReceivedCmdUpdateGroupTaskStepUserInputValue:
|
||||
socketclients.BroadcastMessageExceptUserSessionId(data.Conn.Locals("sessionId").(string), structs.SendSocketMessage{
|
||||
Cmd: utils.SentCmdUpdateGroupTaskStepUserInputValue,
|
||||
Body: receivedMessage.Body,
|
||||
})
|
||||
break
|
||||
|
||||
default:
|
||||
log.Error().Msgf("Received unknown message: %s", receivedMessage)
|
||||
|
|
Loading…
Reference in New Issue