/*
 * 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.UDDIClient
 *  com.l7tech.uddi.UDDIException
 *  com.l7tech.uddi.UDDISubscriptionResults
 *  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.UDDIClient;
import com.l7tech.uddi.UDDIException;
import com.l7tech.uddi.UDDISubscriptionResults;
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 ag
extends ad {
    private static final Logger c;
    private final SubscriptionUDDITaskFactory d;
    private final Goid e;
    private final long f;
    private final long g;
    private static final String[] i;

    ag(SubscriptionUDDITaskFactory subscriptionUDDITaskFactory, Goid goid, long l2, long l3) {
        super(c, subscriptionUDDITaskFactory.f);
        this.d = subscriptionUDDITaskFactory;
        this.e = goid;
        this.f = l2;
        this.g = l3;
    }

    /*
     * WARNING - Removed try catching itself - possible behaviour change.
     * Loose catch block
     */
    @Override
    public void apply(UDDITaskFactory.UDDITaskContext uDDITaskContext) {
        block25: {
            String[] stringArray = i;
            c.fine(stringArray[3]);
            try {
                UDDIRegistry uDDIRegistry;
                block21: {
                    block22: {
                        long l2;
                        long l3;
                        boolean bl2;
                        UDDIRegistrySubscription uDDIRegistrySubscription;
                        block24: {
                            block23: {
                                uDDIRegistry = (UDDIRegistry)this.d.c.findByPrimaryKey(this.e);
                                try {
                                    if (uDDIRegistry == null || !uDDIRegistry.isEnabled()) break block21;
                                }
                                catch (ObjectModelException objectModelException) {
                                    throw ag.a(objectModelException);
                                }
                                uDDIRegistrySubscription = this.d.e.findByUDDIRegistryGoid(this.e);
                                if (uDDIRegistrySubscription == null) break block22;
                                try {
                                    block26: {
                                        if (this.f <= 0L) break block23;
                                        break block26;
                                        catch (ObjectModelException objectModelException) {
                                            throw ag.a(objectModelException);
                                        }
                                    }
                                    bl2 = true;
                                    break block24;
                                }
                                catch (ObjectModelException objectModelException) {
                                    throw ag.a(objectModelException);
                                }
                            }
                            bl2 = false;
                        }
                        boolean bl3 = bl2;
                        String string = uDDIRegistrySubscription.getSubscriptionKey();
                        if (bl3) {
                            l3 = this.f;
                            l2 = this.g;
                            stringArray = i;
                            c.info(stringArray[6] + string + stringArray[4] + SubscriptionUDDITaskFactory.a(uDDIRegistry) + ".");
                        } else {
                            l3 = uDDIRegistrySubscription.getSubscriptionCheckTime();
                            l2 = System.currentTimeMillis();
                        }
                        UDDIClient uDDIClient = null;
                        try {
                            boolean bl4;
                            UDDISubscriptionResults uDDISubscriptionResults;
                            UDDIRegistrySubscription uDDIRegistrySubscription2;
                            UDDITaskFactory.UDDITaskContext uDDITaskContext2;
                            ag ag2;
                            uDDIClient = this.d.d.newUDDIClient(uDDIRegistry);
                            UDDISubscriptionResults uDDISubscriptionResults2 = uDDIClient.pollSubscription(l3, l2, string);
                            try {
                                ag2 = this;
                                uDDITaskContext2 = uDDITaskContext;
                                uDDIRegistrySubscription2 = uDDIRegistrySubscription;
                                uDDISubscriptionResults = uDDISubscriptionResults2;
                                bl4 = !bl3;
                            }
                            catch (ObjectModelException objectModelException) {
                                throw ag.a(objectModelException);
                            }
                            try {
                                ag2.a(uDDITaskContext2, uDDIRegistrySubscription2, uDDISubscriptionResults, bl4);
                                if (!bl3) {
                                    uDDIRegistrySubscription.setSubscriptionCheckTime(l2);
                                    this.d.e.update((PersistentEntity)uDDIRegistrySubscription);
                                }
                            }
                            catch (ObjectModelException objectModelException) {
                                throw ag.a(objectModelException);
                            }
                        }
                        catch (Throwable throwable) {
                            ResourceUtils.closeQuietly(uDDIClient);
                            throw throwable;
                        }
                        ResourceUtils.closeQuietly((Closeable)uDDIClient);
                        break block25;
                    }
                    String[] stringArray2 = new String[1];
                    stringArray = i;
                    stringArray2[0] = stringArray[1] + SubscriptionUDDITaskFactory.a(uDDIRegistry) + ".";
                    uDDITaskContext.logAndAudit((AuditDetailMessage)SystemMessages.UDDI_SUBSCRIPTION_POLL_FAILED, stringArray2);
                    break block25;
                }
                try {
                    if (uDDIRegistry == null) {
                        c.log(Level.WARNING, i[5] + String.valueOf(this.e) + i[0]);
                    }
                }
                catch (ObjectModelException objectModelException) {
                    throw ag.a(objectModelException);
                }
            }
            catch (ObjectModelException objectModelException) {
                uDDITaskContext.logAndAudit((AuditDetailMessage)SystemMessages.UDDI_SUBSCRIPTION_POLL_FAILED, objectModelException, i[2] + String.valueOf(this.e) + ".");
            }
            catch (UDDIException uDDIException) {
                uDDITaskContext.logAndAudit((AuditDetailMessage)SystemMessages.UDDI_SUBSCRIPTION_POLL_FAILED, ExceptionUtils.getDebugException((Throwable)uDDIException), ExceptionUtils.getMessage((Throwable)uDDIException));
            }
        }
    }

    /*
     * Unable to fully structure code
     */
    static {
        block10: {
            block9: {
                var5 = new String[7];
                var3_1 = 0;
                var2_2 = "Q`H/>?+\u00175H$jy\"\n`U5(l.\n)V4#p#X0I,&1\"5)U3#q*X3S\"9|?\u00110R)%qm\u001e/T`8z*\u00113R23?7<!R!(~>\u001d`C28p?X7N%$?=\u0017,J)$xm\u000b5D3)m$\b4O/$?+\u00172\u00062/x$\u000b4T9j<$(/J,#q*X\u0015b\u0004\u0003??\u001d'O3>m4X3S\"9|?\u00110R)%q>V\u0014_`@/8?\u0018<\u0004o`8z*\u00113R23?";
                var4_3 = "Q`H/>?+\u00175H$jy\"\n`U5(l.\n)V4#p#X0I,&1\"5)U3#q*X3S\"9|?\u00110R)%qm\u001e/T`8z*\u00113R23?7<!R!(~>\u001d`C28p?X7N%$?=\u0017,J)$xm\u000b5D3)m$\b4O/$?+\u00172\u00062/x$\u000b4T9j<$(/J,#q*X\u0015b\u0004\u0003??\u001d'O3>m4X3S\"9|?\u00110R)%q>V\u0014_`@/8?\u0018<\u0004o`8z*\u00113R23?".length();
                var1_4 = 34;
                var0_5 = -1;
lbl7:
                // 2 sources

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

                while (true) {
                    var5[var3_1++] = ag.b(v0, ag.b(v2));
                    if ((var0_5 += var1_4) < var4_3) {
                        var1_4 = var2_2.charAt(var0_5);
                        ** continue;
                    }
                    var2_2 = "\u0013:\\7&D\u0014/\rl\f\r\u0001[e\u0016\u0016\u0011t\u0012\u001dO\u0014f\rm\u001c\u0007B\u0001/\u000el\u0017\u001bOSa";
                    var4_3 = "\u0013:\\7&D\u0014/\rl\f\r\u0001[e\u0016\u0016\u0011t\u0012\u001dO\u0014f\rm\u001c\u0007B\u0001/\u000el\u0017\u001bOSa".length();
                    var1_4 = 15;
                    var0_5 = -1;
lbl22:
                    // 2 sources

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

    private static ObjectModelException a(ObjectModelException objectModelException) {
        return objectModelException;
    }

    private static char[] b(String string) {
        char[] cArray = string.toCharArray();
        if (cArray.length < 2) {
            cArray = cArray;
            cArray[0] = (char)(cArray[0] ^ 0x75);
        }
        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 -> 64;
                    case 1 -> 120;
                    case 2 -> 30;
                    case 3 -> 120;
                    case 4 -> 114;
                    case 5 -> 39;
                    default -> 117;
                })));
                ++n3;
                n4 = n4;
            } while (n4 > n3);
        }
        return new String(cArray2).intern();
    }
}