test

bot.go

@@ -85,6 +85,8 @@ func botMsgRescan(m *tb.Message) (string, error) {
 	if r.MatchString(m.Payload) {
 		p := JobPayloadRescanMsg{
 			Query:    fmt.Sprintf("SELECT o.id FROM obj o WHERE o.id = %s AND o.obj_type_id = %d AND o.obj_sub_type_id = %d;", m.Payload, objTypeMessage, objSubTypeMessageUnknown),
+			MsgID64:  int64(m.ID),
+			ChatID64: m.Chat.ID,
 		}
 		b, _ := json.Marshal(p)
 		log.Printf("botMsgRescan : json : %s\n", string(b))

def.go

@@ -111,6 +111,7 @@ type JobPayloadSetDone struct {
 	JobID64  int64  `json:"job_id"`
 	MsgID64  int64  `json:"msg_id"`
 	ChatID64 int64  `json:"chat_id"`
+	Text     string `json:"test"`
 }
 
 const (

job.go

@@ -24,22 +24,39 @@ func jobRescan(j Job) {
 			}
 
 			b, _ := json.Marshal(p)
-			err := createJob(objSubTypeJobRescanMsg, objJobPriorityRescanChildMsg, time.Now(), b)
+			err := createJob(objSubTypeJobRescanMsg, objJobPriorityRescanChildMsg, j.UserID64, time.Now(), b)
 			logOnError(err, "jobRescan : createJob(objSubTypeJobRescanMsg)")
 		}
 		p := JobPayloadSetDone{
 			JobID64:  j.ID64,
+			MsgID64:  j.MsgID64,
+			ChatID64: j.ChatID64,
+			Text:     fmt.Sprintf("%d messages processed.", len(ids)),
 		}
 		b, _ := json.Marshal(p)
-		err := createJob(objSubTypeJobSetJobDone, objJobPriority, time.Now(), b)
+		err := createJob(objSubTypeJobSetJobDone, objJobPriority, j.UserID64, time.Now(), b)
 		logOnError(err, "jobRescan : createJob(objSubTypeJobSetJobDone)")
 	} else if len(ids) == 1 {
 		SQLMsgIdentifyQueue <- ids[0]
 		err = setJobDone(j.ID64)
 		logOnError(err, "jobRescan : setJobDone(1)")
+		m := TGCommand{
+			Type:        commandReplyMsg,
+			Text:        "One message processed.",
+			FromMsgID64: j.MsgID64,
+			FromChatID64j.ChatID64,
+		}
+		TGCmdQueue <- m
 	} else {
 		err = setJobDone(j.ID64)
 		logOnError(err, "jobRescan : setJobDone(0)")
+		m := TGCommand{
+			Type:        commandReplyMsg,
+			Text:        "No message processed.",
+			FromMsgID64: j.MsgID64,
+			FromChatID64j.ChatID64,
+		}
+		TGCmdQueue <- m
 	}
 	return
 }