/* * Decompiled with CFR 0.152. * * Could not load the following classes: * com.ca.apim.gateway.extension.telemetry.TelemetryDataProvider * com.segment.analytics.Analytics * com.segment.analytics.Analytics$Builder * com.segment.analytics.Callback * com.segment.analytics.Log * com.segment.analytics.messages.IdentifyMessage * com.segment.analytics.messages.IdentifyMessage$Builder * com.segment.analytics.messages.Message * com.segment.analytics.messages.MessageBuilder * com.segment.analytics.messages.TrackMessage * com.segment.analytics.messages.TrackMessage$Builder * okhttp3.OkHttpClient * org.jetbrains.annotations.NotNull */ package com.l7tech.server.telemetry; import com.ca.apim.gateway.extension.telemetry.TelemetryDataProvider; import com.l7tech.server.TelemetryPropertiesLoader; import com.l7tech.server.telemetry.GatewaySegmentClientFactory; import com.l7tech.server.telemetry.TelemetryService; import com.l7tech.server.telemetry.c; import com.l7tech.server.telemetry.d; import com.segment.analytics.Analytics; import com.segment.analytics.Callback; import com.segment.analytics.Log; import com.segment.analytics.messages.IdentifyMessage; import com.segment.analytics.messages.Message; import com.segment.analytics.messages.MessageBuilder; import com.segment.analytics.messages.TrackMessage; import java.util.HashMap; import java.util.Map; import java.util.UUID; import java.util.logging.Level; import java.util.logging.Logger; import okhttp3.OkHttpClient; import org.jetbrains.annotations.NotNull; public class GatewaySegmentService implements TelemetryService { private static final Logger a; private static final String 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 static final String j; private static final String k; private static final String l; private static final String m; private static final String n; private OkHttpClient o; private Analytics p; private String q; private boolean r; private String s; private final boolean t; private static final String[] u; public GatewaySegmentService(TelemetryPropertiesLoader telemetryPropertiesLoader) { String[] stringArray = u; String string = telemetryPropertiesLoader.getProperty(stringArray[21], "").trim(); String string2 = telemetryPropertiesLoader.getProperty(stringArray[24], "").trim(); String string3 = telemetryPropertiesLoader.getProperty(stringArray[31], "").trim(); String string4 = telemetryPropertiesLoader.getProperty(stringArray[5], "").trim().replaceAll(stringArray[28], ""); String string5 = telemetryPropertiesLoader.getProperty(stringArray[27], "").trim().replaceAll(stringArray[12], ""); this.o = GatewaySegmentClientFactory.create(string, string2, string3); this.q = telemetryPropertiesLoader.getProperty(stringArray[0], "").trim(); this.t = Boolean.valueOf(telemetryPropertiesLoader.getProperty(stringArray[23], Boolean.FALSE.toString())); this.s = UUID.randomUUID().toString(); this.r = this.b(this.q); if (this.r) { Analytics.Builder builder; block7: { block6: { builder = Analytics.builder((String)this.q).client(this.o).callback((Callback)new d(this)).log((Log)new c()); try { if (!this.a(string5)) break block6; builder.setUploadURL(string5); break block7; } catch (IllegalStateException illegalStateException) { throw GatewaySegmentService.a(illegalStateException); } } try { if (this.a(string4)) { builder.setUploadURL(string4 + u[7]); } } catch (IllegalStateException illegalStateException) { throw GatewaySegmentService.a(illegalStateException); } } this.p = builder.build(); } } private boolean a(String string) { boolean bl2; block5: { block4: { try { try { if (string == null || string.isEmpty()) break block4; } catch (IllegalStateException illegalStateException) { throw GatewaySegmentService.a(illegalStateException); } bl2 = true; break block5; } catch (IllegalStateException illegalStateException) { throw GatewaySegmentService.a(illegalStateException); } } bl2 = false; } return bl2; } private boolean b(String string) { boolean bl2; block5: { block4: { try { try { if (string == null || string.isEmpty()) break block4; } catch (IllegalStateException illegalStateException) { throw GatewaySegmentService.a(illegalStateException); } bl2 = true; break block5; } catch (IllegalStateException illegalStateException) { throw GatewaySegmentService.a(illegalStateException); } } bl2 = false; } return bl2; } @NotNull private Map a(TelemetryDataProvider telemetryDataProvider) { HashMap hashMap; HashMap hashMap2 = new HashMap(); try { hashMap2.put(u[10], telemetryDataProvider.getSiteId()); hashMap2.put(u[14], telemetryDataProvider.isPlaEnabled()); hashMap2.put(u[3], telemetryDataProvider.getInstanceId()); hashMap2.put(u[33], telemetryDataProvider.getProductSku()); hashMap2.put(u[19], telemetryDataProvider.getSkuDescription()); hashMap2.put(u[40], telemetryDataProvider.getChargebackId()); hashMap2.put(u[20], telemetryDataProvider.getDomainName()); hashMap = hashMap2; if (hashMap == null) { GatewaySegmentService.a(0); } } catch (IllegalStateException illegalStateException) { throw GatewaySegmentService.a(illegalStateException); } return hashMap; } @Override public void identify(TelemetryDataProvider telemetryDataProvider) { IdentifyMessage identifyMessage; String string = telemetryDataProvider.getSiteId(); Map map = this.a(telemetryDataProvider); try { identifyMessage = string.length() == 0 ? (IdentifyMessage)((IdentifyMessage.Builder)IdentifyMessage.builder().anonymousId(this.s)).traits(map).build() : (IdentifyMessage)((IdentifyMessage.Builder)IdentifyMessage.builder().userId(string)).traits(map).build(); } catch (IllegalStateException illegalStateException) { throw GatewaySegmentService.a(illegalStateException); } IdentifyMessage identifyMessage2 = identifyMessage; try { this.b((Message)identifyMessage2); if (!this.a((Message)identifyMessage2)) { this.p.enqueue((MessageBuilder)identifyMessage2.toBuilder()); } } catch (IllegalStateException illegalStateException) { throw GatewaySegmentService.a(illegalStateException); } } @Override public void track(TelemetryDataProvider telemetryDataProvider) { TrackMessage trackMessage; Map map = this.a(telemetryDataProvider); String[] stringArray = u; map.put(stringArray[16], telemetryDataProvider.getUsageMetric()); map.put(stringArray[29], telemetryDataProvider.getDateCollected()); map.put(stringArray[36], telemetryDataProvider.getProductVersion()); map.put(stringArray[34], telemetryDataProvider.getExtraDataMap()); String string = telemetryDataProvider.getSiteId(); try { trackMessage = string.length() == 0 ? (TrackMessage)((TrackMessage.Builder)TrackMessage.builder((String)stringArray[38]).anonymousId(this.s)).properties(map).build() : (TrackMessage)((TrackMessage.Builder)TrackMessage.builder((String)u[38]).userId(string)).properties(map).build(); } catch (IllegalStateException illegalStateException) { throw GatewaySegmentService.a(illegalStateException); } TrackMessage trackMessage2 = trackMessage; try { this.b((Message)trackMessage2); if (!this.a((Message)trackMessage2)) { this.p.enqueue((MessageBuilder)trackMessage2.toBuilder()); } } catch (IllegalStateException illegalStateException) { throw GatewaySegmentService.a(illegalStateException); } } private boolean a(Message message) { try { if (!this.t) { this.a(u[18], message); return true; } } catch (IllegalStateException illegalStateException) { throw GatewaySegmentService.a(illegalStateException); } try { if (!this.r) { a.log(Level.INFO, u[26]); this.c(message); return true; } } catch (IllegalStateException illegalStateException) { throw GatewaySegmentService.a(illegalStateException); } try { if (this.p == null) { this.a(u[13], message); return true; } } catch (IllegalStateException illegalStateException) { throw GatewaySegmentService.a(illegalStateException); } return false; } private void b(Message message) { this.a("", message); } private void a(String object, Message message) { if (!((String)object).isEmpty()) { object = (String)object + " "; } a.log(Level.INFO, u[35], new Object[]{object, message}); } private void c(Message message) { a.log(Level.WARNING, u[11], message); } @Override public void close() { try { if (this.p != null) { this.p.flush(); this.p.shutdown(); } } catch (IllegalStateException illegalStateException) { throw GatewaySegmentService.a(illegalStateException); } } /* * Unable to fully structure code */ static { block10: { block9: { var5 = new String[41]; var3_1 = 0; var2_2 = "\n\u001er\u0011l^\u0005\f\u00020\u0007d\\\u001c\u001b\u0015jZvI\u0018\n\u001eU\u0011x\u0013\u001c\u000ew\u0018e\u007f\u0014\u0018\u001ak\u0018uv\u0014\r\b\u007f\u0013d\u000f\r\u0010k+e^\u0002\u001d\tw\u0004uR\u001e\u0010\u000b\u0017\u0015m\u0000`U\u0012\u001b$w\u0010\u0007\r\u0012j\u0011^R\u0015\u001a\n\u001er\u0011l^\u0005\f\u00020\u0007d\\\u001c\u001b\u0015jZdU\u0015\u000e\u0014w\u001au\u000f\u000e\tq\u0010tX\u0005!\r{\u0006rR\u001e\u0010\nQ\r/[hV\u0001\u0011\tj\r\u001d\u0013\u007f\u0006f^\u0013\u001f\u0018u+h_\b\u0015\u001eg+oZ\u001c\u001b\u0007\r\u0012j\u0011^R\u0015&8\u001aw\u0018d_Q\n\u0014>\u0007dU\u0015^\u000f{\u0018dV\u0014\n\tgTl^\u0002\r\u001ay\u0011!`\nN\u0006C\u0002Q_1-\u001ey\u0019dU\u0005^\u0018r\u001ddU\u0005^\u0015q\u0000!R\u001f\u0017\u000fw\u0015mR\u000b\u001b\u001f2TeZ\u0005\u001f[\u007f\u0006d\u001b\u001f\u0011\u000f>\u0007dU\u0005\u000b\u000e\u0017\u007f+dU\u0010\u001c\u0017{\u0010\u000b\u000e\tq\u0010tX\u0005!\bu\u0001\r\u0013\u0014p\u0000iW\b!\u000em\u0015f^\u000b\u0017\u0015m\u0000`U\u0012\u001b$w\u0010\u001c-\u001ey\u0019dU\u0005^\b{\u0006wR\u0012\u001b[w\u0007!_\u0018\r\u001a|\u0018d__\u000f\r\u0010k+e^\u0002\u001d\tw\u0004uR\u001e\u0010\u000b\u001a\u0014s\u0015hU.\u0010\u001as\u0011\u0013\n\u001er\u0011l^\u0005\f\u00020\u0004sT\t\u0007Uk\u0006m\u000e\u001a\u001aj\u0011^X\u001e\u0012\u0017{\u0017u^\u0015\u0019\n\u001er\u0011l^\u0005\f\u00020\u0007d\\\u001c\u001b\u0015jZdU\u0010\u001c\u0017{\u0010\u0018\n\u001er\u0011l^\u0005\f\u00020\u0004sT\t\u0007Uk\u0007dI\u001f\u001f\u0016{\nQ\r/[hV\u0001\u0011\tj/-\u001ey\u0019dU\u0005^\fl\u001du^Q\u0015\u001egThHQ\u0010\u0014jTr^\u0005R[z\u0015uZQ\u001f\t{ToT\u0005^\b{\u001au\u001b\n\u001er\u0011l^\u0005\f\u00020\u0007d\\\u001c\u001b\u0015jZtK\u001d\u0011\u001az!Sw\u0002Q_\u000e\u001a\u001aj\u0011^X\u001e\u0012\u0017{\u0017u^\u0015*>5q\u0000ON\u001d\u0012[s\u0011uS\u001e\u001a[;\u0007/\u001e\u0002^\u0016k\u0007u\u001b\u001f\u0011\u000f>\u0006dO\u0004\f\u0015>\u001atW\u001d\u0018\n\u001er\u0011l^\u0005\f\u00020\u0004sT\t\u0007Un\u0015rH\u0006\u0011\tz\u000b\u000e\u0017\u007f+dU\u0010\u001c\u0017{\u0010\u000b\u000e\tq\u0010tX\u0005!\bu\u0001\b\u0015\u001eg+oZ\u001c\u001b%\u0005Kc dW\u0014\u0013\u001ej\u0006x\u001b\u001c\u001b\bm\u0015f^Q\n\u0014>\u0016d\u001b\u0002\u001b\u0015jTZ@@\u0003&\u000f\u000e\tq\u0010tX\u0005!\r{\u0006rR\u001e\u0010\u000b\u001a\u0014s\u0015hU.\u0010\u001as\u0011\r\u0013\u0014p\u0000iW\b!\u000em\u0015f^"; var4_3 = "\n\u001er\u0011l^\u0005\f\u00020\u0007d\\\u001c\u001b\u0015jZvI\u0018\n\u001eU\u0011x\u0013\u001c\u000ew\u0018e\u007f\u0014\u0018\u001ak\u0018uv\u0014\r\b\u007f\u0013d\u000f\r\u0010k+e^\u0002\u001d\tw\u0004uR\u001e\u0010\u000b\u0017\u0015m\u0000`U\u0012\u001b$w\u0010\u0007\r\u0012j\u0011^R\u0015\u001a\n\u001er\u0011l^\u0005\f\u00020\u0007d\\\u001c\u001b\u0015jZdU\u0015\u000e\u0014w\u001au\u000f\u000e\tq\u0010tX\u0005!\r{\u0006rR\u001e\u0010\nQ\r/[hV\u0001\u0011\tj\r\u001d\u0013\u007f\u0006f^\u0013\u001f\u0018u+h_\b\u0015\u001eg+oZ\u001c\u001b\u0007\r\u0012j\u0011^R\u0015&8\u001aw\u0018d_Q\n\u0014>\u0007dU\u0015^\u000f{\u0018dV\u0014\n\tgTl^\u0002\r\u001ay\u0011!`\nN\u0006C\u0002Q_1-\u001ey\u0019dU\u0005^\u0018r\u001ddU\u0005^\u0015q\u0000!R\u001f\u0017\u000fw\u0015mR\u000b\u001b\u001f2TeZ\u0005\u001f[\u007f\u0006d\u001b\u001f\u0011\u000f>\u0007dU\u0005\u000b\u000e\u0017\u007f+dU\u0010\u001c\u0017{\u0010\u000b\u000e\tq\u0010tX\u0005!\bu\u0001\r\u0013\u0014p\u0000iW\b!\u000em\u0015f^\u000b\u0017\u0015m\u0000`U\u0012\u001b$w\u0010\u001c-\u001ey\u0019dU\u0005^\b{\u0006wR\u0012\u001b[w\u0007!_\u0018\r\u001a|\u0018d__\u000f\r\u0010k+e^\u0002\u001d\tw\u0004uR\u001e\u0010\u000b\u001a\u0014s\u0015hU.\u0010\u001as\u0011\u0013\n\u001er\u0011l^\u0005\f\u00020\u0004sT\t\u0007Uk\u0006m\u000e\u001a\u001aj\u0011^X\u001e\u0012\u0017{\u0017u^\u0015\u0019\n\u001er\u0011l^\u0005\f\u00020\u0007d\\\u001c\u001b\u0015jZdU\u0010\u001c\u0017{\u0010\u0018\n\u001er\u0011l^\u0005\f\u00020\u0004sT\t\u0007Uk\u0007dI\u001f\u001f\u0016{\nQ\r/[hV\u0001\u0011\tj/-\u001ey\u0019dU\u0005^\fl\u001du^Q\u0015\u001egThHQ\u0010\u0014jTr^\u0005R[z\u0015uZQ\u001f\t{ToT\u0005^\b{\u001au\u001b\n\u001er\u0011l^\u0005\f\u00020\u0007d\\\u001c\u001b\u0015jZtK\u001d\u0011\u001az!Sw\u0002Q_\u000e\u001a\u001aj\u0011^X\u001e\u0012\u0017{\u0017u^\u0015*>5q\u0000ON\u001d\u0012[s\u0011uS\u001e\u001a[;\u0007/\u001e\u0002^\u0016k\u0007u\u001b\u001f\u0011\u000f>\u0006dO\u0004\f\u0015>\u001atW\u001d\u0018\n\u001er\u0011l^\u0005\f\u00020\u0004sT\t\u0007Un\u0015rH\u0006\u0011\tz\u000b\u000e\u0017\u007f+dU\u0010\u001c\u0017{\u0010\u000b\u000e\tq\u0010tX\u0005!\bu\u0001\b\u0015\u001eg+oZ\u001c\u001b%\u0005Kc dW\u0014\u0013\u001ej\u0006x\u001b\u001c\u001b\bm\u0015f^Q\n\u0014>\u0016d\u001b\u0002\u001b\u0015jTZ@@\u0003&\u000f\u000e\tq\u0010tX\u0005!\r{\u0006rR\u001e\u0010\u000b\u001a\u0014s\u0015hU.\u0010\u001as\u0011\r\u0013\u0014p\u0000iW\b!\u000em\u0015f^".length(); var1_4 = 26; var0_5 = -1; lbl7: // 2 sources while (true) { v0 = 45; v1 = ++var0_5; v2 = var2_2.substring(v1, v1 + var1_4); v3 = -1; break block9; break; } lbl13: // 1 sources while (true) { var5[var3_1++] = GatewaySegmentService.a(v0, GatewaySegmentService.c(v2)); if ((var0_5 += var1_4) < var4_3) { var1_4 = var2_2.charAt(var0_5); ** continue; } var2_2 = "\u0014\u001dzRd\u0005\f\u0012\u0011\u007fR{W\n\u0001\u0017eR|W\u0014\u0012\u001fr\tzKW0\u0013c\u0018\u007fS\u0001$\u0017p\u0010m\\\f$\u0017e\u000baQ\u001d\r\u0014\u001av\u000foW\u001a\u0016\u0011|\"aV"; var4_3 = "\u0014\u001dzRd\u0005\f\u0012\u0011\u007fR{W\n\u0001\u0017eR|W\u0014\u0012\u001fr\tzKW0\u0013c\u0018\u007fS\u0001$\u0017p\u0010m\\\f$\u0017e\u000baQ\u001d\r\u0014\u001av\u000foW\u001a\u0016\u0011|\"aV".length(); var1_4 = 49; var0_5 = -1; lbl22: // 2 sources while (true) { v0 = 36; 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++] = GatewaySegmentService.a(v0, GatewaySegmentService.c(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; } } GatewaySegmentService.u = var5; GatewaySegmentService.f = GatewaySegmentService.u[6]; GatewaySegmentService.e = GatewaySegmentService.u[2]; GatewaySegmentService.b = GatewaySegmentService.u[4]; GatewaySegmentService.h = GatewaySegmentService.u[22]; GatewaySegmentService.c = GatewaySegmentService.u[17]; GatewaySegmentService.j = GatewaySegmentService.u[8]; GatewaySegmentService.g = GatewaySegmentService.u[32]; GatewaySegmentService.l = GatewaySegmentService.u[38]; GatewaySegmentService.n = GatewaySegmentService.u[25]; GatewaySegmentService.k = GatewaySegmentService.u[37]; GatewaySegmentService.d = GatewaySegmentService.u[15]; GatewaySegmentService.i = GatewaySegmentService.u[38]; GatewaySegmentService.m = GatewaySegmentService.u[9]; GatewaySegmentService.a = Logger.getLogger(GatewaySegmentService.class.getName()); } private static /* synthetic */ void a(int n2) { String[] stringArray = u; throw new IllegalStateException(String.format(stringArray[30], stringArray[39], stringArray[1])); } private static IllegalStateException a(IllegalStateException illegalStateException) { return illegalStateException; } private static char[] c(String string) { char[] cArray = string.toCharArray(); if (cArray.length < 2) { cArray = cArray; cArray[0] = (char)(cArray[0] ^ 0x5C); } 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 -> 83; case 1 -> 86; case 2 -> 51; case 3 -> 89; case 4 -> 44; case 5 -> 22; default -> 92; }))); ++n3; n4 = n4; } while (n4 > n3); } return new String(cArray2).intern(); } }