import org.cactoos.io.TeeInput; //导入依赖的package包/类
@Override
public File export() throws IOException, URISyntaxException {
    final File file = File.createTempFile("report", ".zip");
    new LengthOf(
        new TeeInput(
            new InputOf(
                new URI(
                    this.req
                        .fetch()
                        .as(RestResponse.class)
                        .assertStatus(HttpURLConnection.HTTP_MOVED_TEMP)
                        .headers()
                        .get(HttpHeaders.LOCATION)
                        .get(0)
                )
            ),
            new OutputTo(
                file
            )
        )
    ).value();
    return file;
}
 

import org.cactoos.io.TeeInput; //导入依赖的package包/类
/**
 * Main can print a simple text.
 * @throws Exception If some problem inside
 */
public void testSimpleCompilation() throws Exception {
    final CompileMojo mojo = new CompileMojo();
    this.temp.create();
    final File src = this.temp.newFolder();
    this.setVariableValueToObject(mojo, "sourceDirectory", src);
    new LengthOf(
        new TeeInput(
            new InputOf(
                "type Pixel:\n  Pixel moveTo(Integer x, Integer y)"
            ),
            new OutputTo(new File(src, "main.eo"))
        )
    ).value();
    final File target = this.temp.newFolder();
    this.setVariableValueToObject(mojo, "targetDirectory", target);
    this.setVariableValueToObject(mojo, "project", new MavenProjectStub());
    mojo.execute();
    MatcherAssert.assertThat(
        new File(target, "Pixel.java").exists(),
        Matchers.is(true)
    );
}
 

import org.cactoos.io.TeeInput; //导入依赖的package包/类
/**
 * XMLDocument can find with XPath with custom namespaces.
 * @throws Exception If something goes wrong inside
 */
@Test
public void findsWithXpathWithCustomNamespace() throws Exception {
    final File file = new File(Files.createTempDir(), "x.xml");
    new LengthOf(
        new TeeInput(
            "<a xmlns='urn:foo'><b>\u0433!</b></a>",
            file
        )
    ).value();
    final XML doc = new XMLDocument(file).registerNs("f", "urn:foo");
    MatcherAssert.assertThat(
        doc.nodes("/f:a/f:b[.='\u0433!']"),
        Matchers.hasSize(1)
    );
    MatcherAssert.assertThat(
        doc.xpath("//f:b/text()").get(0),
        Matchers.equalTo("\u0433!")
    );
}
 

import org.cactoos.io.TeeInput; //导入依赖的package包/类
/**
 * TkBadge can render an SVG badge.
 * @throws Exception If some problem inside
 */
@Test
public void rendersSvgBadge() throws Exception {
    MatcherAssert.assertThat(
        XhtmlMatchers.xhtml(
            new TextOf(
                new TeeInput(
                    new InputOf(
                        new RsPrint(
                            new TkBadge(new FakeBase()).act(
                                new RqFake(
                                    new ListOf<>(
                                        "GET /?u=http://www.yegor256.com",
                                        "Host: www.rehttp.net"
                                    ),
                                    ""
                                )
                            )
                        ).printBody()
                    ),
                    new OutputTo(new File("target/rehttp.svg"))
                )
            ).asString()
        ),
        XhtmlMatchers.hasXPath("/svg:svg//svg:path")
    );
}
 

import org.cactoos.io.TeeInput; //导入依赖的package包/类
/**
 * Save report.
 * @param target Target dir
 * @throws IOException If fails
 */
public void save(final Path target) throws IOException {
    final XML xml = new StrictXML(
        new ReportWithStatistics(
            new IoCheckedScalar<>(
                new Reduced<>(
                    this.xml(),
                    (doc, xsl) -> xsl.transform(doc),
                    this.post
                )
            ).value()
        ),
        Report.SCHEMA
    );
    new LengthOf(
        new TeeInput(
            xml.toString(),
            target.resolve(
                String.format("%s.xml", this.metric)
            )
        )
    ).intValue();
    new LengthOf(
        new TeeInput(
            Report.STYLESHEET.transform(xml).toString(),
            target.resolve(
                String.format("%s.html", this.metric)
            )
        )
    ).intValue();
}
 

import org.cactoos.io.TeeInput; //导入依赖的package包/类
/**
 * Copy resource.
 * @param name The name of resource
 * @throws IOException If fails
 */
