delete olf agents after rebooting http-server

backend/cmd/agent/main.go

@@ -15,7 +15,6 @@ import (
 	"github.com/Prrromanssss/DAEE-fullstack/internal/storage"
 )
 
-// TODO: Delete privous agents
 func main() {
 	ctxWithCancel, cancel := context.WithCancel(context.Background())
 	defer cancel()

backend/cmd/orchestrator/main.go

@@ -46,6 +46,12 @@ func main() {
 	// Configuration Storage
 	dbCfg := storage.NewStorage(log, cfg.StorageURL)
 
+	// Delete terminated agents
+	err := dbCfg.Queries.TerminateOldAgents(ctxWithCancel)
+	if err != nil {
+		log.Warn("can't delete old agents")
+	}
+
 	// Configuration Orchestrator
 	application, err := orchestratorapp.New(log, cfg, dbCfg, cancel)
 	if err != nil {

backend/internal/agent/agent.go

@@ -62,18 +62,6 @@ func NewAgent(
 	}, nil
 }
 
-// DeletePreviousAgents deletes previous agents when the application is restarted.
-func (a *Agent) DeletePreviousAgents(ctx context.Context) error {
-	err := a.dbConfig.Queries.DeleteAgents(ctx)
-	if err != nil {
-		a.log.Error("can't delete previous agents", sl.Err(err))
-
-		return err
-	}
-
-	return nil
-}
-
 // GetSafelyNumberOfActiveCalculations gets NumberOfActiveCalculations with Lock.
 func (a *Agent) GetSafelyNumberOfActiveCalculations() int32 {
 	a.mu.Lock()

backend/sql/queries/agents.sql

@@ -16,14 +16,6 @@ SELECT
 FROM agents
 ORDER BY created_at DESC;
 
--- name: GetAgentByID :one
-SELECT
-    agent_id, number_of_parallel_calculations,
-    last_ping, status, created_at,
-    number_of_active_calculations
-FROM agents
-WHERE agent_id = $1;
-
 -- name: UpdateAgentLastPing :exec
 UPDATE agents
 SET last_ping = $1
@@ -39,9 +31,6 @@ UPDATE agents
 SET status = 'terminated', number_of_active_calculations = 0
 WHERE agent_id = $1;
 
--- name: DeleteAgents :exec
-DELETE FROM agents;
-
 -- name: DecrementNumberOfActiveCalculations :exec
 UPDATE agents
 SET number_of_active_calculations = number_of_active_calculations - 1
@@ -56,4 +45,8 @@ WHERE agent_id = $1;
 UPDATE agents
 SET status = 'terminated', number_of_active_calculations = 0
 WHERE EXTRACT(SECOND FROM NOW()::timestamp - agents.last_ping) > $1::numeric
-RETURNING agent_id;
+RETURNING agent_id;
+
+-- name: TerminateOldAgents :exec
+DELETE FROM agents
+WHERE status = 'terminated';

backend/sql/queries/expressions.sql

@@ -25,11 +25,6 @@ SELECT
 FROM expressions
 WHERE expression_id = $1;
 
--- name: UpdateExpressionData :exec
-UPDATE expressions
-SET data = $1
-WHERE expression_id = $2;
-
 -- name: UpdateExpressionParseData :exec
 UPDATE expressions
 SET parse_data = $1