package com.l7tech.external.assertions.gatewaygraphql.server.resolver.mutation; import com.l7tech.external.assertions.gatewaygraphql.EntityTypeInfo; import com.l7tech.external.assertions.gatewaygraphql.server.data.ActiveConnectorDTO; import com.l7tech.external.assertions.gatewaygraphql.server.input.EntityPropertyInput; import com.l7tech.external.assertions.gatewaygraphql.server.resolver.helper.ActiveConnectorHelperFactory; import com.l7tech.external.assertions.gatewaygraphql.server.resolver.transformer.ActiveConnectorTransformer; import com.l7tech.external.assertions.gatewaygraphql.server.util.AssertionLocalBeanFactory; import com.l7tech.gateway.common.transport.SsgActiveConnector; import com.l7tech.gateway.common.transport.SsgActiveConnectorHeader; import com.l7tech.objectmodel.FindException; import com.l7tech.server.transport.SsgActiveConnectorManager; import graphql.schema.DataFetchingEnvironment; import java.util.List; import java.util.logging.Logger; import lombok.Generated; import org.springframework.beans.factory.BeanFactory; import org.springframework.transaction.PlatformTransactionManager; public class ActiveConnectorMutationResolver extends EntityManagerAwareGraphQLMutationResolver2 { @Generated private static final Logger c; private static final String[] d; public ActiveConnectorMutationResolver(PlatformTransactionManager var1, BeanFactory var2, AssertionLocalBeanFactory var3) { super( EntityTypeInfo.ACTIVE_CONNECTOR, var1, (SsgActiveConnectorManager)var2.getBean(d[0], SsgActiveConnectorManager.class), new ActiveConnectorTransformer(var2, var3.getRequired(ActiveConnectorHelperFactory.class)) ); } @Override protected Logger getLogger() { return c; } public ActiveConnectorDTO.ActiveConnectorsPayload setActiveConnectors(List var1, DataFetchingEnvironment var2) { ActiveConnectorDTO.ActiveConnectorsPayload var3 = new ActiveConnectorDTO.ActiveConnectorsPayload(); try { this.transformNoDefEntityMappings(var1, var2); if (var1.isEmpty()) { return var3; } } catch (IllegalArgumentException var4) { throw a(var4); } return this.execute(var2, (var3x, var4x) -> { var1.forEach(var4xx -> this.doUpsertSilently(var4xx, var3x, var3, var4x)); return var3; }); } public ActiveConnectorDTO.ActiveConnectorPayload updateActiveConnector( ActiveConnectorDTO.ActiveConnectorRefInput var1, ActiveConnectorDTO.ActiveConnectorInput var2, DataFetchingEnvironment var3 ) { return this.execute(var3, (var3x, var4) -> { ActiveConnectorDTO.ActiveConnectorPayload var5 = new ActiveConnectorDTO.ActiveConnectorPayload(); var2.setRefInput(var1); this.doUpdateSilently(var2, var3x, var5, var4); return var5; }); } public ActiveConnectorDTO.ActiveConnectorPayload updateActiveConnectorProperties( ActiveConnectorDTO.ActiveConnectorRefInput var1, List var2, DataFetchingEnvironment var3 ) { return this.execute(var3, (var3x, var4) -> { ActiveConnectorDTO.ActiveConnectorPayload var5 = new ActiveConnectorDTO.ActiveConnectorPayload(); ActiveConnectorDTO.ActiveConnectorInput var6 = this.a(var1); var6.setPartialProperties(var2); this.doUpdateSilently(var6, var3x, var5, var4); return var5; }); } public ActiveConnectorDTO.ActiveConnectorPayload updateActiveConnectorAdvancedProperties( ActiveConnectorDTO.ActiveConnectorRefInput var1, List var2, DataFetchingEnvironment var3 ) { return this.execute(var3, (var3x, var4) -> { ActiveConnectorDTO.ActiveConnectorPayload var5 = new ActiveConnectorDTO.ActiveConnectorPayload(); ActiveConnectorDTO.ActiveConnectorInput var6 = this.a(var1); var6.setPartialAdvancedProperties(var2); this.doUpdateSilently(var6, var3x, var5, var4); return var5; }); } public ActiveConnectorDTO.ActiveConnectorsPayload deleteActiveConnectors( List param1, @Deprecated List param2, DataFetchingEnvironment param3 ) { // $VF: Couldn't be decompiled // Please report this to the Vineflower issue tracker, at https://github.com/Vineflower/vineflower/issues with a copy of the class file (if you have the rights to distribute it!) // java.lang.RuntimeException: parsing failure! // at org.jetbrains.java.decompiler.modules.decompiler.decompose.DomHelper.parseGraph(DomHelper.java:211) // at org.jetbrains.java.decompiler.main.rels.MethodProcessor.codeToJava(MethodProcessor.java:174) // // Bytecode: // 00: new com/l7tech/external/assertions/gatewaygraphql/server/data/ActiveConnectorDTO$ActiveConnectorsPayload // 03: dup // 04: invokespecial com/l7tech/external/assertions/gatewaygraphql/server/data/ActiveConnectorDTO$ActiveConnectorsPayload. ()V // 07: astore 4 // 09: aload 1 // 0a: ifnonnull 29 // 0d: aload 2 // 0e: ifnonnull 29 // 11: goto 18 // 14: invokestatic com/l7tech/external/assertions/gatewaygraphql/server/resolver/mutation/ActiveConnectorMutationResolver.a (Ljava/lang/IllegalArgumentException;)Ljava/lang/IllegalArgumentException; // 17: athrow // 18: new java/lang/IllegalArgumentException // 1b: dup // 1c: getstatic com/l7tech/external/assertions/gatewaygraphql/server/resolver/mutation/ActiveConnectorMutationResolver.d [Ljava/lang/String; // 1f: bipush 1 // 20: aaload // 21: invokespecial java/lang/IllegalArgumentException. (Ljava/lang/String;)V // 24: athrow // 25: invokestatic com/l7tech/external/assertions/gatewaygraphql/server/resolver/mutation/ActiveConnectorMutationResolver.a (Ljava/lang/IllegalArgumentException;)Ljava/lang/IllegalArgumentException; // 28: athrow // 29: aload 1 // 2a: ifnull 43 // 2d: aload 0 // 2e: aload 3 // 2f: aload 0 // 30: aload 1 // 31: aload 4 // 33: invokedynamic doInTransaction (Lcom/l7tech/external/assertions/gatewaygraphql/server/resolver/mutation/ActiveConnectorMutationResolver;Ljava/util/List;Lcom/l7tech/external/assertions/gatewaygraphql/server/data/ActiveConnectorDTO$ActiveConnectorsPayload;)Lcom/l7tech/external/assertions/gatewaygraphql/server/resolver/ResolverTransactionCallback; bsm=java/lang/invoke/LambdaMetafactory.metafactory (Ljava/lang/invoke/MethodHandles$Lookup;Ljava/lang/String;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodHandle;Ljava/lang/invoke/MethodType;)Ljava/lang/invoke/CallSite; args=[ (Lcom/l7tech/external/assertions/gatewaygraphql/server/resolver/ResolverExecutionContext;Lorg/springframework/transaction/TransactionStatus;)Ljava/lang/Object;, com/l7tech/external/assertions/gatewaygraphql/server/resolver/mutation/ActiveConnectorMutationResolver.lambda$deleteActiveConnectors$6 (Ljava/util/List;Lcom/l7tech/external/assertions/gatewaygraphql/server/data/ActiveConnectorDTO$ActiveConnectorsPayload;Lcom/l7tech/external/assertions/gatewaygraphql/server/resolver/ResolverExecutionContext;Lorg/springframework/transaction/TransactionStatus;)Lcom/l7tech/external/assertions/gatewaygraphql/server/data/ActiveConnectorDTO$ActiveConnectorsPayload;, (Lcom/l7tech/external/assertions/gatewaygraphql/server/resolver/ResolverExecutionContext;Lorg/springframework/transaction/TransactionStatus;)Lcom/l7tech/external/assertions/gatewaygraphql/server/data/ActiveConnectorDTO$ActiveConnectorsPayload; ] // 38: invokevirtual com/l7tech/external/assertions/gatewaygraphql/server/resolver/mutation/ActiveConnectorMutationResolver.execute (Lgraphql/schema/DataFetchingEnvironment;Lcom/l7tech/external/assertions/gatewaygraphql/server/resolver/ResolverTransactionCallback;)Ljava/lang/Object; // 3b: checkcast com/l7tech/external/assertions/gatewaygraphql/server/data/ActiveConnectorDTO$ActiveConnectorsPayload // 3e: areturn // 3f: invokestatic com/l7tech/external/assertions/gatewaygraphql/server/resolver/mutation/ActiveConnectorMutationResolver.a (Ljava/lang/IllegalArgumentException;)Ljava/lang/IllegalArgumentException; // 42: athrow // 43: aload 0 // 44: aload 3 // 45: aload 0 // 46: aload 2 // 47: aload 4 // 49: invokedynamic doInTransaction (Lcom/l7tech/external/assertions/gatewaygraphql/server/resolver/mutation/ActiveConnectorMutationResolver;Ljava/util/List;Lcom/l7tech/external/assertions/gatewaygraphql/server/data/ActiveConnectorDTO$ActiveConnectorsPayload;)Lcom/l7tech/external/assertions/gatewaygraphql/server/resolver/ResolverTransactionCallback; bsm=java/lang/invoke/LambdaMetafactory.metafactory (Ljava/lang/invoke/MethodHandles$Lookup;Ljava/lang/String;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodHandle;Ljava/lang/invoke/MethodType;)Ljava/lang/invoke/CallSite; args=[ (Lcom/l7tech/external/assertions/gatewaygraphql/server/resolver/ResolverExecutionContext;Lorg/springframework/transaction/TransactionStatus;)Ljava/lang/Object;, com/l7tech/external/assertions/gatewaygraphql/server/resolver/mutation/ActiveConnectorMutationResolver.lambda$deleteActiveConnectors$8 (Ljava/util/List;Lcom/l7tech/external/assertions/gatewaygraphql/server/data/ActiveConnectorDTO$ActiveConnectorsPayload;Lcom/l7tech/external/assertions/gatewaygraphql/server/resolver/ResolverExecutionContext;Lorg/springframework/transaction/TransactionStatus;)Lcom/l7tech/external/assertions/gatewaygraphql/server/data/ActiveConnectorDTO$ActiveConnectorsPayload;, (Lcom/l7tech/external/assertions/gatewaygraphql/server/resolver/ResolverExecutionContext;Lorg/springframework/transaction/TransactionStatus;)Lcom/l7tech/external/assertions/gatewaygraphql/server/data/ActiveConnectorDTO$ActiveConnectorsPayload; ] // 4e: invokevirtual com/l7tech/external/assertions/gatewaygraphql/server/resolver/mutation/ActiveConnectorMutationResolver.execute (Lgraphql/schema/DataFetchingEnvironment;Lcom/l7tech/external/assertions/gatewaygraphql/server/resolver/ResolverTransactionCallback;)Ljava/lang/Object; // 51: checkcast com/l7tech/external/assertions/gatewaygraphql/server/data/ActiveConnectorDTO$ActiveConnectorsPayload // 54: areturn // try (4 -> 8): 9 java/lang/IllegalArgumentException // try (6 -> 18): 18 java/lang/IllegalArgumentException // try (20 -> 31): 31 java/lang/IllegalArgumentException } protected SsgActiveConnector findByRefInput(ActiveConnectorDTO.ActiveConnectorRefInput var1) throws FindException { return this.findByName(var1.getName()); } protected SsgActiveConnector findByInput(ActiveConnectorDTO.ActiveConnectorInput var1) throws FindException { return this.findByName(var1.getName()); } private ActiveConnectorDTO.ActiveConnectorInput a(ActiveConnectorDTO.ActiveConnectorRefInput var1) { ActiveConnectorDTO.ActiveConnectorInput var2 = new ActiveConnectorDTO.ActiveConnectorInput(); var2.setRefInput(var1); var2.setName(var1.getName()); var2.setConnectorType(var1.getConnectorType()); return var2; } static { String[] var5 = new String[2]; int var3 = 0; String var2 = "\u001e\u001fx2\u0002= var4) { d = var5; c = Logger.getLogger(ActiveConnectorMutationResolver.class.getName()); return; } var1 = var2.charAt(var0); } } private static IllegalArgumentException a(IllegalArgumentException var0) { return var0; } private static char[] b(String var0) { char[] var10000 = var0.toCharArray(); if (var10000.length < 2) { var10000[0] = (char)(var10000[0] ^ 120); } return var10000; } private static String c(int var0, char[] var1) { int var10003 = var1.length; int var10002 = var0; char[] var10001 = var1; int var10000 = var10003; for (int var2 = 0; var10000 > var2; var2++) { var10001[var2] = (char)(var10001[var2] ^ var10002 ^ switch (var2 % 7) { case 0 -> 25; case 1 -> 24; case 2 -> 107; case 3 -> 7; case 4 -> 21; case 5 -> 60; default -> 120; }); } return new String(var10001).intern(); } }