add remove old stations

db/db.go

@@ -1962,6 +1962,35 @@ func RemoveSchemaFromAllUsingStations(schemaName string, tenantName string) erro
 	return nil
 }
 
+func GetIsNotActiveStations() ([]models.Station, error) {
+	ctx, cancelfunc := context.WithTimeout(context.Background(), DbOperationTimeout*time.Second)
+	defer cancelfunc()
+	conn, err := MetadataDbClient.Client.Acquire(ctx)
+	if err != nil {
+		return []models.Station{}, err
+	}
+	defer conn.Release()
+	query := `SELECT * FROM stations WHERE is_deleted = true`
+	stmt, err := conn.Conn().Prepare(ctx, "get_not_active_stations", query)
+	if err != nil {
+		return []models.Station{}, err
+	}
+	rows, err := conn.Conn().Query(ctx, stmt.Name)
+	if err != nil {
+		return []models.Station{}, err
+	}
+	defer rows.Close()
+	stations, err := pgx.CollectRows(rows, pgx.RowToStructByPos[models.Station])
+	if err != nil {
+		return []models.Station{}, err
+	}
+	if len(stations) == 0 {
+		return []models.Station{}, err
+	}
+	return stations, nil
+
+}
+
 // Producer Functions
 func GetProducersByConnectionIDWithStationDetails(connectionId string) ([]models.LightProducer, error) {
 	ctx, cancelfunc := context.WithTimeout(context.Background(), DbOperationTimeout*time.Second)

server/memphis_handlers_stations.go

@@ -2165,3 +2165,24 @@ func getUserAndTenantIdFromString(username string) (string, int, error) {
 	return username, -1, nil
 
 }
+
+func (s *Server) RemoveOldStations() error {
+	stations, err := db.GetIsNotActiveStations()
+	if err != nil {
+		return err
+	}
+
+	for _, station := range stations {
+		err = removeStationResources(s, station, true)
+		if err != nil {
+			return err
+		}
+
+		err = db.DeleteStation(station.Name, station.TenantName)
+		if err != nil {
+			return err
+		}
+	}
+
+	return nil
+}

server/memphis_zombie_resources.go

@@ -159,8 +159,6 @@ func killFunc(s *Server) {
 			}
 		}
 	}
-
-	s.removeStaleStations()
 }
 
 func (s *Server) KillZombieResources() {
@@ -180,6 +178,14 @@ func (s *Server) KillZombieResources() {
 	firstIteration := true
 	for range time.Tick(time.Minute * 1) {
 		s.Debugf("Killing Zombie resources iteration")
+		if firstIteration {
+			s.removeStaleStations()
+			err := s.RemoveOldStations()
+			if err != nil {
+				serv.Errorf("KillZombieResources: RemoveOldStations: %v", err.Error())
+				return
+			}
+		}
 		killFunc(s)
 
 		if firstIteration || count == 1*60 { // once in 1 hour