// Document already exists - check if it's stale
        return tryCleanupAndRetry(operationName, data, remainingRetries);
    }

    /**
     * Checks if the existing operation lock is stale (expired or owner inactive) and retries acquisition.
     *
     * @param operationName the operation name.
     * @param data optional data for the operation.
     * @param remainingRetries the number of remaining retry attempts.

        if (form.ragLlmName != null && isValidRagLlmName(form.ragLlmName)) {
            fessConfig.setRagLlmName(form.ragLlmName);
        }

        // OpenID Connect
        if (form.oicClientId != null && StringUtil.isNotBlank(form.oicClientId.replace("*", " "))) {
            fessConfig.setSystemProperty("oic.client.id", form.oicClientId);
        }

        assertEquals("ollama", request.getAttribute(Constants.SEARCH_LOG_ACCESS_TYPE));

        request.setAttribute(Constants.SEARCH_LOG_ACCESS_TYPE, "openai");
        assertEquals("openai", request.getAttribute(Constants.SEARCH_LOG_ACCESS_TYPE));
    }

    @Test
    public void test_accessType_constantValues() {
        assertEquals("json", Constants.SEARCH_LOG_ACCESS_TYPE_JSON);

# Default values for min/max heap memory allocated to fess java process
packaging.fess.heap.min=256m
packaging.fess.heap.max=1g

# Specifies the maximum file descriptor number
packaging.os.max.open.files=65535

# Maximum number of VMA (Virtual Memory Areas) a process can own
packaging.os.max.map.count=262144

# Simple marker to check that properties are correctly overridden
packaging.type=tar.gz

errors.design_editor_disabled = Deze functie is uitgeschakeld.
errors.not_found_on_file_system = Niet gevonden. Oorzaak: {0}
errors.could_not_open_on_system = Kan {0} niet openen.<br>Controleer of het bestand is gekoppeld aan een toepassing.
errors.result_size_exceeded = Er kunnen geen verdere resultaten worden weergegeven.
errors.target_file_does_not_exist = Bestand {0} bestaat niet.

  --type=data
```

**Step 2: Convert to Fess Format**

Transform documents to include Fess required fields. Example transformation script:

```python
import json

with open('documents.json', 'r') as infile, \
     open('fess-documents.json', 'w') as outfile:
    for line in infile:
        doc = json.loads(line)

        # Transform to Fess format
        fess_doc = {
            "url": doc.get("url", ""),

 */

plugins {
    id("base")
    id("checkstyle")
    id("codenarc")
    id("net.ltgt.errorprone")
    id("net.ltgt.nullaway")
}

open class ErrorProneProjectExtension(
    val disabledChecks: ListProperty<String>,
    val nullawayEnabled: Property<Boolean>
)

open class ErrorProneSourceSetExtension(
    val enabled: Property<Boolean>
)

val errorproneExtension = project.extensions.create<ErrorProneProjectExtension>(

    @Test
    public void test_variousTokenTypes() {
        // Test with various common token types
        String[] tokenTypes = { "Bearer", "JWT", "OAuth", "OAuth2", "APIKey", "Session", "Basic", "Digest", "SAML", "OpenID" };

        for (String tokenType : tokenTypes) {
            String message = tokenType + " token is invalid";
            InvalidAccessTokenException exception = new InvalidAccessTokenException(tokenType, message);

            return
        }

        val taskPath = event.descriptor.taskPath
        if (shouldInclude(taskPath)) {
            action(taskPath, event.result)
        }
    }

    protected open fun shouldInclude(taskPath: String): Boolean = parameters.monitoredTaskPaths.get().contains(taskPath)

    abstract fun action(taskPath: String, taskResult: TaskOperationResult)

import japicmp.model.JApiMethod
import javassist.bytecode.SourceFileAttribute
import java.io.File


/**
 * Repository of sources for binary compatibility checks.
 *
 * `WARN` Holds resources open for performance, must be closed after use.
 */
class BinaryCompatibilityRepository internal constructor(

    private
    val sources: SourcesRepository

) : AutoCloseable {

    companion object {