/* * Decompiled with CFR 0.152. * * Could not load the following classes: * com.l7tech.common.log.HybridDiagnosticContext * com.l7tech.common.log.HybridDiagnosticContext$SavedDiagnosticContext * com.l7tech.common.mime.ContentTypeHeader * com.l7tech.common.mime.NoSuchPartException * com.l7tech.common.mime.StashManager * com.l7tech.gateway.common.LicenseException * com.l7tech.identity.User * com.l7tech.identity.UserBean * com.l7tech.json.InvalidJsonException * com.l7tech.json.JSONData * com.l7tech.json.JSONFactory * com.l7tech.json.JsonSchemaVersion * com.l7tech.message.HttpRequestKnob * com.l7tech.message.HttpRequestKnobAdapter * com.l7tech.message.HttpResponseKnob * com.l7tech.message.Message * com.l7tech.policy.assertion.Assertion * com.l7tech.policy.assertion.AssertionStatus * com.l7tech.policy.assertion.PolicyAssertionException * com.l7tech.policy.assertion.composite.CompositeAssertion * com.l7tech.policy.wsp.WspReader * com.l7tech.policy.wsp.WspReader$Visibility * com.l7tech.security.token.OpaqueSecurityToken * com.l7tech.security.token.SecurityToken * com.l7tech.util.Charsets * com.l7tech.util.ExceptionUtils * com.l7tech.util.IOUtils * com.l7tech.util.Pair * com.l7tech.util.ResourceUtils * org.jetbrains.annotations.Nullable */ package com.l7tech.server.service; import com.l7tech.common.log.HybridDiagnosticContext; import com.l7tech.common.mime.ContentTypeHeader; import com.l7tech.common.mime.NoSuchPartException; import com.l7tech.common.mime.StashManager; import com.l7tech.gateway.common.LicenseException; import com.l7tech.identity.User; import com.l7tech.identity.UserBean; import com.l7tech.json.InvalidJsonException; import com.l7tech.json.JSONData; import com.l7tech.json.JSONFactory; import com.l7tech.json.JsonSchemaVersion; import com.l7tech.message.HttpRequestKnob; import com.l7tech.message.HttpRequestKnobAdapter; import com.l7tech.message.HttpResponseKnob; import com.l7tech.message.Message; import com.l7tech.policy.assertion.Assertion; import com.l7tech.policy.assertion.AssertionStatus; import com.l7tech.policy.assertion.PolicyAssertionException; import com.l7tech.policy.assertion.composite.CompositeAssertion; import com.l7tech.policy.wsp.WspReader; import com.l7tech.security.token.OpaqueSecurityToken; import com.l7tech.security.token.SecurityToken; import com.l7tech.server.StashManagerFactory; import com.l7tech.server.identity.AuthenticationResult; import com.l7tech.server.message.PolicyEnforcementContext; import com.l7tech.server.message.PolicyEnforcementContextFactory; import com.l7tech.server.policy.ServerPolicyException; import com.l7tech.server.policy.ServerPolicyFactory; import com.l7tech.server.policy.assertion.ServerAssertion; import com.l7tech.server.service.MigrationBundleBootstrapService; import com.l7tech.server.service.a; import com.l7tech.server.service.d; import com.l7tech.server.service.e; import com.l7tech.server.service.f; import com.l7tech.util.Charsets; import com.l7tech.util.ExceptionUtils; import com.l7tech.util.IOUtils; import com.l7tech.util.Pair; import com.l7tech.util.ResourceUtils; import java.io.File; import java.io.FileInputStream; import java.io.IOException; import java.io.InputStream; import java.io.PipedInputStream; import java.io.PipedOutputStream; import java.nio.charset.StandardCharsets; import java.nio.file.FileVisitOption; import java.nio.file.Files; import java.nio.file.Path; import java.nio.file.attribute.BasicFileAttributes; import java.util.ArrayList; import java.util.HashMap; import java.util.HashSet; import java.util.List; import java.util.Map; import java.util.Set; import java.util.concurrent.ExecutorService; import java.util.concurrent.Executors; import java.util.concurrent.atomic.AtomicBoolean; import java.util.function.BiPredicate; import java.util.function.Supplier; import java.util.logging.Level; import java.util.logging.Logger; import java.util.stream.Stream; import org.jetbrains.annotations.Nullable; public class GraphmanBundleProcessor { private static final Logger a; private static final byte[] b; private static final String c; private static final String d; private static final String e; private static final String f; private static final String g; private static final String h; private static final String i; private final ServerPolicyFactory j; private final WspReader k; private final StashManagerFactory l; private ExecutorService m; private boolean n; private boolean o; private File p; private String q; private d r; private String[] s; private static final String[] t; public GraphmanBundleProcessor(ServerPolicyFactory serverPolicyFactory, WspReader wspReader, StashManagerFactory stashManagerFactory) { this.j = serverPolicyFactory; this.k = wspReader; this.l = stashManagerFactory; this.n = true; this.o = false; } public void setBootstrapConfig(String string, String string2, boolean bl2, boolean bl3) { this.p = new File(string); this.q = string2; this.n = bl2; this.o = bl3; } /* * Loose catch block * Enabled force condition propagation * Lifted jumps to return sites */ public void bootstrapBundles(UserBean userBean) throws MigrationBundleBootstrapService.BundleInstallFailedException { ServerAssertion serverAssertion; block32: { block31: { block33: { if (this.p == null) return; if (!this.p.exists()) return; break block33; catch (Throwable throwable) { throw GraphmanBundleProcessor.a(throwable); } } try { if (this.p.isDirectory()) break block31; return; catch (Throwable throwable) { throw GraphmanBundleProcessor.a(throwable); } } catch (Throwable throwable) { throw GraphmanBundleProcessor.a(throwable); } } serverAssertion = null; serverAssertion = this.a(); this.r = new d(this.p, this.b(serverAssertion)); if (this.n) { Stream stream = Files.list(this.p.toPath()).sorted(); try { for (Path path2 : stream.toList()) { this.a(serverAssertion, userBean, path2.toFile()); } } catch (Throwable throwable) { if (stream == null) throw throwable; try { stream.close(); throw throwable; } catch (Throwable throwable2) { throwable.addSuppressed(throwable2); } throw throwable; } try { if (stream != null) { stream.close(); } break block32; } catch (Throwable throwable) { throw GraphmanBundleProcessor.a(throwable); } } BiPredicate biPredicate = (path, basicFileAttributes) -> { boolean bl2; block5: { block4: { try { try { if (!basicFileAttributes.isRegularFile() || !path.toString().endsWith(t[13])) break block4; } catch (RuntimeException runtimeException) { throw GraphmanBundleProcessor.a(runtimeException); } bl2 = true; break block5; } catch (RuntimeException runtimeException) { throw GraphmanBundleProcessor.a(runtimeException); } } bl2 = false; } return bl2; }; Stream stream = Files.find(this.p.toPath(), Integer.MAX_VALUE, biPredicate, new FileVisitOption[0]).sorted(); try { for (Path path3 : stream.toList()) { this.a(serverAssertion, userBean, path3.toFile()); } } catch (Throwable throwable) { if (stream == null) throw throwable; try { stream.close(); throw throwable; } catch (Throwable throwable3) { throwable.addSuppressed(throwable3); } throw throwable; } try { if (stream != null) { stream.close(); } } catch (Throwable throwable) { throw GraphmanBundleProcessor.a(throwable); } } try { ResourceUtils.closeQuietly(serverAssertion); if (this.m == null) return; this.m.shutdown(); return; } catch (Throwable throwable) { throw GraphmanBundleProcessor.a(throwable); } catch (LicenseException | PolicyAssertionException | IOException throwable) { try { throw new MigrationBundleBootstrapService.BundleInstallFailedException(t[26] + ExceptionUtils.getMessage((Throwable)throwable), throwable); } catch (Throwable throwable4) { try { ResourceUtils.closeQuietly(serverAssertion); if (this.m == null) throw throwable4; this.m.shutdown(); throw throwable4; } catch (Throwable throwable5) { throw GraphmanBundleProcessor.a(throwable5); } } } } private void a(ServerAssertion serverAssertion, UserBean userBean, File file) throws MigrationBundleBootstrapService.BundleInstallFailedException { try { HashSet hashSet = new HashSet(); if (file.isDirectory()) { for (Pair> pair : this.b(file, hashSet)) { this.a(serverAssertion, userBean, (File)pair.left, (Map)pair.right, hashSet); } } else { this.a(serverAssertion, userBean, file, this.a(file, hashSet), hashSet); } } catch (GraphmanBundleException graphmanBundleException) { block7: { try { if (!this.o) break block7; a.log(Level.WARNING, ExceptionUtils.getDebugException((Throwable)graphmanBundleException), () -> { String[] stringArray = t; return stringArray[54] + String.valueOf(file) + stringArray[1] + ExceptionUtils.getMessageWithCause((Throwable)graphmanBundleException); }); } catch (GraphmanBundleException graphmanBundleException2) { throw GraphmanBundleProcessor.a(graphmanBundleException2); } } throw new MigrationBundleBootstrapService.FatalBundleInstallFailedException(t[31] + String.valueOf(file), graphmanBundleException); } } private void a(ServerAssertion serverAssertion, UserBean userBean, File file, Map map, Set set) throws MigrationBundleBootstrapService.BundleInstallFailedException { try { try { if (!map.isEmpty()) { this.a(serverAssertion, userBean, map, set); } } catch (MigrationBundleBootstrapService.BundleInstallFailedException bundleInstallFailedException) { throw GraphmanBundleProcessor.a(bundleInstallFailedException); } } catch (GraphmanBundleException graphmanBundleException) { block8: { try { if (!this.o) break block8; a.log(Level.WARNING, ExceptionUtils.getDebugException((Throwable)graphmanBundleException), () -> { String[] stringArray = t; return stringArray[54] + String.valueOf(file) + stringArray[22] + ExceptionUtils.getMessageWithCause((Throwable)graphmanBundleException); }); } catch (GraphmanBundleException graphmanBundleException2) { throw GraphmanBundleProcessor.a(graphmanBundleException2); } } throw new MigrationBundleBootstrapService.FatalBundleInstallFailedException(t[54] + String.valueOf(file), graphmanBundleException); } } /* * Loose catch block * Enabled force condition propagation * Lifted jumps to return sites */ private void a(ServerAssertion serverAssertion, UserBean userBean, Map map, Set set) throws GraphmanBundleException, MigrationBundleBootstrapService.BundleInstallFailedException { HybridDiagnosticContext.SavedDiagnosticContext savedDiagnosticContext = HybridDiagnosticContext.save(); try (PolicyEnforcementContext policyEnforcementContext = PolicyEnforcementContextFactory.createPolicyEnforcementContext(new Message(), new Message());){ String string; block18: { String[] stringArray = t; policyEnforcementContext.setVariable(stringArray[9], this.q); policyEnforcementContext.setVariable(stringArray[43], this.a(serverAssertion, GraphmanBundleProcessor.b(map.get(stringArray[28])))); policyEnforcementContext.setVariable(stringArray[56], map); this.a(policyEnforcementContext.getRequest(), set); policyEnforcementContext.getRequest().attachHttpRequestKnob((HttpRequestKnob)new HttpRequestKnobAdapter()); policyEnforcementContext.getResponse().attachHttpResponseKnob((HttpResponseKnob)new a(this)); policyEnforcementContext.getDefaultAuthenticationContext().addAuthenticationResult(new AuthenticationResult((User)userBean, (SecurityToken)new OpaqueSecurityToken())); AssertionStatus assertionStatus = serverAssertion.checkRequest(policyEnforcementContext); int n2 = policyEnforcementContext.getResponse().getHttpResponseKnob().getStatus(); string = new String(IOUtils.slurpStream((InputStream)policyEnforcementContext.getResponse().getMimeKnob().getEntireMessageBodyAsInputStream()), Charsets.UTF8); a.log(Level.INFO, () -> { String string2 = string; int n3 = n2; String string3 = String.valueOf(assertionStatus); String[] stringArray = t; return stringArray[40] + string3 + stringArray[37] + n3 + stringArray[27] + string2; }); if (!AssertionStatus.NONE.equals(assertionStatus)) throw new GraphmanBundleException(t[10] + String.valueOf(assertionStatus) + t[33] + n2); try { if (n2 == 200) break block18; throw new GraphmanBundleException(t[10] + String.valueOf(assertionStatus) + t[33] + n2); catch (Throwable throwable) { throw GraphmanBundleProcessor.a(throwable); } } catch (Throwable throwable) { throw GraphmanBundleProcessor.a(throwable); } } this.a(string); return; } catch (NoSuchPartException | PolicyAssertionException | IOException throwable) { String[] stringArray = t; throw new GraphmanBundleException(stringArray[18] + ExceptionUtils.getMessage((Throwable)throwable), throwable); } catch (RuntimeException runtimeException) { try { if (!(runtimeException.getCause() instanceof IOException)) throw runtimeException; throw new GraphmanBundleException(t[48] + ExceptionUtils.getMessage((Throwable)runtimeException), runtimeException); } catch (Throwable throwable) { throw GraphmanBundleProcessor.a(throwable); } } finally { HybridDiagnosticContext.restore((HybridDiagnosticContext.SavedDiagnosticContext)savedDiagnosticContext); } } /* * Loose catch block * Enabled force condition propagation * Lifted jumps to return sites */ private void a(String string) throws GraphmanBundleException { try { Map map = GraphmanBundleProcessor.b(string); if (map.containsKey(t[8])) throw new GraphmanBundleException(t[35]); try { if (!this.a(GraphmanBundleProcessor.b(map.get(t[52])))) return; throw new GraphmanBundleException(t[35]); catch (InvalidJsonException invalidJsonException) { throw GraphmanBundleProcessor.a(invalidJsonException); } } catch (InvalidJsonException invalidJsonException) { throw GraphmanBundleProcessor.a(invalidJsonException); } } catch (InvalidJsonException | ClassCastException | IllegalStateException throwable) { a.log(Level.INFO, throwable, () -> GraphmanBundleProcessor.lambda$assertResponse$4((Exception)throwable)); throw new GraphmanBundleException(t[24]); } } private boolean a(Map map) { try { if (map == null) { return true; } } catch (RuntimeException runtimeException) { throw GraphmanBundleProcessor.a(runtimeException); } for (Map.Entry entry : map.entrySet()) { String[] stringArray; Map map2 = GraphmanBundleProcessor.a(entry.getValue()); List list = GraphmanBundleProcessor.d(map2.get((stringArray = t)[30])); if (list == null) continue; for (Object object : list) { Map map3 = GraphmanBundleProcessor.a(object); try { if (!t[59].equals(map3.get(t[17]))) continue; return true; } catch (RuntimeException runtimeException) { throw GraphmanBundleProcessor.a(runtimeException); } } } return false; } private ServerAssertion a() throws IOException, LicenseException, ServerPolicyException { String string = t[0]; Assertion assertion = this.k.parseStrictly(string, WspReader.Visibility.omitDisabled); return this.j.compilePolicy(assertion, false); } private Assertion a(ServerAssertion serverAssertion) { return (Assertion)((CompositeAssertion)serverAssertion.getAssertion()).getChildren().get(0); } private String a(ServerAssertion serverAssertion, Map map) throws MigrationBundleBootstrapService.BundleInstallFailedException { block13: { int n2; String[] stringArray; block15: { block14: { if (this.s == null) { try { String[] stringArray2; block12: { Supplier supplier; block11: { String[] stringArray3 = t; Supplier supplier2 = (Supplier)this.a(serverAssertion).meta().get(stringArray3[25]); Supplier supplier3 = (Supplier)this.a(serverAssertion).meta().get(stringArray3[36]); supplier = (Supplier)this.a(serverAssertion).meta().get(stringArray3[41]); try { GraphmanBundleProcessor graphmanBundleProcessor = this; if (supplier2 == null) break block11; String[] stringArray4 = new String[2]; stringArray4[0] = (String)supplier2.get(); stringArray2 = stringArray4; stringArray4[1] = (String)supplier3.get(); break block12; } catch (RuntimeException runtimeException) { throw GraphmanBundleProcessor.a(runtimeException); } } String[] stringArray5 = new String[1]; stringArray2 = stringArray5; stringArray5[0] = (String)supplier.get(); } graphmanBundleProcessor.s = stringArray2; } catch (RuntimeException runtimeException) { String[] stringArray6 = t; throw new MigrationBundleBootstrapService.BundleInstallFailedException(stringArray6[14] + ExceptionUtils.getMessage((Throwable)runtimeException), runtimeException); } } try { try { try { if (map == null || !t[2].equals(map.get(t[7]))) break block13; } catch (RuntimeException runtimeException) { throw GraphmanBundleProcessor.a(runtimeException); } stringArray = this.s; if (this.s.length <= 1) break block14; } catch (RuntimeException runtimeException) { throw GraphmanBundleProcessor.a(runtimeException); } n2 = 1; break block15; } catch (RuntimeException runtimeException) { throw GraphmanBundleProcessor.a(runtimeException); } } n2 = 0; } return stringArray[n2]; } return this.s[0]; } private Set b(ServerAssertion serverAssertion) { return (Set)this.a(serverAssertion).meta().get(t[44]); } private ExecutorService b() { try { if (this.m == null) { this.m = Executors.newSingleThreadExecutor(); } } catch (RuntimeException runtimeException) { throw GraphmanBundleProcessor.a(runtimeException); } return this.m; } private Map a(File file, Set set) throws MigrationBundleBootstrapService.BundleInstallFailedException, GraphmanBundleException { Map map; try { if (!file.getName().endsWith(t[55])) { return new HashMap(); } } catch (Throwable throwable) { throw GraphmanBundleProcessor.a(throwable); } String[] stringArray = t; a.log(Level.INFO, stringArray[11], file.getPath()); FileInputStream fileInputStream = new FileInputStream(file); try { Map map2 = GraphmanBundleProcessor.a(fileInputStream); map2.forEach((string, object) -> { block6: { block5: { try { if (!(object instanceof List)) break block5; this.r.preprocess(file.toPath(), (String)string, GraphmanBundleProcessor.c(object), set); break block6; } catch (RuntimeException runtimeException) { throw GraphmanBundleProcessor.a(runtimeException); } } try { if (!string.equals(t[28])) { a.log(Level.WARNING, t[60], new Object[]{file, string}); } } catch (RuntimeException runtimeException) { throw GraphmanBundleProcessor.a(runtimeException); } } }); map = map2; } catch (Throwable throwable) { try { try { ((InputStream)fileInputStream).close(); } catch (Throwable throwable2) { throwable.addSuppressed(throwable2); } throw throwable; } catch (IOException iOException) { stringArray = t; throw new MigrationBundleBootstrapService.BundleInstallFailedException(stringArray[46] + ExceptionUtils.getMessage((Throwable)iOException), iOException); } catch (InvalidJsonException | RuntimeException throwable3) { throw new GraphmanBundleException(t[20] + ExceptionUtils.getMessage((Throwable)throwable3), throwable3); } } ((InputStream)fileInputStream).close(); return map; } /* * Enabled aggressive block sorting * Enabled unnecessary exception pruning * Enabled aggressive exception aggregation */ private List>> b(File file, Set set) throws GraphmanBundleException, MigrationBundleBootstrapService.BundleInstallFailedException { BiPredicate biPredicate = (path, basicFileAttributes) -> { boolean bl2; block5: { block4: { try { try { if (!basicFileAttributes.isRegularFile() || !path.toString().endsWith(t[55])) break block4; } catch (RuntimeException runtimeException) { throw GraphmanBundleProcessor.a(runtimeException); } bl2 = true; break block5; } catch (RuntimeException runtimeException) { throw GraphmanBundleProcessor.a(runtimeException); } } bl2 = false; } return bl2; }; try { List>> list; String[] stringArray; ArrayList>> arrayList; Stream stream; block30: { List list2; block27: { stream = Files.find(file.toPath(), Integer.MAX_VALUE, biPredicate, new FileVisitOption[0]).sorted(); list2 = stream.toList(); arrayList = new ArrayList>>(); if (!list2.isEmpty()) break block27; ArrayList>> arrayList2 = arrayList; try { if (stream == null) return arrayList2; stream.close(); return arrayList2; } catch (Throwable throwable) { throw GraphmanBundleProcessor.a(throwable); } } try { stringArray = t; a.log(Level.INFO, stringArray[34], file.getPath()); AtomicBoolean atomicBoolean = new AtomicBoolean(true); HashMap> hashMap = new HashMap>(); String string = null; for (Path path2 : list2) { stringArray = t; a.log(Level.INFO, stringArray[3], path2); try (FileInputStream fileInputStream = new FileInputStream(path2.toFile());){ Map map; block29: { block28: { map = GraphmanBundleProcessor.a(fileInputStream); arrayList.add((Pair>)Pair.pair((Object)path2.toFile(), map)); String string3 = this.b(map); if (string == null) { string = string3; } try { if (string3.equals(string)) break block28; a.log(Level.INFO, t[23], path2); atomicBoolean.set(false); break block29; } catch (Throwable throwable) { throw GraphmanBundleProcessor.a(throwable); } } try { if (this.c(map)) { a.log(Level.INFO, t[32], path2); atomicBoolean.set(false); } } catch (Throwable throwable) { throw GraphmanBundleProcessor.a(throwable); } } map.forEach((string2, object) -> { block8: { block7: { try { try { if (!(object instanceof List)) break block7; this.r.preprocess(path2, (String)string2, GraphmanBundleProcessor.c(object), set); if (!atomicBoolean.get()) break block8; } catch (RuntimeException runtimeException) { throw GraphmanBundleProcessor.a(runtimeException); } GraphmanBundleProcessor.c(hashMap.computeIfAbsent((String)string2, string -> new ArrayList())).addAll(GraphmanBundleProcessor.c(object)); break block8; } catch (RuntimeException runtimeException) { throw GraphmanBundleProcessor.a(runtimeException); } } try { if (!string2.equals(t[58])) { a.log(Level.WARNING, t[42], new Object[]{path2, string2}); } } catch (RuntimeException runtimeException) { throw GraphmanBundleProcessor.a(runtimeException); } } }); } } if (!atomicBoolean.get()) break block30; stringArray = t; hashMap.put(stringArray[28], Map.of(stringArray[4], string)); list = List.of(Pair.pair((Object)file, hashMap)); } catch (Throwable throwable) { if (stream == null) throw throwable; try { stream.close(); throw throwable; } catch (Throwable throwable2) { throwable.addSuppressed(throwable2); } throw throwable; } try { if (stream == null) return list; stream.close(); return list; } catch (Throwable throwable) { throw GraphmanBundleProcessor.a(throwable); } } stringArray = t; a.log(Level.INFO, stringArray[53], file.getPath()); list = arrayList; try { if (stream == null) return list; stream.close(); return list; } catch (Throwable throwable) { throw GraphmanBundleProcessor.a(throwable); } } catch (IOException iOException) { String[] stringArray = t; throw new MigrationBundleBootstrapService.BundleInstallFailedException(stringArray[6] + ExceptionUtils.getMessage((Throwable)iOException), iOException); } catch (InvalidJsonException | RuntimeException throwable) { throw new GraphmanBundleException(t[21] + ExceptionUtils.getMessage((Throwable)throwable), throwable); } } private String b(Map map) { String string; block3: { Map map2; String[] stringArray; block2: { stringArray = t; map2 = GraphmanBundleProcessor.b(map.get(stringArray[28])); try { if (map2 != null) break block2; string = stringArray[29]; break block3; } catch (RuntimeException runtimeException) { throw GraphmanBundleProcessor.a(runtimeException); } } stringArray = t; string = GraphmanBundleProcessor.e(map2.getOrDefault(stringArray[4], stringArray[38])); } return string; } private boolean c(Map map) { boolean bl2; block5: { block4: { String[] stringArray = t; Map map2 = GraphmanBundleProcessor.b(map.get(stringArray[28])); try { try { if (map2 == null || map2.get(stringArray[45]) == null) break block4; } catch (RuntimeException runtimeException) { throw GraphmanBundleProcessor.a(runtimeException); } bl2 = true; break block5; } catch (RuntimeException runtimeException) { throw GraphmanBundleProcessor.a(runtimeException); } } bl2 = false; } return bl2; } private void a(Message message, Set set) throws IOException { try { if (set.isEmpty()) { return; } } catch (IOException iOException) { throw GraphmanBundleProcessor.a(iOException); } String[] stringArray = t; String string = stringArray[19] + System.currentTimeMillis(); String string2 = stringArray[47] + string; ContentTypeHeader contentTypeHeader = ContentTypeHeader.parseValue((String)(stringArray[50] + string)); PipedOutputStream pipedOutputStream = new PipedOutputStream(); StashManager stashManager = this.l.createStashManager(); f f2 = new f(pipedOutputStream); this.b().execute(() -> f2.write(set, string2)); message.initialize(stashManager, contentTypeHeader, (InputStream)new PipedInputStream(pipedOutputStream)); } private static Map b(String string) throws InvalidJsonException { JSONData jSONData = JSONFactory.INSTANCE.newJsonData(string, JsonSchemaVersion.DRAFT_V4); return GraphmanBundleProcessor.a(jSONData.getJsonObject()); } private static Map a(InputStream inputStream) throws IOException, InvalidJsonException { return GraphmanBundleProcessor.b(new String(IOUtils.slurpStream((InputStream)inputStream), StandardCharsets.UTF_8)); } private static Map a(Object object) { try { if (!(object instanceof Map)) { throw new IllegalStateException(t[39]); } } catch (RuntimeException runtimeException) { throw GraphmanBundleProcessor.a(runtimeException); } return (Map)object; } @Nullable private static Map b(Object object) { try { if (object == null) { return null; } } catch (RuntimeException runtimeException) { throw GraphmanBundleProcessor.a(runtimeException); } return GraphmanBundleProcessor.a(object); } private static List c(Object object) { try { if (!(object instanceof List)) { throw new IllegalStateException(t[5]); } } catch (RuntimeException runtimeException) { throw GraphmanBundleProcessor.a(runtimeException); } return (List)object; } @Nullable private static List d(Object object) { try { if (object == null) { return null; } } catch (RuntimeException runtimeException) { throw GraphmanBundleProcessor.a(runtimeException); } return GraphmanBundleProcessor.c(object); } private static String e(Object object) { try { if (!(object instanceof String)) { throw new IllegalStateException(t[49]); } } catch (RuntimeException runtimeException) { throw GraphmanBundleProcessor.a(runtimeException); } return (String)object; } private static /* synthetic */ String lambda$assertResponse$4(Exception exception) { return t[15] + ExceptionUtils.getMessage((Throwable)exception); } /* * Unable to fully structure code */ static { block10: { block9: { var5 = new String[61]; var3_1 = 0; var2_2 = "^#\u001fEb\u0018\u0011\u0007n\u0014AaVZ@-I\u0018,\u0018\u0002\f\u007f\bLgV\u0000_>2|H\u0015_@#Y\"2O\u0014\u0012&7GbQ\u0004\u001b<\u001fEbV\u0014XPPX3\u001a\u000f\u0016h\u0017\u0012!\u0017\u0010\u0015kIDoA\u0002\u0010+\u0013MmPI\u0001s\n\u0007yKH\u0012s\u000bAmAEBd\nD`K]\u0015o\u0017\u0015,P\u0013\u0016l]\u0007!K\u0004\ny\nI}\u0016\u001f\u000fp\u0014GoHI\rn\u0000\u0007yKHP,W\u001a!\tUMl\bDg[\u001e@\"m\b.\u0018G^k\u0014X4y\u000b\u000e<\u0010[~\u00022\u0011}\u0000M3\u001a5\u0007m\u0012A|]\u0003@\"m\b.\u0018GBE\u0011\u0011y\u0015^kJ*\rx\u0012Dk~\u000e\u000ey\u0014\u0005Lv\u0014G`27r\u0006Jb]G\u0016sGZkY\u0003B[5i^p*#RGE{L\u0006\u0016u\bF.J\u0002\u0013i\u0002[z\u0018\u0003\u0007h\u0006AbK]B8$}\u000eDk\\G\u0016sGXoJ\u0014\u0007<\u0013@k\u0018 0]7`Cy)Bq\u0012\\oL\u000e\rrGZkK\u0017\rr\u0014M.Y\u0014BV4g@\u0002G\b\u000f}\u0017XgV\u0000\u0011\u0006\u0011h\u0006\\{K'%N&xFu&,<\u0005GaL\u0014\u0016n\u0006X~Q\t\u0005<\u0015M\u007fM\u0002\u0011hGNoQ\u000b\u0007x]\b\bO1J\u0005#\u0015JO\u001c$}\u000eDk\\G\u0016sGXoJ\u0014\u0007<\u0013@k\u0018\u0005\u0017r\u0003Dk\u0002G/$}\u000eDk\\G\u0016sGKaU\u0005\u000br\u0002\bzP\u0002B~\u0012FjT\u0002\u0011<\u0001ZaUG\u0016t\u0002\bhW\u000b\u0006y\u0015\u0012.\u0002NE\u0011\u0011y\u0015^kJ*\rx\u0012Dk~\u000e\u000ey\u0014\u0005Lv\u0014G`27r\u0006Jb]G\u0016sGZkY\u0003B[5i^p*#RGE{L\u0006\u0016u\bF.J\u0002\u0013i\u0002[z\u0018\u0003\u0007h\u0006AbK]B8$}\u000eDk\\G\u0016sGXoJ\u0014\u0007<\u0013@k\u0018 0]7`Cy)Bq\u0012\\oL\u000e\rrGZkK\u0017\rr\u0014M.Y\u0014BV4g@\u0002G\b\u000f}\u0017XgV\u0000\u0011\u0006\u0011h\u0006\\{K'%N&xFu&,<\u0005GaL\u0014\u0016n\u0006X~Q\t\u0005<\u0015M\u007fM\u0002\u0011hGNoQ\u000b\u0007x]\b\bO1J\u0005#\u0015JO\u001c$}\u000eDk\\G\u0016sGXoJ\u0014\u0007<\u0013@k\u0018\u0005\u0017r\u0003Dk\u0002G/$}\u000eDk\\G\u0016sGKaU\u0005\u000br\u0002\bzP\u0002B~\u0012FjT\u0002\u0011<\u0001ZaUG\u0016t\u0002\bhW\u000b\u0006y\u0015\u0012.\u0002N 26; case 1 -> 100; case 2 -> 31; case 3 -> 80; case 4 -> 118; case 5 -> 64; default -> 31; }))); ++n3; n4 = n4; } while (n4 > n3); } return new String(cArray2).intern(); } static class GraphmanBundleException extends Exception { static final long serialVersionUID = -1895841617838199883L; GraphmanBundleException(String string) { super(string); } GraphmanBundleException(String string, Throwable throwable) { super(string, throwable); } } }