/* * Decompiled with CFR 0.152. * * Could not load the following classes: * com.l7tech.gateway.common.audit.AssertionMessages * com.l7tech.gateway.common.audit.Audit * com.l7tech.gateway.common.audit.AuditDetailMessage * com.l7tech.gateway.common.cluster.ClusterNodeInfo * com.l7tech.gateway.common.security.password.SecurePassword * com.l7tech.message.HttpRequestKnob * com.l7tech.message.JmsKnob * com.l7tech.message.MQTTConnectResponseKnob * com.l7tech.message.MQTTSubscribeResponseKnob * com.l7tech.message.Message * com.l7tech.message.MessageKnob * com.l7tech.message.TcpKnob * com.l7tech.objectmodel.FindException * com.l7tech.objectmodel.Goid * com.l7tech.policy.assertion.Assertion * com.l7tech.policy.assertion.credential.LoginCredentials * com.l7tech.policy.variable.BuiltinVariables * com.l7tech.policy.variable.NoSuchVariableException * com.l7tech.policy.variable.VariableNotSettableException * com.l7tech.util.CachedCallable * com.l7tech.util.ExceptionUtils * com.l7tech.util.SyspropUtil * com.l7tech.util.TimeSource * org.jetbrains.annotations.NotNull */ package com.l7tech.server.policy.variable; import com.l7tech.gateway.common.audit.AssertionMessages; import com.l7tech.gateway.common.audit.Audit; import com.l7tech.gateway.common.audit.AuditDetailMessage; import com.l7tech.gateway.common.cluster.ClusterNodeInfo; import com.l7tech.gateway.common.security.password.SecurePassword; import com.l7tech.message.HttpRequestKnob; import com.l7tech.message.JmsKnob; import com.l7tech.message.MQTTConnectResponseKnob; import com.l7tech.message.MQTTSubscribeResponseKnob; import com.l7tech.message.Message; import com.l7tech.message.MessageKnob; import com.l7tech.message.TcpKnob; import com.l7tech.objectmodel.FindException; import com.l7tech.objectmodel.Goid; import com.l7tech.policy.assertion.Assertion; import com.l7tech.policy.assertion.credential.LoginCredentials; import com.l7tech.policy.variable.BuiltinVariables; import com.l7tech.policy.variable.NoSuchVariableException; import com.l7tech.policy.variable.VariableNotSettableException; import com.l7tech.server.cluster.ClusterInfoManager; import com.l7tech.server.cluster.ClusterPropertyCache; import com.l7tech.server.message.HasOriginalContext; import com.l7tech.server.message.PolicyEnforcementContext; import com.l7tech.server.policy.variable.MessageSelector; import com.l7tech.server.policy.variable.au; import com.l7tech.server.policy.variable.b0; import com.l7tech.server.policy.variable.b1; import com.l7tech.server.policy.variable.b2; import com.l7tech.server.policy.variable.b3; import com.l7tech.server.policy.variable.b4; import com.l7tech.server.policy.variable.b5; import com.l7tech.server.policy.variable.b6; import com.l7tech.server.policy.variable.b7; import com.l7tech.server.policy.variable.b8; import com.l7tech.server.policy.variable.b9; import com.l7tech.server.policy.variable.b_; import com.l7tech.server.policy.variable.bi; import com.l7tech.server.policy.variable.bj; import com.l7tech.server.policy.variable.bk; import com.l7tech.server.policy.variable.bl; import com.l7tech.server.policy.variable.bm; import com.l7tech.server.policy.variable.bn; import com.l7tech.server.policy.variable.bo; import com.l7tech.server.policy.variable.bp; import com.l7tech.server.policy.variable.bq; import com.l7tech.server.policy.variable.br; import com.l7tech.server.policy.variable.bs; import com.l7tech.server.policy.variable.bt; import com.l7tech.server.policy.variable.bu; import com.l7tech.server.policy.variable.bv; import com.l7tech.server.policy.variable.bw; import com.l7tech.server.policy.variable.bx; import com.l7tech.server.policy.variable.by; import com.l7tech.server.policy.variable.bz; import com.l7tech.server.policy.variable.c0; import com.l7tech.server.policy.variable.c1; import com.l7tech.server.policy.variable.c2; import com.l7tech.server.policy.variable.c3; import com.l7tech.server.policy.variable.c4; import com.l7tech.server.policy.variable.c5; import com.l7tech.server.policy.variable.c6; import com.l7tech.server.policy.variable.c7; import com.l7tech.server.policy.variable.c8; import com.l7tech.server.policy.variable.c9; import com.l7tech.server.policy.variable.c_; import com.l7tech.server.policy.variable.ca; import com.l7tech.server.policy.variable.cb; import com.l7tech.server.policy.variable.cc; import com.l7tech.server.policy.variable.cd; import com.l7tech.server.policy.variable.ce; import com.l7tech.server.policy.variable.cf; import com.l7tech.server.policy.variable.cg; import com.l7tech.server.policy.variable.ch; import com.l7tech.server.policy.variable.ci; import com.l7tech.server.policy.variable.cj; import com.l7tech.server.policy.variable.ck; import com.l7tech.server.policy.variable.cl; import com.l7tech.server.policy.variable.cm; import com.l7tech.server.policy.variable.cn; import com.l7tech.server.policy.variable.co; import com.l7tech.server.policy.variable.cp; import com.l7tech.server.policy.variable.cq; import com.l7tech.server.policy.variable.cr; import com.l7tech.server.policy.variable.cs; import com.l7tech.server.policy.variable.ct; import com.l7tech.server.policy.variable.cu; import com.l7tech.server.policy.variable.cv; import com.l7tech.server.policy.variable.cw; import com.l7tech.server.policy.variable.cx; import com.l7tech.server.policy.variable.cy; import com.l7tech.server.policy.variable.cz; import com.l7tech.server.policy.variable.d0; import com.l7tech.server.policy.variable.d1; import com.l7tech.server.policy.variable.d2; import com.l7tech.server.policy.variable.d3; import com.l7tech.server.policy.variable.d4; import com.l7tech.server.policy.variable.d5; import com.l7tech.server.policy.variable.d6; import com.l7tech.server.policy.variable.d8; import com.l7tech.server.policy.variable.d9; import com.l7tech.server.policy.variable.d_; import com.l7tech.server.policy.variable.da; import com.l7tech.server.policy.variable.db; import com.l7tech.server.policy.variable.dc; import com.l7tech.server.policy.variable.dd; import com.l7tech.server.policy.variable.de; import com.l7tech.server.policy.variable.df; import com.l7tech.server.policy.variable.dg; import com.l7tech.server.policy.variable.dh; import com.l7tech.server.policy.variable.di; import com.l7tech.server.policy.variable.dj; import com.l7tech.server.policy.variable.dk; import com.l7tech.server.policy.variable.dl; import com.l7tech.server.policy.variable.dm; import com.l7tech.server.policy.variable.dp; import com.l7tech.server.policy.variable.dq; import com.l7tech.server.policy.variable.ds; import com.l7tech.server.policy.variable.dt; import com.l7tech.server.policy.variable.du; import com.l7tech.server.policy.variable.dv; import com.l7tech.server.policy.variable.dw; import com.l7tech.server.policy.variable.dx; import com.l7tech.server.policy.variable.dy; import com.l7tech.server.policy.variable.dz; import com.l7tech.server.policy.variable.ea; import com.l7tech.server.policy.variable.eb; import com.l7tech.server.policy.variable.ec; import com.l7tech.server.policy.variable.ed; import com.l7tech.server.policy.variable.ee; import com.l7tech.server.policy.variable.eg; import com.l7tech.server.policy.variable.fi; import com.l7tech.server.policy.variable.fj; import com.l7tech.server.policy.variable.fk; import com.l7tech.server.policy.variable.fl; import com.l7tech.server.policy.variable.fm; import com.l7tech.server.policy.variable.fn; import com.l7tech.server.policy.variable.fo; import com.l7tech.server.policy.variable.fp; import com.l7tech.server.policy.variable.fq; import com.l7tech.server.policy.variable.fv; import com.l7tech.server.policy.variable.fw; import com.l7tech.server.policy.variable.fx; import com.l7tech.server.security.password.SecurePasswordManager; import com.l7tech.util.CachedCallable; import com.l7tech.util.ExceptionUtils; import com.l7tech.util.SyspropUtil; import com.l7tech.util.TimeSource; import java.io.IOException; import java.net.MalformedURLException; import java.net.URL; import java.security.cert.X509Certificate; import java.text.ParseException; import java.util.ArrayList; import java.util.HashMap; import java.util.List; import java.util.Map; import java.util.concurrent.Callable; import java.util.logging.Level; import java.util.logging.Logger; import java.util.regex.Matcher; import java.util.regex.Pattern; import org.jetbrains.annotations.NotNull; /* * Exception performing whole class analysis ignored. */ public class ServerVariables { static Logger a; private static final String b; public static final String PREFIX_SHARED_BUCKET; private static final dx c; private static final dw d; private static final eg e; private static final Map f; private static final Map g; private static ClusterPropertyCache h; private static SecurePasswordManager i; private static ClusterInfoManager j; private static final long k; private static final CachedCallable l; static final String m; static String n; static Pattern o; @NotNull private static TimeSource p; private static final fv[] q; private static final Pattern r; public static final Pattern SINGLE_SECPASS_PATTERN; static final /* synthetic */ boolean s; private static final String[] t; static void a() { String[] stringArray = t; n = SyspropUtil.getString((String)stringArray[127], (String)stringArray[136]); o = Pattern.compile(n); } static fv a(String string, PolicyEnforcementContext policyEnforcementContext) { fv fv2; String string2; block8: { string2 = string.toLowerCase(); fv2 = f.get(string2); try { try { if (fv2 == null || !fv2.a(policyEnforcementContext)) break block8; } catch (IllegalArgumentException illegalArgumentException) { throw ServerVariables.a(illegalArgumentException); } return fv2; } catch (IllegalArgumentException illegalArgumentException) { throw ServerVariables.a(illegalArgumentException); } } int n2 = string2.length(); do { String string3; if ((fv2 = g.get(string3 = string2.substring(0, n2))) == null) continue; try { if (fv2.a(policyEnforcementContext)) { return fv2; } } catch (IllegalArgumentException illegalArgumentException) { throw ServerVariables.a(illegalArgumentException); } } while ((n2 = string2.lastIndexOf(".", n2 - 1)) > 0); return null; } private static String[] a(String string, String string2, PolicyEnforcementContext policyEnforcementContext) throws IOException { HttpRequestKnob httpRequestKnob = (HttpRequestKnob)policyEnforcementContext.getRequest().getKnob(HttpRequestKnob.class); try { if (httpRequestKnob == null) { return new String[0]; } } catch (IOException iOException) { throw ServerVariables.a(iOException); } try { if (!string2.startsWith(string)) { throw new IllegalArgumentException(t[46] + string2 + t[98]); } } catch (IOException iOException) { throw ServerVariables.a(iOException); } String string3 = string2.substring(string.length()); try { if (!string3.startsWith(".")) { a.warning(t[4] + string2 + t[24]); return null; } } catch (IOException iOException) { throw ServerVariables.a(iOException); } String string4 = string2.substring(string.length() + 1); return httpRequestKnob.getParameterValues(string4); } public static void set(String string, Object object, PolicyEnforcementContext policyEnforcementContext) throws VariableNotSettableException, NoSuchVariableException { fv fv2 = ServerVariables.a(string, policyEnforcementContext); if (!(fv2 instanceof fx)) { try { if (fv2 == null) { throw new NoSuchVariableException(string, t[138] + string + t[88]); } } catch (VariableNotSettableException variableNotSettableException) { throw ServerVariables.a((Exception)((Object)variableNotSettableException)); } throw new VariableNotSettableException(string); } fx fx2 = (fx)fv2; fx2.a(string, object, policyEnforcementContext); } public static Object get(String string, PolicyEnforcementContext policyEnforcementContext) throws NoSuchVariableException { fv fv2 = ServerVariables.a(string, policyEnforcementContext); try { if (fv2 == null) { throw new NoSuchVariableException(string, t[62] + string + t[140]); } } catch (NoSuchVariableException noSuchVariableException) { throw ServerVariables.a((Exception)((Object)noSuchVariableException)); } return fv2.a(string, policyEnforcementContext); } public static boolean isValidForContext(String string, PolicyEnforcementContext policyEnforcementContext) { boolean bl2; try { bl2 = ServerVariables.a(string, policyEnforcementContext) != null; } catch (IllegalArgumentException illegalArgumentException) { throw ServerVariables.a(illegalArgumentException); } return bl2; } private static X509Certificate a(List list, Class clazz) { X509Certificate x509Certificate = null; for (LoginCredentials loginCredentials : list) { block7: { try { try { try { if (loginCredentials == null || !loginCredentials.getFormat().isClientCert()) continue; } catch (IllegalArgumentException illegalArgumentException) { throw ServerVariables.a(illegalArgumentException); } if (loginCredentials.getCredentialSourceAssertion() != clazz) continue; } catch (IllegalArgumentException illegalArgumentException) { throw ServerVariables.a(illegalArgumentException); } if (x509Certificate == null) break block7; } catch (IllegalArgumentException illegalArgumentException) { throw ServerVariables.a(illegalArgumentException); } x509Certificate = null; break; } x509Certificate = loginCredentials.getClientCert(); } return x509Certificate; } private static String a(Message message) { String string; TcpKnob tcpKnob = (TcpKnob)message.getKnob(TcpKnob.class); try { string = tcpKnob == null ? null : tcpKnob.getRemoteAddress(); } catch (IllegalArgumentException illegalArgumentException) { throw ServerVariables.a(illegalArgumentException); } return string; } private static String b(Message message) { return null; } private static String c(Message message) { String string; try { string = message.getKnob(JmsKnob.class) != null ? t[22] : null; } catch (IllegalArgumentException illegalArgumentException) { throw ServerVariables.a(illegalArgumentException); } return string; } private static Object a(String string, String string2, Object object) { URL uRL; String string3; block42: { String string4; block44: { block43: { block45: { int n2; block40: { String string5; block41: { try { if (object == null) { return null; } } catch (MalformedURLException malformedURLException) { throw ServerVariables.a(malformedURLException); } String string6 = string2.substring(string.length()); try { if (string6.length() == 0) { return object.toString(); } } catch (MalformedURLException malformedURLException) { throw ServerVariables.a(malformedURLException); } string3 = string6.substring(1); if (object instanceof URL) { uRL = (URL)object; } else { try { uRL = new URL(object.toString()); } catch (MalformedURLException malformedURLException) { String[] stringArray = t; a.log(Level.WARNING, stringArray[86], new String[]{object.toString()}); return null; } } string5 = uRL.getProtocol(); try { if (BuiltinVariables.SERVICE_SUFFIX_HOST.equalsIgnoreCase(string3)) { return uRL.getHost(); } } catch (MalformedURLException malformedURLException) { throw ServerVariables.a(malformedURLException); } try { if (BuiltinVariables.SERVICE_SUFFIX_PROTOCOL.equalsIgnoreCase(string3)) { return string5; } } catch (MalformedURLException malformedURLException) { throw ServerVariables.a(malformedURLException); } if (!BuiltinVariables.SERVICE_SUFFIX_PORT.equalsIgnoreCase(string3)) break block45; n2 = uRL.getPort(); try { if (n2 != -1) break block40; if (!t[51].equalsIgnoreCase(string5)) break block41; } catch (MalformedURLException malformedURLException) { throw ServerVariables.a(malformedURLException); } n2 = 80; break block40; } String[] stringArray = t; if (stringArray[11].equalsIgnoreCase(string5)) { n2 = 443; } else { stringArray = t; if (stringArray[78].equalsIgnoreCase(string5)) { n2 = 21; } else { stringArray = t; if (stringArray[54].equalsIgnoreCase(string5)) { n2 = 25; } else { stringArray = t; if (stringArray[132].equalsIgnoreCase(string5)) { n2 = 110; } else { stringArray = t; if (stringArray[105].equalsIgnoreCase(string5)) { n2 = 143; } } } } } } return Integer.toString(n2); } try { if (BuiltinVariables.SERVICE_SUFFIX_FILE.equalsIgnoreCase(string3)) { return uRL.getFile(); } } catch (MalformedURLException malformedURLException) { throw ServerVariables.a(malformedURLException); } try { if (BuiltinVariables.SERVICE_SUFFIX_PATH.equalsIgnoreCase(string3)) { return uRL.getPath(); } } catch (MalformedURLException malformedURLException) { throw ServerVariables.a(malformedURLException); } try { try { if (!BuiltinVariables.SERVICE_SUFFIX_QUERY.equalsIgnoreCase(string3)) break block42; if (uRL.getQuery() != null) break block43; } catch (MalformedURLException malformedURLException) { throw ServerVariables.a(malformedURLException); } string4 = null; break block44; } catch (MalformedURLException malformedURLException) { throw ServerVariables.a(malformedURLException); } } string4 = "?" + uRL.getQuery(); } return string4; } try { if (BuiltinVariables.SERVICE_SUFFIX_FRAGMENT.equalsIgnoreCase(string3)) { return uRL.getRef(); } } catch (MalformedURLException malformedURLException) { throw ServerVariables.a(malformedURLException); } a.log(Level.WARNING, t[112] + string2); return null; } private static ClusterPropertyCache b() { return h; } public static void setClusterPropertyCache(ClusterPropertyCache clusterPropertyCache) { try { if (h == null) { h = clusterPropertyCache; } } catch (IllegalArgumentException illegalArgumentException) { throw ServerVariables.a(illegalArgumentException); } } public static void setClusterInfoManager(ClusterInfoManager clusterInfoManager) { try { if (j == null) { j = clusterInfoManager; } } catch (IllegalArgumentException illegalArgumentException) { throw ServerVariables.a(illegalArgumentException); } } public static void setSecurePasswordManager(SecurePasswordManager securePasswordManager) { i = securePasswordManager; } public static void setTimeSource(@NotNull TimeSource timeSource) { try { if (timeSource == null) { ServerVariables.a(0); } } catch (IllegalArgumentException illegalArgumentException) { throw ServerVariables.a(illegalArgumentException); } p = timeSource; } /* * Exception decompiling */ public static String expandPasswordOnlyVariable(Audit var0, String var1_1) throws FindException { /* * This method has failed to decompile. When submitting a bug report, please provide this stack trace, and (if you hold appropriate legal rights) the relevant class file. * * org.benf.cfr.reader.util.ConfusedCFRException: Tried to end blocks [1[TRYBLOCK]], but top level block is 18[FORLOOP] * at org.benf.cfr.reader.bytecode.analysis.opgraph.Op04StructuredStatement.processEndingBlocks(Op04StructuredStatement.java:435) * at org.benf.cfr.reader.bytecode.analysis.opgraph.Op04StructuredStatement.buildNestedBlocks(Op04StructuredStatement.java:484) * at org.benf.cfr.reader.bytecode.analysis.opgraph.Op03SimpleStatement.createInitialStructuredBlock(Op03SimpleStatement.java:736) * at org.benf.cfr.reader.bytecode.CodeAnalyser.getAnalysisInner(CodeAnalyser.java:850) * at org.benf.cfr.reader.bytecode.CodeAnalyser.getAnalysisOrWrapFail(CodeAnalyser.java:278) * at org.benf.cfr.reader.bytecode.CodeAnalyser.getAnalysis(CodeAnalyser.java:201) * at org.benf.cfr.reader.entities.attributes.AttributeCode.analyse(AttributeCode.java:94) * at org.benf.cfr.reader.entities.Method.analyse(Method.java:531) * at org.benf.cfr.reader.entities.ClassFile.analyseMid(ClassFile.java:1055) * at org.benf.cfr.reader.entities.ClassFile.analyseTop(ClassFile.java:942) * at org.benf.cfr.reader.Driver.doJarVersionTypes(Driver.java:257) * at org.benf.cfr.reader.Driver.doJar(Driver.java:139) * at org.benf.cfr.reader.CfrDriverImpl.analyse(CfrDriverImpl.java:76) * at org.benf.cfr.reader.Main.main(Main.java:54) */ throw new IllegalStateException("Decompilation failed"); } /* * Loose catch block */ public static String expandSinglePasswordOnlyVariable(Audit audit, String string) throws FindException { String string2; block24: { block23: { try { if (string == null) { return null; } } catch (ParseException parseException) { throw ServerVariables.a(parseException); } Matcher matcher = SINGLE_SECPASS_PATTERN.matcher(string); try { if (!matcher.matches()) { return string; } } catch (ParseException parseException) { throw ServerVariables.a(parseException); } try { if (i == null) { throw new IllegalStateException(t[90]); } } catch (ParseException parseException) { throw ServerVariables.a(parseException); } string2 = matcher.group(1); if (s) break block23; try { block25: { if (string2 != null) break block23; break block25; catch (ParseException parseException) { throw ServerVariables.a(parseException); } } throw new AssertionError(); } catch (ParseException parseException) { throw ServerVariables.a(parseException); } } if (s) break block24; try { block26: { if (string2.length() > 0) break block24; break block26; catch (ParseException parseException) { throw ServerVariables.a(parseException); } } throw new AssertionError(); } catch (ParseException parseException) { throw ServerVariables.a(parseException); } } SecurePassword securePassword = ServerVariables.a(string2); try { if (securePassword == null) { audit.logAndAudit((AuditDetailMessage)AssertionMessages.EXCEPTION_WARNING_WITH_MORE_INFO, new String[]{t[77]}); return string; } } catch (ParseException parseException) { throw ServerVariables.a(parseException); } try { char[] cArray = ServerVariables.a(securePassword); if (cArray == null) { String[] stringArray = new String[1]; String[] stringArray2 = t; stringArray[0] = stringArray2[21]; audit.logAndAudit((AuditDetailMessage)AssertionMessages.EXCEPTION_INFO_WITH_MORE_INFO, stringArray); return ""; } return new String(cArray); } catch (ParseException parseException) { String[] stringArray = t; String string3 = stringArray[3]; a.log(Level.FINER, stringArray[3], ExceptionUtils.getDebugException((Throwable)parseException)); throw new FindException(stringArray[3]); } } public static String getSecurePasswordByGoid(Audit audit, Goid goid) throws FindException { try { if (i == null) { throw new IllegalStateException(t[93]); } } catch (ParseException parseException) { throw ServerVariables.a(parseException); } SecurePassword securePassword = (SecurePassword)i.findByPrimaryKey(goid); try { if (securePassword == null) { audit.logAndAudit((AuditDetailMessage)AssertionMessages.EXCEPTION_WARNING_WITH_MORE_INFO, new String[]{t[104] + String.valueOf(goid) + t[72]}); return ""; } } catch (ParseException parseException) { throw ServerVariables.a(parseException); } try { char[] cArray = ServerVariables.a(securePassword); if (cArray == null) { String[] stringArray = new String[1]; String[] stringArray2 = t; stringArray[0] = stringArray2[135] + String.valueOf(goid) + stringArray2[114]; audit.logAndAudit((AuditDetailMessage)AssertionMessages.EXCEPTION_INFO_WITH_MORE_INFO, stringArray); return ""; } return new String(cArray); } catch (ParseException parseException) { String[] stringArray = t; String string = stringArray[135] + String.valueOf(goid) + stringArray[33]; a.log(Level.FINER, string, ExceptionUtils.getDebugException((Throwable)parseException)); throw new FindException(string); } } static SecurePassword a(String string) throws FindException { return (SecurePassword)i.findByUniqueName(string); } static char[] a(SecurePassword securePassword) throws FindException, ParseException { char[] cArray; block5: { String string; block4: { string = securePassword.getEncodedPassword(); try { try { if (string != null && string.length() >= 1) break block4; } catch (FindException findException) { throw ServerVariables.a((Exception)((Object)findException)); } cArray = null; break block5; } catch (FindException findException) { throw ServerVariables.a((Exception)((Object)findException)); } } cArray = i.decryptPassword(string); } return cArray; } static ClusterNodeInfo c() { try { return (ClusterNodeInfo)l.call(); } catch (Exception exception) { a.log(Level.WARNING, t[108] + ExceptionUtils.getMessage((Throwable)exception), ExceptionUtils.getDebugException((Throwable)exception)); return null; } } static PolicyEnforcementContext a(PolicyEnforcementContext policyEnforcementContext) { PolicyEnforcementContext policyEnforcementContext2; try { policyEnforcementContext2 = policyEnforcementContext instanceof HasOriginalContext ? ((HasOriginalContext)((Object)policyEnforcementContext)).getOriginalContext() : null; } catch (IllegalArgumentException illegalArgumentException) { throw ServerVariables.a(illegalArgumentException); } return policyEnforcementContext2; } public static PolicyEnforcementContext getRootContext(PolicyEnforcementContext policyEnforcementContext) { PolicyEnforcementContext policyEnforcementContext2; PolicyEnforcementContext policyEnforcementContext3 = ServerVariables.a(policyEnforcementContext); try { policyEnforcementContext2 = policyEnforcementContext3 == null ? policyEnforcementContext : ServerVariables.getRootContext(policyEnforcementContext3); } catch (IllegalArgumentException illegalArgumentException) { throw ServerVariables.a(illegalArgumentException); } return policyEnforcementContext2; } @NotNull private static MQTTConnectResponseKnob b(@NotNull PolicyEnforcementContext policyEnforcementContext) { MQTTConnectResponseKnob mQTTConnectResponseKnob; try { if (policyEnforcementContext == null) { ServerVariables.a(1); } } catch (IllegalArgumentException illegalArgumentException) { throw ServerVariables.a(illegalArgumentException); } MQTTConnectResponseKnob mQTTConnectResponseKnob2 = (MQTTConnectResponseKnob)policyEnforcementContext.getResponse().getKnob(MQTTConnectResponseKnob.class); if (mQTTConnectResponseKnob2 == null) { mQTTConnectResponseKnob2 = new fj(); policyEnforcementContext.getResponse().attachKnob((MessageKnob)mQTTConnectResponseKnob2, new Class[]{MQTTConnectResponseKnob.class}); } try { mQTTConnectResponseKnob = mQTTConnectResponseKnob2; if (mQTTConnectResponseKnob == null) { ServerVariables.a(2); } } catch (IllegalArgumentException illegalArgumentException) { throw ServerVariables.a(illegalArgumentException); } return mQTTConnectResponseKnob; } @NotNull private static MQTTSubscribeResponseKnob c(@NotNull PolicyEnforcementContext policyEnforcementContext) { MQTTSubscribeResponseKnob mQTTSubscribeResponseKnob; try { if (policyEnforcementContext == null) { ServerVariables.a(3); } } catch (IllegalArgumentException illegalArgumentException) { throw ServerVariables.a(illegalArgumentException); } MQTTSubscribeResponseKnob mQTTSubscribeResponseKnob2 = (MQTTSubscribeResponseKnob)policyEnforcementContext.getResponse().getKnob(MQTTSubscribeResponseKnob.class); if (mQTTSubscribeResponseKnob2 == null) { mQTTSubscribeResponseKnob2 = new fk(); policyEnforcementContext.getResponse().attachKnob((MessageKnob)mQTTSubscribeResponseKnob2, new Class[]{MQTTSubscribeResponseKnob.class}); } try { mQTTSubscribeResponseKnob = mQTTSubscribeResponseKnob2; if (mQTTSubscribeResponseKnob == null) { ServerVariables.a(4); } } catch (IllegalArgumentException illegalArgumentException) { throw ServerVariables.a(illegalArgumentException); } return mQTTSubscribeResponseKnob; } /* * Could not resolve type clashes * Unable to fully structure code */ static { block23: { block22: { var5 = new String[142]; var3_1 = 0; var2_2 = "\u0003mSS\u001b;*DnRX\u00076+\u0016_{WD\r+,\u0003mIP\u0018v7]{TP\u001c17C\t_{WD\r+,dza}\u007fUB\u001f7*I3I_\u0004!xNqHE\r ,\rhGC\u00019:A{\u0006T\u0010(*HmUX\u00076x_{@T\u001a*=I>R^H+=NkTTH(9^mQ^\u001a\u0001\u001e_{WD\r+,\u0003iUBF+1JpO_\u000f;=_jOW\u0001;9Y{\r\u0003iO]\u0004v5HmUP\u000f=\u0007\u0003kHX\u0019-=\f\u0003sCB\u001b9?HJ_A\r\u0014_{UA\u00076+H0NE\u001c(v^jGE\u001d+\n\u0003lCA\u0004!,HfR\u0005EjRA\u001bt}\u007fUB\u001f7*I3I_\u0004!xNqHE\r ,\rhGC\u00019:A{\u0006T\u0010(*HmUX\u00076x_{@T\u001a*=I>R^H9xCqHT\u00101+Y{HEH+=NkTTH(9^mQ^\u001aJX\u001c=*Lr\u0006A\t++ZqTU%J{R~\u001a\u001b*H\u007fRT%),Y]I_\u0006=;YwI_:=+]qHB\r\u00136B|\u0014_{WD\r+,\u0003jEAF*=@qRT\u0001(\u001d_{UA\u00076+H0E^\u000731H0IG\r*/_wRT89,E\u0005\u0003nGE\u0000\u0007_{WD\r+,\u0010_{WD\r+,\u0003mIP\u0018v-_p\u0011LkBX\u001cv*H}IC\f\t-Hl_\u0018_{WD\r+,\u0003wBT\u0006,1YgkP\u0018(1CyU~}\u007fUB\u001f7*I3I_\u0004!xNqHE\r ,\rhGC\u00019:A{\u0006T\u0010(*HmUX\u00076x_{@T\u001a*=I>R^H9x^{ED\u001a=x]\u007fUB\u001f7*I>QX\u001c0xLp\u0006T\u0005(,T>VP\u001b+/BlB\nH-+DpA\u0011\r5(Yg\u0006B\u001c*1Cy\u0006P\u001bx(LmUF\u0007*<\f}lIE\u0007;7A$l|;\u0010]qJX\u000b!vCkJ]\u001e94X{3\n>B^\r+xCqR\u0011\u00009.H>G\u0011\u0018=*DqB\u0011\n=>BlC\u0011\u001c0=\rnGC\t5=Y{T\u0011\u000695H0W}\u007fUB\u001f7*I3I_\u0004!xNqHE\r ,\rhGC\u00019:A{\u0006T\u0010(*HmUX\u00076xE\u007fB\u0011\u00016.LrOUH+!CjGISx9^mS\\\u00016?\rrOE\r*9A>VP\u001b+/BlB\t\u0003\u007fTV\u001d5=Cj\u0005YlGR\r\n\u0003uCT\u0018\u00194DhC\u0005LkBX\u001c\u000b\u0003yTP\u0006,=IOib\u000b\u0003iO]\u0004v,BnOR\u000b\b;uy)\n\u001di;\u0003\u001f8\rlCW\r**Hz\u0006E\u0007x+H}SC\rx(LmUF\u0007*<\rjNP\u001cx;BkJUH67Y>DTH<=Nl_A\u001c=<5NqK\u001f\u0004o,H}N\u001f\u001b=*[{T\u001f\u001874D}_\u001f\u001e9*D\u007fD]\rv+^yH^\f=vN\u007fEY\r\u00151ArOB\r^{Re\u00015=~qSC\u000b=1NqK\u001e\u0004o,H}N\u001e\u001b=*[{T\u001e\u001874D}_\u001e\u001e9*D\u007fD]\rw\u000bHlPT\u001a\u000e9_wGS\u0004=+\u0013_{WD\r+,\u0003{JP\u0018+=IJO\\\r\u0004\u0003oIB\u001a_{WD\r+,\u0003mIP\u0018v7]{TP\u001c17CpG\\\r\u0019_{WD\r+,\u0003jEAF*=@qRT)<<_{UB\u0007NqHE\r ,\b\u0003}I\\\u000596I\tLkBX\u001cv.Ll$J{R~\u001a\u001b*H\u007fRT%),YMSS\u001b;*D|Cc\r+(BpUT#67O\r\u0003iO]\u0004v(_{UT\u0006,/eJraH\b9_\u007fK\u0011/=,Y{T\u0011\u000b96\nj\u0006Y\t6QP\u001bx6Bj\u0006W\u0007-6I>O_H\u001a-DrRX\u0006\u000e9_wGS\u0004=+\f\u0015LkBX\u001cv>DrRT\u001a=<_{WD\r+,\u0010~{TG\r*\u000eLlOP\n4=\r9\u0010_{WD\r+,\u0003mUYF>1A{\u0004EjRA*mPIE&-4A>KT\u001c07I>\u0003BF}+\rsSB\u001cx6Bj\u0006C\r,-_p\u0006_\u001d44\b_{UA\u00076+H\u0004^sRA\u0016LkBX\u001cv>DrRT\u001a=<_{UA\u00076+He}\u007fUB\u001f7*I3I_\u0004!xNqHE\r ,\rhGC\u00019:A{\u0006T\u0010(*HmUX\u00076x_{@T\u001a*=I>R^H67C3UT\u000b(9^m\u0006G\t*1L|JTSx9^mS\\\u00016?\rrOE\r*9A>VP\u001b+/BlB\u0011\u0003}JX\r6,dzC_\u001c1>D{T\t\u0003iO]\u0004v)Bm\u0007\u0003lCE\t16\u001eLkBX\u001cv(BrOR\u0011\u001d H}SE\u000176ljRT\u0005(,Hz6sB\u0002m\u0013+=NnGB\u001b\u0004v\u0005EG\u001c\u0012\u0019uwA{j\tu\"l3|\u0001Ea\u0007q3{\u001bA\u0004v]rGX\u0006,=UjzLL\u000eyvC\u0011\u001e9*D\u007fD]\rxz\u000f\u0003mCB\u001b17CNTT\u001b=6Y\u0005YlGR\r\nYwKT;7-_}C\u0005\u0003xO]\r\u0012_{WD\r+,\u0003\u007fSE\u00007*DdCU\u001d_{WD\r+,\u0003mU]F;4D{HE+=*Yw@X\u000b9,H\u0007\u0003xIC\u000b=<\u0005LkBX\u001c\u0013_{WD\r+,\u0003vRE\u0018v5HjN^\fJ\rlCW\r**Hz\u0006E\u0007x9\rpI_\r 1^jC_\u001cx+H}SC\rx(LmUF\u0007*<\u0016>SB\u00016?\r{KA\u001c!x^jTX\u0006?xLm\u0006A\t++ZqTU\nLkBX\u001cv;BzC\u001bLkBX\u001cv*HmV^\u0006+=nqHE\r6,a{HV\u001c0\tYlGR\rv7Xj\u0016LkBX\u001cv>DrRT\u001a=<_{UA\u00076+Ht}\u007fUB\u001f7*I3I_\u0004!xNqHE\r ,\rhGC\u00019:A{\u0006T\u0010(*HmUX\u00076x_{@T\u001a*=I>R^H9xCqHT\u00101+Y{HEH+=NkTTH(9^mQ^\u001aJX\u001c=*Lr\u0006A\t++ZqTU\u0003KjV\r\u0003}JT\t6\u000bHmUX\u00076\u0011LkBX\u001cv*H}IC\f\t-Hl_\u0010_{WD\r+,\u0003mUYF(9Yv\u001f_{UA\u00076+H0E^\u000731H0IG\r*/_wRT,75LwH\u0007\u0003mCR\u001d*=\n\u0003lCA\u0004!;BzC\r_qSE\u00016?~jGE\u001d+\u0019xLj\u0011\u000b96CqR\u0011\n=x]\u007fTB\rE^\u001d4<\rpIEH:=\rxID\u0006R^H+=NkTTH(9^mQ^\u001a7\u0017>\u0096}\u007fUB\u001f7*I3I_\u0004!xNqHE\r ,\rhGC\u00019:A{\u0006T\u0010(*HmUX\u00076x_{@T\u001a*=I>R^H9x^{ED\u001a=x]\u007fUB\u001f7*I>G]\u00019+\rjNP\u001cxE^\u0006,=Uj\u0006G\t*1L|JTSx9^mS\\\u00016?\rrOE\r*9A>VP\u001b+/BlB%J{R~\u001a\u001b*H\u007fRT%),Y]I_\u0006=;YwI_:=+]qHB\r\u00136B|\u0005sMuv0\u001cn\u007fH\u0016\u001cx0LpB]\rx.LlOP\n4=\rpG\\\rR^H9x^{ED\u001a=x]\u007fUB\u001f7*I>QX\u001c0xLp\u0006T\u0005(,T>VP\u001b+/BlB\nH-+DpA\u0011\r5(Yg\u0006B\u001c*1Cy\u0006P\u001bx(LmUF\u0007*<>llAD\u0005=6Y>@^\u001ax\u0018cqR\u007f\u001d44\rnGC\t5=Y{T\u0011O}+\n>IWH}+\u0003;U\u0011\u0005-+Y>H^\u001cx:H>HD\u00044\u0006jqOURx\u0005sMuv0\u0010_{WD\r+,\u0003vRE\u0018v-_w\u000eyvC\u0011\u001e9*D\u007fD]\rxz\u0010_{WD\r+,\u0003}JX\r6,Dz"; var4_3 = "\u0003mSS\u001b;*DnRX\u00076+\u0016_{WD\r+,\u0003mIP\u0018v7]{TP\u001c17C\t_{WD\r+,dza}\u007fUB\u001f7*I3I_\u0004!xNqHE\r ,\rhGC\u00019:A{\u0006T\u0010(*HmUX\u00076x_{@T\u001a*=I>R^H+=NkTTH(9^mQ^\u001a\u0001\u001e_{WD\r+,\u0003iUBF+1JpO_\u000f;=_jOW\u0001;9Y{\r\u0003iO]\u0004v5HmUP\u000f=\u0007\u0003kHX\u0019-=\f\u0003sCB\u001b9?HJ_A\r\u0014_{UA\u00076+H0NE\u001c(v^jGE\u001d+\n\u0003lCA\u0004!,HfR\u0005EjRA\u001bt}\u007fUB\u001f7*I3I_\u0004!xNqHE\r ,\rhGC\u00019:A{\u0006T\u0010(*HmUX\u00076x_{@T\u001a*=I>R^H9xCqHT\u00101+Y{HEH+=NkTTH(9^mQ^\u001aJX\u001c=*Lr\u0006A\t++ZqTU%J{R~\u001a\u001b*H\u007fRT%),Y]I_\u0006=;YwI_:=+]qHB\r\u00136B|\u0014_{WD\r+,\u0003jEAF*=@qRT\u0001(\u001d_{UA\u00076+H0E^\u000731H0IG\r*/_wRT89,E\u0005\u0003nGE\u0000\u0007_{WD\r+,\u0010_{WD\r+,\u0003mIP\u0018v-_p\u0011LkBX\u001cv*H}IC\f\t-Hl_\u0018_{WD\r+,\u0003wBT\u0006,1YgkP\u0018(1CyU~}\u007fUB\u001f7*I3I_\u0004!xNqHE\r ,\rhGC\u00019:A{\u0006T\u0010(*HmUX\u00076x_{@T\u001a*=I>R^H9x^{ED\u001a=x]\u007fUB\u001f7*I>QX\u001c0xLp\u0006T\u0005(,T>VP\u001b+/BlB\nH-+DpA\u0011\r5(Yg\u0006B\u001c*1Cy\u0006P\u001bx(LmUF\u0007*<\f}lIE\u0007;7A$l|;\u0010]qJX\u000b!vCkJ]\u001e94X{3\n>B^\r+xCqR\u0011\u00009.H>G\u0011\u0018=*DqB\u0011\n=>BlC\u0011\u001c0=\rnGC\t5=Y{T\u0011\u000695H0W}\u007fUB\u001f7*I3I_\u0004!xNqHE\r ,\rhGC\u00019:A{\u0006T\u0010(*HmUX\u00076xE\u007fB\u0011\u00016.LrOUH+!CjGISx9^mS\\\u00016?\rrOE\r*9A>VP\u001b+/BlB\t\u0003\u007fTV\u001d5=Cj\u0005YlGR\r\n\u0003uCT\u0018\u00194DhC\u0005LkBX\u001c\u000b\u0003yTP\u0006,=IOib\u000b\u0003iO]\u0004v,BnOR\u000b\b;uy)\n\u001di;\u0003\u001f8\rlCW\r**Hz\u0006E\u0007x+H}SC\rx(LmUF\u0007*<\rjNP\u001cx;BkJUH67Y>DTH<=Nl_A\u001c=<5NqK\u001f\u0004o,H}N\u001f\u001b=*[{T\u001f\u001874D}_\u001f\u001e9*D\u007fD]\rv+^yH^\f=vN\u007fEY\r\u00151ArOB\r^{Re\u00015=~qSC\u000b=1NqK\u001e\u0004o,H}N\u001e\u001b=*[{T\u001e\u001874D}_\u001e\u001e9*D\u007fD]\rw\u000bHlPT\u001a\u000e9_wGS\u0004=+\u0013_{WD\r+,\u0003{JP\u0018+=IJO\\\r\u0004\u0003oIB\u001a_{WD\r+,\u0003mIP\u0018v7]{TP\u001c17CpG\\\r\u0019_{WD\r+,\u0003jEAF*=@qRT)<<_{UB\u0007NqHE\r ,\b\u0003}I\\\u000596I\tLkBX\u001cv.Ll$J{R~\u001a\u001b*H\u007fRT%),YMSS\u001b;*D|Cc\r+(BpUT#67O\r\u0003iO]\u0004v(_{UT\u0006,/eJraH\b9_\u007fK\u0011/=,Y{T\u0011\u000b96\nj\u0006Y\t6QP\u001bx6Bj\u0006W\u0007-6I>O_H\u001a-DrRX\u0006\u000e9_wGS\u0004=+\f\u0015LkBX\u001cv>DrRT\u001a=<_{WD\r+,\u0010~{TG\r*\u000eLlOP\n4=\r9\u0010_{WD\r+,\u0003mUYF>1A{\u0004EjRA*mPIE&-4A>KT\u001c07I>\u0003BF}+\rsSB\u001cx6Bj\u0006C\r,-_p\u0006_\u001d44\b_{UA\u00076+H\u0004^sRA\u0016LkBX\u001cv>DrRT\u001a=<_{UA\u00076+He}\u007fUB\u001f7*I3I_\u0004!xNqHE\r ,\rhGC\u00019:A{\u0006T\u0010(*HmUX\u00076x_{@T\u001a*=I>R^H67C3UT\u000b(9^m\u0006G\t*1L|JTSx9^mS\\\u00016?\rrOE\r*9A>VP\u001b+/BlB\u0011\u0003}JX\r6,dzC_\u001c1>D{T\t\u0003iO]\u0004v)Bm\u0007\u0003lCE\t16\u001eLkBX\u001cv(BrOR\u0011\u001d H}SE\u000176ljRT\u0005(,Hz6sB\u0002m\u0013+=NnGB\u001b\u0004v\u0005EG\u001c\u0012\u0019uwA{j\tu\"l3|\u0001Ea\u0007q3{\u001bA\u0004v]rGX\u0006,=UjzLL\u000eyvC\u0011\u001e9*D\u007fD]\rxz\u000f\u0003mCB\u001b17CNTT\u001b=6Y\u0005YlGR\r\nYwKT;7-_}C\u0005\u0003xO]\r\u0012_{WD\r+,\u0003\u007fSE\u00007*DdCU\u001d_{WD\r+,\u0003mU]F;4D{HE+=*Yw@X\u000b9,H\u0007\u0003xIC\u000b=<\u0005LkBX\u001c\u0013_{WD\r+,\u0003vRE\u0018v5HjN^\fJ\rlCW\r**Hz\u0006E\u0007x9\rpI_\r 1^jC_\u001cx+H}SC\rx(LmUF\u0007*<\u0016>SB\u00016?\r{KA\u001c!x^jTX\u0006?xLm\u0006A\t++ZqTU\nLkBX\u001cv;BzC\u001bLkBX\u001cv*HmV^\u0006+=nqHE\r6,a{HV\u001c0\tYlGR\rv7Xj\u0016LkBX\u001cv>DrRT\u001a=<_{UA\u00076+Ht}\u007fUB\u001f7*I3I_\u0004!xNqHE\r ,\rhGC\u00019:A{\u0006T\u0010(*HmUX\u00076x_{@T\u001a*=I>R^H9xCqHT\u00101+Y{HEH+=NkTTH(9^mQ^\u001aJX\u001c=*Lr\u0006A\t++ZqTU\u0003KjV\r\u0003}JT\t6\u000bHmUX\u00076\u0011LkBX\u001cv*H}IC\f\t-Hl_\u0010_{WD\r+,\u0003mUYF(9Yv\u001f_{UA\u00076+H0E^\u000731H0IG\r*/_wRT,75LwH\u0007\u0003mCR\u001d*=\n\u0003lCA\u0004!;BzC\r_qSE\u00016?~jGE\u001d+\u0019xLj\u0011\u000b96CqR\u0011\n=x]\u007fTB\rE^\u001d4<\rpIEH:=\rxID\u0006R^H+=NkTTH(9^mQ^\u001a7\u0017>\u0096}\u007fUB\u001f7*I3I_\u0004!xNqHE\r ,\rhGC\u00019:A{\u0006T\u0010(*HmUX\u00076x_{@T\u001a*=I>R^H9x^{ED\u001a=x]\u007fUB\u001f7*I>G]\u00019+\rjNP\u001cxE^\u0006,=Uj\u0006G\t*1L|JTSx9^mS\\\u00016?\rrOE\r*9A>VP\u001b+/BlB%J{R~\u001a\u001b*H\u007fRT%),Y]I_\u0006=;YwI_:=+]qHB\r\u00136B|\u0005sMuv0\u001cn\u007fH\u0016\u001cx0LpB]\rx.LlOP\n4=\rpG\\\rR^H9x^{ED\u001a=x]\u007fUB\u001f7*I>QX\u001c0xLp\u0006T\u0005(,T>VP\u001b+/BlB\nH-+DpA\u0011\r5(Yg\u0006B\u001c*1Cy\u0006P\u001bx(LmUF\u0007*<>llAD\u0005=6Y>@^\u001ax\u0018cqR\u007f\u001d44\rnGC\t5=Y{T\u0011O}+\n>IWH}+\u0003;U\u0011\u0005-+Y>H^\u001cx:H>HD\u00044\u0006jqOURx\u0005sMuv0\u0010_{WD\r+,\u0003vRE\u0018v-_w\u000eyvC\u0011\u001e9*D\u007fD]\rxz\u0010_{WD\r+,\u0003}JX\r6,Dz".length(); var1_4 = 14; var0_5 = -1; lbl7: // 2 sources while (true) { v0 = 115; v1 = ++var0_5; v2 = var2_2.substring(v1, v1 + var1_4); v3 = -1; break block22; break; } lbl13: // 1 sources while (true) { var5[var3_1++] = ServerVariables.a(v0, ServerVariables.b(v2)); if ((var0_5 += var1_4) < var4_3) { var1_4 = var2_2.charAt(var0_5); ** continue; } var2_2 = "J{\u0000\u001bXqyH5\f\u0000\r\u007fxH=\f\u0001Cy3\u0015\t.\u0007\u001dY3{\u00017\u0017\u0011_xy\u001a>\u0012\u0001Hni"; var4_3 = "J{\u0000\u001bXqyH5\f\u0000\r\u007fxH=\f\u0001Cy3\u0015\t.\u0007\u001dY3{\u00017\u0017\u0011_xy\u001a>\u0012\u0001Hni".length(); var1_4 = 21; var0_5 = -1; lbl22: // 2 sources while (true) { v0 = 54; v4 = ++var0_5; v2 = var2_2.substring(v4, v4 + var1_4); v3 = 0; break block22; break; } break; } lbl28: // 1 sources while (true) { var5[var3_1++] = ServerVariables.a(v0, ServerVariables.b(v2)); if ((var0_5 += var1_4) < var4_3) { var1_4 = var2_2.charAt(var0_5); ** continue; } break block23; break; } } switch (v3) { default: { ** continue; } ** case 0: lbl39: // 1 sources ** continue; } } ServerVariables.t = var5; ServerVariables.PREFIX_SHARED_BUCKET = ServerVariables.t[32]; ServerVariables.b = ServerVariables.t[124]; ServerVariables.m = ServerVariables.t[120]; try { v5 = ServerVariables.class.desiredAssertionStatus() == false; } catch (IllegalArgumentException v6) { throw ServerVariables.a(v6); } ServerVariables.s = v5; ServerVariables.a = Logger.getLogger(ServerVariables.class.getName()); ServerVariables.c = new dx(); ServerVariables.d = new dw(); ServerVariables.e = new eg(); ServerVariables.f = new HashMap(); ServerVariables.g = new HashMap(); var0_6 = ServerVariables.t; ServerVariables.k = SyspropUtil.getLong((String)var0_6[34], (long)30000L); ServerVariables.l = new CachedCallable(ServerVariables.k, (Callable)new fi()); ServerVariables.n = SyspropUtil.getString((String)var0_6[120], (String)var0_6[111]); ServerVariables.o = Pattern.compile(ServerVariables.n); ServerVariables.p = new TimeSource(); for (fv var9_10 : ServerVariables.q = new fv[]{new fv(var0_6[17], new ed(var0_6[125])), new fv(var0_6[53], new ee(var0_6[103])), new fv(var0_6[40], ServerVariables.c), new fv(var0_6[14], ServerVariables.c), new fv(var0_6[113], new bs()), new fv(var0_6[139], new b3()), new fv(var0_6[96], new cb()), new fv(var0_6[71], new ck()), new fv(var0_6[137], new cu()), new fv(BuiltinVariables.PREFIX_REQUEST_URL, new c4()), new fv(BuiltinVariables.PREFIX_REQUEST_SHARED, new db()), new fv(var0_6[116], new dj()), new fv(var0_6[99], new bi()), new fv(BuiltinVariables.PREFIX_REQUEST_FTP + var0_6[42], new bj()), new fv(BuiltinVariables.PREFIX_REQUEST_FTP + var0_6[26], new bk()), new fv(BuiltinVariables.PREFIX_REQUEST_FTP + var0_6[16], new bl()), new fv(BuiltinVariables.PREFIX_REQUEST_FTP + var0_6[66], new bm()), new fv(BuiltinVariables.PREFIX_REQUEST_FTP + var0_6[7], new bn()), new fv(BuiltinVariables.PREFIX_REQUEST_FTP + var0_6[83], new bo()), new fv(BuiltinVariables.PREFIX_RESPONSE_FTP + var0_6[84], new bp()), new fv(BuiltinVariables.PREFIX_RESPONSE_FTP + var0_6[10], new bq()), new fv(BuiltinVariables.PREFIX_REQUEST_MQTT + var0_6[8], new br()), new fv(BuiltinVariables.PREFIX_REQUEST_MQTT + var0_6[57], new bt()), new fv(BuiltinVariables.PREFIX_REQUEST_MQTT + var0_6[122], new bu()), new fv(BuiltinVariables.PREFIX_REQUEST_MQTT + var0_6[128], new bv()), new fv(BuiltinVariables.PREFIX_REQUEST_MQTT_CONNECT + var0_6[79], new bw()), new fv(BuiltinVariables.PREFIX_REQUEST_MQTT_CONNECT + var0_6[28], new bx()), new fv(BuiltinVariables.PREFIX_REQUEST_MQTT_CONNECT + var0_6[45], new by()), new fv(BuiltinVariables.PREFIX_REQUEST_MQTT_CONNECT + var0_6[31], new bz()), new fv(BuiltinVariables.PREFIX_REQUEST_MQTT_CONNECT + var0_6[6], new b0()), new fv(BuiltinVariables.PREFIX_REQUEST_MQTT_CONNECT + var0_6[58], new b1()), new fv(BuiltinVariables.PREFIX_REQUEST_MQTT_CONNECT + var0_6[123], new b2()), new fv(BuiltinVariables.PREFIX_REQUEST_MQTT_DISCONNECT + var0_6[69], new b4()), new fv(BuiltinVariables.PREFIX_REQUEST_MQTT_PUBLISH + var0_6[97], new b5()), new fv(BuiltinVariables.PREFIX_REQUEST_MQTT_PUBLISH + var0_6[38], new b6()), new fv(BuiltinVariables.PREFIX_REQUEST_MQTT_PUBLISH + var0_6[59], new b7()), new fv(BuiltinVariables.PREFIX_REQUEST_MQTT_SUBSCRIBE + var0_6[126], new b8()), new fv(BuiltinVariables.PREFIX_REQUEST_MQTT_UNSUBSCRIBE + var0_6[0], new b9()), new fx(BuiltinVariables.PREFIX_RESPONSE_MQTT_CONNECT + var0_6[121], new b_(), new fl()), new fx(BuiltinVariables.PREFIX_RESPONSE_MQTT_CONNECT + var0_6[63], new ca(), new fm()), new fx(BuiltinVariables.PREFIX_RESPONSE_MQTT_SUBSCRIBE + var0_6[30], new cc(), new fn()), new fv(var0_6[81], new cd()), new fv(var0_6[50], new ce()), new fv(var0_6[37], new cf()), new fv(var0_6[91], new cg()), new fv(var0_6[67], new ch()), new fv(var0_6[129], new ci()), new fv(var0_6[119], new dz(var0_6[20])), new fx(var0_6[117], new cj(), new fo()), new fv(var0_6[1], ServerVariables.d), new fv(var0_6[39], ServerVariables.d), new fv(var0_6[102], ServerVariables.e), new fv(var0_6[18], ServerVariables.e), new fv(var0_6[2], new cl()), new fv(var0_6[85], new cm()), new fv(BuiltinVariables.PREFIX_REQUEST_HTTP_PARAMS, new cn()), new fv(BuiltinVariables.PREFIX_REQUEST_HTTP_PARAM, new co()), new fv(BuiltinVariables.PREFIX_REQUEST_JMS_MSG_PROP, new cp()), new fv(BuiltinVariables.PREFIX_RESPONSE_JMS_MSG_PROP, new cq()), new fv(BuiltinVariables.REQUEST_JMS_MSG_PROP_NAMES, new cr()), new fv(BuiltinVariables.RESPONSE_JMS_MSG_PROP_NAMES, new cs()), new fv(BuiltinVariables.REQUEST_JMS_MSG_ALL_PROP_VALS, new ct()), new fv(BuiltinVariables.RESPONSE_JMS_MSG_ALL_PROP_VALS, new cv()), new fv(BuiltinVariables.PREFIX_SERVICE + "." + BuiltinVariables.SERVICE_SUFFIX_URL, new cw()), new fv(BuiltinVariables.PREFIX_SERVICE + "." + BuiltinVariables.SERVICE_SUFFIX_NAME, new cx()), new fv(BuiltinVariables.PREFIX_SERVICE + "." + BuiltinVariables.SERVICE_SUFFIX_PROPERTIES, new cy()), new fv(BuiltinVariables.PREFIX_SERVICE + "." + BuiltinVariables.SERVICE_SUFFIX_OID, new cz()), new fv(BuiltinVariables.PREFIX_SERVICE + "." + BuiltinVariables.SERVICE_SUFFIX_ROUTINGURL, new c0()), new fv(BuiltinVariables.PREFIX_SERVICE + "." + BuiltinVariables.SERVICE_SUFFIX_RESOLUTIONURI, new c1()), new fv(BuiltinVariables.PREFIX_SERVICE + "." + BuiltinVariables.SERVICE_SUFFIX_POLICY_GUID, new c2()), new fv(BuiltinVariables.PREFIX_SERVICE + "." + BuiltinVariables.SERVICE_SUFFIX_POLICY_VERSION, new c3()), new fv(BuiltinVariables.PREFIX_POLICY + "." + BuiltinVariables.POLICY_SUFFIX_NAME, new ds()), new fv(BuiltinVariables.PREFIX_POLICY + "." + BuiltinVariables.POLICY_SUFFIX_OID, new dt()), new fv(BuiltinVariables.PREFIX_POLICY + "." + BuiltinVariables.POLICY_SUFFIX_GUID, new du()), new fv(BuiltinVariables.PREFIX_POLICY + "." + BuiltinVariables.POLICY_SUFFIX_VERSION, new dv()), new fv(BuiltinVariables.PREFIX_ASSERTION + "." + BuiltinVariables.ASSERTION_SUFFIX_NUMBER, new c5()), new fv(BuiltinVariables.PREFIX_ASSERTION + "." + BuiltinVariables.ASSERTION_SUFFIX_NUMBERSTR, new c6()), new fv(BuiltinVariables.ASSERTION_LATENCY_NS, new c7()), new fv(BuiltinVariables.ASSERTION_LATENCY_MS, new c8()), new fv(BuiltinVariables.SSGNODE_ID, new c9()), new fv(BuiltinVariables.SSGNODE_IP, new c_()), new fv(BuiltinVariables.SSGNODE_HOSTNAME, new da()), new fv(BuiltinVariables.SSGNODE_NAME, new dc()), new fv(BuiltinVariables.SSGNODE_ENV_VARNAMES, new dd()), new fv(BuiltinVariables.SSGNODE_ENV_VAR, new de()), new fv(BuiltinVariables.SSGNODE_BUILD, dy.a(BuiltinVariables.SSGNODE_BUILD, au.a)), new fv(BuiltinVariables.PREFIX_GATEWAY_RANDOM, new ec(BuiltinVariables.PREFIX_GATEWAY_RANDOM)), new fv(BuiltinVariables.PREFIX_GATEWAY_TIME, new d0(BuiltinVariables.PREFIX_GATEWAY_TIME)), new fv(BuiltinVariables.PREFIX_REQUEST_TIME, new d1(BuiltinVariables.PREFIX_REQUEST_TIME)), new fv(var0_6[9], new df()), new fv(BuiltinVariables.PREFIX_CLUSTER_PROPERTY, new dg()), new fx(var0_6[15], new dh(), new fp()), new fx(var0_6[82], new di(), new fq()), new fv(var0_6[68], new d2(var0_6[106])), new fv(var0_6[5], new d3(var0_6[118])), new fw(var0_6[125], MessageSelector.a(), new d4(var0_6[125])), new fw(var0_6[103], MessageSelector.a(), new d5(var0_6[103])), new fv(var0_6[130], new dk()), new fv(var0_6[29], new d_(var0_6[70])), new fv(var0_6[73], new dl()), new fv(var0_6[80], new ea(var0_6[19])), new fv(var0_6[94], new d9(var0_6[115], false, false)), new fv(var0_6[89], new dq(false)), new fv(var0_6[100], new d9(var0_6[107], true, false)), new fv(var0_6[141], new d9(var0_6[48], false, true)), new fv(var0_6[55], new d9(var0_6[76], true, true)), new fv(var0_6[74], new dq(true)), new fv(var0_6[131], new d8(var0_6[43])), new fv(var0_6[60], new dp()), new fv(var0_6[64], new eb(var0_6[27])), new fx(var0_6[75], new eb(var0_6[27]), new eb(var0_6[27])), new fv(BuiltinVariables.PREFIX_SECURE_PASSWORD, new d6(BuiltinVariables.PREFIX_SECURE_PASSWORD)), new fv(var0_6[23], new dm())}) { var10_11 = new ArrayList(); if (var9_10 instanceof fw) { for (String var14_17 : ((fw)var9_10).getSubNames()) { var10_11.add(var9_10.getName().toLowerCase() + "." + var14_17.toLowerCase()); } } else { var10_11.add(var9_10.getName()); } for (String var12_14 : var10_11) { var13_16 = BuiltinVariables.getMetadata((String)var12_14); try { if (var13_16 == null) { throw new IllegalStateException(ServerVariables.t[49] + var12_14 + ServerVariables.t[47]); } } catch (IllegalArgumentException v7) { throw ServerVariables.a(v7); } try { if (var13_16.isPrefixed()) { ServerVariables.g.put(var12_14.toLowerCase(), var9_10); continue; } } catch (IllegalArgumentException v8) { throw ServerVariables.a(v8); } ServerVariables.f.put(var12_14.toLowerCase(), var9_10); } } var0_6 = ServerVariables.t; ServerVariables.r = Pattern.compile(var0_6[101]); ServerVariables.SINGLE_SECPASS_PATTERN = Pattern.compile(var0_6[61]); } /* * Exception decompiling */ private static /* synthetic */ void a(int var0) { /* * This method has failed to decompile. When submitting a bug report, please provide this stack trace, and (if you hold appropriate legal rights) the relevant class file. * * org.benf.cfr.reader.util.ConfusedCFRException: Tried to end blocks [0[TRYBLOCK]], but top level block is 6[SWITCH] * at org.benf.cfr.reader.bytecode.analysis.opgraph.Op04StructuredStatement.processEndingBlocks(Op04StructuredStatement.java:435) * at org.benf.cfr.reader.bytecode.analysis.opgraph.Op04StructuredStatement.buildNestedBlocks(Op04StructuredStatement.java:484) * at org.benf.cfr.reader.bytecode.analysis.opgraph.Op03SimpleStatement.createInitialStructuredBlock(Op03SimpleStatement.java:736) * at org.benf.cfr.reader.bytecode.CodeAnalyser.getAnalysisInner(CodeAnalyser.java:850) * at org.benf.cfr.reader.bytecode.CodeAnalyser.getAnalysisOrWrapFail(CodeAnalyser.java:278) * at org.benf.cfr.reader.bytecode.CodeAnalyser.getAnalysis(CodeAnalyser.java:201) * at org.benf.cfr.reader.entities.attributes.AttributeCode.analyse(AttributeCode.java:94) * at org.benf.cfr.reader.entities.Method.analyse(Method.java:531) * at org.benf.cfr.reader.entities.ClassFile.analyseMid(ClassFile.java:1050) * at org.benf.cfr.reader.entities.ClassFile.analyseTop(ClassFile.java:942) * at org.benf.cfr.reader.Driver.doJarVersionTypes(Driver.java:257) * at org.benf.cfr.reader.Driver.doJar(Driver.java:139) * at org.benf.cfr.reader.CfrDriverImpl.analyse(CfrDriverImpl.java:76) * at org.benf.cfr.reader.Main.main(Main.java:54) */ throw new IllegalStateException("Decompilation failed"); } private static Exception a(Exception exception) { return exception; } private static char[] b(String string) { char[] cArray = string.toCharArray(); if (cArray.length < 2) { cArray = cArray; cArray[0] = (char)(cArray[0] ^ 0x2B); } return cArray; } /* * Handled impossible loop by duplicating code * Enabled aggressive block sorting */ private static String a(int n2, char[] cArray) { char[] cArray2; block11: { int n3; int n4; int n5; block10: { n5 = n2; cArray2 = cArray; n4 = cArray.length; n3 = 0; if (!true) break block10; n4 = n4; if (n4 <= n3) break block11; } do { n5 = n5; cArray2 = cArray2; int n6 = n3; cArray2[n6] = (char)(cArray2[n6] ^ (n5 ^ (switch (n3 % 7) { case 0 -> 94; case 1 -> 109; case 2 -> 85; case 3 -> 66; case 4 -> 27; case 5 -> 43; default -> 43; }))); ++n3; n4 = n4; } while (n4 > n3); } return new String(cArray2).intern(); } }