Method Prune

internal/daemon/memory_runtime.go:1096–1134

(
	ctx context.Context,
	req contract.MemorySessionsPruneRequest,
)

}

func (s *daemonMemorySessionLedgerService) Prune(
	ctx context.Context,
	req contract.MemorySessionsPruneRequest,
) (contract.MemorySessionsPruneResponse, error) {
	if req.OlderThanHours <= 0 {
		return contract.MemorySessionsPruneResponse{}, errors.New("older_than_hours must be positive")
	}
	paths, err := s.listPaths(ctx)
	if err != nil {
		return contract.MemorySessionsPruneResponse{}, err
	}
	cutoff := s.now().UTC().Add(-time.Duration(req.OlderThanHours) * time.Hour)
	response := contract.MemorySessionsPruneResponse{DryRun: req.DryRun}
	for _, path := range paths {
		if err := ctx.Err(); err != nil {
			return response, fmt.Errorf("daemon: prune memory session ledgers: %w", err)
		}
		ledger, err := readSessionLedger(path)
		if err != nil {
			return response, err
		}
		stopTime := ledger.Meta.CreatedAt
		if ledger.Meta.StoppedAt != nil {
			stopTime = *ledger.Meta.StoppedAt
		}
		if !stopTime.Before(cutoff) {
			continue
		}
		response.PrunedSessions++
		response.PrunedEvents += len(ledger.Events)
		if req.DryRun {
			continue
		}
		if err := os.RemoveAll(filepath.Dir(path)); err != nil {
			return response, fmt.Errorf("daemon: prune ledger %q: %w", path, err)
		}
	}
	return response, nil
}

func (s *daemonMemorySessionLedgerService) Repair(
	context.Context,