feat(parser): add store arg

Author: fiftin

services/tasks/TaskPool.go

@@ -186,7 +186,7 @@ func (p *TaskPool) MoveToNextStage(
 			matched = true
 		} else {
 			var ok bool
-			ok, err = parser.Parse(currentStage, newOutput)
+			ok, err = parser.Parse(currentStage, newOutput, p.store)
 			if err != nil {
 				log.Error(err.Error())
 			} else if ok {

services/tasks/stage_parsers/ansible_play.go

@@ -48,7 +48,7 @@ func (p AnsibleRunningStageParser) IsEnd(currentStage *db.TaskStage, output db.T
 const ansibleTaskMaker = "TASK ["
 const failedTaskMaker = "fatal: ["
 
-func (p AnsibleRunningStageParser) Parse(currentStage *db.TaskStage, output db.TaskOutput) (ok bool, err error) {
+func (p AnsibleRunningStageParser) Parse(currentStage *db.TaskStage, output db.TaskOutput, store db.Store) (ok bool, err error) {
 
 	if currentStage == nil {
 		return

services/tasks/stage_parsers/ansible_result.go

@@ -75,7 +75,7 @@ type AnsibleResultStageParserState struct {
 	Hosts []AnsibleResultHost
 }
 
-func (p AnsibleResultStageParser) Parse(currentStage *db.TaskStage, output db.TaskOutput) (ok bool, err error) {
+func (p AnsibleResultStageParser) Parse(currentStage *db.TaskStage, output db.TaskOutput, store db.Store) (ok bool, err error) {
 
 	if currentStage == nil {
 		return

services/tasks/stage_parsers/common.go

@@ -10,7 +10,7 @@ type StageResultParser interface {
 	IsEnd(currentStage *db.TaskStage, output db.TaskOutput) bool
 	NeedParse() bool
 	State() any
-	Parse(currentStage *db.TaskStage, output db.TaskOutput) (bool, error)
+	Parse(currentStage *db.TaskStage, output db.TaskOutput, store db.Store) (bool, error)
 	Result() map[string]any
 }
 
@@ -82,7 +82,7 @@ func (p InitStageParser) IsEnd(currentStage *db.TaskStage, output db.TaskOutput)
 	return false
 }
 
-func (p InitStageParser) Parse(currentStage *db.TaskStage, output db.TaskOutput) (bool, error) {
+func (p InitStageParser) Parse(currentStage *db.TaskStage, output db.TaskOutput, store db.Store) (bool, error) {
 	return false, nil
 }