refactor(tasks): add Clear method

Author: fiftin

db_lib/AnsibleApp.go

@@ -69,6 +69,9 @@ func (t *AnsibleApp) Log(msg string) {
 	t.Logger.Log(msg)
 }
 
+func (t *AnsibleApp) Clear() {
+}
+
 func (t *AnsibleApp) InstallRequirements(environmentVars []string, tplParams any, params any) error {
 	if err := t.installCollectionsRequirements(); err != nil {
 		return err

db_lib/LocalApp.go

@@ -40,4 +40,5 @@ type LocalApp interface {
 	SetLogger(logger task_logger.Logger) task_logger.Logger
 	InstallRequirements(environmentVars []string, tplParams any, params any) error
 	Run(args LocalAppRunningArgs) error
+	Clear()
 }

db_lib/ShellApp.go

@@ -74,6 +74,9 @@ func (t *ShellApp) SetLogger(logger task_logger.Logger) task_logger.Logger {
 	return logger
 }
 
+func (t *ShellApp) Clear() {
+}
+
 func (t *ShellApp) InstallRequirements(environmentVars []string, tplParams any, params any) error {
 	return nil
 }

db_lib/TerraformApp.go

@@ -194,6 +194,9 @@ func (t *TerraformApp) selectWorkspace(workspace string, environmentVars []strin
 	return nil
 }
 
+func (t *TerraformApp) Clear() {
+}
+
 func (t *TerraformApp) InstallRequirements(environmentVars []string, tplParams any, params any) (err error) {
 
 	tpl := tplParams.(*db.TerraformTemplateParams)
@@ -207,7 +210,7 @@ func (t *TerraformApp) InstallRequirements(environmentVars []string, tplParams a
 	backendFile := path.Join(t.GetFullPath(), backendFilename)
 
 	if tpl.OverrideBackend {
-		err = os.WriteFile(backendFile, []byte("terraform { backend \"http\" {} }"), 0644)
+		err = os.WriteFile(backendFile, []byte("terraform {\n  backend \"http\" {\n  }\n}\n"), 0644)
 		if err != nil {
 			return
 		}
@@ -217,15 +220,15 @@ func (t *TerraformApp) InstallRequirements(environmentVars []string, tplParams a
 		return
 	}
 
-	if tpl.OverrideBackend {
-		err = os.Remove(backendFile)
-		if os.IsNotExist(err) {
-			err = nil
-		}
-		if err != nil {
-			return
-		}
-	}
+	//if tpl.OverrideBackend {
+	//	err = os.Remove(backendFile)
+	//	if os.IsNotExist(err) {
+	//		err = nil
+	//	}
+	//	if err != nil {
+	//		return
+	//	}
+	//}
 
 	workspace := "default"
 

services/tasks/LocalJob.go

@@ -526,6 +526,7 @@ func (t *LocalJob) Run(username string, incomingVersion *string, alias string) (
 	defer func() {
 		t.destroyKeys()
 		t.destroyInventoryFile()
+		t.App.Clear()
 	}()
 
 	t.SetStatus(task_logger.TaskRunningStatus) // It is required for local mode. Don't delete

services/tasks/TaskPool.go

@@ -508,6 +508,26 @@ func getNextBuildVersion(startVersion string, currentVersion string) string {
 	return prefix + strconv.Itoa(newVer) + suffix
 }
 
+// AddTask creates and queues a new task for execution in the task pool.
+//
+// Parameters:
+//   - taskObj: The task object with initial configuration
+//   - userID: Optional ID of the user initiating the task
+//   - username: Username of the user initiating the task
+//   - projectID: ID of the project this task belongs to
+//   - needAlias: Whether to generate a unique alias for the task
+//
+// The method:
+//   - Sets initial task properties (created time, waiting status, etc.)
+//   - Validates the task against its template
+//   - For build templates, calculates the next version number
+//   - Creates the task record in the database
+//   - Sets up appropriate job handler (local or remote)
+//   - Queues the task for execution
+//
+// Returns:
+//   - The newly created task with all properties set
+//   - An error if task creation or validation fails
 func (p *TaskPool) AddTask(
 	taskObj db.Task,
 	userID *int,
@@ -558,6 +578,7 @@ func (p *TaskPool) AddTask(
 	}
 
 	if needAlias {
+		// A unique, randomly-generated identifier that persists throughout the task's lifecycle.
 		taskRunner.Alias = random.String(32)
 	}
 

services/tasks/TaskRunner.go

@@ -48,6 +48,8 @@ type TaskRunner struct {
 	statusListeners []task_logger.StatusListener
 	logListeners    []task_logger.LogListener
 
+	// Alias uses if task require an alias for run.
+	// For example, terraform task require an alias for run.
 	Alias string
 
 	logWG sync.WaitGroup