private void copy(final String name) throws IOException {
    new IoCheckedScalar<>(
        new LengthOf(
            new TeeInput(
                new ResourceOf(String.format("org/jpeek/%s", name)),
                this.output.resolve(name)
            )
        )
    ).value();
}
 

import org.cactoos.io.TeeInput; //导入依赖的package包/类
/**
 * Save file.
 * @param data Content
 * @param name The name of destination file
 * @throws IOException If fails
 */
private void save(final String data, final String name) throws IOException {
    new IoCheckedScalar<>(
        new LengthOf(
            new TeeInput(
                data,
                this.output.resolve(name)
            )
        )
    ).value();
}
 

import org.cactoos.io.TeeInput; //导入依赖的package包/类
@Override
public void start(final Environment env) throws IOException {
    new LengthOf(
        new TeeInput(this.command, new OutputTo(this.output))
    ).value();
    this.callback.onExit(0);
}
 

import org.cactoos.io.TeeInput; //导入依赖的package包/类
/**
 * TextResource should be able to read files as text.
 * @throws Exception If something goes wrong.
 */
@Test
public void readsFileAsText() throws Exception {
    final String text = "<a xmlns='urn:foo'><b>\u0433!</b></a>";
    final File file = new File(Files.createTempDir(), "dummy.xml");
    new LengthOf(new TeeInput(text, file)).value();
    MatcherAssert.assertThat(
        new TextResource(file).toString(),
        Matchers.is(text)
    );
}
 

import org.cactoos.io.TeeInput; //导入依赖的package包/类
/**
 * FileSources can resolve resource.
 * @throws Exception If something goes wrong inside
 */
@Test
public void sourcesResolvedFromDir() throws Exception {
    final File file = new File(Files.createTempDir(), "dummy.xml");
    new LengthOf(new TeeInput("test", file)).value();
    MatcherAssert.assertThat(
        new FileSources().resolve(file.getAbsolutePath(), null),
        Matchers.notNullValue()
    );
}
 

import org.cactoos.io.TeeInput; //导入依赖的package包/类
@Override
public Func<String, Response> apply(final String group,
    final String artifact) throws IOException {
    final String grp = group.replace(".", "/");
    final Path input = this.sources.resolve(grp).resolve(artifact);
    if (Files.exists(input)) {
        throw new IllegalStateException(
            String.format(
                "The input directory for %s:%s already exists: %s",
                group, artifact, input
            )
        );
    }
    final String version = new XMLDocument(
        new TextOf(
            new URL(
                String.format(
                    // @checkstyle LineLength (1 line)
                    "http://repo1.maven.org/maven2/%s/%s/maven-metadata.xml",
                    grp, artifact
                )
            )
        ).asString()
    ).xpath("/metadata/versioning/latest/text()").get(0);
    final String name = String.format("%s-%s.jar", artifact, version);
    new IoCheckedScalar<>(
        new LengthOf(
            new TeeInput(
                new URL(
                    String.format(
                        "http://repo1.maven.org/maven2/%s/%s/%s/%s",
                        grp, artifact, version, name
                    )
                ),
                input.resolve(name)
            )
        )
    ).value();
    try {
        final File none = new File("/dev/null");
        final int exit = new ProcessBuilder()
            .redirectOutput(ProcessBuilder.Redirect.to(none))
            .redirectInput(ProcessBuilder.Redirect.from(none))
            .redirectError(ProcessBuilder.Redirect.to(none))
            .directory(input.toFile())
            .command("unzip", name)
            .start()
            .waitFor();
        if (exit != 0) {
            throw new IllegalStateException(
                String.format(
                    "Failed to unzip %s:%s archive, exit code %d",
                    group, artifact, exit
                )
            );
        }
    } catch (final InterruptedException ex) {
        Thread.currentThread().interrupt();
        throw new IllegalStateException(ex);
    }
    final Path output = this.target.resolve(grp).resolve(artifact);
    if (Files.exists(output)) {
        throw new IllegalStateException(
            String.format(
                "The output directory for %s:%s already exists: %s",
                group, artifact, output
            )
        );
    }
    new App(input, output).analyze();
    synchronized (this.sources) {
        new Results().add(String.format("%s:%s", group, artifact), output);
        new Mistakes().add(output);
        new Sigmas().add(output);
    }
    return new TypedPages(new Pages(output));
}
 

