NetMirror.apk
Download file
package com.facebook.react.modules.websocket;
import D2.h;
import K2.o;
import M2.B;
import M2.D;
import M2.H;
import M2.I;
import M2.z;
import b3.l;
import com.facebook.fbreact.specs.NativeWebSocketModuleSpec;
import com.facebook.react.bridge.Arguments;
import com.facebook.react.bridge.ReactApplicationContext;
import com.facebook.react.bridge.ReadableArray;
import com.facebook.react.bridge.ReadableMap;
import com.facebook.react.bridge.ReadableMapKeySetIterator;
import com.facebook.react.bridge.ReadableType;
import com.facebook.react.bridge.WritableMap;
import com.facebook.react.modules.network.d;
import java.io.IOException;
import java.net.URI;
import java.net.URISyntaxException;
import java.util.HashMap;
import java.util.Iterator;
import java.util.List;
import java.util.Map;
import java.util.concurrent.ConcurrentHashMap;
import java.util.concurrent.TimeUnit;
import kotlin.jvm.internal.DefaultConstructorMarker;
import v1.InterfaceC0756a;
/* JADX INFO: loaded from: classes.dex */
@InterfaceC0756a(name = "WebSocketModule")
public final class WebSocketModule extends NativeWebSocketModuleSpec {
public static final a Companion = new a(null);
public static final String NAME = "WebSocketModule";
private static com.facebook.react.modules.network.b customClientBuilder;
private final Map<Integer, b> contentHandlers;
private final d cookieHandler;
private final Map<Integer, H> webSocketConnections;
public static final class a {
public /* synthetic */ a(DefaultConstructorMarker defaultConstructorMarker) {
this();
}
/* JADX INFO: Access modifiers changed from: private */
public final void c(z.a aVar) {
WebSocketModule.access$getCustomClientBuilder$cp();
}
/* JADX INFO: Access modifiers changed from: private */
/* JADX WARN: Removed duplicated region for block: B:27:0x004d */
/*
Code decompiled incorrectly, please refer to instructions dump.
To view partially-correct code enable 'Show inconsistent code' option in preferences
*/
public final java.lang.String d(java.lang.String r7) {
/*
r6 = this;
java.net.URI r0 = new java.net.URI // Catch: java.net.URISyntaxException -> L92
r0.<init>(r7) // Catch: java.net.URISyntaxException -> L92
java.lang.String r1 = r0.getScheme() // Catch: java.net.URISyntaxException -> L92
if (r1 == 0) goto L4d
int r2 = r1.hashCode() // Catch: java.net.URISyntaxException -> L92
r3 = 3804(0xedc, float:5.33E-42)
java.lang.String r4 = "http"
if (r2 == r3) goto L45
r3 = 118039(0x1cd17, float:1.65408E-40)
java.lang.String r5 = "https"
if (r2 == r3) goto L3a
r3 = 3213448(0x310888, float:4.503E-39)
if (r2 == r3) goto L2e
r3 = 99617003(0x5f008eb, float:2.2572767E-35)
if (r2 == r3) goto L27
goto L4d
L27:
boolean r1 = r1.equals(r5) // Catch: java.net.URISyntaxException -> L92
if (r1 != 0) goto L35
goto L4d
L2e:
boolean r1 = r1.equals(r4) // Catch: java.net.URISyntaxException -> L92
if (r1 != 0) goto L35
goto L4d
L35:
java.lang.String r4 = r0.getScheme() // Catch: java.net.URISyntaxException -> L92
goto L4f
L3a:
java.lang.String r2 = "wss"
boolean r1 = r1.equals(r2) // Catch: java.net.URISyntaxException -> L92
if (r1 != 0) goto L43
goto L4d
L43:
r4 = r5
goto L4f
L45:
java.lang.String r2 = "ws"
boolean r1 = r1.equals(r2) // Catch: java.net.URISyntaxException -> L92
if (r1 != 0) goto L4f
L4d:
java.lang.String r4 = ""
L4f:
int r1 = r0.getPort() // Catch: java.net.URISyntaxException -> L92
r2 = -1
java.lang.String r3 = "format(...)"
if (r1 == r2) goto L79
D2.u r1 = D2.u.f192a // Catch: java.net.URISyntaxException -> L92
java.lang.String r1 = "%s://%s:%s"
java.lang.String r2 = r0.getHost() // Catch: java.net.URISyntaxException -> L92
int r0 = r0.getPort() // Catch: java.net.URISyntaxException -> L92
java.lang.Integer r0 = java.lang.Integer.valueOf(r0) // Catch: java.net.URISyntaxException -> L92
java.lang.Object[] r0 = new java.lang.Object[]{r4, r2, r0} // Catch: java.net.URISyntaxException -> L92
r2 = 3
java.lang.Object[] r0 = java.util.Arrays.copyOf(r0, r2) // Catch: java.net.URISyntaxException -> L92
java.lang.String r0 = java.lang.String.format(r1, r0) // Catch: java.net.URISyntaxException -> L92
D2.h.e(r0, r3) // Catch: java.net.URISyntaxException -> L92
goto L91
L79:
D2.u r1 = D2.u.f192a // Catch: java.net.URISyntaxException -> L92
java.lang.String r1 = "%s://%s"
java.lang.String r0 = r0.getHost() // Catch: java.net.URISyntaxException -> L92
java.lang.Object[] r0 = new java.lang.Object[]{r4, r0} // Catch: java.net.URISyntaxException -> L92
r2 = 2
java.lang.Object[] r0 = java.util.Arrays.copyOf(r0, r2) // Catch: java.net.URISyntaxException -> L92
java.lang.String r0 = java.lang.String.format(r1, r0) // Catch: java.net.URISyntaxException -> L92
D2.h.e(r0, r3) // Catch: java.net.URISyntaxException -> L92
L91:
return r0
L92:
java.lang.IllegalArgumentException r0 = new java.lang.IllegalArgumentException
java.lang.StringBuilder r1 = new java.lang.StringBuilder
r1.<init>()
java.lang.String r2 = "Unable to set "
r1.append(r2)
r1.append(r7)
java.lang.String r7 = " as default origin header"
r1.append(r7)
java.lang.String r7 = r1.toString()
r0.<init>(r7)
throw r0
*/
throw new UnsupportedOperationException("Method not decompiled: com.facebook.react.modules.websocket.WebSocketModule.a.d(java.lang.String):java.lang.String");
}
public final void e(com.facebook.react.modules.network.b bVar) {
WebSocketModule.access$setCustomClientBuilder$cp(bVar);
}
private a() {
}
}
public interface b {
void a(l lVar, WritableMap writableMap);
void b(String str, WritableMap writableMap);
}
public static final class c extends I {
/* JADX INFO: renamed from: b, reason: collision with root package name */
final /* synthetic */ int f7052b;
c(int i3) {
this.f7052b = i3;
}
@Override // M2.I
public void a(H h3, int i3, String str) {
h.f(h3, "webSocket");
h.f(str, "reason");
WritableMap writableMapCreateMap = Arguments.createMap();
writableMapCreateMap.putInt("id", this.f7052b);
writableMapCreateMap.putInt("code", i3);
writableMapCreateMap.putString("reason", str);
WebSocketModule webSocketModule = WebSocketModule.this;
h.c(writableMapCreateMap);
webSocketModule.sendEvent("websocketClosed", writableMapCreateMap);
}
@Override // M2.I
public void b(H h3, int i3, String str) {
h.f(h3, "websocket");
h.f(str, "reason");
h3.a(i3, str);
}
@Override // M2.I
public void c(H h3, Throwable th, D d4) {
h.f(h3, "webSocket");
h.f(th, "t");
WebSocketModule.this.notifyWebSocketFailed(this.f7052b, th.getMessage());
}
@Override // M2.I
public void d(H h3, l lVar) {
h.f(h3, "webSocket");
h.f(lVar, "bytes");
WritableMap writableMapCreateMap = Arguments.createMap();
writableMapCreateMap.putInt("id", this.f7052b);
writableMapCreateMap.putString("type", "binary");
b bVar = (b) WebSocketModule.this.contentHandlers.get(Integer.valueOf(this.f7052b));
if (bVar != null) {
h.c(writableMapCreateMap);
bVar.a(lVar, writableMapCreateMap);
} else {
writableMapCreateMap.putString("data", lVar.a());
}
WebSocketModule webSocketModule = WebSocketModule.this;
h.c(writableMapCreateMap);
webSocketModule.sendEvent("websocketMessage", writableMapCreateMap);
}
@Override // M2.I
public void e(H h3, String str) {
h.f(h3, "webSocket");
h.f(str, "text");
WritableMap writableMapCreateMap = Arguments.createMap();
writableMapCreateMap.putInt("id", this.f7052b);
writableMapCreateMap.putString("type", "text");
b bVar = (b) WebSocketModule.this.contentHandlers.get(Integer.valueOf(this.f7052b));
if (bVar != null) {
h.c(writableMapCreateMap);
bVar.b(str, writableMapCreateMap);
} else {
writableMapCreateMap.putString("data", str);
}
WebSocketModule webSocketModule = WebSocketModule.this;
h.c(writableMapCreateMap);
webSocketModule.sendEvent("websocketMessage", writableMapCreateMap);
}
@Override // M2.I
public void f(H h3, D d4) {
h.f(h3, "webSocket");
h.f(d4, "response");
WebSocketModule.this.webSocketConnections.put(Integer.valueOf(this.f7052b), h3);
WritableMap writableMapCreateMap = Arguments.createMap();
writableMapCreateMap.putInt("id", this.f7052b);
writableMapCreateMap.putString("protocol", d4.a0("Sec-WebSocket-Protocol", ""));
WebSocketModule webSocketModule = WebSocketModule.this;
h.c(writableMapCreateMap);
webSocketModule.sendEvent("websocketOpen", writableMapCreateMap);
}
}
/* JADX WARN: 'super' call moved to the top of the method (can break code semantics) */
public WebSocketModule(ReactApplicationContext reactApplicationContext) {
super(reactApplicationContext);
h.f(reactApplicationContext, "context");
this.webSocketConnections = new ConcurrentHashMap();
this.contentHandlers = new ConcurrentHashMap();
this.cookieHandler = new d();
}
public static final /* synthetic */ com.facebook.react.modules.network.b access$getCustomClientBuilder$cp() {
return null;
}
public static final /* synthetic */ void access$setCustomClientBuilder$cp(com.facebook.react.modules.network.b bVar) {
}
private final String getCookie(String str) {
try {
List list = (List) this.cookieHandler.get(new URI(Companion.d(str)), new HashMap()).get("Cookie");
if (list != null && !list.isEmpty()) {
return (String) list.get(0);
}
return null;
} catch (IOException unused) {
throw new IllegalArgumentException("Unable to get cookie from " + str);
} catch (URISyntaxException unused2) {
throw new IllegalArgumentException("Unable to get cookie from " + str);
}
}
/* JADX INFO: Access modifiers changed from: private */
public final void notifyWebSocketFailed(int i3, String str) {
WritableMap writableMapCreateMap = Arguments.createMap();
writableMapCreateMap.putInt("id", i3);
writableMapCreateMap.putString("message", str);
h.c(writableMapCreateMap);
sendEvent("websocketFailed", writableMapCreateMap);
}
/* JADX INFO: Access modifiers changed from: private */
public final void sendEvent(String str, WritableMap writableMap) {
ReactApplicationContext reactApplicationContext = getReactApplicationContext();
if (reactApplicationContext.hasActiveReactInstance()) {
reactApplicationContext.emitDeviceEvent(str, writableMap);
}
}
public static final void setCustomClientBuilder(com.facebook.react.modules.network.b bVar) {
Companion.e(bVar);
}
@Override // com.facebook.fbreact.specs.NativeWebSocketModuleSpec
public void addListener(String str) {
h.f(str, "eventName");
}
@Override // com.facebook.fbreact.specs.NativeWebSocketModuleSpec
public void close(double d4, String str, double d5) {
int i3 = (int) d5;
H h3 = this.webSocketConnections.get(Integer.valueOf(i3));
if (h3 == null) {
return;
}
try {
h3.a((int) d4, str);
this.webSocketConnections.remove(Integer.valueOf(i3));
this.contentHandlers.remove(Integer.valueOf(i3));
} catch (Exception e4) {
Y.a.n("ReactNative", "Could not close WebSocket connection for id " + i3, e4);
}
}
@Override // com.facebook.fbreact.specs.NativeWebSocketModuleSpec
public void connect(String str, ReadableArray readableArray, ReadableMap readableMap, double d4) {
boolean z3;
h.f(str, "url");
int i3 = (int) d4;
z.a aVar = new z.a();
TimeUnit timeUnit = TimeUnit.SECONDS;
z.a aVarM = aVar.e(10L, timeUnit).N(10L, timeUnit).M(0L, TimeUnit.MINUTES);
Companion.c(aVarM);
z zVarB = aVarM.b();
B.a aVarM2 = new B.a().k(Integer.valueOf(i3)).m(str);
String cookie = getCookie(str);
if (cookie != null) {
aVarM2.a("Cookie", cookie);
}
if (readableMap != null && readableMap.hasKey("headers") && readableMap.getType("headers") == ReadableType.Map) {
ReadableMap map = readableMap.getMap("headers");
if (map == null) {
throw new IllegalStateException("Required value was null.");
}
ReadableMapKeySetIterator readableMapKeySetIteratorKeySetIterator = map.keySetIterator();
z3 = false;
while (readableMapKeySetIteratorKeySetIterator.hasNextKey()) {
String strNextKey = readableMapKeySetIteratorKeySetIterator.nextKey();
if (ReadableType.String == map.getType(strNextKey)) {
if (o.n(strNextKey, "origin", true)) {
z3 = true;
}
String string = map.getString(strNextKey);
if (string == null) {
throw new IllegalStateException(("value for name " + strNextKey + " == null").toString());
}
aVarM2.a(strNextKey, string);
} else {
Y.a.I("ReactNative", "Ignoring: requested " + strNextKey + ", value not a string");
}
}
} else {
z3 = false;
}
if (!z3) {
aVarM2.a("origin", Companion.d(str));
}
if (readableArray != null && readableArray.size() > 0) {
StringBuilder sb = new StringBuilder("");
int size = readableArray.size();
for (int i4 = 0; i4 < size; i4++) {
String string2 = readableArray.getString(i4);
String string3 = string2 != null ? o.w0(string2).toString() : null;
if (!(string3 == null || string3.length() == 0) && !o.E(string3, ",", false, 2, null)) {
sb.append(string3);
sb.append(",");
}
}
if (sb.length() > 0) {
sb.replace(sb.length() - 1, sb.length(), "");
String string4 = sb.toString();
h.e(string4, "toString(...)");
aVarM2.a("Sec-WebSocket-Protocol", string4);
}
}
zVarB.D(aVarM2.b(), new c(i3));
zVarB.c().a().shutdown();
}
@Override // com.facebook.react.bridge.BaseJavaModule, com.facebook.react.bridge.NativeModule, com.facebook.react.turbomodule.core.interfaces.TurboModule
public void invalidate() {
Iterator<H> it = this.webSocketConnections.values().iterator();
while (it.hasNext()) {
it.next().a(1001, null);
}
this.webSocketConnections.clear();
this.contentHandlers.clear();
}
@Override // com.facebook.fbreact.specs.NativeWebSocketModuleSpec
public void ping(double d4) {
int i3 = (int) d4;
H h3 = this.webSocketConnections.get(Integer.valueOf(i3));
if (h3 != null) {
try {
h3.f(l.f5638e);
return;
} catch (Exception e4) {
notifyWebSocketFailed(i3, e4.getMessage());
return;
}
}
WritableMap writableMapCreateMap = Arguments.createMap();
h.e(writableMapCreateMap, "createMap(...)");
writableMapCreateMap.putInt("id", i3);
writableMapCreateMap.putString("message", "client is null");
sendEvent("websocketFailed", writableMapCreateMap);
WritableMap writableMapCreateMap2 = Arguments.createMap();
writableMapCreateMap2.putInt("id", i3);
writableMapCreateMap2.putInt("code", 0);
writableMapCreateMap2.putString("reason", "client is null");
sendEvent("websocketClosed", writableMapCreateMap2);
this.webSocketConnections.remove(Integer.valueOf(i3));
this.contentHandlers.remove(Integer.valueOf(i3));
}
@Override // com.facebook.fbreact.specs.NativeWebSocketModuleSpec
public void removeListeners(double d4) {
}
@Override // com.facebook.fbreact.specs.NativeWebSocketModuleSpec
public void send(String str, double d4) {
h.f(str, "message");
int i3 = (int) d4;
H h3 = this.webSocketConnections.get(Integer.valueOf(i3));
if (h3 != null) {
try {
h3.b(str);
return;
} catch (Exception e4) {
notifyWebSocketFailed(i3, e4.getMessage());
return;
}
}
WritableMap writableMapCreateMap = Arguments.createMap();
h.e(writableMapCreateMap, "createMap(...)");
writableMapCreateMap.putInt("id", i3);
writableMapCreateMap.putString("message", "client is null");
sendEvent("websocketFailed", writableMapCreateMap);
WritableMap writableMapCreateMap2 = Arguments.createMap();
writableMapCreateMap2.putInt("id", i3);
writableMapCreateMap2.putInt("code", 0);
writableMapCreateMap2.putString("reason", "client is null");
sendEvent("websocketClosed", writableMapCreateMap2);
this.webSocketConnections.remove(Integer.valueOf(i3));
this.contentHandlers.remove(Integer.valueOf(i3));
}
@Override // com.facebook.fbreact.specs.NativeWebSocketModuleSpec
public void sendBinary(String str, double d4) {
h.f(str, "base64String");
int i3 = (int) d4;
H h3 = this.webSocketConnections.get(Integer.valueOf(i3));
if (h3 != null) {
try {
l lVarA = l.f5639f.a(str);
if (lVarA == null) {
throw new IllegalStateException("bytes == null");
}
h3.f(lVarA);
return;
} catch (Exception e4) {
notifyWebSocketFailed(i3, e4.getMessage());
return;
}
}
WritableMap writableMapCreateMap = Arguments.createMap();
h.e(writableMapCreateMap, "createMap(...)");
writableMapCreateMap.putInt("id", i3);
writableMapCreateMap.putString("message", "client is null");
sendEvent("websocketFailed", writableMapCreateMap);
WritableMap writableMapCreateMap2 = Arguments.createMap();
writableMapCreateMap2.putInt("id", i3);
writableMapCreateMap2.putInt("code", 0);
writableMapCreateMap2.putString("reason", "client is null");
sendEvent("websocketClosed", writableMapCreateMap2);
this.webSocketConnections.remove(Integer.valueOf(i3));
this.contentHandlers.remove(Integer.valueOf(i3));
}
public final void setContentHandler(int i3, b bVar) {
if (bVar == null) {
this.contentHandlers.remove(Integer.valueOf(i3));
} else {
this.contentHandlers.put(Integer.valueOf(i3), bVar);
}
}
public final void sendBinary(l lVar, int i3) {
h.f(lVar, "byteString");
H h3 = this.webSocketConnections.get(Integer.valueOf(i3));
if (h3 == null) {
WritableMap writableMapCreateMap = Arguments.createMap();
h.e(writableMapCreateMap, "createMap(...)");
writableMapCreateMap.putInt("id", i3);
writableMapCreateMap.putString("message", "client is null");
sendEvent("websocketFailed", writableMapCreateMap);
WritableMap writableMapCreateMap2 = Arguments.createMap();
writableMapCreateMap2.putInt("id", i3);
writableMapCreateMap2.putInt("code", 0);
writableMapCreateMap2.putString("reason", "client is null");
sendEvent("websocketClosed", writableMapCreateMap2);
this.webSocketConnections.remove(Integer.valueOf(i3));
this.contentHandlers.remove(Integer.valueOf(i3));
return;
}
try {
h3.f(lVar);
} catch (Exception e4) {
notifyWebSocketFailed(i3, e4.getMessage());
}
}
}
⚠️ This content was hidden by an advertisement filtering extension in your browser. Please disable it and reload the page to access the decompiled content.
We only display one small text ad to keep this service free. Here's what it looks like:
Read the Docs for Business: You write the docs. We do the rest.
Try it today!Ad by EthicalAds