)
    assertThat(bodyAsString(body)).isEqualTo("foo")
  }

  @Test
  fun contentTypeHeader() {
    val request =
      fromArgs(
        "-d",
        "foo",
        "-H",
        "Content-Type: application/json",
        "http://example.com",
      ).createRequest()
    val body = request.body
    assertThat(request.method).isEqualTo("POST")

    }

    public void test_constructor_withLongMessage() {
        // Test with long message
        StringBuilder sb = new StringBuilder();
        for (int i = 0; i < 1000; i++) {
            sb.append("Long message content ");
        }
        String longMessage = sb.toString();
        ResultOffsetExceededException exception = new ResultOffsetExceededException(longMessage);

        assertEquals(longMessage, exception.getMessage());

                "operationId": "read_items_items__get",
                "responses": {
                    "200": {
                        "description": "Successful Response",
                        "content": {
                            "application/json": {
                                "schema": {}
                            }
                        }
                    }
                },

     * When enabled, suggestions are generated from previous searches.
     */
    @Size(max = 10)
    public String suggestSearchLog;

    /**
     * Enable or disable search suggestions based on document content.
     * When enabled, suggestions are generated from indexed documents.
     */
    @Size(max = 10)
    public String suggestDocuments;

    /**

    <example>${fe:replace(input, regex, replacement)}</example>
  </function>

  <function>
    <description>Format a content as code.</description>
    <name>formatCode</name>
    <function-class>org.codelibs.fess.taglib.FessFunctions</function-class>

        // Buffer length is based on maximum_length/2 from the encoded data
        assertEquals(translatedName.name.maximum_length / 2, decodedName.name.buffer.length);
        // Verify the actual string content
        for (int i = 0; i < translatedName.name.buffer.length; i++) {
            assertEquals(translatedName.name.buffer[i], decodedName.name.buffer[i]);
        }

	}

	// Initialize erasure metadata.
	for index := range partsMetadata {
		partsMetadata[index] = fi
	}

	// Guess content-type from the extension if possible.
	if userDefined["content-type"] == "" {
		userDefined["content-type"] = mimedb.TypeByExtension(path.Ext(object))
	}

	// if storageClass is standard no need to save it as part of metadata.

        boolBuilder.add(new PrefixQuery(new Term("content", "search")), BooleanClause.Occur.SHOULD);
        boolBuilder.add(new WildcardQuery(new Term("url", "*.html")), BooleanClause.Occur.MUST_NOT);
        BooleanQuery boolQuery = boolBuilder.build();
        BoostQuery boostQuery = new BoostQuery(boolQuery, 5.5f);

        QueryContext context = new QueryContext("test", false);

     *
     * @param witnessServer the witness server address
     * @param context the CIFS context
     * @throws IOException if initialization fails
     */
    public WitnessClient(InetAddress witnessServer, CIFSContext context) throws IOException {
        this(witnessServer, context, new WitnessRpcClient(witnessServer, context));
    }

    /**

        }
      }
    }
  }

  @Throws(Exception::class)
  private fun processHandshakeFailure(raw: Socket) {
    val context = SSLContext.getInstance("TLS")
    context.init(null, arrayOf<TrustManager>(UNTRUSTED_TRUST_MANAGER), SecureRandom())
    val sslSocketFactory = context.socketFactory
    val socket =
      sslSocketFactory.createSocket(
        raw,
        raw.inetAddress.hostAddress,
        raw.port,