/* * Decompiled with CFR 0.152. * * Could not load the following classes: * com.l7tech.common.io.CertUtils * com.l7tech.gateway.common.audit.AuditSearchCriteria$Builder * com.l7tech.gateway.common.transport.SsgConnector$Endpoint * com.l7tech.objectmodel.FindException * com.l7tech.server.management.NodeStateType * com.l7tech.server.management.api.monitoring.BuiltinMonitorables * com.l7tech.server.management.api.monitoring.NodeStatus * com.l7tech.server.management.api.node.NodeApi * com.l7tech.server.management.api.node.NodeApi$UnsupportedPropertyException * com.l7tech.util.ConfigFactory * com.l7tech.util.IOUtils * jakarta.annotation.Resource * jakarta.inject.Inject * jakarta.servlet.ServletRequest * jakarta.servlet.http.HttpServletRequest * jakarta.xml.ws.WebServiceContext */ package com.l7tech.server; import com.l7tech.common.io.CertUtils; import com.l7tech.gateway.common.audit.AuditSearchCriteria; import com.l7tech.gateway.common.transport.SsgConnector; import com.l7tech.objectmodel.FindException; import com.l7tech.server.audit.AuditRecordManager; import com.l7tech.server.boot.ShutdownWatcher; import com.l7tech.server.cluster.DatabaseReplicationMonitor; import com.l7tech.server.management.NodeStateType; import com.l7tech.server.management.api.monitoring.BuiltinMonitorables; import com.l7tech.server.management.api.monitoring.NodeStatus; import com.l7tech.server.management.api.node.NodeApi; import com.l7tech.server.transport.ListenerException; import com.l7tech.server.transport.http.HttpTransportModule; import com.l7tech.util.ConfigFactory; import com.l7tech.util.IOUtils; import jakarta.annotation.Resource; import jakarta.inject.Inject; import jakarta.servlet.ServletRequest; import jakarta.servlet.http.HttpServletRequest; import jakarta.xml.ws.WebServiceContext; import java.io.File; import java.io.IOException; import java.net.InetAddress; import java.net.UnknownHostException; import java.security.cert.CertificateException; import java.security.cert.X509Certificate; import java.util.Date; import java.util.logging.Level; import java.util.logging.Logger; public class NodeApiImpl implements NodeApi { private static final Logger a; @Inject private ShutdownWatcher shutdowner; @Inject private AuditRecordManager auditRecordManager; @Inject private DatabaseReplicationMonitor databaseReplicationMonitor; @Resource private WebServiceContext wscontext; private X509Certificate b; private static final String[] c; public void shutdown() { this.a(); a.warning(c[15]); this.shutdowner.shutdownNow(); } public void ping() { this.a(); a.fine(c[11]); } public NodeStatus getNodeStatus() { this.a(); a.fine(c[17]); return new NodeStatus(NodeStateType.RUNNING, new Date(), new Date()); } public String getProperty(String string) throws NodeApi.UnsupportedPropertyException, FindException { try { this.a(); a.fine(c[6]); if (string.equals(BuiltinMonitorables.AUDIT_SIZE.getName())) { return Integer.toString(this.auditRecordManager.findCount(new AuditSearchCriteria.Builder().fromLevel(Level.ALL).toLevel(Level.OFF).build())); } } catch (NodeApi.UnsupportedPropertyException unsupportedPropertyException) { throw NodeApiImpl.a((Exception)((Object)unsupportedPropertyException)); } try { if (string.equals(BuiltinMonitorables.DATABASE_REPLICATION_DELAY.getName())) { return Long.toString(this.databaseReplicationMonitor.getReplicationDelay()); } } catch (NodeApi.UnsupportedPropertyException unsupportedPropertyException) { throw NodeApiImpl.a((Exception)((Object)unsupportedPropertyException)); } throw new NodeApi.UnsupportedPropertyException(c[3]); } /* * Loose catch block */ private void a() { block18: { String[] stringArray = c; HttpServletRequest httpServletRequest = (HttpServletRequest)this.wscontext.getMessageContext().get((Object)stringArray[0]); try { if (httpServletRequest == null) { throw new IllegalStateException(stringArray[2]); } } catch (ListenerException listenerException) { throw NodeApiImpl.a(listenerException); } try { HttpTransportModule.requireEndpoint((ServletRequest)httpServletRequest, SsgConnector.Endpoint.PC_NODE_API); X509Certificate x509Certificate = this.a(httpServletRequest); try { if (x509Certificate == null) { a.fine(c[13]); throw new IllegalStateException(c[7]); } } catch (ListenerException listenerException) { throw NodeApiImpl.a(listenerException); } try { if (!InetAddress.getByName(httpServletRequest.getRemoteAddr()).isLoopbackAddress()) { throw new IllegalStateException(c[9]); } } catch (ListenerException listenerException) { throw NodeApiImpl.a(listenerException); } X509Certificate x509Certificate2 = this.b(); if (x509Certificate2 == null) break block18; try { block19: { if (CertUtils.certsAreEqual((X509Certificate)x509Certificate2, (X509Certificate)x509Certificate)) break block18; break block19; catch (ListenerException listenerException) { throw NodeApiImpl.a(listenerException); } } throw new IllegalStateException(c[1]); } catch (ListenerException listenerException) { throw NodeApiImpl.a(listenerException); } } catch (ListenerException listenerException) { stringArray = c; throw new IllegalStateException(stringArray[16]); } catch (UnknownHostException unknownHostException) { stringArray = c; throw new IllegalStateException(stringArray[12], unknownHostException); } catch (CertificateException certificateException) { stringArray = c; throw new IllegalStateException(stringArray[10], certificateException); } catch (IOException iOException) { throw new IllegalStateException(c[5], iOException); } } } private X509Certificate a(HttpServletRequest httpServletRequest) { X509Certificate x509Certificate; String[] stringArray = c; Object object = httpServletRequest.getAttribute(stringArray[14]); if (object instanceof X509Certificate) { x509Certificate = (X509Certificate)object; } else if (object instanceof X509Certificate[]) { X509Certificate x509Certificate2; X509Certificate[] x509CertificateArray = (X509Certificate[])object; try { x509Certificate2 = x509CertificateArray.length > 0 ? x509CertificateArray[0] : null; } catch (IllegalStateException illegalStateException) { throw NodeApiImpl.a(illegalStateException); } x509Certificate = x509Certificate2; } else if (object != null) { stringArray = c; a.warning(stringArray[18] + object.getClass().getName() + stringArray[8]); x509Certificate = null; } else { x509Certificate = null; } return x509Certificate; } private X509Certificate b() throws CertificateException, IOException { String string; X509Certificate x509Certificate = this.b; if (x509Certificate == null && (string = ConfigFactory.getProperty((String)c[4])) != null) { this.b = x509Certificate = CertUtils.decodeCert((byte[])IOUtils.slurpFile((File)new File(string))); } return x509Certificate; } /* * Unable to fully structure code */ static { block10: { block9: { var5 = new String[19]; var3_1 = 0; var2_2 = "O+V=\u0002(\u0019\u000b2P0^+\u000b\u000b9X.\u00060\u001dQdO9\u0001)\u001dV>&w/L)\u0015/\f\u0005.X2\u00199\u001c\u0005b^9\u0002(\u0011C#^=\u00049XH#N1\u0011(\u001bMc\u00134w/L)\u0015/\f\u00058X?\u00155\u000e@.\u001d3\u0005(\u000bL.X|\u001f:X@2M9\u0013(\u001dAjN9\u0002*\u0014@>\u001d?\u001f2\f@2I\nU8R,\u0015.\f\\\u0003Y'F%Pr\u001ck\f@)Ur\u00039\nS/Or\u0000.\u0017F/N/33\u0016Q8R0\u001c9\nf/O(.w/L)\u0015/\f\u0005.X2\u00199\u001c\u0005bX.\u00023\n\u0005:O3\u00139\u000bV#S;P?\u001dW>T:\u0019?\u0019Q/\u0014r\u000bB/I\f\u00023\b@8I% w/L)\u0015/\f\u0005.X2\u00199\u001c\u0005bS3P?\u001dW>T:\u0019?\u0019Q/\u0014r\u0018\tjS3\u0004|\u0019Kjei@e;@8I5\u00165\u001bD>X%w/L)\u0015/\f\u0005.X2\u00199\u001c\u0005,R.P2\u0017KgQ3\u0013=\u0014\u0005+Y8\u00029\u000bVd.w/L)\u0015/\f\u0005.X2\u00199\u001c\u0005bX.\u00023\n\u0005:O3\u00139\u000bV#S;P?\u001dW>T:\u0019?\u0019Q/\u0014r\u0004U#S;%w/L)\u0015/\f\u0005.X2\u00199\u001c\u0005,R.P2\u0017KgQ3\u0013=\u0014\u0005+Y8\u00029\u000bVd&f&T9\u001e(XF/O(\u0019:\u0011F+I9P1\u0011V9T2\u0017|\u0011KjO9\u0001)\u001dV>\u0013'O+V=\u0002(\u0019\u000b9X.\u00060\u001dQdO9\u0001)\u001dV>\u0013\u0004ElAf/O(\u0019:\u0011F+I9\u0017k%Y9P\u000f\u0010P>Y3\u00072XW/L)\u0015/\f@.Cq\"T/P2\u0017A/\u001d4\u0011/XK%I|\u00129\u001dKj^3\u001e:\u0011B?O9\u0014|\u001eJ8\u001d)\u00039XG3\u001d(\u00189Xu8R?\u0015/\u000b\u0005\tR2\u0004.\u0017I&X."; var4_3 = "O+V=\u0002(\u0019\u000b2P0^+\u000b\u000b9X.\u00060\u001dQdO9\u0001)\u001dV>&w/L)\u0015/\f\u0005.X2\u00199\u001c\u0005b^9\u0002(\u0011C#^=\u00049XH#N1\u0011(\u001bMc\u00134w/L)\u0015/\f\u00058X?\u00155\u000e@.\u001d3\u0005(\u000bL.X|\u001f:X@2M9\u0013(\u001dAjN9\u0002*\u0014@>\u001d?\u001f2\f@2I\nU8R,\u0015.\f\\\u0003Y'F%Pr\u001ck\f@)Ur\u00039\nS/Or\u0000.\u0017F/N/33\u0016Q8R0\u001c9\nf/O(.w/L)\u0015/\f\u0005.X2\u00199\u001c\u0005bX.\u00023\n\u0005:O3\u00139\u000bV#S;P?\u001dW>T:\u0019?\u0019Q/\u0014r\u000bB/I\f\u00023\b@8I% w/L)\u0015/\f\u0005.X2\u00199\u001c\u0005bS3P?\u001dW>T:\u0019?\u0019Q/\u0014r\u0018\tjS3\u0004|\u0019Kjei@e;@8I5\u00165\u001bD>X%w/L)\u0015/\f\u0005.X2\u00199\u001c\u0005,R.P2\u0017KgQ3\u0013=\u0014\u0005+Y8\u00029\u000bVd.w/L)\u0015/\f\u0005.X2\u00199\u001c\u0005bX.\u00023\n\u0005:O3\u00139\u000bV#S;P?\u001dW>T:\u0019?\u0019Q/\u0014r\u0004U#S;%w/L)\u0015/\f\u0005.X2\u00199\u001c\u0005,R.P2\u0017KgQ3\u0013=\u0014\u0005+Y8\u00029\u000bVd&f&T9\u001e(XF/O(\u0019:\u0011F+I9P1\u0011V9T2\u0017|\u0011KjO9\u0001)\u001dV>\u0013'O+V=\u0002(\u0019\u000b9X.\u00060\u001dQdO9\u0001)\u001dV>\u0013\u0004ElAf/O(\u0019:\u0011F+I9\u0017k%Y9P\u000f\u0010P>Y3\u00072XW/L)\u0015/\f@.Cq\"T/P2\u0017A/\u001d4\u0011/XK%I|\u00129\u001dKj^3\u001e:\u0011B?O9\u0014|\u001eJ8\u001d)\u00039XG3\u001d(\u00189Xu8R?\u0015/\u000b\u0005\tR2\u0004.\u0017I&X.".length(); var1_4 = 30; var0_5 = -1; lbl7: // 2 sources while (true) { v0 = 1; v1 = ++var0_5; v2 = var2_2.substring(v1, v1 + var1_4); v3 = -1; break block9; break; } lbl13: // 1 sources while (true) { var5[var3_1++] = NodeApiImpl.a(v0, NodeApiImpl.a(v2)); if ((var0_5 += var1_4) < var4_3) { var1_4 = var2_2.charAt(var0_5); ** continue; } var2_2 = "]0V\r\u0000'\u0002i!C7\u001a0\u0019y9K&\u00017GY0P7\u0006%\u000eY4V&O4\u0006IuCc"; var4_3 = "]0V\r\u0000'\u0002i!C7\u001a0\u0019y9K&\u00017GY0P7\u0006%\u000eY4V&O4\u0006IuCc".length(); var1_4 = 13; var0_5 = -1; lbl22: // 2 sources while (true) { v0 = 30; v4 = ++var0_5; v2 = var2_2.substring(v4, v4 + var1_4); v3 = 0; break block9; break; } break; } lbl28: // 1 sources while (true) { var5[var3_1++] = NodeApiImpl.a(v0, NodeApiImpl.a(v2)); if ((var0_5 += var1_4) < var4_3) { var1_4 = var2_2.charAt(var0_5); ** continue; } break block10; break; } } switch (v3) { default: { ** continue; } ** case 0: lbl39: // 1 sources ** continue; } } NodeApiImpl.c = var5; NodeApiImpl.a = Logger.getLogger(NodeApiImpl.class.getName()); } private static Exception a(Exception exception) { return exception; } private static char[] a(String string) { char[] cArray = string.toCharArray(); if (cArray.length < 2) { cArray = cArray; cArray[0] = (char)(cArray[0] ^ 0x79); } 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 -> 36; case 1 -> 75; case 2 -> 60; case 3 -> 93; case 4 -> 113; case 5 -> 93; default -> 121; }))); ++n3; n4 = n4; } while (n4 > n3); } return new String(cArray2).intern(); } }