* Gets the query languages from the current request.
     * @return An optional containing the query languages array, or empty if not available.
     */
    protected OptionalThing<String[]> getQueryLanguages() {
        return LaRequestUtil.getOptionalRequest()
                .map(request -> ComponentUtil.getFessConfig()
                        .getQueryLanguages(request.getLocales(), (String[]) request.getAttribute(Constants.REQUEST_LANGUAGES)));

)

var port int

func init() {
	flag.IntVar(&port, "port", 8080, "Port to listen on")
}

func mainHandler(w http.ResponseWriter, r *http.Request) {
	body, err := io.ReadAll(r.Body)
	defer r.Body.Close()
	if err != nil {
		log.Printf("Error reading request body: %v", err)
		w.WriteHeader(http.StatusBadRequest)
		return
	}

	log.Printf(">>> %s %s\n", r.Method, r.URL.Path)
	var out bytes.Buffer

import jcifs.internal.util.SMBUtil;

/**
 * SMB2 Logoff request message. This command is used to terminate an SMB2 session.
 *
 * @author mbechler
 *
 */
public class Smb2LogoffRequest extends ServerMessageBlock2Request<Smb2LogoffResponse> {

    /**
     * Constructs an SMB2 logoff request with the given configuration.
     *
     * @param config the configuration for this request
     */

import assertk.assertThat
import assertk.assertions.hasSize
import assertk.assertions.isEmpty
import assertk.assertions.isEqualTo
import okhttp3.HttpUrl.Companion.toHttpUrl
import okhttp3.OkHttpClient
import okhttp3.Request
import okhttp3.internal.platform.Platform
import org.junit.After
import org.junit.Test
import org.junit.jupiter.api.parallel.Isolated

@Isolated
@SdkSuppress(minSdkVersion = 28)
class StrictModeTest {

        this.creditsGranted = 0;
    }

    /**
     * Get initial number of credits to request
     *
     * @return initial credits
     */
    public int getInitialCredits() {
        return initialCredits;
    }

    /**
     * Set initial credits
     *
     * @param initialCredits initial credits to request
     */
    public void setInitialCredits(int initialCredits) {

    ResolutionGroup retrieve(MetadataResolutionRequest request) throws ArtifactMetadataRetrievalException;

    @Override
    ResolutionGroup retrieve(
            Artifact artifact, ArtifactRepository localRepository, List<ArtifactRepository> remoteRepositories)
            throws ArtifactMetadataRetrievalException;

    List<ArtifactVersion> retrieveAvailableVersions(MetadataResolutionRequest request)
            throws ArtifactMetadataRetrievalException;

  private var awaitingPong = false

  init {
    require("GET" == originalRequest.method) {
      "Request must be GET: ${originalRequest.method}"
    }

    this.key = ByteArray(16).apply { random.nextBytes(this) }.toByteString().base64()
  }

  override fun request(): Request = originalRequest

  @Synchronized override fun queueSize(): Long = queueSize

  override fun cancel() {

        // Test path with both leading and trailing backslash
        request.setPath("\\test\\directory\\");
        assertEquals("\\test\\directory", request.getPath());

        // Test single backslash
        request.setPath("\\");
        assertEquals("\\", request.getPath());

        // Test empty path
        request.setPath("");
        assertEquals("\\", request.getPath());
    }

                }))
                .status(Status.OK)
                .result());
    }

    /**
     * Creates a new boost document rule setting.
     *
     * @param body the request body containing boost document rule information
     * @return JSON response with result status
     */
    // POST /api/admin/boostdoc/setting
    @Execute

 */
package jcifs.internal.witness;

/**
 * Represents a witness heartbeat request as defined in MS-SWN specification.
 * Used to maintain active witness registrations.
 */
public class WitnessHeartbeatRequest {
    /**
     * Creates a new witness heartbeat request.
     */
    public WitnessHeartbeatRequest() {
        // Default constructor
    }