* governing permissions and limitations under the License.
 */
package org.codelibs.fess.app.web.api.admin.dict;

import java.util.stream.Collectors;
import java.util.stream.Stream;

import org.codelibs.fess.app.web.api.ApiResult;
import org.codelibs.fess.app.web.api.admin.FessApiAdminAction;
import org.codelibs.fess.dict.DictionaryFile;

package jcifs.netbios;

import static org.junit.jupiter.api.Assertions.assertEquals;
import static org.junit.jupiter.api.Assertions.assertTrue;
import static org.junit.jupiter.api.Assertions.fail;

import java.util.stream.Stream;

import org.junit.jupiter.api.DisplayName;
import org.junit.jupiter.api.Test;
import org.junit.jupiter.params.ParameterizedTest;
import org.junit.jupiter.params.provider.Arguments;

    }

    @Nested
    @DisplayName("Constructor createDisposition calculation")
    class CreateDispositionTests {
        static java.util.stream.Stream<Arguments> flagsProvider() {
            return java.util.stream.Stream.of(
                    Arguments.of(SmbConstants.O_TRUNC | SmbConstants.O_CREAT, SmbComNTCreateAndX.FILE_OVERWRITE_IF),

    }

    /**
     * Traverses resources contained in a ZIP file input stream.
     * <p>
     * Of the resources in the input stream, only those with paths starting with the specified prefix are traversed.
     * The handler receives the entry name with the prefix removed. For example, if the prefix is <code>/aaa/bbb/</code>
     * and the input stream contains a resource <code>/aaa/bbb/ccc/ddd/eee.txt</code>, the handler receives

     *
     * @param id the backup file ID to download
     * @return stream response containing the backup file data
     */
    // GET /api/admin/backup/file/{id}
    @Execute
    public StreamResponse get$file(final String id) {
        final FessConfig fessConfig = ComponentUtil.getFessConfig();
        if (stream(fessConfig.getIndexBackupAllTargets()).get(stream -> stream.anyMatch(s -> s.equals(id)))) {

 * is deleted when the stream is closed.
 */
public class TemporaryFileInputStream extends InputStream {

    private final File tempFile;

    private final FileInputStream fileInputStream;

    /**
     * A class that provides an input stream for reading from a temporary file.

        if (StringUtil.isBlank(slackWebhookUrls)) {
            return;
        }
        final String body = toSlackMessage(discloser);
        StreamUtil.split(slackWebhookUrls, "[,\\s]").of(stream -> stream.filter(StringUtil::isNotBlank).forEach(url -> {
            try (CurlResponse response = Curl.post(url).header("Content-Type", "application/json").body(body).execute()) {
                if (response.getHttpStatusCode() == 200) {

        });

        userBhv.selectCursor(cb -> cb.query().setGroups_Equal(group.getId()), entity -> {
            entity.setGroups(
                    stream(entity.getGroups()).get(stream -> stream.filter(s -> !s.equals(group.getId())).toArray(n -> new String[n])));
            userBhv.insertOrUpdate(entity);
        });

    }

    /**

        this.useFilename = useFilename;
    }

    /**
     * Sets whether to use the filename for MIME type detection when the stream is octet-stream.
     *
     * @param useFilenameOnOctetStream true to use the filename for MIME type detection when the stream is octet-stream; false otherwise.
     */
    public void setUseFilenameOnOctetStream(final boolean useFilenameOnOctetStream) {

     */
    protected WriterUtil() {
    }

    /**
     * Creates a {@link Writer} to output to a stream with the specified encoding.
     *
     * @param os the stream (must not be {@literal null})
     * @param encoding the encoding (must not be {@literal null} or empty)
     * @return a {@link Writer} to output to the stream
     */
    public static Writer create(final OutputStream os, final String encoding) {