/*
 * Decompiled with CFR 0.152.
 * 
 * Could not load the following classes:
 *  com.l7tech.gateway.common.audit.AuditDetailMessage
 *  com.l7tech.gateway.common.audit.SystemMessages
 *  com.l7tech.gateway.common.uddi.UDDIRegistry
 *  com.l7tech.objectmodel.Goid
 *  com.l7tech.objectmodel.ObjectModelException
 *  com.l7tech.objectmodel.PersistentEntity
 *  com.l7tech.uddi.UDDIException
 *  com.l7tech.uddi.UDDIInvalidKeyException
 *  com.l7tech.util.ExceptionUtils
 *  com.l7tech.util.ResourceUtils
 */
package com.l7tech.server.uddi;

import com.l7tech.gateway.common.audit.AuditDetailMessage;
import com.l7tech.gateway.common.audit.SystemMessages;
import com.l7tech.gateway.common.uddi.UDDIRegistry;
import com.l7tech.objectmodel.Goid;
import com.l7tech.objectmodel.ObjectModelException;
import com.l7tech.objectmodel.PersistentEntity;
import com.l7tech.server.uddi.SubscriptionUDDITaskFactory;
import com.l7tech.server.uddi.UDDIRegistrySubscription;
import com.l7tech.server.uddi.UDDITaskFactory;
import com.l7tech.server.uddi.ad;
import com.l7tech.uddi.UDDIException;
import com.l7tech.uddi.UDDIInvalidKeyException;
import com.l7tech.util.ExceptionUtils;
import com.l7tech.util.ResourceUtils;
import java.io.Closeable;
import java.util.logging.Level;
import java.util.logging.Logger;

