Class ClassEnvironment

src/main/java/matcher/type/ClassEnvironment.java:45–642

import matcher.type.Signature.ClassSignature;

public final class ClassEnvironment implements ClassEnv {
	public void init(ProjectConfig config, DoubleConsumer progressReceiver) {
		final double cpInitCost = 0.05;
		final double classReadCost = 0.2;
		double progress = 0;

		inputsBeforeClassPath = config.hasInputsBeforeClassPath();
		nonObfuscatedClassPatternA = config.getNonObfuscatedClassPatternA().isEmpty() ? null : Pattern.compile(config.getNonObfuscatedClassPatternA());
		nonObfuscatedClassPatternB = config.getNonObfuscatedClassPatternB().isEmpty() ? null : Pattern.compile(config.getNonObfuscatedClassPatternB());
		nonObfuscatedMemberPatternA = config.getNonObfuscatedMemberPatternA().isEmpty() ? null : Pattern.compile(config.getNonObfuscatedMemberPatternA());
		nonObfuscatedMemberPatternB = config.getNonObfuscatedMemberPatternB().isEmpty() ? null : Pattern.compile(config.getNonObfuscatedMemberPatternB());

		try {
			for (int i = 0; i < 2; i++) {
				if ((i == 0) != inputsBeforeClassPath) {
					// class path indexing
					initClassPath(config.getSharedClassPath(), inputsBeforeClassPath);
					CompletableFuture.allOf(
							CompletableFuture.runAsync(() -> extractorA.processClassPath(config.getClassPathA(), inputsBeforeClassPath)),
							CompletableFuture.runAsync(() -> extractorB.processClassPath(config.getClassPathB(), inputsBeforeClassPath))).get();
					progress += cpInitCost;
				} else {
					// async class reading
					CompletableFuture.allOf(
							CompletableFuture.runAsync(() -> extractorA.processInputs(config.getPathsA(), nonObfuscatedClassPatternA)),
							CompletableFuture.runAsync(() -> extractorB.processInputs(config.getPathsB(), nonObfuscatedClassPatternB))).get();
					progress += classReadCost;
				}

				progressReceiver.accept(progress);
			}

			// synchronous feature extraction
			extractorA.process(nonObfuscatedMemberPatternA);
			progressReceiver.accept(0.8);

			extractorB.process(nonObfuscatedMemberPatternB);
			progressReceiver.accept(0.98);
		} catch (InterruptedException | ExecutionException | IOException e) {
			throw new RuntimeException(e);
		} finally {
			classPathIndex.clear();
			openFileSystems.forEach(Util::closeSilently);
			openFileSystems.clear();
		}

		progressReceiver.accept(1);
	}

	private void initClassPath(Collection<Path> sharedClassPath, boolean checkExisting) throws IOException {
		for (Path archive : sharedClassPath) {
			cpFiles.add(new InputFile(archive));

			FileSystem fs = Util.iterateJar(archive, false, file -> {
				String name = file.toAbsolutePath().toString();
				if (!name.startsWith("/") || !name.endsWith(".class") || name.startsWith("//")) throw new RuntimeException("invalid path: "+archive+" ("+name+")");
				name = name.substring(1, name.length() - ".class".length());