import org.cactoos.io.TeeInput; //导入依赖的package包/类
@Override
public Iterable<Path> files() throws IOException {
    final Path temp = Files.createTempDirectory("jpeek");
    final Iterable<String> sources = new Mapped<>(
        cls -> String.format("%s.java", cls),
        this.classes
    );
    new IoCheckedScalar<>(
        new And(
            java -> {
                new LengthOf(
                    new TeeInput(
                        new ResourceOf(
                            String.format("org/jpeek/samples/%s", java)
                        ),
                        temp.resolve(java)
                    )
                ).value();
            },
            sources
        )
    ).value();
    if (sources.iterator().hasNext()) {
        final int exit;
        try {
            exit = new ProcessBuilder()
                .redirectOutput(ProcessBuilder.Redirect.INHERIT)
                .redirectInput(ProcessBuilder.Redirect.INHERIT)
                .redirectError(ProcessBuilder.Redirect.INHERIT)
                .directory(temp.toFile())
                .command(
                    new ListOf<>(
                        new Joined<String>(
                            new ListOf<>("javac"),
                            sources
                        )
                    )
                )
                .start()
                .waitFor();
        } catch (final InterruptedException ex) {
            Thread.currentThread().interrupt();
            throw new IllegalStateException(ex);
        }
        if (exit != 0) {
            throw new IllegalStateException(
                String.format("javac failed with exit code %d", exit)
            );
        }
    }
    return new DefaultBase(temp).files();
}
 

import org.cactoos.io.TeeInput; //导入依赖的package包/类
/**
 * Compile it to Java and save.
 * @throws IOException If fails
 */
public void compile() throws IOException {
    final String[] lines = new TextOf(this.input).asString().split("\n");
    final ANTLRErrorListener errors = new BaseErrorListener() {
        // @checkstyle ParameterNumberCheck (10 lines)
        @Override
        public void syntaxError(final Recognizer<?, ?> recognizer,
            final Object symbol, final int line,
            final int position, final String msg,
            final RecognitionException error) {
            throw new CompileException(
                String.format(
                    "[%d:%d] %s: \"%s\"",
                    line, position, msg, lines[line - 1]
                ),
                error
            );
        }
    };
    final ProgramLexer lexer = new ProgramLexer(
        CharStreams.fromStream(this.input.stream())
    );
    lexer.removeErrorListeners();
    lexer.addErrorListener(errors);
    final ProgramParser parser = new ProgramParser(
        new CommonTokenStream(lexer)
    );
    parser.removeErrorListeners();
    parser.addErrorListener(errors);
    final Tree tree = parser.program().ret;
    new IoCheckedScalar<>(
        new And(
            tree.java().entrySet(),
            path -> {
                new LengthOf(
                    new TeeInput(
                        path.getValue(),
                        this.target.apply(path.getKey())
                    )
                ).value();
            }
        )
    ).value();
}
 

import org.cactoos.io.TeeInput; //导入依赖的package包/类
/**
 * Ctor.
 * @param path Directory to work in
 * @throws IOException If fails
 */
@SuppressWarnings("PMD.ConstructorOnlyInitializesOrCallOtherConstructors")
public Sshd(final File path) throws IOException {
    this.dir = path;
    final File rsa = new File(this.dir, "host_rsa_key");
    new LengthOf(
        new TeeInput(
            new ResourceOf("com/jcabi/ssh/ssh_host_rsa_key"), rsa
        )
    ).value();
    final File keys = new File(this.dir, "authorized");
    new LengthOf(
        new TeeInput(
            new ResourceOf("com/jcabi/ssh/authorized_keys"), keys
        )
    ).value();
    new VerboseProcess(
        new ProcessBuilder().command(
            "chmod", "600",
            keys.getAbsolutePath(),
            rsa.getAbsolutePath()
        )
    ).stdout();
    this.prt = Sshd.reserve();
    this.process = new ProcessBuilder().command(
        "/usr/sbin/sshd",
        "-p",
        Integer.toString(this.prt),
        "-h",
        rsa.getAbsolutePath(),
        "-D",
        "-e",
        "-o", String.format("PidFile=%s", new File(this.dir, "pid")),
        "-o", "UsePAM=no",
        "-o", String.format("AuthorizedKeysFile=%s", keys),
        "-o", "StrictModes=no"
    ).start();
    new Thread(() -> new VerboseProcess(this.process).stdout()).start();
    Runtime.getRuntime().addShutdownHook(new Thread(this::close));
    try {
        TimeUnit.SECONDS.sleep(1L);
    } catch (final InterruptedException ex) {
        Thread.currentThread().interrupt();
        throw new IllegalStateException(ex);
    }
}