final class ae
extends ad {
    private static final Logger c;
    private final SubscriptionUDDITaskFactory d;
    private final Goid e;
    private final boolean f;
    private static final String[] g;

    private ae(SubscriptionUDDITaskFactory subscriptionUDDITaskFactory, Goid goid, boolean bl2) {
        super(c, null);
        this.d = subscriptionUDDITaskFactory;
        this.e = goid;
        this.f = bl2;
    }

    /*
     * WARNING - Removed try catching itself - possible behaviour change.
     * Unable to fully structure code
     */
    @Override
    public void apply(UDDITaskFactory.UDDITaskContext var1_1) {
        block34: {
            var17_2 = ae.g;
            ae.c.fine(var17_2[9] + String.valueOf(this.e) + ".");
            try {
                block35: {
                    block32: {
                        block33: {
                            var2_3 = (UDDIRegistry)this.d.c.findByPrimaryKey(this.e);
                            try {
                                if (var2_3 == null || !var2_3.isEnabled()) break block32;
                            }
                            catch (UDDIInvalidKeyException v0) {
                                throw ae.a(v0);
                            }
                            var3_6 = null;
                            try {
                                block36: {
                                    var3_6 = this.d.d.newUDDIClient(var2_3);
                                    var4_7 = this.d.e.findByUDDIRegistryGoid(this.e);
                                    if (var4_7 == null) ** GOTO lbl52
                                    if (var4_7.getSubscriptionKey() == null) ** GOTO lbl52
                                    break block36;
                                    catch (UDDIInvalidKeyException v1) {
                                        throw ae.a(v1);
                                    }
                                }
                                try {
                                    block37: {
                                        if (!this.f) break block33;
                                        break block37;
                                        catch (UDDIInvalidKeyException v2) {
                                            throw ae.a(v2);
                                        }
                                    }
                                    if (this.isExpiring(var4_7)) break block33;
                                }
                                catch (UDDIInvalidKeyException v3) {
                                    throw ae.a(v3);
                                }
                            }
                            catch (Throwable var13_19) {
                                ResourceUtils.closeQuietly(var3_6);
                                throw var13_19;
                            }
                            ResourceUtils.closeQuietly((Closeable)var3_6);
                            return;
                        }
                        try {
                            var3_6.deleteSubscription(var4_7.getSubscriptionKey());
                            var4_7.setSubscriptionKey(null);
                        }
                        catch (UDDIInvalidKeyException var5_8) {
                            var17_2 = ae.g;
                            ae.c.log(Level.WARNING, var17_2[6] + var4_7.getSubscriptionKey() + var17_2[15] + SubscriptionUDDITaskFactory.a(var2_3) + var17_2[12]);
                        }
                        catch (UDDIException var5_9) {
                            var17_2 = ae.g;
                            ae.c.log(Level.WARNING, var17_2[4] + var4_7.getSubscriptionKey() + var17_2[1] + SubscriptionUDDITaskFactory.a(var2_3) + ".", ExceptionUtils.getDebugException((Throwable)var5_9));
                        }
lbl52:
                        // 5 sources

                        var5_10 = null;
                        var6_11 = 0L;
                        if (var2_3.isSubscribeForNotifications()) {
                            var5_10 = var1_1.getSubscriptionBindingKey(this.e);
                            try {
                                if (var5_10 == null) {
                                    throw new UDDIException(ae.g[3]);
                                }
                            }
                            catch (UDDIInvalidKeyException v4) {
                                throw ae.a(v4);
                            }
                            var6_11 = var2_3.getMonitoringFrequency();
                        }
                        var17_2 = ae.g;
                        ae.c.info(var17_2[8] + SubscriptionUDDITaskFactory.a(var2_3) + ".");
                        var8_12 = System.currentTimeMillis() + SubscriptionUDDITaskFactory.a;
                        var10_13 = var3_6.subscribe(var8_12, var6_11, var5_10);
                        if (var4_7 == null) {
                            var4_7 = new UDDIRegistrySubscription();
                            var4_7.setUddiRegistryGoid(this.e);
                        }
                        try {
                            var4_7.setSubscriptionKey(var10_13);
                            var4_7.setSubscriptionExpiryTime(var8_12);
                            v5 = var4_7;
                            v6 = var5_10 == null ? System.currentTimeMillis() : 0L;
                        }
                        catch (UDDIInvalidKeyException v7) {
                            throw ae.a(v7);
                        }
                        v5.setSubscriptionCheckTime(v6);
                        var4_7.setSubscriptionNotifiedTime(0L);
                        try {
                            if (Goid.isDefault((Goid)var4_7.getGoid())) {
                                this.d.e.save((PersistentEntity)var4_7);
                            } else {
                                this.d.e.update((PersistentEntity)var4_7);
                            }
                        }
                        catch (Exception var11_14) {
                            var17_2 = ae.g;
                            ae.c.log(Level.WARNING, var17_2[11] + SubscriptionUDDITaskFactory.a(var2_3) + var17_2[5] + ExceptionUtils.getMessage((Throwable)var11_14), ExceptionUtils.getDebugException((Throwable)var11_14));
                            try {
                                var3_6.deleteSubscription(var10_13);
                            }
                            catch (UDDIException var12_15) {
                                var14_16 = ExceptionUtils.getMessage((Throwable)var12_15);
                                var15_17 = SubscriptionUDDITaskFactory.a(var2_3);
                                var16_18 = var10_13;
                                var17_2 = ae.g;
                                ae.c.log(Level.WARNING, var17_2[4] + var16_18 + var17_2[1] + var15_17 + var17_2[10] + var14_16, ExceptionUtils.getDebugException((Throwable)var12_15));
                            }
                            var17_2 = ae.g;
                            throw new UDDIException(var17_2[0] + SubscriptionUDDITaskFactory.a(var2_3) + ".");
                        }
                        ResourceUtils.closeQuietly((Closeable)var3_6);
                        break block34;
                    }
                    try {
                        if (var2_3 != null) break block35;
                        ae.c.log(Level.WARNING, ae.g[2] + String.valueOf(this.e) + ae.g[16]);
                        break block34;
                    }
                    catch (UDDIInvalidKeyException v8) {
                        throw ae.a(v8);
                    }
                }
                var17_2 = ae.g;
                throw new UDDIException(var17_2[7] + SubscriptionUDDITaskFactory.a(var2_3) + var17_2[14]);
            }
            catch (ObjectModelException var2_4) {
                var1_1.logAndAudit((AuditDetailMessage)SystemMessages.UDDI_SUBSCRIPTION_SUBSCRIBE_FAILED, var2_4, new String[]{ae.g[13] + String.valueOf(this.e) + "."});
            }
            catch (UDDIException var2_5) {
                var1_1.logAndAudit((AuditDetailMessage)SystemMessages.UDDI_SUBSCRIPTION_SUBSCRIBE_FAILED, ExceptionUtils.getDebugException((Throwable)var2_5), new String[]{ExceptionUtils.getMessage((Throwable)var2_5)});
            }
        }
    }

    /*
     * Unable to fully structure code
     */
    static {
        block10: {
            block9: {
                var5 = new String[17];
                var3_1 = 0;
                var2_2 = "\u000fXo\u001ff'\u0002/Xn\u0019gs\u001b$M=\u0003ae\u0001)Xt\u0000`n\u001d$\n{\u001ff'\u0000/Mt\u0003`u\u000bj\u000fm\n{\u001ff'\u0000/Mt\u0003`u\u000bj\u000f\u001fnY9Fb\u0015#Yi\u0002m'ZiV\u000fXo\u001ff'\u0001?Hn\u0013fn\u0010#DzPrh\u0000jDr\u0004}a\u001b)Ki\u0019{i\u0001f\nH4PNR$Ei\u0019rn\u0011+^t\u001fz'\u0001/Xk\u0019wbR'Cn\u0003}i\u0015jEoPai\u0002?Hq\u0019go\u0017.\u0004\u001f\u001fD|\u0012xbR>E=\u0014qk\u0017>O=\u0003ae\u0001)Xt\u0000`n\u001d$\n:\td\n^\u0011at\u0017p\n\u001f\u001fD|\u0012xbR>E=\u0014qk\u0017>O=\u0003ae\u0001)Xt\u0000`n\u001d$\n:\u000e\u001fnY94u\u0017-Cn\u0004f~R1\u0019_\u007f\u0003wu\u001b(Cs\u00174a\u001d8\ns\u001f`n\u0014#I|\u0004}h\u001c9\n{\u0002{jR\u001fnY94u\u0017-Cn\u0004f~R(\tBx\u0013\u007fn\u001c-\nn\u0005vt\u00118Cm\u0004}h\u001cjLr\u00024R6\u000ec=\u0002q`\u001b9^o\t4\td\n^\u0011at\u0017p\n0\u000fXo\u001ff'\u0002/Xn\u0019gs\u001b$M=\u0005pc\u001bjYh\u0012gd\u0000#Zi\u0019{iR,EoPfb\u0015#Yi\u0002m'$f\nv\u0015m'\u001b9\nt\u001ebf\u001e#N=Xwh\u0007&N=\u0012q'\u00172Zt\u0002qc[d7\u000eKi\u0011vf\u0001/\nx\u0002fh\u0000j]u\u0015z'\u0002%Fq\u0019z`R9_\u007f\u0003wu\u001b:^t\u001fz'\u0014%X=\u0002q`\u001b9^o\t4$\rjCnPpn\u0001+Hq\u0015p)";
                var4_3 = "\u000fXo\u001ff'\u0002/Xn\u0019gs\u001b$M=\u0003ae\u0001)Xt\u0000`n\u001d$\n{\u001ff'\u0000/Mt\u0003`u\u000bj\u000fm\n{\u001ff'\u0000/Mt\u0003`u\u000bj\u000f\u001fnY9Fb\u0015#Yi\u0002m'ZiV\u000fXo\u001ff'\u0001?Hn\u0013fn\u0010#DzPrh\u0000jDr\u0004}a\u001b)Ki\u0019{i\u0001f\nH4PNR$Ei\u0019rn\u0011+^t\u001fz'\u0001/Xk\u0019wbR'Cn\u0003}i\u0015jEoPai\u0002?Hq\u0019go\u0017.\u0004\u001f\u001fD|\u0012xbR>E=\u0014qk\u0017>O=\u0003ae\u0001)Xt\u0000`n\u001d$\n:\td\n^\u0011at\u0017p\n\u001f\u001fD|\u0012xbR>E=\u0014qk\u0017>O=\u0003ae\u0001)Xt\u0000`n\u001d$\n:\u000e\u001fnY94u\u0017-Cn\u0004f~R1\u0019_\u007f\u0003wu\u001b(Cs\u00174a\u001d8\ns\u001f`n\u0014#I|\u0004}h\u001c9\n{\u0002{jR\u001fnY94u\u0017-Cn\u0004f~R(\tBx\u0013\u007fn\u001c-\nn\u0005vt\u00118Cm\u0004}h\u001cjLr\u00024R6\u000ec=\u0002q`\u001b9^o\t4\td\n^\u0011at\u0017p\n0\u000fXo\u001ff'\u0002/Xn\u0019gs\u001b$M=\u0005pc\u001bjYh\u0012gd\u0000#Zi\u0019{iR,EoPfb\u0015#Yi\u0002m'$f\nv\u0015m'\u001b9\nt\u001ebf\u001e#N=Xwh\u0007&N=\u0012q'\u00172Zt\u0002qc[d7\u000eKi\u0011vf\u0001/\nx\u0002fh\u0000j]u\u0015z'\u0002%Fq\u0019z`R9_\u007f\u0003wu\u001b:^t\u001fz'\u0014%X=\u0002q`\u001b9^o\t4$\rjCnPpn\u0001+Hq\u0015p)".length();
                var1_4 = 43;
                var0_5 = -1;
lbl7:
                // 2 sources

                while (true) {
                    v0 = 98;
                    v1 = ++var0_5;
                    v2 = var2_2.substring(v1, v1 + var1_4);
                    v3 = -1;
                    break block9;
                    break;
                }
lbl13:
                // 1 sources

                while (true) {
                    var5[var3_1++] = ae.b(v0, ae.b(v2));
                    if ((var0_5 += var1_4) < var4_3) {
                        var1_4 = var2_2.charAt(var0_5);
                        ** continue;
                    }
                    var2_2 = "\u0018\u007f\u000ej\u0013RuZ8\u0001v\u0015\u0000~\u001f\u001d\u0016\u007f\u0006j\u0015RaP*\u0006aA\u0014hM\u007f\u001bp\u0003\u0001dM6\u0018q\b\u001di\u0011";
                    var4_3 = "\u0018\u007f\u000ej\u0013RuZ8\u0001v\u0015\u0000~\u001f\u001d\u0016\u007f\u0006j\u0015RaP*\u0006aA\u0014hM\u007f\u001bp\u0003\u0001dM6\u0018q\b\u001di\u0011".length();
                    var1_4 = 15;
                    var0_5 = -1;
lbl22:
                    // 2 sources

                    while (true) {
                        v0 = 23;
                        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++] = ae.b(v0, ae.b(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;
            }
        }
        ae.g = var5;
        ae.c = Logger.getLogger(ae.class.getName());
    }

    private static UDDIInvalidKeyException a(UDDIInvalidKeyException uDDIInvalidKeyException) {
        return uDDIInvalidKeyException;
    }

    private static char[] b(String string) {
        char[] cArray = string.toCharArray();
        if (cArray.length < 2) {
            cArray = cArray;
            cArray[0] = (char)(cArray[0] ^ 0x10);
        }
        return cArray;
    }

    /*
     * Handled impossible loop by duplicating code
     * Enabled aggressive block sorting
     */
    private static String b(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 -> 40;
                    case 1 -> 72;
                    case 2 -> 127;
                    case 3 -> 18;
                    case 4 -> 118;
                    case 5 -> 101;
                    default -> 16;
                })));
                ++n3;
                n4 = n4;
            } while (n4 > n3);
        }
        return new String(cArray2).intern();
    }
}