from botocore.session import get_session

from client_grants import ClientGrantsCredentialProvider

boto3.set_stream_logger('boto3.resources', logging.DEBUG)

bc_session = get_session()
bc_session.get_component('credential_provider').insert_before(
    'env',
    ClientGrantsCredentialProvider('NZLOOFRSluw9RfIkuHGqfk1HFp4a',
                                   '0Z4VTG8uJBSekn42HE40DK9vQb4a'),
)

        if (name.endsWith(JOB_EXECUTOR_SUFFIX)) {
            return getComponent(name);
        }
        return getComponent("script" + JOB_EXECUTOR_SUFFIX);
    }

    /**
     * Gets the file type helper component.
     * @return The file type helper.
     */
    public static FileTypeHelper getFileTypeHelper() {
        return getComponent(FILE_TYPE_HELPER);
    }

    /**

{"index":{"_index":"fess_config.scheduled_job","_id":"log_purger"}}

     * Test that MsWordExtractor properly closes resources on successful extraction.
     */
    public void test_MsWordExtractor_closesResourcesOnSuccess() throws IOException {
        final MsWordExtractor extractor = container.getComponent("msWordExtractor");
        final AtomicBoolean streamClosed = new AtomicBoolean(false);

        try (final InputStream originalStream = ResourceUtil.getResourceAsStream("extractor/msoffice/test.doc")) {

                    rule.setResponseProcessor(container.getComponent("defaultResponseProcessor"));
                });

        crawler = container.getComponent("crawler");
        dataService = container.getComponent("dataService");
        urlQueueService = container.getComponent("urlQueueService");
        fileTransformer = container.getComponent("fileTransformer");

    }

        clientFactory.addClient("smb1:.*", container.getComponent("smb1Client"));
        clientFactory.addClient("ftp:.*", container.getComponent("ftpClient"));
        clientFactory.addClient("storage:.*", container.getComponent("storageClient"));
    }

    public void test_getClient() {
        String url;
        CrawlerClient client;

        url = "http://hoge.com/";
        client = clientFactory.getClient(url);

                case WEB -> {
                    final WebConfigService webConfigService = ComponentUtil.getComponent(WebConfigService.class);
                    yield webConfigService.getWebConfig(id).get();
                }
                case FILE -> {
                    final FileConfigService fileConfigService = ComponentUtil.getComponent(FileConfigService.class);
                    yield fileConfigService.getFileConfig(id).get();

        ;
        includeFilter = container.getComponent("includeFilter");
        includeFilter.setIncludeFilteringPattern("$1$2$3.*");
        excludeFilter = container.getComponent("excludeFilter");
        excludeFilter.setExcludeFilteringPattern("$1$2$3.*");
        domainFilter = container.getComponent("domainFilter");
        domainFilter.setIncludeFilteringPattern("http://$2/.*");

        sitemap.setLoc("https://example.com/page1");

        SitemapSet sitemapSet = new SitemapSet();
        sitemapSet.addSitemap(sitemap);

        when(crawlerContainer.getComponent("sitemapsHelper")).thenReturn(sitemapsHelper);
        try {
            when(sitemapsHelper.parse(any(InputStream.class))).thenReturn(sitemapSet);
        } catch (Exception e) {

                .singleton("tikaExtractor", TikaExtractor.class);
        textTransformer = container.getComponent("textTransformer");
        textTransformer.setName("textTransformer");
        ExtractorFactory extractorFactory = container.getComponent("extractorFactory");
        TikaExtractor tikaExtractor = container.getComponent("tikaExtractor");
        extractorFactory.addExtractor("text/plain", tikaExtractor);