/* * 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.UDDIProxiedServiceInfo * com.l7tech.gateway.common.uddi.UDDIProxiedServiceInfo$PublishType * com.l7tech.gateway.common.uddi.UDDIPublishStatus * com.l7tech.gateway.common.uddi.UDDIPublishStatus$PublishStatus * com.l7tech.gateway.common.uddi.UDDIRegistry * com.l7tech.gateway.common.uddi.UDDIRegistry$UDDIRegistryType * com.l7tech.gateway.common.uddi.UDDIServiceControl * com.l7tech.objectmodel.FindException * com.l7tech.objectmodel.Goid * com.l7tech.objectmodel.ObjectModelException * com.l7tech.objectmodel.PersistentEntity * com.l7tech.objectmodel.UpdateException * com.l7tech.uddi.UDDIClient * com.l7tech.uddi.UDDIRegistrySpecificMetaData * com.l7tech.util.Config * com.l7tech.util.ExceptionUtils */ 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.UDDIProxiedServiceInfo; import com.l7tech.gateway.common.uddi.UDDIPublishStatus; import com.l7tech.gateway.common.uddi.UDDIRegistry; import com.l7tech.gateway.common.uddi.UDDIServiceControl; import com.l7tech.objectmodel.FindException; import com.l7tech.objectmodel.Goid; import com.l7tech.objectmodel.ObjectModelException; import com.l7tech.objectmodel.PersistentEntity; import com.l7tech.objectmodel.UpdateException; import com.l7tech.server.service.ServiceCache; import com.l7tech.server.uddi.UDDIHelper; import com.l7tech.server.uddi.UDDIProxiedServiceInfoManager; import com.l7tech.server.uddi.UDDIPublishStatusManager; import com.l7tech.server.uddi.UDDIRegistryManager; import com.l7tech.server.uddi.UDDIServiceControlManager; import com.l7tech.server.uddi.UDDITaskFactory; import com.l7tech.server.uddi.a; import com.l7tech.server.uddi.o; import com.l7tech.uddi.UDDIClient; import com.l7tech.uddi.UDDIRegistrySpecificMetaData; import com.l7tech.util.Config; import com.l7tech.util.ExceptionUtils; import java.util.logging.Logger; public class PublishingUDDITaskFactory extends UDDITaskFactory { private final UDDIRegistryManager a; private final UDDIProxiedServiceInfoManager b; private final UDDIPublishStatusManager c; private final ServiceCache d; private final UDDIHelper e; private final UDDIServiceControlManager f; private final Config g; private static final Logger h; private static final String[] i; public PublishingUDDITaskFactory(UDDIRegistryManager uDDIRegistryManager, UDDIProxiedServiceInfoManager uDDIProxiedServiceInfoManager, ServiceCache serviceCache, UDDIHelper uDDIHelper, UDDIServiceControlManager uDDIServiceControlManager, UDDIPublishStatusManager uDDIPublishStatusManager, Config config) { this.a = uDDIRegistryManager; this.b = uDDIProxiedServiceInfoManager; this.d = serviceCache; this.e = uDDIHelper; this.f = uDDIServiceControlManager; this.c = uDDIPublishStatusManager; this.g = config; } /* * Exception decompiling */ @Override public UDDITaskFactory.UDDITask buildUDDITask(o var1_1) { /* * This method has failed to decompile. When submitting a bug report, please provide this stack trace, and (if you hold appropriate legal rights) the relevant class file. * * org.benf.cfr.reader.util.ConfusedCFRException: Tried to end blocks [13[CASE]], but top level block is 1[TRYBLOCK] * at org.benf.cfr.reader.bytecode.analysis.opgraph.Op04StructuredStatement.processEndingBlocks(Op04StructuredStatement.java:435) * at org.benf.cfr.reader.bytecode.analysis.opgraph.Op04StructuredStatement.buildNestedBlocks(Op04StructuredStatement.java:484) * at org.benf.cfr.reader.bytecode.analysis.opgraph.Op03SimpleStatement.createInitialStructuredBlock(Op03SimpleStatement.java:736) * at org.benf.cfr.reader.bytecode.CodeAnalyser.getAnalysisInner(CodeAnalyser.java:850) * at org.benf.cfr.reader.bytecode.CodeAnalyser.getAnalysisOrWrapFail(CodeAnalyser.java:278) * at org.benf.cfr.reader.bytecode.CodeAnalyser.getAnalysis(CodeAnalyser.java:201) * at org.benf.cfr.reader.entities.attributes.AttributeCode.analyse(AttributeCode.java:94) * at org.benf.cfr.reader.entities.Method.analyse(Method.java:531) * at org.benf.cfr.reader.entities.ClassFile.analyseMid(ClassFile.java:1055) * at org.benf.cfr.reader.entities.ClassFile.analyseTop(ClassFile.java:942) * at org.benf.cfr.reader.Driver.doJarVersionTypes(Driver.java:257) * at org.benf.cfr.reader.Driver.doJar(Driver.java:139) * at org.benf.cfr.reader.CfrDriverImpl.analyse(CfrDriverImpl.java:76) * at org.benf.cfr.reader.Main.main(Main.java:54) */ throw new IllegalStateException("Decompilation failed"); } private static UDDIRegistrySpecificMetaData a(UDDIRegistry uDDIRegistry, UDDIServiceControl uDDIServiceControl, UDDIProxiedServiceInfo uDDIProxiedServiceInfo, PublishingUDDITaskFactory publishingUDDITaskFactory, UDDIClient uDDIClient) { boolean bl2; boolean bl3 = bl2 = uDDIServiceControl != null && uDDIProxiedServiceInfo.getPublishType() == UDDIProxiedServiceInfo.PublishType.PROXY && uDDIRegistry.getUddiRegistryType().equals(UDDIRegistry.UDDIRegistryType.CENTRASITE_ACTIVE_SOA.toString()) && Goid.equals((Goid)uDDIServiceControl.getUddiRegistryGoid(), (Goid)uDDIRegistry.getGoid()); if (bl2) { return new a(publishingUDDITaskFactory, uDDIClient, uDDIServiceControl); } return null; } private static void a(Goid goid, UDDITaskFactory.UDDITaskContext uDDITaskContext, UDDIPublishStatusManager uDDIPublishStatusManager, UDDIPublishStatus.PublishStatus publishStatus, UDDIPublishStatus.PublishStatus publishStatus2) throws UpdateException, FindException { UDDIPublishStatus uDDIPublishStatus = (UDDIPublishStatus)uDDIPublishStatusManager.findByPrimaryKey(goid); if (uDDIPublishStatus != null) { block4: { block3: { int n2 = uDDITaskContext.getMaxRetryAttempts(); int n3 = uDDIPublishStatus.getFailCount(); try { if (n3 < n2) break block3; uDDIPublishStatus.setPublishStatus(publishStatus2); break block4; } catch (UpdateException updateException) { throw PublishingUDDITaskFactory.a((ObjectModelException)((Object)updateException)); } } uDDIPublishStatus.setPublishStatus(publishStatus); } int n4 = uDDIPublishStatus.getFailCount() + 1; uDDIPublishStatus.setFailCount(n4); uDDIPublishStatusManager.update((PersistentEntity)uDDIPublishStatus); } } private static void a(Goid goid, UDDITaskFactory.UDDITaskContext uDDITaskContext, UDDIPublishStatusManager uDDIPublishStatusManager) throws UpdateException, FindException { PublishingUDDITaskFactory.a(goid, uDDITaskContext, uDDIPublishStatusManager, UDDIPublishStatus.PublishStatus.PUBLISH_FAILED, UDDIPublishStatus.PublishStatus.CANNOT_PUBLISH); } private static void b(Goid goid, UDDITaskFactory.UDDITaskContext uDDITaskContext, UDDIPublishStatusManager uDDIPublishStatusManager) throws UpdateException, FindException { PublishingUDDITaskFactory.a(goid, uDDITaskContext, uDDIPublishStatusManager, UDDIPublishStatus.PublishStatus.DELETE_FAILED, UDDIPublishStatus.PublishStatus.CANNOT_DELETE); } private static void a(final UDDITaskFactory.UDDITaskContext uDDITaskContext, Exception exception, final Goid goid, final PublishingUDDITaskFactory publishingUDDITaskFactory, final boolean bl2) throws UDDITaskFactory.UDDIHandledTaskException { throw new UDDITaskFactory.UDDIHandledTaskException(ExceptionUtils.getMessage((Throwable)exception), exception){ static final long serialVersionUID = -2107533049972398519L; private static final String[] a; @Override public void handleTaskError() { block10: { try { block9: { try { if (!bl2) break block9; PublishingUDDITaskFactory.a(goid, uDDITaskContext, publishingUDDITaskFactory.c); break block10; } catch (UpdateException updateException) { throw 2.a(updateException); } } PublishingUDDITaskFactory.b(goid, uDDITaskContext, publishingUDDITaskFactory.c); } catch (UpdateException updateException) { block11: { try { if (!bl2) break block11; uDDITaskContext.logAndAudit((AuditDetailMessage)SystemMessages.UDDI_PUBLISH_ENDPOINT_FAILED, updateException, a[3]); } catch (UpdateException updateException2) { throw 2.a(updateException2); } } String[] stringArray = new String[1]; String[] stringArray2 = a; stringArray[0] = stringArray2[1]; uDDITaskContext.logAndAudit((AuditDetailMessage)SystemMessages.UDDI_PUBLISH_ENDPOINT_FAILED, updateException, stringArray); } catch (FindException findException) { block12: { try { if (!bl2) break block12; uDDITaskContext.logAndAudit((AuditDetailMessage)SystemMessages.UDDI_PUBLISH_ENDPOINT_FAILED, findException, a[2]); } catch (UpdateException updateException) { throw 2.a(updateException); } } uDDITaskContext.logAndAudit((AuditDetailMessage)SystemMessages.UDDI_PUBLISH_ENDPOINT_FAILED, findException, a[0]); } } } private static UpdateException a(UpdateException updateException) { return updateException; } /* * Unable to fully structure code */ static { block10: { block9: { var5 = new String[4]; var3_1 = 0; var2_2 = ",Fo\\:\u0010\u0010\r\u0007~O*\u001e\u0011HPsX6Q\u0016\u0018CzI1\u001f\u0004HCzI9\u0013\u0002\u001bB;J1\u0005\u000bHC~Q=\u0005\u0006HAzT4Q\u0010\u001cFoNv=,Fo\\:\u0010\u0010\r\u0007~O*\u001e\u0011HPsX6Q\u0016\u0018CzI1\u001f\u0004HCzI9\u0013\u0002\u001bB;J1\u0005\u000bHC~Q=\u0005\u0006HAzT4Q\u0010\u001cFoNv"; var4_3 = ",Fo\\:\u0010\u0010\r\u0007~O*\u001e\u0011HPsX6Q\u0016\u0018CzI1\u001f\u0004HCzI9\u0013\u0002\u001bB;J1\u0005\u000bHC~Q=\u0005\u0006HAzT4Q\u0010\u001cFoNv=,Fo\\:\u0010\u0010\r\u0007~O*\u001e\u0011HPsX6Q\u0016\u0018CzI1\u001f\u0004HCzI9\u0013\u0002\u001bB;J1\u0005\u000bHC~Q=\u0005\u0006HAzT4Q\u0010\u001cFoNv".length(); var1_4 = 61; var0_5 = -1; lbl7: // 2 sources while (true) { v0 = 20; v1 = ++var0_5; v2 = var2_2.substring(v1, v1 + var1_4); v3 = -1; break block9; break; } lbl13: // 1 sources while (true) { var5[var3_1++] = 2.a(v0, 2.a(v2)); if ((var0_5 += var1_4) < var4_3) { var1_4 = var2_2.charAt(var0_5); ** continue; } var2_2 = "}\u0017>\rkAA\\V/\u001e{O@\u0019\u0001\"\tg\u0000GI\u0012+\u0018`NU\u0019\u0012+\u0018hBSJ\u0013j\u001b`TZ\u0019\u0006?\u000eeIAQV,\r`L\u0012J\u0002+\u0018z\u000e>}\u0017>\rkAA\\V/\u001e{O@\u0019\u0001\"\tg\u0000GI\u0012+\u0018`NU\u0019\u0012+\u0018hBSJ\u0013j\u001b`TZ\u0019\u0006?\u000eeIAQV,\r`L\u0012J\u0002+\u0018z\u000e"; var4_3 = "}\u0017>\rkAA\\V/\u001e{O@\u0019\u0001\"\tg\u0000GI\u0012+\u0018`NU\u0019\u0012+\u0018hBSJ\u0013j\u001b`TZ\u0019\u0006?\u000eeIAQV,\r`L\u0012J\u0002+\u0018z\u000e>}\u0017>\rkAA\\V/\u001e{O@\u0019\u0001\"\tg\u0000GI\u0012+\u0018`NU\u0019\u0012+\u0018hBSJ\u0013j\u001b`TZ\u0019\u0006?\u000eeIAQV,\r`L\u0012J\u0002+\u0018z\u000e".length(); var1_4 = 62; var0_5 = -1; lbl22: // 2 sources while (true) { v0 = 69; 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++] = 2.a(v0, 2.a(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; } } 2.a = var5; } private static char[] a(String string) { char[] cArray = string.toCharArray(); if (cArray.length < 2) { cArray = cArray; cArray[0] = (char)(cArray[0] ^ 0x77); } 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 -> 124; case 1 -> 51; case 2 -> 15; case 3 -> 41; case 4 -> 76; case 5 -> 101; default -> 119; }))); ++n3; n4 = n4; } while (n4 > n3); } return new String(cArray2).intern(); } }; } /* * Enabled aggressive block sorting */ static { String[] stringArray = new String[3]; int n2 = 0; String string = "Hg_WjO\u0002(\u001a7B[u|G)= n3) { i = stringArray; h = Logger.getLogger(PublishingUDDITaskFactory.class.getName()); return; } n4 = string.charAt(n5); } } private static ObjectModelException a(ObjectModelException objectModelException) { return objectModelException; } private static char[] a(String string) { char[] cArray = string.toCharArray(); if (cArray.length < 2) { cArray = cArray; cArray[0] = (char)(cArray[0] ^ 0x59); } 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 -> 10; case 1 -> 63; case 2 -> 11; case 3 -> 27; case 4 -> 40; case 5 -> 2; default -> 89; }))); ++n3; n4 = n4; } while (n4 > n3); } return new String(cArray2).intern(); } }