package com.l7tech.server.transport.http.websocket; import com.l7tech.gateway.common.transport.SsgConnector; import com.l7tech.message.Message; import com.l7tech.policy.variable.NoSuchVariableException; import com.l7tech.server.MessageProcessor; import com.l7tech.server.message.PolicyEnforcementContext; import com.l7tech.server.message.PolicyEnforcementContextFactory; import com.l7tech.server.transport.http.websocket.message.ExternalServerByteMessageHandler; import com.l7tech.server.transport.http.websocket.message.ExternalServerStringMessageHandler; import com.l7tech.server.transport.http.websocket.message.SsgWebSocketByteMessageHandler; import com.l7tech.server.transport.http.websocket.message.SsgWebSocketStringMessageHandler; import com.l7tech.util.ResourceUtils; import jakarta.websocket.CloseReason; import jakarta.websocket.Endpoint; import jakarta.websocket.EndpointConfig; import jakarta.websocket.Session; import jakarta.websocket.CloseReason.CloseCode; import jakarta.websocket.CloseReason.CloseCodes; import java.util.Map; import java.util.logging.Level; import java.util.logging.Logger; import org.jetbrains.annotations.NotNull; import org.jetbrains.annotations.Nullable; public class SsgWebSocketEndpoint extends Endpoint { private static final Logger a; private PolicyEnforcementContext b; private static final String[] c; public void onOpen(@NotNull Session var1, @NotNull EndpointConfig var2) { try { if (var1 == null) { a(0); } } catch (Exception var10) { throw a(var10); } try { if (var2 == null) { a(1); } } catch (Exception var11) { throw a(var11); } String var3 = this.a(var2); SsgWebSocketEndpointHandler var4 = SsgWebSocketManager.getInstance().getEndpointHandler(); Map var10000 = var2.getUserProperties(); String[] var8 = c; var10000.put(var8[19], var1); try { Session var5 = (Session)var2.getUserProperties().get(var8[2]); if (var5 != null) { boolean var6 = Boolean.parseBoolean((String)var2.getUserProperties().get(var8[1])); SsgConnector var7 = (SsgConnector)var2.getUserProperties().get(var8[36]); var5.addMessageHandler(new ExternalServerByteMessageHandler(var4, var7, var5, var1, var3, var6)); var5.addMessageHandler(new ExternalServerStringMessageHandler(var4, var7, var5, var1, var3, var6)); } var10000 = var2.getUserProperties(); var8 = c; boolean var12 = Boolean.parseBoolean((String)var10000.get(var8[7])); SsgConnector var13 = (SsgConnector)var2.getUserProperties().get(var8[17]); var1.addMessageHandler(new SsgWebSocketByteMessageHandler(var4, var13, var1, var5, var3, var12)); var1.addMessageHandler(new SsgWebSocketStringMessageHandler(var4, var13, var1, var5, var3, var12)); } catch (Exception var9) { throw new SsgWebSocketRuntimeException(c[29], var9); } } @NotNull private String a(@NotNull EndpointConfig var1) { try { if (var1 == null) { a(2); } } catch (SsgWebSocketRuntimeException var2) { throw a(var2); } return this.a((String)var1.getUserProperties().get(c[23])); } @NotNull private String a(@NotNull String param1) { // $VF: Couldn't be decompiled // Please report this to the Vineflower issue tracker, at https://github.com/Vineflower/vineflower/issues with a copy of the class file (if you have the rights to distribute it!) // java.lang.RuntimeException: parsing failure! // at org.jetbrains.java.decompiler.modules.decompiler.decompose.DomHelper.parseGraph(DomHelper.java:211) // at org.jetbrains.java.decompiler.main.rels.MethodProcessor.codeToJava(MethodProcessor.java:174) // // Bytecode: // 00: aload 1 // 01: ifnonnull 0f // 04: bipush 3 // 05: invokestatic com/l7tech/server/transport/http/websocket/SsgWebSocketEndpoint.a (I)V // 08: goto 0f // 0b: invokestatic com/l7tech/server/transport/http/websocket/SsgWebSocketEndpoint.a (Ljava/lang/Exception;)Ljava/lang/Exception; // 0e: athrow // 0f: invokestatic com/l7tech/server/transport/http/websocket/SsgWebSocketManager.getInstance ()Lcom/l7tech/server/transport/http/websocket/SsgWebSocketManager; // 12: aload 1 // 13: invokevirtual com/l7tech/server/transport/http/websocket/SsgWebSocketManager.getHandshakeSsgServerEndpointConfig (Ljava/lang/String;)Lcom/l7tech/server/transport/http/websocket/SsgServerEndpointConfig; // 16: astore 2 // 17: aload 2 // 18: ifnull 29 // 1b: aload 2 // 1c: invokevirtual com/l7tech/server/transport/http/websocket/SsgServerEndpointConfig.getPath ()Ljava/lang/String; // 1f: ifnonnull 3b // 22: goto 29 // 25: invokestatic com/l7tech/server/transport/http/websocket/SsgWebSocketEndpoint.a (Ljava/lang/Exception;)Ljava/lang/Exception; // 28: athrow // 29: new com/l7tech/server/transport/http/websocket/SsgWebSocketRuntimeException // 2c: dup // 2d: getstatic com/l7tech/server/transport/http/websocket/SsgWebSocketEndpoint.c [Ljava/lang/String; // 30: bipush 26 // 32: aaload // 33: invokespecial com/l7tech/server/transport/http/websocket/SsgWebSocketRuntimeException. (Ljava/lang/String;)V // 36: athrow // 37: invokestatic com/l7tech/server/transport/http/websocket/SsgWebSocketEndpoint.a (Ljava/lang/Exception;)Ljava/lang/Exception; // 3a: athrow // 3b: aload 2 // 3c: invokevirtual com/l7tech/server/transport/http/websocket/SsgServerEndpointConfig.getPath ()Ljava/lang/String; // 3f: dup // 40: ifnonnull 4e // 43: bipush 4 // 44: invokestatic com/l7tech/server/transport/http/websocket/SsgWebSocketEndpoint.a (I)V // 47: goto 4e // 4a: invokestatic com/l7tech/server/transport/http/websocket/SsgWebSocketEndpoint.a (Ljava/lang/Exception;)Ljava/lang/Exception; // 4d: athrow // 4e: areturn // try (0 -> 4): 5 com/l7tech/server/transport/http/websocket/SsgWebSocketRuntimeException // try (11 -> 16): 17 com/l7tech/server/transport/http/websocket/SsgWebSocketRuntimeException // try (13 -> 26): 26 com/l7tech/server/transport/http/websocket/SsgWebSocketRuntimeException // try (28 -> 34): 35 com/l7tech/server/transport/http/websocket/SsgWebSocketRuntimeException } public void onClose(@NotNull Session var1, @NotNull CloseReason var2) { try { if (var1 == null) { a(5); } } catch (SsgWebSocketRuntimeException var8) { throw a(var8); } try { if (var2 == null) { a(6); } } catch (SsgWebSocketRuntimeException var6) { throw a(var6); } try { if (!CloseCodes.NORMAL_CLOSURE.equals(var2.getCloseCode())) { a.log(Level.WARNING, c[28], new Object[]{this.getFriendlyId(), var2}); } } catch (SsgWebSocketRuntimeException var7) { throw a(var7); } CloseReason var3 = var2; Map var10000 = var1.getUserProperties(); String[] var5 = c; if (Boolean.parseBoolean((String)var10000.get(var5[16]))) { CloseReason var4 = this.a( var1.isSecure(), this.a((String)var1.getUserProperties().get(var5[21])), SsgWebSocketManager.getInstance().getEndpointHandler().getMessageProcessor() ); if (var4 != null) { var3 = var4; } } SsgWebSocketUpgradeProcessor.a(var1, (Session)var1.getUserProperties().get(c[38]), var2, var3, this.getFriendlyId()); } @Nullable private CloseReason a(boolean var1, @NotNull String var2, @NotNull MessageProcessor var3) { try { if (var2 == null) { a(7); } } catch (SsgWebSocketExpectedRuntimeException var16) { throw a(var16); } try { if (var3 == null) { a(8); } } catch (SsgWebSocketExpectedRuntimeException var21) { throw a(var21); } PolicyEnforcementContext var4 = this.a(); Message var5 = var4.getRequest(); try { try { var5.attachHttpRequestKnob(new a(this, var2, var1)); var4.setVariable(c[9], c[4]); if (a.isLoggable(Level.FINE)) { a.fine(c[3]); } } catch (SsgWebSocketExpectedRuntimeException var17) { throw a(var17); } var3.processMessage(var4); String[] var9 = c; String var6 = this.a(var4, var9[12]); if (var6 == null) { return null; } CloseCode var10002 = CloseCodes.getCloseCode(Integer.parseInt(var6)); var9 = c; return new CloseReason(var10002, this.a(var4, var9[5])); } catch (SsgWebSocketExpectedRuntimeException var18) { throw var18; } catch (Exception var19) { throw new SsgWebSocketRuntimeException(c[18], var19); } finally { ResourceUtils.closeQuietly(var4); } } @Nullable private String a(@NotNull PolicyEnforcementContext var1, @NotNull String var2) { try { if (var1 == null) { a(9); } } catch (NoSuchVariableException var4) { throw a(var4); } try { if (var2 == null) { a(10); } } catch (NoSuchVariableException var7) { throw a(var7); } try { Object var3 = var1.getVariable(var2); try { if (var3 == null) { return null; } } catch (NoSuchVariableException var5) { throw a(var5); } return var3.toString(); } catch (NoSuchVariableException var6) { return null; } } public void onError(Session var1, Throwable var2) { try { a.log(Level.WARNING, c[10], new Object[]{this.getFriendlyId(), var2}); if (a.isLoggable(Level.FINE)) { a.log(Level.FINE, var2, () -> c[8] + this.getFriendlyId()); } } catch (SsgWebSocketRuntimeException var3) { throw a(var3); } } public String getFriendlyId() { return ""; } public SsgWebSocketEndpoint getTargetEndpoint() { return this; } PolicyEnforcementContext a() { try { if (this.b != null) { return this.b; } } catch (SsgWebSocketRuntimeException var1) { throw a(var1); } return PolicyEnforcementContextFactory.createPolicyEnforcementContext(null, null, true); } public void setOnClosePec(PolicyEnforcementContext var1) { this.b = var1; } static { String[] var5 = new String[39]; int var3 = 0; String var2 = "|@RB8\u00120~_R_.L\u007fz\u001c\u000e%'iE^Tp\u00104l_\u0010e52:jKU\u001c\u0010%&lMZTp\u0006'pA\u0010t%40mB\\]\u0017L\u007fz\u001c\u000e%&lER_p\u0014:2iEE82;~@\u0012RINB<'0?\\O^>%&lESV\u0007PB~]2303hI_B2#>zX\u0013^3\u00039p_X\u001f>,:lIoT<3:q|UC<30KCnT/60mcKT/2<{I\u0016xIIc83:sZXU\u000e%'iE^T\r!!w,L\u007fz\u001c\u000e%'iE^Tp\u00104l_\u0010e52:jKU\u001c\u0010%&lMZTp\u0014:2iEE82;~@)Z^O^/`0qORD340mIY\u00114.uj_T_:`!wI\u001dF8\"&pOVT)`\u000fhI_B2#>zX\u0013T+%;k2Z^O^/`0qORD340mIY\u00114.uj_T_:`!wI\u001dF8\"&pOVT)h./Q\u0014\u001d};db\u0012xIIr2.!zTIg<2<~NQT+hI_B2#>zX\u0013^3\u00039p_X\u001f>,:lI~^9%\u0001p\u007fXC+%'PZXC/)1z\u0004qMPT\u000bwMSU.(4tItU\u0007pB~]230#L\u007fz\u001c\u000e%'iE^Tp\u000f;2oQ^.%xZTXR(402|R]4#,\u0014L\u007fz\u001c\u001e/;qI^E22xZBIX)9&Z^O^/`%mC^T.3%uoMIYq`40{@D\u0011359s*_bRE\u001359s\fPT)(:{\f\u0018Bse&?AHB)`;pX\u001dC84 mB\u001d_(,9*\\@RB4.2?XUT}70}_RR6%!7W\rLt`\"vXU\u0011/%4lCS\u0011&q(%JBXI-%6kIY\u001182'p^\u001d^-%;vBZ\u0011)(0?ISU-/zX\u0013T+%;k2Z^O^/`0qORD340mIY\u00114.uj_T_:`!wI\u001dF8\"&pOVT)h./Q\u0014\u001d};db\u0012xIIr2.!zTIg<2<~NQT+hI_B2#>zX\u0013^3\u00039p_X\u001f>,:lI~^9%\u0001p\u007fXC+%'PZXC/)1z\u0004qMPT\u000bwMSU.(4tItU\u0007pB~]230#L\u007fz\u001c\u000e%'iE^Tp\u000f;2oQ^.%xZTXR(402|R]4#,\u0014L\u007fz\u001c\u001e/;qI^E22xZBIX)9&Z^O^/`%mC^T.3%uoMIYq`40{@D\u0011359s*_bRE\u001359s\fPT)(:{\f\u0018Bse&?AHB)`;pX\u001dC84 mB\u001d_(,9*\\@RB4.2?XUT}70}_RR6%!7W\rLt`\"vXU\u0011/%4lCS\u0011&q(%JBXI-%6kIY\u001182'p^\u001d^-%;vBZ\u0011)(0?ISU-/= var4) { c = var5; a = Logger.getLogger(SsgWebSocketEndpoint.class.getName()); return; } var1 = var2.charAt(var7); break; default: var5[var3++] = var8; if ((var7 += var1) < var4) { var1 = var2.charAt(var7); continue label24; } var2 = "\u0006\u0006\u0002\u001ch}c3T\u0003\u0006w8M\t\u001b\u0011'ptag\u0004\u0004\u001bduh3\u0011\u0017I\"=~`T\n\u000f%=~iQ\u0016Ihm~3T\u000b\u0006q8o\"T\u000b\u001cit\u0017\u0014'\"DV}~4\u001d\n\u0007(Lbj1\u001d\u001d`jc&\u0018"; var4 = "\u0006\u0006\u0002\u001ch}c3T\u0003\u0006w8M\t\u001b\u0011'ptag\u0004\u0004\u001bduh3\u0011\u0017I\"=~`T\n\u000f%=~iQ\u0016Ihm~3T\u000b\u0006q8o\"T\u000b\u001cit\u0017\u0014'\"DV}~4\u001d\n\u0007(Lbj1\u001d\u001d`jc&\u0018" .length(); var1 = '>'; var7 = -1; } var10000 = 91; var10001 = var2.substring(++var7, var7 + var1); var10002 = 0; } } } private static Exception a(Exception var0) { return var0; } private static char[] b(String var0) { char[] var10000 = var0.toCharArray(); if (var10000.length < 2) { var10000[0] = (char)(var10000[0] ^ 86); } return var10000; } private static String a(int var0, char[] var1) { int var10003 = var1.length; int var10002 = var0; char[] var10001 = var1; int var10000 = var10003; for (int var2 = 0; var10000 > var2; var2++) { var10001[var2] = (char)(var10001[var2] ^ var10002 ^ switch (var2 % 7) { case 0 -> 28; case 1 -> 47; case 2 -> 62; case 3 -> 50; case 4 -> 94; case 5 -> 67; default -> 86; }); } return new String(var10001).intern(); } }