/**
   * Returns the value nearest to {@code value} which is within the closed range {@code [min..max]}.
   *
   * <p>If {@code value} is within the range {@code [min..max]}, {@code value} is returned
   * unchanged. If {@code value} is less than {@code min}, {@code min} is returned, and if {@code
   * value} is greater than {@code max}, {@code max} is returned.
   *
   * @param value the {@code short} value to constrain

  /**
   * Returns the value nearest to {@code value} which is within the closed range {@code [min..max]}.
   *
   * <p>If {@code value} is within the range {@code [min..max]}, {@code value} is returned
   * unchanged. If {@code value} is less than {@code min}, {@code min} is returned, and if {@code
   * value} is greater than {@code max}, {@code max} is returned.
   *
   * @param value the {@code short} value to constrain

            bufferIndex += server.encryptionKeyLength;
            if (byteCount > server.encryptionKeyLength) {
                int len = 0;
                // Use appropriate string decoding based on Unicode flag
                try {
                    if ((flags2 & FLAGS2_UNICODE) == FLAGS2_UNICODE) {
                        while (buffer[bufferIndex + len] != (byte) 0x00 || buffer[bufferIndex + len + 1] != (byte) 0x00) {

 * directly.  Since the byte‑encoding logic is located in the superclass, the
 * tests verify that the byte buffer created by {@link
 * SmbComQueryInformation#writeBytesWireFormat(byte[], int)} is correctly built
 * for both Unicode and OEM encodings.
 */
@ExtendWith(MockitoExtension.class)
@MockitoSettings(strictness = Strictness.LENIENT)
class SmbComQueryInformationTest {

    @Mock
    Configuration mockConfig;

        // Test with special characters in document content
        Map<String, Object> doc = new HashMap<>();
        doc.put("special", "!@#$%^&*()_+-=[]{}|;':\",./<>?");
        doc.put("unicode", "こんにちは世界");
        doc.put("emoji", "😀🎉");

        SearchResult result = SearchResult.create().addDocument(doc).build();

        assertEquals(1, result.getDocumentList().size());

        final PermissionHelper permissionHelper = ComponentUtil.getPermissionHelper();
        body.permissions = stream(entity.getPermissions()).get(stream -> stream.map(s -> permissionHelper.decode(s))
                .filter(StringUtil::isNotBlank)
                .distinct()
                .collect(Collectors.joining("\n")));

    }

    // Edge/null/empty: message-only constructor should propagate message and set unsuccessful status
    @ParameterizedTest
    @NullSource
    @ValueSource(strings = { "", " ", "simple", "with unicode Ω≈ç√", "long-0123456789-abcdefghijklmnopqrstuvwxyz" })
    @DisplayName("Message-only ctor: propagates message and unsuccessful status")
    void messageOnlyConstructor_setsMessage_andUnsuccessfulStatus(String msg) {

}

var _ yaml.Unmarshaler = &BatchJobExpirePurge{}

// UnmarshalYAML - BatchJobExpirePurge extends unmarshal to extract line, col
func (p *BatchJobExpirePurge) UnmarshalYAML(val *yaml.Node) error {
	type purge BatchJobExpirePurge
	var tmp purge
	err := val.Decode(&tmp)
	if err != nil {
		return err
	}

	*p = BatchJobExpirePurge(tmp)
	p.line, p.col = val.Line, val.Column
	return nil
}

        discloser.setSubject("テスト件名 🚀");
        discloser.setPlainText("テスト内容です。\n改行もあります。");

        String result = notificationHelper.toSlackMessage(discloser);

        assertNotNull(result);
        // Unicode characters may be escaped in JSON
        assertTrue(result.contains("テスト") || result.contains("\\u"));
    }

    public void test_toGoogleChatMessage_withUnicodeContent() {

import okhttp3.Headers
import okhttp3.Request
import okhttp3.Response
import okhttp3.Route
import okhttp3.internal.connection.RealCall
import okio.Sink
import okio.Socket
import okio.Source

/** Encodes HTTP requests and decodes HTTP responses. */
interface ExchangeCodec {
  /** The connection or CONNECT tunnel that owns this codec. */
  val carrier: Carrier