}
        });
    }

    /**
     * Marks statistics tracking as complete for the specified crawler object.
     * Decrements the reference count and if it reaches zero, removes the
     * statistics object from cache and outputs the final statistics.
     *
     * @param keyObj the crawler object to complete tracking for
     */
    public void done(final Object keyObj) {

import jakarta.servlet.http.HttpSession;

/**
 * Helper class for managing user information and session tracking in Fess search system.
 * This class handles user identification through cookies, session management, and query tracking.
 * It provides functionality for generating unique user codes, managing user sessions,
 * and tracking search result document IDs for analytics and personalization.
 *
 */
public class UserInfoHelper {

        super.setUp(testInfo);
        purgeLogJob = new PurgeLogJob();
    }

    // Test all services execute successfully
    @Test
    public void test_execute_allSuccess() {
        // Setup tracking variables
        final boolean[] deleteCrawlingInfoCalled = { false };
        final boolean[] deleteSearchLogCalled = { false };
        final boolean[] deleteJobLogCalled = { false };

                    dir, event.getSession().getLocalRepositoryManager().getPathForLocalArtifact(event.getArtifact()));
            trackingDir = dir.getParentFile().toPath().resolve(".tracking");
        } else {
            trackingDir = event.getFile().getParentFile().toPath().resolve(".tracking");
        }

        String baseName;
        String ext = missing ? ".miss" : ".dep";
        Path trackingFile = null;

- [ ] Add lease context to Create request/response
- [ ] Implement lease break notification handling
- [ ] Modify SmbFile to support lease-based caching
- [ ] Add lease upgrade/downgrade logic
- [ ] Implement lease epoch tracking for v2 leases

#### 1.3 Integration Points
- Modify `Smb2CreateRequest` to include lease contexts
- Update `SmbFile` caching logic to use leases
- Add lease break handling in `SmbTransport`

---

    private final int maxAttemptsPerIp;
    private final int maxGlobalAttemptsPerMinute;
    private final Duration lockoutDuration;
    private final Duration cleanupInterval;

    // Tracking maps
    private final Map<String, AccountAttempts> accountAttempts = new ConcurrentHashMap<>();
    private final Map<String, IpAttempts> ipAttempts = new ConcurrentHashMap<>();

     *
     * @return {@code true} if location tracking is enabled, {@code false} otherwise.
     */
    boolean isLocationTracking();

    /**
     * Enables/disables the tracking of line/column numbers for the model source being parsed. By default, input
     * locations are not tracked.
     *
     * @param locationTracking {@code true} to enable location tracking, {@code false} to disable it.

     */
    public static ResourceManager getInstance() {
        return INSTANCE;
    }

    /**
     * Register a resource for tracking
     *
     * @param resource the resource to track
     * @return resource ID for tracking
     */
    public String registerResource(AutoCloseable resource) {
        if (resource == null) {

        }

        return needsRotation;
    }

    /**
     * Reset key rotation tracking after new keys are established
     */
    public void resetKeyRotationTracking() {
        bytesEncrypted.set(0);
        encryptionStartTime = System.currentTimeMillis();
        log.debug("Key rotation tracking reset");
    }

    /**
     * Rotate encryption keys for enhanced security
     *

    // Proactive health monitoring
    private volatile boolean proactiveHealthCheckEnabled = true;
    private final long proactiveCheckInterval = DEFAULT_PROACTIVE_CHECK_INTERVAL;

    // Connection failure tracking
    private final Map<String, Long> lastFailureTimes = new ConcurrentHashMap<>();
    private final Map<String, AtomicInteger> consecutiveFailures = new ConcurrentHashMap<>();