checkFile((line, message) -> log(line, message), max, fileText.toLinesArray());
    }

    static void checkFile(BiConsumer<Integer, String> log, int max, String... lineArray) {
        LineItr lines = new LineItr(Arrays.asList(lineArray).iterator());
        while (lines.hasNext()) {
            Matcher m = START.matcher(lines.next());
            if (m.matches()) {

        if (shouldApplyHeaders(doNodeValue)) {
            ObjectNode headersNode = (ObjectNode) doNodeValue.get("headers");
            if (headersNode == null) {
                headersNode = new ObjectNode(jsonNodeFactory);
            }

            for (Map.Entry<String, String> entry : headers.entrySet()) {
                headersNode.set(entry.getKey(), TextNode.valueOf(entry.getValue()));
            }

 * This form handles the creation of API access tokens with configurable permissions and expiration dates.
 */
public class CreateForm {

    /**
     * Creates a new CreateForm instance.
     */
    public CreateForm() {
        // Default constructor
    }

    /**
     * The CRUD operation mode for this form.

                final BulkRequestBuilder bulkRequest = client.prepareBulk();
                for (final LogNotificationEvent event : batch) {
                    final Map<String, Object> source = new HashMap<>();
                    source.put("hostname", hostname);
                    source.put("level", event.getLevel());
                    source.put("loggerName", event.getLoggerName());

        switch (il) {
        case FileSystemInformation.SMB_INFO_ALLOCATION:
            return 0x1;
        case FileSystemInformation.FS_SIZE_INFO:
            return 0x103;
        }
        throw new IllegalArgumentException("Unhandled information level");
    }

    @Override
    protected int writeDataWireFormat(final byte[] dst, final int dstIndex) {
        return 0;
    }

    @Override

        final int start = bufferIndex;
        final int nciphers = SMBUtil.readInt2(buffer, bufferIndex);
        bufferIndex += 2;

        this.ciphers = new int[nciphers];
        for (int i = 0; i < nciphers; i++) {
            this.ciphers[i] = SMBUtil.readInt2(buffer, bufferIndex);
            bufferIndex += 2;
        }

        return bufferIndex - start;
    }

    @Test
    @DisplayName("toInetAddress should handle UnknownHostException")
    void testToInetAddressWithException() throws UnknownHostException {
        // Given
        when(mockAddress.toInetAddress()).thenThrow(new UnknownHostException("Host not found"));

        // When & Then
        assertThrows(UnknownHostException.class, () -> {
            mockAddress.toInetAddress();
        }, "Should propagate UnknownHostException");

        TransferResource resource = event.getResource();
        long contentLength = event.getTransferredBytes();
        FileSizeFormat format = new FileSizeFormat();

        MessageBuilder message = messageBuilderFactory.builder();
        message.append(action).style(STYLE).append(' ').append(direction).append(' ');

    /**
     * Constructor for PopularWordsRequestBuilder.
     * @param client The OpenSearch client.
     */
    public PopularWordsRequestBuilder(final Client client) {
        super(client, new PopularWordsRequest());
    }

    /**
     * Sets the index for the request.
     * @param index The index name.
     * @return This builder instance.
     */

    /** Logger instance for this class */
    private static final Logger logger = LogManager.getLogger(PurgeThumbnailJob.class);

    /**
     * Default constructor for PurgeThumbnailJob.
     * Creates a new instance of the thumbnail purging job with default expiry time (30 days).
     */
    public PurgeThumbnailJob() {
        // Default constructor
    }