send log data

main
alex 2023-06-26 23:46:29 +02:00
parent 43a25f817b
commit 2187f2951e
4 changed files with 48 additions and 14 deletions

View File

@ -4,7 +4,16 @@
"languages": [ "languages": [
{ {
"lang": "en", "lang": "en",
"message": "%userId% has started group tasks" "message": "%userId% has started group task %groupTaskId% %groupTaskName%"
}
]
},
{
"id": 1,
"languages": [
{
"lang": "en",
"message": "%userId% has reloaded group tasks config of category %category%"
} }
] ]
} }

View File

@ -114,16 +114,11 @@ func ReadLogs(date string, systemLogs bool) []structs.LogMessageResponse {
for _, systemLanguageLogMessage := range languageLogMessages { for _, systemLanguageLogMessage := range languageLogMessages {
if logMessage.Id == systemLanguageLogMessage.Id { if logMessage.Id == systemLanguageLogMessage.Id {
replacedLogMessage := systemLanguageLogMessage.Languages[0].Message
for _, message := range logMessage.Messages {
replacedLogMessage = strings.ReplaceAll(replacedLogMessage, "%"+message.Type+"%", message.Value)
}
logMessages = append(logMessages, structs.LogMessageResponse{ logMessages = append(logMessages, structs.LogMessageResponse{
Time: logMessage.Time, Time: logMessage.Time,
Type: logMessage.Type, Type: logMessage.Type,
Message: replacedLogMessage, Message: systemLanguageLogMessage.Languages[0].Message,
LogData: logMessage.Messages,
}) })
break break
} }

View File

@ -30,4 +30,5 @@ type LogMessageResponse struct {
Time time.Time Time time.Time
Type uint8 Type uint8
Message string Message string
LogData []LogData
} }

View File

@ -93,12 +93,6 @@ func RunHub() {
Messages: []structs.LogData{ Messages: []structs.LogData{
{Type: "userId", Value: user.Id}}}) {Type: "userId", Value: user.Id}}})
logger.AddGroupTasksLog(structs.LogMessage{
Id: 0,
Type: utils.LogTypeInfo,
Messages: []structs.LogData{
{Type: "userId", Value: user.Id}}})
case data := <-broadcast: case data := <-broadcast:
var receivedMessage structs.ReceivedMessage var receivedMessage structs.ReceivedMessage
@ -156,6 +150,26 @@ func RunHub() {
TaskStepId: "", TaskStepId: "",
GlobalInputs: globalInputsJsonString, GlobalInputs: globalInputsJsonString,
}) })
logger.AddGroupTasksLog(structs.LogMessage{
Id: 0,
Type: utils.LogTypeInfo,
Messages: []structs.LogData{
{
Type: "userId",
Value: data.Conn.Locals("userId").(string),
},
{
Type: "groupTaskId",
Value: groupTaskId,
},
{
Type: "groupTaskName",
Value: groupTasks.GroupName,
},
},
})
break break
case utils.ReceivedCmdTaskFailedTryAgainRunTaskStep: case utils.ReceivedCmdTaskFailedTryAgainRunTaskStep:
go grouptasks.RunGroupTask(grouptasks.RunGroupTaskArgs{ go grouptasks.RunGroupTask(grouptasks.RunGroupTaskArgs{
@ -194,6 +208,21 @@ func RunHub() {
}) })
grouptasks.LoadGroups(category) grouptasks.LoadGroups(category)
logger.AddGroupTasksLog(structs.LogMessage{
Id: 1,
Type: utils.LogTypeInfo,
Messages: []structs.LogData{
{
Type: "userId",
Value: data.Conn.Locals("userId").(string),
},
{
Type: "category",
Value: category,
},
},
})
break break
case utils.ReceivedCmdTaskLocking: case utils.ReceivedCmdTaskLocking:
cache.AddLockedGroupTaskStep(structs.LockedGroupTaskSteps{ cache.AddLockedGroupTaskStep(structs.LockedGroupTaskSteps{