diff options
Diffstat (limited to 'org.eclipse.osbp.xtext.datainterchange/xtend-gen/org/eclipse/osbp/xtext/datainterchange/jvmmodel/DataDSLJvmModelInferrer.java')
| -rw-r--r-- | org.eclipse.osbp.xtext.datainterchange/xtend-gen/org/eclipse/osbp/xtext/datainterchange/jvmmodel/DataDSLJvmModelInferrer.java | 2622 |
1 files changed, 0 insertions, 2622 deletions
diff --git a/org.eclipse.osbp.xtext.datainterchange/xtend-gen/org/eclipse/osbp/xtext/datainterchange/jvmmodel/DataDSLJvmModelInferrer.java b/org.eclipse.osbp.xtext.datainterchange/xtend-gen/org/eclipse/osbp/xtext/datainterchange/jvmmodel/DataDSLJvmModelInferrer.java deleted file mode 100644 index 8c6bccf..0000000 --- a/org.eclipse.osbp.xtext.datainterchange/xtend-gen/org/eclipse/osbp/xtext/datainterchange/jvmmodel/DataDSLJvmModelInferrer.java +++ /dev/null @@ -1,2622 +0,0 @@ -/** - * Copyright (c) 2011, 2016 - Loetz GmbH&Co.KG (69115 Heidelberg, Germany) - * - * All rights reserved. This program and the accompanying materials - * are made available under the terms of the Eclipse Public License v1.0 - * which accompanies this distribution, and is available at - * http://www.eclipse.org/legal/epl-v10.html - * - * Contributors: - * Christophe Loetz (Loetz GmbH&Co.KG) - initial implementation - * - * - * This copyright notice shows up in the generated Java code - */ -package org.eclipse.osbp.xtext.datainterchange.jvmmodel; - -import com.google.common.base.Objects; -import com.vaadin.ui.Button; -import com.vaadin.ui.CssLayout; -import com.vaadin.ui.Label; -import com.vaadin.ui.VerticalLayout; -import java.io.OutputStream; -import java.net.URL; -import java.util.ArrayList; -import java.util.Arrays; -import java.util.HashMap; -import java.util.Iterator; -import java.util.List; -import java.util.Locale; -import java.util.Map; -import java.util.concurrent.ExecutorService; -import javax.annotation.PostConstruct; -import javax.annotation.PreDestroy; -import javax.inject.Inject; -import javax.persistence.EntityManager; -import javax.xml.transform.Transformer; -import javax.xml.transform.TransformerFactory; -import org.eclipse.e4.core.contexts.IEclipseContext; -import org.eclipse.e4.core.services.events.IEventBroker; -import org.eclipse.e4.ui.model.application.MApplication; -import org.eclipse.emf.common.util.EList; -import org.eclipse.emf.ecore.EObject; -import org.eclipse.osbp.dsl.entity.xtext.extensions.ModelExtensions; -import org.eclipse.osbp.dsl.semantic.common.types.LReference; -import org.eclipse.osbp.dsl.semantic.common.types.LType; -import org.eclipse.osbp.dsl.semantic.entity.LEntity; -import org.eclipse.osbp.dsl.semantic.entity.LEntityAttribute; -import org.eclipse.osbp.dsl.semantic.entity.LEntityFeature; -import org.eclipse.osbp.osgi.hybrid.api.AbstractHybridVaaclipseView; -import org.eclipse.osbp.persistence.IPersistenceService; -import org.eclipse.osbp.ui.api.metadata.IDSLMetadataService; -import org.eclipse.osbp.ui.api.user.IUser; -import org.eclipse.osbp.utils.constants.GeneratorConstants; -import org.eclipse.osbp.utils.entitymock.IEntityImportInitializationListener; -import org.eclipse.osbp.xtext.datainterchange.DataInterchange; -import org.eclipse.osbp.xtext.datainterchange.DataInterchangeBean; -import org.eclipse.osbp.xtext.datainterchange.DataInterchangeFile; -import org.eclipse.osbp.xtext.datainterchange.DataInterchangeFileCSV; -import org.eclipse.osbp.xtext.datainterchange.DataInterchangeFileEDI; -import org.eclipse.osbp.xtext.datainterchange.DataInterchangeFileXML; -import org.eclipse.osbp.xtext.datainterchange.DataInterchangeLookup; -import org.eclipse.osbp.xtext.datainterchange.DataInterchangePackage; -import org.eclipse.osbp.xtext.datainterchange.ProgressBarStylesEnum; -import org.eclipse.osbp.xtext.datainterchange.common.WorkerThreadRunnable; -import org.eclipse.osbp.xtext.datainterchange.jvmmodel.DataDSLModelGenerator; -import org.eclipse.osbp.xtext.i18n.DSLOutputConfigurationProvider; -import org.eclipse.xtend2.lib.StringConcatenation; -import org.eclipse.xtext.common.types.JvmAnnotationReference; -import org.eclipse.xtext.common.types.JvmConstructor; -import org.eclipse.xtext.common.types.JvmDeclaredType; -import org.eclipse.xtext.common.types.JvmField; -import org.eclipse.xtext.common.types.JvmFormalParameter; -import org.eclipse.xtext.common.types.JvmGenericType; -import org.eclipse.xtext.common.types.JvmMember; -import org.eclipse.xtext.common.types.JvmOperation; -import org.eclipse.xtext.common.types.JvmTypeReference; -import org.eclipse.xtext.common.types.JvmVisibility; -import org.eclipse.xtext.naming.IQualifiedNameProvider; -import org.eclipse.xtext.naming.QualifiedName; -import org.eclipse.xtext.xbase.compiler.output.ITreeAppendable; -import org.eclipse.xtext.xbase.jvmmodel.AbstractModelInferrer; -import org.eclipse.xtext.xbase.jvmmodel.IJvmDeclaredTypeAcceptor; -import org.eclipse.xtext.xbase.jvmmodel.JvmTypesBuilder; -import org.eclipse.xtext.xbase.lib.Conversions; -import org.eclipse.xtext.xbase.lib.Extension; -import org.eclipse.xtext.xbase.lib.Procedures.Procedure1; -import org.eclipse.xtext.xbase.lib.StringExtensions; -import org.milyn.Smooks; -import org.milyn.SmooksFactory; -import org.milyn.container.ExecutionContext; -import org.osgi.framework.BundleEvent; -import org.osgi.framework.BundleListener; -import org.osgi.service.event.EventHandler; -import org.slf4j.Logger; - -/** - * <p> - * Data Interchange Repository Domain Specific Language - * This inferrer infers models of extension .data and generates code to be used by any data interchanging process - * to facilitate the communication with external data sources and drains. Underlying components - * are from the smooks repository - * </p> - * - * @author Joerg Riegel - */ -@SuppressWarnings("all") -public class DataDSLJvmModelInferrer extends AbstractModelInferrer { - @Inject - @Extension - private JvmTypesBuilder _jvmTypesBuilder; - - @Inject - @Extension - private IQualifiedNameProvider _iQualifiedNameProvider; - - @Inject - @Extension - private DataDSLModelGenerator dg; - - @Inject - @Extension - private ModelExtensions _modelExtensions; - - /** - * ramp up NTHREADS and threads are finished start more but up to this limit - */ - private int NTHREADS = 10; - - /** - * infer model on package base. Will be called for every defined package. - * - * @param dataInterchangePackage - * An instance of {@link DataInterchangePackage} - * @param acceptor - * the xtext acceptor interface - * @param isPreIndexingPhase - * true if in preindexing phase - */ - protected void _infer(final DataInterchangePackage dataInterchangePackage, final IJvmDeclaredTypeAcceptor acceptor, final boolean isPreIndexingPhase) { - this.dg.generatePckgName(dataInterchangePackage, acceptor); - String _name = dataInterchangePackage.getName(); - String _string = _name.toString(); - String _concat = _string.concat("TriggerView"); - JvmGenericType cls = this._jvmTypesBuilder.toClass(dataInterchangePackage, _concat); - String _simpleName = cls.getSimpleName(); - String _firstUpper = StringExtensions.toFirstUpper(_simpleName); - cls.setSimpleName(_firstUpper); - final Procedure1<JvmGenericType> _function = new Procedure1<JvmGenericType>() { - public void apply(final JvmGenericType it) { - EList<JvmTypeReference> _superTypes = it.getSuperTypes(); - JvmTypeReference _typeRef = DataDSLJvmModelInferrer.this._typeReferenceBuilder.typeRef(AbstractHybridVaaclipseView.class); - DataDSLJvmModelInferrer.this._jvmTypesBuilder.<JvmTypeReference>operator_add(_superTypes, _typeRef); - EList<JvmTypeReference> _superTypes_1 = it.getSuperTypes(); - JvmTypeReference _typeRef_1 = DataDSLJvmModelInferrer.this._typeReferenceBuilder.typeRef(BundleListener.class); - DataDSLJvmModelInferrer.this._jvmTypesBuilder.<JvmTypeReference>operator_add(_superTypes_1, _typeRef_1); - EList<JvmTypeReference> _superTypes_2 = it.getSuperTypes(); - JvmTypeReference _typeRef_2 = DataDSLJvmModelInferrer.this._typeReferenceBuilder.typeRef(IUser.UserLocaleListener.class); - DataDSLJvmModelInferrer.this._jvmTypesBuilder.<JvmTypeReference>operator_add(_superTypes_2, _typeRef_2); - DataDSLJvmModelInferrer.this._jvmTypesBuilder.setDocumentation(it, GeneratorConstants.GENERATED_CLASSES_DOCUMENTATION); - EList<JvmAnnotationReference> _annotations = it.getAnnotations(); - JvmAnnotationReference _annotationRef = DataDSLJvmModelInferrer.this._annotationTypesBuilder.annotationRef(SuppressWarnings.class, "serial"); - DataDSLJvmModelInferrer.this._jvmTypesBuilder.<JvmAnnotationReference>operator_add(_annotations, _annotationRef); - QualifiedName _fullyQualifiedName = DataDSLJvmModelInferrer.this._iQualifiedNameProvider.getFullyQualifiedName(dataInterchangePackage); - String _string = _fullyQualifiedName.toString(); - it.setPackageName(_string); - DataDSLJvmModelInferrer.this.toFields(it, dataInterchangePackage); - DataDSLJvmModelInferrer.this.toConstructor(it, dataInterchangePackage); - DataDSLJvmModelInferrer.this.toOperations(it, dataInterchangePackage); - } - }; - acceptor.<JvmGenericType>accept(cls, _function); - EList<DataInterchange> _datInts = dataInterchangePackage.getDatInts(); - for (final DataInterchange dataInterchange : _datInts) { - { - QualifiedName clsName2 = this._iQualifiedNameProvider.getFullyQualifiedName(dataInterchange); - JvmGenericType _class = this._jvmTypesBuilder.toClass(dataInterchange, clsName2); - final Procedure1<JvmGenericType> _function_1 = new Procedure1<JvmGenericType>() { - public void apply(final JvmGenericType it) { - EList<JvmTypeReference> _superTypes = it.getSuperTypes(); - JvmTypeReference _typeRef = DataDSLJvmModelInferrer.this._typeReferenceBuilder.typeRef(WorkerThreadRunnable.class); - DataDSLJvmModelInferrer.this._jvmTypesBuilder.<JvmTypeReference>operator_add(_superTypes, _typeRef); - EList<JvmAnnotationReference> _annotations = it.getAnnotations(); - JvmAnnotationReference _annotationRef = DataDSLJvmModelInferrer.this._annotationTypesBuilder.annotationRef(SuppressWarnings.class, "serial"); - DataDSLJvmModelInferrer.this._jvmTypesBuilder.<JvmAnnotationReference>operator_add(_annotations, _annotationRef); - DataDSLJvmModelInferrer.this._jvmTypesBuilder.setDocumentation(it, GeneratorConstants.GENERATED_CLASSES_DOCUMENTATION); - DataDSLJvmModelInferrer.this.toConstructor(it, dataInterchange); - DataDSLJvmModelInferrer.this.toFields(it, dataInterchange); - DataDSLJvmModelInferrer.this.toOperations(it, dataInterchange); - } - }; - acceptor.<JvmGenericType>accept(_class, _function_1); - } - } - } - - /** - * generate the fields in the inferred class. - * - * @param type - * the xtext generic types list - * @param pkg - * the current package inferred {@link DataInterchangePackage} - */ - public void toFields(final JvmGenericType type, final DataInterchangePackage pkg) { - JvmField field = null; - JvmTypeReference _typeRef = this._typeReferenceBuilder.typeRef(VerticalLayout.class); - JvmField _field = this._jvmTypesBuilder.toField(pkg, "sidebar", _typeRef); - field = _field; - EList<JvmMember> _members = type.getMembers(); - this._jvmTypesBuilder.<JvmField>operator_add(_members, field); - String _name = pkg.getName(); - String _string = _name.toString(); - String name = _string.replace(".", ":"); - String[] parts = name.split(":"); - final String[] _converted_parts = (String[])parts; - int _size = ((List<String>)Conversions.doWrapArray(_converted_parts)).size(); - int _minus = (_size - 1); - String _get = parts[_minus]; - final String clsName = StringExtensions.toFirstUpper(_get); - JvmTypeReference _typeRef_1 = this._typeReferenceBuilder.typeRef(Logger.class); - final Procedure1<JvmField> _function = new Procedure1<JvmField>() { - public void apply(final JvmField it) { - final Procedure1<ITreeAppendable> _function = new Procedure1<ITreeAppendable>() { - public void apply(final ITreeAppendable it) { - StringConcatenation _builder = new StringConcatenation(); - _builder.append("LoggerFactory.getLogger("); - _builder.append(clsName, ""); - _builder.append("TriggerView.class)"); - it.append(_builder); - } - }; - DataDSLJvmModelInferrer.this._jvmTypesBuilder.setInitializer(it, _function); - } - }; - JvmField _field_1 = this._jvmTypesBuilder.toField(pkg, "log", _typeRef_1, _function); - field = _field_1; - field.setFinal(true); - field.setStatic(true); - EList<JvmMember> _members_1 = type.getMembers(); - this._jvmTypesBuilder.<JvmField>operator_add(_members_1, field); - JvmTypeReference _typeRef_2 = this._typeReferenceBuilder.typeRef(CssLayout.class); - JvmField _field_2 = this._jvmTypesBuilder.toField(pkg, "menu", _typeRef_2); - field = _field_2; - EList<JvmMember> _members_2 = type.getMembers(); - this._jvmTypesBuilder.<JvmField>operator_add(_members_2, field); - JvmTypeReference _typeRef_3 = this._typeReferenceBuilder.typeRef(EventHandler.class); - JvmField _field_3 = this._jvmTypesBuilder.toField(pkg, "workerInfo", _typeRef_3); - field = _field_3; - EList<JvmMember> _members_3 = type.getMembers(); - this._jvmTypesBuilder.<JvmField>operator_add(_members_3, field); - JvmTypeReference _typeRef_4 = this._typeReferenceBuilder.typeRef(CssLayout.class); - JvmField _field_4 = this._jvmTypesBuilder.toField(pkg, "branding", _typeRef_4); - field = _field_4; - EList<JvmMember> _members_4 = type.getMembers(); - this._jvmTypesBuilder.<JvmField>operator_add(_members_4, field); - JvmTypeReference _typeRef_5 = this._typeReferenceBuilder.typeRef(IEventBroker.class); - final Procedure1<JvmField> _function_1 = new Procedure1<JvmField>() { - public void apply(final JvmField it) { - EList<JvmAnnotationReference> _annotations = it.getAnnotations(); - JvmAnnotationReference _annotationRef = DataDSLJvmModelInferrer.this._annotationTypesBuilder.annotationRef(Inject.class); - DataDSLJvmModelInferrer.this._jvmTypesBuilder.<JvmAnnotationReference>operator_add(_annotations, _annotationRef); - } - }; - JvmField _field_5 = this._jvmTypesBuilder.toField(pkg, "eventBroker", _typeRef_5, _function_1); - field = _field_5; - EList<JvmMember> _members_5 = type.getMembers(); - this._jvmTypesBuilder.<JvmField>operator_add(_members_5, field); - JvmTypeReference _typeRef_6 = this._typeReferenceBuilder.typeRef(IPersistenceService.class); - final Procedure1<JvmField> _function_2 = new Procedure1<JvmField>() { - public void apply(final JvmField it) { - EList<JvmAnnotationReference> _annotations = it.getAnnotations(); - JvmAnnotationReference _annotationRef = DataDSLJvmModelInferrer.this._annotationTypesBuilder.annotationRef(Inject.class); - DataDSLJvmModelInferrer.this._jvmTypesBuilder.<JvmAnnotationReference>operator_add(_annotations, _annotationRef); - } - }; - JvmField _field_6 = this._jvmTypesBuilder.toField(pkg, "persistenceService", _typeRef_6, _function_2); - field = _field_6; - EList<JvmMember> _members_6 = type.getMembers(); - this._jvmTypesBuilder.<JvmField>operator_add(_members_6, field); - JvmTypeReference _typeRef_7 = this._typeReferenceBuilder.typeRef(String.class); - JvmTypeReference _typeRef_8 = this._typeReferenceBuilder.typeRef(WorkerThreadRunnable.class); - JvmTypeReference _typeRef_9 = this._typeReferenceBuilder.typeRef(Map.class, _typeRef_7, _typeRef_8); - JvmField _field_7 = this._jvmTypesBuilder.toField(pkg, "progressBars", _typeRef_9); - field = _field_7; - EList<JvmMember> _members_7 = type.getMembers(); - this._jvmTypesBuilder.<JvmField>operator_add(_members_7, field); - JvmTypeReference _typeRef_10 = this._typeReferenceBuilder.typeRef(ExecutorService.class); - JvmField _field_8 = this._jvmTypesBuilder.toField(pkg, "executorService", _typeRef_10); - field = _field_8; - field.setStatic(true); - EList<JvmMember> _members_8 = type.getMembers(); - this._jvmTypesBuilder.<JvmField>operator_add(_members_8, field); - JvmTypeReference _typeRef_11 = this._typeReferenceBuilder.typeRef(IDSLMetadataService.class); - final Procedure1<JvmField> _function_3 = new Procedure1<JvmField>() { - public void apply(final JvmField it) { - EList<JvmAnnotationReference> _annotations = it.getAnnotations(); - JvmAnnotationReference _annotationRef = DataDSLJvmModelInferrer.this._annotationTypesBuilder.annotationRef(Inject.class); - DataDSLJvmModelInferrer.this._jvmTypesBuilder.<JvmAnnotationReference>operator_add(_annotations, _annotationRef); - } - }; - JvmField _field_9 = this._jvmTypesBuilder.toField(pkg, "dslMetadataService", _typeRef_11, _function_3); - field = _field_9; - EList<JvmMember> _members_9 = type.getMembers(); - this._jvmTypesBuilder.<JvmField>operator_add(_members_9, field); - JvmTypeReference _typeRef_12 = this._typeReferenceBuilder.typeRef(IUser.class); - final Procedure1<JvmField> _function_4 = new Procedure1<JvmField>() { - public void apply(final JvmField it) { - EList<JvmAnnotationReference> _annotations = it.getAnnotations(); - JvmAnnotationReference _annotationRef = DataDSLJvmModelInferrer.this._annotationTypesBuilder.annotationRef(Inject.class); - DataDSLJvmModelInferrer.this._jvmTypesBuilder.<JvmAnnotationReference>operator_add(_annotations, _annotationRef); - } - }; - JvmField _field_10 = this._jvmTypesBuilder.toField(pkg, "user", _typeRef_12, _function_4); - field = _field_10; - EList<JvmMember> _members_10 = type.getMembers(); - this._jvmTypesBuilder.<JvmField>operator_add(_members_10, field); - JvmTypeReference _typeRef_13 = this._typeReferenceBuilder.typeRef(Label.class); - JvmField _field_11 = this._jvmTypesBuilder.toField(pkg, "logo", _typeRef_13); - field = _field_11; - EList<JvmMember> _members_11 = type.getMembers(); - this._jvmTypesBuilder.<JvmField>operator_add(_members_11, field); - JvmTypeReference _typeRef_14 = this._typeReferenceBuilder.typeRef(Button.class); - JvmTypeReference _typeRef_15 = this._typeReferenceBuilder.typeRef(ArrayList.class); - JvmTypeReference _typeRef_16 = this._typeReferenceBuilder.typeRef(HashMap.class, _typeRef_14, _typeRef_15); - JvmField _field_12 = this._jvmTypesBuilder.toField(pkg, "buttons", _typeRef_16); - field = _field_12; - EList<JvmMember> _members_12 = type.getMembers(); - this._jvmTypesBuilder.<JvmField>operator_add(_members_12, field); - } - - /** - * <p>build the constructors to be used by an e4 application.</p> - */ - public void toConstructor(final JvmDeclaredType type, final DataInterchangePackage pkg) { - EList<JvmMember> _members = type.getMembers(); - final Procedure1<JvmConstructor> _function = new Procedure1<JvmConstructor>() { - public void apply(final JvmConstructor it) { - EList<JvmAnnotationReference> _annotations = it.getAnnotations(); - JvmAnnotationReference _annotationRef = DataDSLJvmModelInferrer.this._annotationTypesBuilder.annotationRef(Inject.class); - DataDSLJvmModelInferrer.this._jvmTypesBuilder.<JvmAnnotationReference>operator_add(_annotations, _annotationRef); - EList<JvmFormalParameter> _parameters = it.getParameters(); - JvmTypeReference _typeRef = DataDSLJvmModelInferrer.this._typeReferenceBuilder.typeRef(VerticalLayout.class); - JvmFormalParameter _parameter = DataDSLJvmModelInferrer.this._jvmTypesBuilder.toParameter(pkg, "parent", _typeRef); - DataDSLJvmModelInferrer.this._jvmTypesBuilder.<JvmFormalParameter>operator_add(_parameters, _parameter); - EList<JvmFormalParameter> _parameters_1 = it.getParameters(); - JvmTypeReference _typeRef_1 = DataDSLJvmModelInferrer.this._typeReferenceBuilder.typeRef(IEclipseContext.class); - JvmFormalParameter _parameter_1 = DataDSLJvmModelInferrer.this._jvmTypesBuilder.toParameter(pkg, "context", _typeRef_1); - DataDSLJvmModelInferrer.this._jvmTypesBuilder.<JvmFormalParameter>operator_add(_parameters_1, _parameter_1); - EList<JvmFormalParameter> _parameters_2 = it.getParameters(); - JvmTypeReference _typeRef_2 = DataDSLJvmModelInferrer.this._typeReferenceBuilder.typeRef(MApplication.class); - JvmFormalParameter _parameter_2 = DataDSLJvmModelInferrer.this._jvmTypesBuilder.toParameter(pkg, "app", _typeRef_2); - DataDSLJvmModelInferrer.this._jvmTypesBuilder.<JvmFormalParameter>operator_add(_parameters_2, _parameter_2); - final Procedure1<ITreeAppendable> _function = new Procedure1<ITreeAppendable>() { - public void apply(final ITreeAppendable it) { - StringConcatenation _builder = new StringConcatenation(); - _builder.append("super(parent,context,app);"); - it.append(_builder); - } - }; - DataDSLJvmModelInferrer.this._jvmTypesBuilder.setBody(it, _function); - } - }; - JvmConstructor _constructor = this._jvmTypesBuilder.toConstructor(pkg, _function); - this._jvmTypesBuilder.<JvmConstructor>operator_add(_members, _constructor); - } - - /** - * generate the fields in the inferred class. - * - * @param type - * the xtext generic types list - * @param pkg - * the current package inferred {@link DataInterchangePackage} - */ - public void toOperations(final JvmGenericType type, final DataInterchangePackage pkg) { - EList<JvmMember> _members = type.getMembers(); - JvmTypeReference _typeRef = this._typeReferenceBuilder.typeRef(Void.TYPE); - final Procedure1<JvmOperation> _function = new Procedure1<JvmOperation>() { - public void apply(final JvmOperation it) { - EList<JvmFormalParameter> _parameters = it.getParameters(); - JvmTypeReference _typeRef = DataDSLJvmModelInferrer.this._typeReferenceBuilder.typeRef(VerticalLayout.class); - JvmFormalParameter _parameter = DataDSLJvmModelInferrer.this._jvmTypesBuilder.toParameter(pkg, "parent", _typeRef); - DataDSLJvmModelInferrer.this._jvmTypesBuilder.<JvmFormalParameter>operator_add(_parameters, _parameter); - final Procedure1<ITreeAppendable> _function = new Procedure1<ITreeAppendable>() { - public void apply(final ITreeAppendable it) { - StringConcatenation _builder = new StringConcatenation(); - String _createView = DataDSLJvmModelInferrer.this.createView(pkg); - _builder.append(_createView, ""); - it.append(_builder); - } - }; - DataDSLJvmModelInferrer.this._jvmTypesBuilder.setBody(it, _function); - } - }; - JvmOperation _method = this._jvmTypesBuilder.toMethod(pkg, "createView", _typeRef, _function); - this._jvmTypesBuilder.<JvmOperation>operator_add(_members, _method); - EList<JvmMember> _members_1 = type.getMembers(); - JvmTypeReference _typeRef_1 = this._typeReferenceBuilder.typeRef(Void.TYPE); - final Procedure1<JvmOperation> _function_1 = new Procedure1<JvmOperation>() { - public void apply(final JvmOperation it) { - final Procedure1<ITreeAppendable> _function = new Procedure1<ITreeAppendable>() { - public void apply(final ITreeAppendable it) { - StringConcatenation _builder = new StringConcatenation(); - String _createComponents = DataDSLJvmModelInferrer.this.createComponents(pkg); - _builder.append(_createComponents, ""); - it.append(_builder); - } - }; - DataDSLJvmModelInferrer.this._jvmTypesBuilder.setBody(it, _function); - } - }; - JvmOperation _method_1 = this._jvmTypesBuilder.toMethod(pkg, "createComponents", _typeRef_1, _function_1); - this._jvmTypesBuilder.<JvmOperation>operator_add(_members_1, _method_1); - EList<JvmMember> _members_2 = type.getMembers(); - JvmTypeReference _typeRef_2 = this._typeReferenceBuilder.typeRef(String.class); - final Procedure1<JvmOperation> _function_2 = new Procedure1<JvmOperation>() { - public void apply(final JvmOperation it) { - EList<JvmFormalParameter> _parameters = it.getParameters(); - JvmTypeReference _typeRef = DataDSLJvmModelInferrer.this._typeReferenceBuilder.typeRef(String.class); - JvmFormalParameter _parameter = DataDSLJvmModelInferrer.this._jvmTypesBuilder.toParameter(pkg, "name", _typeRef); - DataDSLJvmModelInferrer.this._jvmTypesBuilder.<JvmFormalParameter>operator_add(_parameters, _parameter); - final Procedure1<ITreeAppendable> _function = new Procedure1<ITreeAppendable>() { - public void apply(final ITreeAppendable it) { - StringConcatenation _builder = new StringConcatenation(); - String _uniqueName = DataDSLJvmModelInferrer.this.uniqueName(pkg); - _builder.append(_uniqueName, ""); - it.append(_builder); - } - }; - DataDSLJvmModelInferrer.this._jvmTypesBuilder.setBody(it, _function); - } - }; - JvmOperation _method_2 = this._jvmTypesBuilder.toMethod(pkg, "uniqueName", _typeRef_2, _function_2); - this._jvmTypesBuilder.<JvmOperation>operator_add(_members_2, _method_2); - EList<JvmMember> _members_3 = type.getMembers(); - JvmTypeReference _typeRef_3 = this._typeReferenceBuilder.typeRef(boolean.class); - final Procedure1<JvmOperation> _function_3 = new Procedure1<JvmOperation>() { - public void apply(final JvmOperation it) { - EList<JvmFormalParameter> _parameters = it.getParameters(); - JvmTypeReference _typeRef = DataDSLJvmModelInferrer.this._typeReferenceBuilder.typeRef(String.class); - JvmFormalParameter _parameter = DataDSLJvmModelInferrer.this._jvmTypesBuilder.toParameter(pkg, "name", _typeRef); - DataDSLJvmModelInferrer.this._jvmTypesBuilder.<JvmFormalParameter>operator_add(_parameters, _parameter); - final Procedure1<ITreeAppendable> _function = new Procedure1<ITreeAppendable>() { - public void apply(final ITreeAppendable it) { - StringConcatenation _builder = new StringConcatenation(); - String _isDuplicate = DataDSLJvmModelInferrer.this.isDuplicate(pkg); - _builder.append(_isDuplicate, ""); - it.append(_builder); - } - }; - DataDSLJvmModelInferrer.this._jvmTypesBuilder.setBody(it, _function); - } - }; - JvmOperation _method_3 = this._jvmTypesBuilder.toMethod(pkg, "isDuplicate", _typeRef_3, _function_3); - this._jvmTypesBuilder.<JvmOperation>operator_add(_members_3, _method_3); - EList<JvmMember> _members_4 = type.getMembers(); - JvmTypeReference _typeRef_4 = this._typeReferenceBuilder.typeRef(VerticalLayout.class); - final Procedure1<JvmOperation> _function_4 = new Procedure1<JvmOperation>() { - public void apply(final JvmOperation it) { - EList<JvmFormalParameter> _parameters = it.getParameters(); - JvmTypeReference _typeRef = DataDSLJvmModelInferrer.this._typeReferenceBuilder.typeRef(Button.class); - JvmFormalParameter _parameter = DataDSLJvmModelInferrer.this._jvmTypesBuilder.toParameter(pkg, "button", _typeRef); - DataDSLJvmModelInferrer.this._jvmTypesBuilder.<JvmFormalParameter>operator_add(_parameters, _parameter); - final Procedure1<ITreeAppendable> _function = new Procedure1<ITreeAppendable>() { - public void apply(final ITreeAppendable it) { - StringConcatenation _builder = new StringConcatenation(); - String _findButtonLayout = DataDSLJvmModelInferrer.this.findButtonLayout(pkg); - _builder.append(_findButtonLayout, ""); - it.append(_builder); - } - }; - DataDSLJvmModelInferrer.this._jvmTypesBuilder.setBody(it, _function); - } - }; - JvmOperation _method_4 = this._jvmTypesBuilder.toMethod(pkg, "findButtonLayout", _typeRef_4, _function_4); - this._jvmTypesBuilder.<JvmOperation>operator_add(_members_4, _method_4); - EList<JvmMember> _members_5 = type.getMembers(); - JvmTypeReference _typeRef_5 = this._typeReferenceBuilder.typeRef(Void.TYPE); - final Procedure1<JvmOperation> _function_5 = new Procedure1<JvmOperation>() { - public void apply(final JvmOperation it) { - EList<JvmAnnotationReference> _annotations = it.getAnnotations(); - JvmAnnotationReference _annotationRef = DataDSLJvmModelInferrer.this._annotationTypesBuilder.annotationRef(Override.class); - DataDSLJvmModelInferrer.this._jvmTypesBuilder.<JvmAnnotationReference>operator_add(_annotations, _annotationRef); - EList<JvmFormalParameter> _parameters = it.getParameters(); - JvmTypeReference _typeRef = DataDSLJvmModelInferrer.this._typeReferenceBuilder.typeRef(BundleEvent.class); - JvmFormalParameter _parameter = DataDSLJvmModelInferrer.this._jvmTypesBuilder.toParameter(pkg, "event", _typeRef); - DataDSLJvmModelInferrer.this._jvmTypesBuilder.<JvmFormalParameter>operator_add(_parameters, _parameter); - final Procedure1<ITreeAppendable> _function = new Procedure1<ITreeAppendable>() { - public void apply(final ITreeAppendable it) { - StringConcatenation _builder = new StringConcatenation(); - String _bundleChanged = DataDSLJvmModelInferrer.this.bundleChanged(pkg); - _builder.append(_bundleChanged, ""); - it.append(_builder); - } - }; - DataDSLJvmModelInferrer.this._jvmTypesBuilder.setBody(it, _function); - } - }; - JvmOperation _method_5 = this._jvmTypesBuilder.toMethod(pkg, "bundleChanged", _typeRef_5, _function_5); - this._jvmTypesBuilder.<JvmOperation>operator_add(_members_5, _method_5); - EList<JvmMember> _members_6 = type.getMembers(); - JvmTypeReference _typeRef_6 = this._typeReferenceBuilder.typeRef(Void.TYPE); - final Procedure1<JvmOperation> _function_6 = new Procedure1<JvmOperation>() { - public void apply(final JvmOperation it) { - it.setVisibility(JvmVisibility.PROTECTED); - EList<JvmAnnotationReference> _annotations = it.getAnnotations(); - JvmAnnotationReference _annotationRef = DataDSLJvmModelInferrer.this._annotationTypesBuilder.annotationRef(PostConstruct.class); - DataDSLJvmModelInferrer.this._jvmTypesBuilder.<JvmAnnotationReference>operator_add(_annotations, _annotationRef); - final Procedure1<ITreeAppendable> _function = new Procedure1<ITreeAppendable>() { - public void apply(final ITreeAppendable it) { - StringConcatenation _builder = new StringConcatenation(); - String _subscribe = DataDSLJvmModelInferrer.this.subscribe(pkg); - _builder.append(_subscribe, ""); - it.append(_builder); - } - }; - DataDSLJvmModelInferrer.this._jvmTypesBuilder.setBody(it, _function); - } - }; - JvmOperation _method_6 = this._jvmTypesBuilder.toMethod(pkg, "subscribe", _typeRef_6, _function_6); - this._jvmTypesBuilder.<JvmOperation>operator_add(_members_6, _method_6); - EList<JvmMember> _members_7 = type.getMembers(); - JvmTypeReference _typeRef_7 = this._typeReferenceBuilder.typeRef(Void.TYPE); - final Procedure1<JvmOperation> _function_7 = new Procedure1<JvmOperation>() { - public void apply(final JvmOperation it) { - it.setVisibility(JvmVisibility.PROTECTED); - EList<JvmAnnotationReference> _annotations = it.getAnnotations(); - JvmAnnotationReference _annotationRef = DataDSLJvmModelInferrer.this._annotationTypesBuilder.annotationRef(PreDestroy.class); - DataDSLJvmModelInferrer.this._jvmTypesBuilder.<JvmAnnotationReference>operator_add(_annotations, _annotationRef); - final Procedure1<ITreeAppendable> _function = new Procedure1<ITreeAppendable>() { - public void apply(final ITreeAppendable it) { - StringConcatenation _builder = new StringConcatenation(); - String _unsubscribe = DataDSLJvmModelInferrer.this.unsubscribe(pkg); - _builder.append(_unsubscribe, ""); - it.append(_builder); - } - }; - DataDSLJvmModelInferrer.this._jvmTypesBuilder.setBody(it, _function); - } - }; - JvmOperation _method_7 = this._jvmTypesBuilder.toMethod(pkg, "unsubscribe", _typeRef_7, _function_7); - this._jvmTypesBuilder.<JvmOperation>operator_add(_members_7, _method_7); - EList<JvmMember> _members_8 = type.getMembers(); - JvmTypeReference _typeRef_8 = this._typeReferenceBuilder.typeRef(Void.TYPE); - final Procedure1<JvmOperation> _function_8 = new Procedure1<JvmOperation>() { - public void apply(final JvmOperation it) { - it.setVisibility(JvmVisibility.PUBLIC); - EList<JvmAnnotationReference> _annotations = it.getAnnotations(); - JvmAnnotationReference _annotationRef = DataDSLJvmModelInferrer.this._annotationTypesBuilder.annotationRef(Override.class); - DataDSLJvmModelInferrer.this._jvmTypesBuilder.<JvmAnnotationReference>operator_add(_annotations, _annotationRef); - EList<JvmFormalParameter> _parameters = it.getParameters(); - JvmTypeReference _typeRef = DataDSLJvmModelInferrer.this._typeReferenceBuilder.typeRef(Locale.class); - JvmFormalParameter _parameter = DataDSLJvmModelInferrer.this._jvmTypesBuilder.toParameter(pkg, "locale", _typeRef); - DataDSLJvmModelInferrer.this._jvmTypesBuilder.<JvmFormalParameter>operator_add(_parameters, _parameter); - final Procedure1<ITreeAppendable> _function = new Procedure1<ITreeAppendable>() { - public void apply(final ITreeAppendable it) { - StringConcatenation _builder = new StringConcatenation(); - CharSequence _localeChanged = DataDSLJvmModelInferrer.this.localeChanged(pkg); - _builder.append(_localeChanged, ""); - it.append(_builder); - } - }; - DataDSLJvmModelInferrer.this._jvmTypesBuilder.setBody(it, _function); - } - }; - JvmOperation _method_8 = this._jvmTypesBuilder.toMethod(pkg, "localeChanged", _typeRef_8, _function_8); - this._jvmTypesBuilder.<JvmOperation>operator_add(_members_8, _method_8); - } - - /** - * handle the worker progress UI. provide the appropriate code. - * - * @param pkg - * the current package inferred {@link DataInterchangePackage} - * @return code fragment - */ - public String workerInfo(final DataInterchangePackage pkg) { - String body = ""; - StringConcatenation _builder = new StringConcatenation(); - _builder.append(body, ""); - _builder.newLineIfNotEmpty(); - _builder.append("new EventHandler() {"); - _builder.newLine(); - _builder.append("\t"); - _builder.append("@Override"); - _builder.newLine(); - _builder.append("\t"); - _builder.append("public void handleEvent(Event event) {"); - _builder.newLine(); - _builder.append("\t\t"); - _builder.append("// a worker notified this view that it is finished"); - _builder.newLine(); - _builder.append("\t\t"); - _builder.append("String workername = (String)event.getProperty(EventUtils.DATA);"); - _builder.newLine(); - _builder.append("\t\t"); - _builder.append("if (progressBars.containsKey(workername)) {"); - _builder.newLine(); - _builder.append("\t\t\t"); - _builder.append("final WorkerThreadRunnable worker = progressBars.get(workername); "); - _builder.newLine(); - _builder.append("\t\t\t"); - _builder.append("((VerticalLayout)worker.getProgressBarArea().getParent()).removeComponent(worker.getProgressBarArea());"); - _builder.newLine(); - _builder.append("\t\t\t"); - _builder.append("progressBars.remove(workername);"); - _builder.newLine(); - _builder.append("\t\t"); - _builder.append("}"); - _builder.newLine(); - _builder.append("\t"); - _builder.append("}"); - _builder.newLine(); - _builder.append("};"); - _builder.newLine(); - body = _builder.toString(); - return body; - } - - /** - * subscribe the event broker for messages on changed locale and worker progress. - * - * @param pkg - * the current package inferred {@link DataInterchangePackage} - * @return code fragment - */ - public String subscribe(final DataInterchangePackage pkg) { - String body = ""; - StringConcatenation _builder = new StringConcatenation(); - _builder.append(body, ""); - _builder.newLineIfNotEmpty(); - _builder.append("eventBroker.subscribe(EventBrokerMsg.WORKER_THREAD_INFO, workerInfo);"); - _builder.newLine(); - body = _builder.toString(); - return body; - } - - /** - * unsubscribe from event broker for messages. - * - * @param pkg - * the current package inferred {@link DataInterchangePackage} - * @return code fragment - */ - public String unsubscribe(final DataInterchangePackage pkg) { - String body = ""; - StringConcatenation _builder = new StringConcatenation(); - _builder.append(body, ""); - _builder.newLineIfNotEmpty(); - _builder.append("eventBroker.unsubscribe(workerInfo);"); - _builder.newLine(); - body = _builder.toString(); - return body; - } - - /** - * normalize package name. - * - * @param pkg - * the current package inferred {@link DataInterchangePackage} - * @return normalized package name - */ - public String toEventID(final DataInterchangePackage pkg) { - QualifiedName _fullyQualifiedName = this._iQualifiedNameProvider.getFullyQualifiedName(pkg); - String _string = _fullyQualifiedName.toString(); - String _upperCase = _string.toUpperCase(); - return _upperCase.replaceAll("(\\W)", "_"); - } - - /** - * let the app wait for finishing the workers before allowing to stop bundle. - * - * @param pkg - * the current package inferred {@link DataInterchangePackage} - * @return code fragment - */ - public String bundleChanged(final DataInterchangePackage pkg) { - String body = ""; - StringConcatenation _builder = new StringConcatenation(); - _builder.append(body, ""); - _builder.newLineIfNotEmpty(); - _builder.append("if (event.getType() == BundleEvent.STOPPING) {"); - _builder.newLine(); - _builder.append("\t"); - _builder.append("log.debug(\"bundle is stopping\");"); - _builder.newLine(); - _builder.append("\t"); - _builder.append("// This will make the executorService accept no new threads"); - _builder.newLine(); - _builder.append("\t"); - _builder.append("// and finish all existing threads in the queue"); - _builder.newLine(); - _builder.append("\t"); - _builder.append("if (executorService != null) {"); - _builder.newLine(); - _builder.append("\t "); - _builder.append("executorService.shutdown();"); - _builder.newLine(); - _builder.append("\t "); - _builder.append("// Wait until all threads are finished"); - _builder.newLine(); - _builder.append("\t "); - _builder.append("try {"); - _builder.newLine(); - _builder.append("\t\t\t"); - _builder.append("executorService.awaitTermination(10, TimeUnit.SECONDS);"); - _builder.newLine(); - _builder.append("\t\t"); - _builder.append("} catch (InterruptedException e) {"); - _builder.newLine(); - _builder.append("\t\t\t"); - _builder.append("e.printStackTrace();"); - _builder.newLine(); - _builder.append("\t\t"); - _builder.append("}"); - _builder.newLine(); - _builder.append("\t"); - _builder.append("}"); - _builder.newLine(); - _builder.append("\t"); - _builder.append("log.debug(\"all executors finished\");"); - _builder.newLine(); - _builder.append("}"); - _builder.newLine(); - body = _builder.toString(); - return body; - } - - /** - * find the right button layout for a given button. - * - * @param pkg - * the current package inferred {@link DataInterchangePackage} - * @return code fragment - */ - public String findButtonLayout(final DataInterchangePackage pkg) { - String body = ""; - StringConcatenation _builder = new StringConcatenation(); - _builder.append(body, ""); - _builder.newLineIfNotEmpty(); - _builder.append("int count = menu.getComponentCount(); "); - _builder.newLine(); - _builder.append("for(int i=0; i<count; i++) {"); - _builder.newLine(); - _builder.append("\t"); - _builder.append("VerticalLayout buttonLayout = (VerticalLayout)menu.getComponent(i);"); - _builder.newLine(); - _builder.append("\t"); - _builder.append("Button b = (Button)buttonLayout.getComponent(0);"); - _builder.newLine(); - _builder.append("\t"); - _builder.append("if (b == button) {"); - _builder.newLine(); - _builder.append("\t\t"); - _builder.append("return buttonLayout;"); - _builder.newLine(); - _builder.append("\t"); - _builder.append("}"); - _builder.newLine(); - _builder.append("}"); - _builder.newLine(); - _builder.append("return null;"); - _builder.newLine(); - body = _builder.toString(); - return body; - } - - /** - * find out if a given thread-id is already running. - * - * @param pkg - * the current package inferred {@link DataInterchangePackage} - * @return code fragment - */ - public String isDuplicate(final DataInterchangePackage pkg) { - String body = ""; - StringConcatenation _builder = new StringConcatenation(); - _builder.append(body, ""); - _builder.newLineIfNotEmpty(); - _builder.append("boolean found = false;"); - _builder.newLine(); - _builder.append("for(String threadName : progressBars.keySet()) {"); - _builder.newLine(); - _builder.append("\t"); - _builder.append("if (name.equals(threadName)) {"); - _builder.newLine(); - _builder.append("\t\t"); - _builder.append("found = true;"); - _builder.newLine(); - _builder.append("\t\t"); - _builder.append("break;"); - _builder.newLine(); - _builder.append("\t"); - _builder.append("}"); - _builder.newLine(); - _builder.append("}"); - _builder.newLine(); - _builder.append("return found;"); - _builder.newLine(); - body = _builder.toString(); - return body; - } - - /** - * make a name unique by concatenating a number. - * - * @param pkg - * the current package inferred {@link DataInterchangePackage} - * @return code fragment - */ - public String uniqueName(final DataInterchangePackage pkg) { - String body = ""; - StringConcatenation _builder = new StringConcatenation(); - _builder.append(body, ""); - _builder.newLineIfNotEmpty(); - _builder.append("Integer cnt = 0;"); - _builder.newLine(); - _builder.append("String searchName;"); - _builder.newLine(); - _builder.append("do {"); - _builder.newLine(); - _builder.append("\t"); - _builder.append("if (cnt > 0) {"); - _builder.newLine(); - _builder.append("\t\t"); - _builder.append("searchName = name+cnt.toString();"); - _builder.newLine(); - _builder.append("\t"); - _builder.append("} else {"); - _builder.newLine(); - _builder.append("\t\t"); - _builder.append("searchName = name;"); - _builder.newLine(); - _builder.append("\t"); - _builder.append("}"); - _builder.newLine(); - _builder.append("\t"); - _builder.append("cnt ++;"); - _builder.newLine(); - _builder.append("}while(isDuplicate(searchName));"); - _builder.newLine(); - _builder.append("return searchName;"); - _builder.newLine(); - body = _builder.toString(); - return body; - } - - public String descriptionI18nKey(final DataInterchange dataInterchange) { - String _xifexpression = null; - boolean _or = false; - String _descriptionValue = dataInterchange.getDescriptionValue(); - boolean _equals = Objects.equal(_descriptionValue, null); - if (_equals) { - _or = true; - } else { - String _descriptionValue_1 = dataInterchange.getDescriptionValue(); - boolean _isEmpty = _descriptionValue_1.isEmpty(); - _or = _isEmpty; - } - if (_or) { - _xifexpression = dataInterchange.getName(); - } else { - _xifexpression = dataInterchange.getDescriptionValue(); - } - return _xifexpression; - } - - /** - * build an e4 compatible view and create necessary components. - * - * @param pkg - * the current package inferred {@link DataInterchangePackage} - * @return code fragment - */ - public String createView(final DataInterchangePackage pkg) { - StringConcatenation _builder = new StringConcatenation(); - _builder.append("buttons = new HashMap<Button, ArrayList>();"); - _builder.newLine(); - _builder.append("workerInfo = "); - String _workerInfo = this.workerInfo(pkg); - _builder.append(_workerInfo, ""); - _builder.newLineIfNotEmpty(); - _builder.append("Bundle bundle = FrameworkUtil.getBundle(getClass());"); - _builder.newLine(); - _builder.append("if (bundle != null) {"); - _builder.newLine(); - _builder.append("\t"); - _builder.append("BundleContext ctx = bundle.getBundleContext();"); - _builder.newLine(); - _builder.append("\t"); - _builder.append("if (ctx != null) {"); - _builder.newLine(); - _builder.append("\t\t"); - _builder.append("ctx.addBundleListener(this);"); - _builder.newLine(); - _builder.append("\t"); - _builder.append("}"); - _builder.newLine(); - _builder.append("}"); - _builder.newLine(); - _builder.append("FrameworkUtil.getBundle(getClass()).getBundleContext().addBundleListener(this);"); - _builder.newLine(); - _builder.append("executorService = Executors.newFixedThreadPool("); - _builder.append(this.NTHREADS, ""); - _builder.append(");"); - _builder.newLineIfNotEmpty(); - _builder.append("progressBars = new HashMap<String,WorkerThreadRunnable>(); "); - _builder.newLine(); - _builder.append("sidebar=new VerticalLayout();"); - _builder.newLine(); - _builder.append("menu=new CssLayout();"); - _builder.newLine(); - _builder.append("branding=new CssLayout();"); - _builder.newLine(); - _builder.append("parent.setPrimaryStyleName(\"osbp\");"); - _builder.newLine(); - _builder.append("parent.setId(\"parent\");"); - _builder.newLine(); - _builder.append("parent.setSizeFull();"); - _builder.newLine(); - _builder.append("sidebar.setSpacing(true);"); - _builder.newLine(); - _builder.append("sidebar.setId(\"sidebar\");"); - _builder.newLine(); - _builder.append("parent.addComponent(sidebar);"); - _builder.newLine(); - _builder.append("parent.setExpandRatio(sidebar, 1.0f);"); - _builder.newLine(); - _builder.append("// create sidebar"); - _builder.newLine(); - _builder.append("sidebar.addStyleName(\"osbpsidebar\");"); - _builder.newLine(); - _builder.append("sidebar.setSizeFull();"); - _builder.newLine(); - _builder.append("sidebar.addComponent(branding);"); - _builder.newLine(); - _builder.append("// branding title"); - _builder.newLine(); - _builder.append("branding.addStyleName(\"branding\");"); - _builder.newLine(); - _builder.append("logo = new Label();"); - _builder.newLine(); - _builder.append("logo.setContentMode(ContentMode.HTML);"); - _builder.newLine(); - _builder.append("logo.setSizeUndefined();"); - _builder.newLine(); - _builder.append("branding.addComponent(logo);"); - _builder.newLine(); - _builder.append("// add menu"); - _builder.newLine(); - _builder.append("sidebar.addComponent(menu);"); - _builder.newLine(); - _builder.append("sidebar.setExpandRatio(menu, 1.0f);"); - _builder.newLine(); - _builder.newLine(); - String body = _builder.toString(); - StringConcatenation _builder_1 = new StringConcatenation(); - _builder_1.append(body, ""); - _builder_1.newLineIfNotEmpty(); - _builder_1.append("\t\t"); - _builder_1.append("// add menu items"); - _builder_1.newLine(); - _builder_1.append("\t\t"); - _builder_1.append("Button b;"); - _builder_1.newLine(); - _builder_1.append("\t\t"); - _builder_1.append("VerticalLayout buttonLayout;"); - _builder_1.newLine(); - body = _builder_1.toString(); - EList<DataInterchange> _datInts = pkg.getDatInts(); - for (final DataInterchange dataInterchange : _datInts) { - { - StringConcatenation _builder_2 = new StringConcatenation(); - _builder_2.append(body, ""); - _builder_2.newLineIfNotEmpty(); - _builder_2.append("b = new NativeButton();"); - _builder_2.newLine(); - _builder_2.append("b.setHtmlContentAllowed(true);"); - _builder_2.newLine(); - _builder_2.append("buttons.put(b, new ArrayList<String>(Arrays.asList(new String[] {\""); - _builder_2.append(DataDSLModelGenerator.CAPTION__REPFIX_I18NKEY_IMPORT, ""); - _builder_2.append("\", \""); - String _name = dataInterchange.getName(); - _builder_2.append(_name, ""); - _builder_2.append("\",\""); - String _descriptionI18nKey = this.descriptionI18nKey(dataInterchange); - _builder_2.append(_descriptionI18nKey, ""); - _builder_2.append("\"})));"); - _builder_2.newLineIfNotEmpty(); - _builder_2.append("b.addStyleName(\"icon-download\");"); - _builder_2.newLine(); - _builder_2.append("b.addClickListener(new ClickListener() {"); - _builder_2.newLine(); - _builder_2.append("\t"); - _builder_2.append("@Override"); - _builder_2.newLine(); - _builder_2.append("\t"); - _builder_2.append("public void buttonClick(ClickEvent event) {"); - _builder_2.newLine(); - _builder_2.append("\t\t"); - _builder_2.append("log.debug(\"pressed "); - String _name_1 = dataInterchange.getName(); - _builder_2.append(_name_1, "\t\t"); - _builder_2.append(" import\");"); - _builder_2.newLineIfNotEmpty(); - _builder_2.append("\t\t"); - _builder_2.append("String uniqueName = uniqueName(\""); - String _name_2 = dataInterchange.getName(); - _builder_2.append(_name_2, "\t\t"); - _builder_2.append("\");"); - _builder_2.newLineIfNotEmpty(); - _builder_2.append("\t\t"); - String _fileURL = this.getFileURL(dataInterchange); - String _basicRunConfiguration = this.getBasicRunConfiguration(dataInterchange, false, _fileURL); - _builder_2.append(_basicRunConfiguration, "\t\t"); - _builder_2.newLineIfNotEmpty(); - _builder_2.append("\t\t"); - String _defaultVariableName = this.getDefaultVariableName(dataInterchange); - _builder_2.append(_defaultVariableName, "\t\t"); - _builder_2.append(".setName(uniqueName);"); - _builder_2.newLineIfNotEmpty(); - _builder_2.append("\t\t"); - String _defaultVariableName_1 = this.getDefaultVariableName(dataInterchange); - _builder_2.append(_defaultVariableName_1, "\t\t"); - _builder_2.append(".setEventBroker(eventBroker);"); - _builder_2.newLineIfNotEmpty(); - _builder_2.append("\t\t"); - String _defaultVariableName_2 = this.getDefaultVariableName(dataInterchange); - _builder_2.append(_defaultVariableName_2, "\t\t"); - _builder_2.append(".setUi(UI.getCurrent());"); - _builder_2.newLineIfNotEmpty(); - _builder_2.append("\t\t"); - String _defaultVariableName_3 = this.getDefaultVariableName(dataInterchange); - _builder_2.append(_defaultVariableName_3, "\t\t"); - _builder_2.append(".setDirection(WorkerThreadRunnable.Direction.IMPORT);"); - _builder_2.newLineIfNotEmpty(); - _builder_2.append("\t\t"); - { - ProgressBarStylesEnum _progressBarStyle = dataInterchange.getProgressBarStyle(); - boolean _notEquals = (!Objects.equal(_progressBarStyle, null)); - if (_notEquals) { - String _defaultVariableName_4 = this.getDefaultVariableName(dataInterchange); - _builder_2.append(_defaultVariableName_4, "\t\t"); - _builder_2.append(".setProgressBarStyleName(\""); - ProgressBarStylesEnum _progressBarStyle_1 = dataInterchange.getProgressBarStyle(); - String _literal = _progressBarStyle_1.getLiteral(); - _builder_2.append(_literal, "\t\t"); - _builder_2.append("\");"); - } - } - _builder_2.newLineIfNotEmpty(); - _builder_2.append("\t\t"); - _builder_2.append("findButtonLayout(event.getButton()).addComponent("); - String _defaultVariableName_5 = this.getDefaultVariableName(dataInterchange); - _builder_2.append(_defaultVariableName_5, "\t\t"); - _builder_2.append(".getProgressBarArea());"); - _builder_2.newLineIfNotEmpty(); - _builder_2.append("\t\t"); - _builder_2.append("progressBars.put(uniqueName, "); - String _defaultVariableName_6 = this.getDefaultVariableName(dataInterchange); - _builder_2.append(_defaultVariableName_6, "\t\t"); - _builder_2.append(");"); - _builder_2.newLineIfNotEmpty(); - _builder_2.append("\t\t"); - _builder_2.append("executorService.execute("); - String _defaultVariableName_7 = this.getDefaultVariableName(dataInterchange); - _builder_2.append(_defaultVariableName_7, "\t\t"); - _builder_2.append(");"); - _builder_2.newLineIfNotEmpty(); - _builder_2.append("\t\t"); - _builder_2.append("log.debug(\""); - String _name_3 = dataInterchange.getName(); - _builder_2.append(_name_3, "\t\t"); - _builder_2.append(" import added to executor queue\");"); - _builder_2.newLineIfNotEmpty(); - _builder_2.append("\t"); - _builder_2.append("}"); - _builder_2.newLine(); - _builder_2.append("});"); - _builder_2.newLine(); - _builder_2.append("buttonLayout = new VerticalLayout();"); - _builder_2.newLine(); - _builder_2.append("buttonLayout.addComponent(b); "); - _builder_2.newLine(); - _builder_2.append("menu.addComponent(buttonLayout);"); - _builder_2.newLine(); - body = _builder_2.toString(); - StringConcatenation _builder_3 = new StringConcatenation(); - _builder_3.append(body, ""); - _builder_3.newLineIfNotEmpty(); - _builder_3.append("b = new NativeButton();"); - _builder_3.newLine(); - _builder_3.append("b.setHtmlContentAllowed(true);"); - _builder_3.newLine(); - _builder_3.append("buttons.put(b, new ArrayList<String>(Arrays.asList(new String[] {\""); - _builder_3.append(DataDSLModelGenerator.CAPTION__REPFIX_I18NKEY_EXPORT, ""); - _builder_3.append("\", \""); - String _name_4 = dataInterchange.getName(); - _builder_3.append(_name_4, ""); - _builder_3.append("\",\""); - String _descriptionI18nKey_1 = this.descriptionI18nKey(dataInterchange); - _builder_3.append(_descriptionI18nKey_1, ""); - _builder_3.append("\"})));"); - _builder_3.newLineIfNotEmpty(); - _builder_3.append("b.addStyleName(\"icon-upload\");"); - _builder_3.newLine(); - _builder_3.append("b.addClickListener(new ClickListener() {"); - _builder_3.newLine(); - _builder_3.append("\t"); - _builder_3.append("@Override"); - _builder_3.newLine(); - _builder_3.append("\t"); - _builder_3.append("public void buttonClick(ClickEvent event) {"); - _builder_3.newLine(); - _builder_3.append("\t\t"); - _builder_3.append("log.debug(\"pressed "); - String _name_5 = dataInterchange.getName(); - _builder_3.append(_name_5, "\t\t"); - _builder_3.append(" export\");"); - _builder_3.newLineIfNotEmpty(); - _builder_3.append("\t\t"); - _builder_3.append("String uniqueName = uniqueName(\""); - String _name_6 = dataInterchange.getName(); - _builder_3.append(_name_6, "\t\t"); - _builder_3.append("\");"); - _builder_3.newLineIfNotEmpty(); - _builder_3.append("\t\t"); - String _fileURL_1 = this.getFileURL(dataInterchange); - String _basicRunConfiguration_1 = this.getBasicRunConfiguration(dataInterchange, false, _fileURL_1); - _builder_3.append(_basicRunConfiguration_1, "\t\t"); - _builder_3.newLineIfNotEmpty(); - _builder_3.append("\t\t"); - String _defaultVariableName_8 = this.getDefaultVariableName(dataInterchange); - _builder_3.append(_defaultVariableName_8, "\t\t"); - _builder_3.append(".setName(uniqueName);"); - _builder_3.newLineIfNotEmpty(); - _builder_3.append("\t\t"); - String _defaultVariableName_9 = this.getDefaultVariableName(dataInterchange); - _builder_3.append(_defaultVariableName_9, "\t\t"); - _builder_3.append(".setEventBroker(eventBroker);"); - _builder_3.newLineIfNotEmpty(); - _builder_3.append("\t\t"); - String _defaultVariableName_10 = this.getDefaultVariableName(dataInterchange); - _builder_3.append(_defaultVariableName_10, "\t\t"); - _builder_3.append(".setUi(UI.getCurrent());"); - _builder_3.newLineIfNotEmpty(); - _builder_3.append("\t\t"); - String _defaultVariableName_11 = this.getDefaultVariableName(dataInterchange); - _builder_3.append(_defaultVariableName_11, "\t\t"); - _builder_3.append(".setDirection(WorkerThreadRunnable.Direction.EXPORT);"); - _builder_3.newLineIfNotEmpty(); - _builder_3.append("\t\t"); - { - ProgressBarStylesEnum _progressBarStyle_2 = dataInterchange.getProgressBarStyle(); - boolean _notEquals_1 = (!Objects.equal(_progressBarStyle_2, null)); - if (_notEquals_1) { - String _defaultVariableName_12 = this.getDefaultVariableName(dataInterchange); - _builder_3.append(_defaultVariableName_12, "\t\t"); - _builder_3.append(".setProgressBarStyleName(\""); - ProgressBarStylesEnum _progressBarStyle_3 = dataInterchange.getProgressBarStyle(); - String _literal_1 = _progressBarStyle_3.getLiteral(); - _builder_3.append(_literal_1, "\t\t"); - _builder_3.append("\");"); - } - } - _builder_3.newLineIfNotEmpty(); - _builder_3.append("\t\t"); - _builder_3.append("findButtonLayout(event.getButton()).addComponent("); - String _defaultVariableName_13 = this.getDefaultVariableName(dataInterchange); - _builder_3.append(_defaultVariableName_13, "\t\t"); - _builder_3.append(".getProgressBarArea());"); - _builder_3.newLineIfNotEmpty(); - _builder_3.append("\t\t"); - _builder_3.append("progressBars.put(uniqueName, "); - String _defaultVariableName_14 = this.getDefaultVariableName(dataInterchange); - _builder_3.append(_defaultVariableName_14, "\t\t"); - _builder_3.append(");"); - _builder_3.newLineIfNotEmpty(); - _builder_3.append("\t\t"); - _builder_3.append("executorService.execute("); - String _defaultVariableName_15 = this.getDefaultVariableName(dataInterchange); - _builder_3.append(_defaultVariableName_15, "\t\t"); - _builder_3.append(");"); - _builder_3.newLineIfNotEmpty(); - _builder_3.append("\t\t"); - _builder_3.append("log.debug(\""); - String _name_7 = dataInterchange.getName(); - _builder_3.append(_name_7, "\t\t"); - _builder_3.append(" export added to executor queue\");"); - _builder_3.newLineIfNotEmpty(); - _builder_3.append("\t"); - _builder_3.append("}"); - _builder_3.newLine(); - _builder_3.append("});"); - _builder_3.newLine(); - _builder_3.append("buttonLayout = new VerticalLayout();"); - _builder_3.newLine(); - _builder_3.append("buttonLayout.addComponent(b); "); - _builder_3.newLine(); - _builder_3.append("menu.addComponent(buttonLayout);"); - _builder_3.newLine(); - body = _builder_3.toString(); - } - } - StringConcatenation _builder_2 = new StringConcatenation(); - _builder_2.append(body, ""); - _builder_2.newLineIfNotEmpty(); - _builder_2.append("menu.addStyleName(\"menu\");"); - _builder_2.newLine(); - _builder_2.append("menu.setHeight(\"100%\");"); - _builder_2.newLine(); - _builder_2.append("user.addUserLocaleListener(this);"); - _builder_2.newLine(); - body = _builder_2.toString(); - return body; - } - - public String getDefaultVariableName(final DataInterchange dataInterchange) { - String _name = dataInterchange.getName(); - return StringExtensions.toFirstLower(_name); - } - - public String getBasicRunConfiguration(final DataInterchange dataInterchange, final boolean fqClass, final String fileURL) { - String className = ""; - if (fqClass) { - QualifiedName _fullyQualifiedName = this._iQualifiedNameProvider.getFullyQualifiedName(dataInterchange); - String _string = _fullyQualifiedName.toString(); - className = _string; - } else { - String _name = dataInterchange.getName(); - className = _name; - } - StringConcatenation _builder = new StringConcatenation(); - _builder.append(className, ""); - _builder.append(" "); - String _defaultVariableName = this.getDefaultVariableName(dataInterchange); - _builder.append(_defaultVariableName, ""); - _builder.append(" = new "); - _builder.append(className, ""); - _builder.append("();"); - _builder.newLineIfNotEmpty(); - String _defaultVariableName_1 = this.getDefaultVariableName(dataInterchange); - _builder.append(_defaultVariableName_1, ""); - _builder.append(".setFileURL(\""); - _builder.append(fileURL, ""); - _builder.append("\");"); - _builder.newLineIfNotEmpty(); - String _defaultVariableName_2 = this.getDefaultVariableName(dataInterchange); - _builder.append(_defaultVariableName_2, ""); - _builder.append(".setPersistenceService(persistenceService);"); - _builder.newLineIfNotEmpty(); - return _builder.toString(); - } - - public String getFileURL(final DataInterchange dataInterchange) { - DataInterchangeFile _fileEndpoint = dataInterchange.getFileEndpoint(); - boolean _matched = false; - if (!_matched) { - if (_fileEndpoint instanceof DataInterchangeFileXML) { - _matched=true; - DataInterchangeFile _fileEndpoint_1 = dataInterchange.getFileEndpoint(); - return ((DataInterchangeFileXML) _fileEndpoint_1).getFileURL(); - } - } - if (!_matched) { - if (_fileEndpoint instanceof DataInterchangeFileCSV) { - _matched=true; - DataInterchangeFile _fileEndpoint_1 = dataInterchange.getFileEndpoint(); - return ((DataInterchangeFileCSV) _fileEndpoint_1).getFileURL(); - } - } - if (!_matched) { - if (_fileEndpoint instanceof DataInterchangeFileEDI) { - _matched=true; - DataInterchangeFile _fileEndpoint_1 = dataInterchange.getFileEndpoint(); - return ((DataInterchangeFileEDI) _fileEndpoint_1).getFileURL(); - } - } - return ""; - } - - /** - * create more components. this fragment is repainted if something changes (e.g. language) - * - * @param pkg - * the current package inferred {@link DataInterchangePackage} - * @return code fragment - */ - public String createComponents(final DataInterchangePackage pkg) { - return ""; - } - - /** - * <p>build the constructor for each smooks class.</p> - * - * @param pkg - * the current datainterchange inferred {@link DataInterchange} - */ - public void toConstructor(final JvmDeclaredType type, final DataInterchange dataInterchange) { - EList<JvmMember> _members = type.getMembers(); - final Procedure1<JvmConstructor> _function = new Procedure1<JvmConstructor>() { - public void apply(final JvmConstructor it) { - final Procedure1<ITreeAppendable> _function = new Procedure1<ITreeAppendable>() { - public void apply(final ITreeAppendable it) { - StringConcatenation _builder = new StringConcatenation(); - _builder.append("setName(\""); - String _name = dataInterchange.getName(); - _builder.append(_name, ""); - _builder.append("\");"); - _builder.newLineIfNotEmpty(); - it.append(_builder); - } - }; - DataDSLJvmModelInferrer.this._jvmTypesBuilder.setBody(it, _function); - } - }; - JvmConstructor _constructor = this._jvmTypesBuilder.toConstructor(dataInterchange, _function); - this._jvmTypesBuilder.<JvmConstructor>operator_add(_members, _constructor); - } - - /** - * <p>build the class variables.</p> - */ - public void toFields(final JvmDeclaredType type, final DataInterchange dataInterchange) { - JvmField field = null; - JvmTypeReference _typeRef = this._typeReferenceBuilder.typeRef(Logger.class); - final Procedure1<JvmField> _function = new Procedure1<JvmField>() { - public void apply(final JvmField it) { - final Procedure1<ITreeAppendable> _function = new Procedure1<ITreeAppendable>() { - public void apply(final ITreeAppendable it) { - StringConcatenation _builder = new StringConcatenation(); - _builder.append("LoggerFactory.getLogger(\"dataInterchange\")"); - it.append(_builder); - } - }; - DataDSLJvmModelInferrer.this._jvmTypesBuilder.setInitializer(it, _function); - } - }; - JvmField _field = this._jvmTypesBuilder.toField(dataInterchange, "log", _typeRef, _function); - field = _field; - field.setFinal(true); - field.setStatic(true); - EList<JvmMember> _members = type.getMembers(); - this._jvmTypesBuilder.<JvmField>operator_add(_members, field); - JvmTypeReference _typeRef_1 = this._typeReferenceBuilder.typeRef(SmooksFactory.class); - final Procedure1<JvmField> _function_1 = new Procedure1<JvmField>() { - public void apply(final JvmField it) { - final Procedure1<ITreeAppendable> _function = new Procedure1<ITreeAppendable>() { - public void apply(final ITreeAppendable it) { - StringConcatenation _builder = new StringConcatenation(); - _builder.append("null"); - it.append(_builder); - } - }; - DataDSLJvmModelInferrer.this._jvmTypesBuilder.setInitializer(it, _function); - } - }; - JvmField _field_1 = this._jvmTypesBuilder.toField(dataInterchange, "smooksOSGIFactory", _typeRef_1, _function_1); - field = _field_1; - EList<JvmMember> _members_1 = type.getMembers(); - this._jvmTypesBuilder.<JvmField>operator_add(_members_1, field); - JvmTypeReference _typeRef_2 = this._typeReferenceBuilder.typeRef(Smooks.class); - JvmField _field_2 = this._jvmTypesBuilder.toField(dataInterchange, "smooks", _typeRef_2); - field = _field_2; - EList<JvmMember> _members_2 = type.getMembers(); - this._jvmTypesBuilder.<JvmField>operator_add(_members_2, field); - JvmTypeReference _typeRef_3 = this._typeReferenceBuilder.typeRef(EntityManager.class); - JvmField _field_3 = this._jvmTypesBuilder.toField(dataInterchange, "em", _typeRef_3); - field = _field_3; - EList<JvmMember> _members_3 = type.getMembers(); - this._jvmTypesBuilder.<JvmField>operator_add(_members_3, field); - JvmTypeReference _typeRef_4 = this._typeReferenceBuilder.typeRef(URL.class); - JvmField _field_4 = this._jvmTypesBuilder.toField(dataInterchange, "fileURL", _typeRef_4); - field = _field_4; - EList<JvmMember> _members_4 = type.getMembers(); - this._jvmTypesBuilder.<JvmField>operator_add(_members_4, field); - JvmTypeReference _typeRef_5 = this._typeReferenceBuilder.typeRef(ExecutionContext.class); - JvmField _field_5 = this._jvmTypesBuilder.toField(dataInterchange, "executionContext", _typeRef_5); - field = _field_5; - EList<JvmMember> _members_5 = type.getMembers(); - this._jvmTypesBuilder.<JvmField>operator_add(_members_5, field); - JvmTypeReference _typeRef_6 = this._typeReferenceBuilder.typeRef(OutputStream.class); - JvmField _field_6 = this._jvmTypesBuilder.toField(dataInterchange, "file", _typeRef_6); - field = _field_6; - EList<JvmMember> _members_6 = type.getMembers(); - this._jvmTypesBuilder.<JvmField>operator_add(_members_6, field); - JvmTypeReference _typeRef_7 = this._typeReferenceBuilder.typeRef(OutputStream.class); - JvmField _field_7 = this._jvmTypesBuilder.toField(dataInterchange, "out", _typeRef_7); - field = _field_7; - EList<JvmMember> _members_7 = type.getMembers(); - this._jvmTypesBuilder.<JvmField>operator_add(_members_7, field); - JvmTypeReference _typeRef_8 = this._typeReferenceBuilder.typeRef(int.class); - final Procedure1<JvmField> _function_2 = new Procedure1<JvmField>() { - public void apply(final JvmField it) { - final Procedure1<ITreeAppendable> _function = new Procedure1<ITreeAppendable>() { - public void apply(final ITreeAppendable it) { - StringConcatenation _builder = new StringConcatenation(); - _builder.append("500"); - it.append(_builder); - } - }; - DataDSLJvmModelInferrer.this._jvmTypesBuilder.setInitializer(it, _function); - } - }; - JvmField _field_8 = this._jvmTypesBuilder.toField(dataInterchange, "pollingInterval", _typeRef_8, _function_2); - field = _field_8; - EList<JvmMember> _members_8 = type.getMembers(); - this._jvmTypesBuilder.<JvmField>operator_add(_members_8, field); - JvmTypeReference _typeRef_9 = this._typeReferenceBuilder.typeRef(TransformerFactory.class); - final Procedure1<JvmField> _function_3 = new Procedure1<JvmField>() { - public void apply(final JvmField it) { - final Procedure1<ITreeAppendable> _function = new Procedure1<ITreeAppendable>() { - public void apply(final ITreeAppendable it) { - StringConcatenation _builder = new StringConcatenation(); - _builder.append("TransformerFactory.newInstance()"); - it.append(_builder); - } - }; - DataDSLJvmModelInferrer.this._jvmTypesBuilder.setInitializer(it, _function); - } - }; - JvmField _field_9 = this._jvmTypesBuilder.toField(dataInterchange, "transformerFactory", _typeRef_9, _function_3); - field = _field_9; - EList<JvmMember> _members_9 = type.getMembers(); - this._jvmTypesBuilder.<JvmField>operator_add(_members_9, field); - JvmTypeReference _typeRef_10 = this._typeReferenceBuilder.typeRef(Transformer.class); - JvmField _field_10 = this._jvmTypesBuilder.toField(dataInterchange, "transformer", _typeRef_10); - field = _field_10; - EList<JvmMember> _members_10 = type.getMembers(); - this._jvmTypesBuilder.<JvmField>operator_add(_members_10, field); - } - - /** - * <p>build the methods.</p> - */ - public void toOperations(final JvmDeclaredType type, final DataInterchange dataInterchange) { - EList<JvmMember> _members = type.getMembers(); - JvmTypeReference _typeRef = this._typeReferenceBuilder.typeRef(Void.TYPE); - final Procedure1<JvmOperation> _function = new Procedure1<JvmOperation>() { - public void apply(final JvmOperation it) { - EList<JvmAnnotationReference> _annotations = it.getAnnotations(); - JvmAnnotationReference _annotationRef = DataDSLJvmModelInferrer.this._annotationTypesBuilder.annotationRef(Override.class); - DataDSLJvmModelInferrer.this._jvmTypesBuilder.<JvmAnnotationReference>operator_add(_annotations, _annotationRef); - final Procedure1<ITreeAppendable> _function = new Procedure1<ITreeAppendable>() { - public void apply(final ITreeAppendable it) { - StringConcatenation _builder = new StringConcatenation(); - _builder.append("run(null);"); - it.append(_builder); - } - }; - DataDSLJvmModelInferrer.this._jvmTypesBuilder.setBody(it, _function); - } - }; - JvmOperation _method = this._jvmTypesBuilder.toMethod(dataInterchange, "run", _typeRef, _function); - this._jvmTypesBuilder.<JvmOperation>operator_add(_members, _method); - EList<JvmMember> _members_1 = type.getMembers(); - JvmTypeReference _typeRef_1 = this._typeReferenceBuilder.typeRef(Void.TYPE); - final Procedure1<JvmOperation> _function_1 = new Procedure1<JvmOperation>() { - public void apply(final JvmOperation it) { - EList<JvmFormalParameter> _parameters = it.getParameters(); - JvmTypeReference _typeRef = DataDSLJvmModelInferrer.this._typeReferenceBuilder.typeRef(IEntityImportInitializationListener.class); - JvmFormalParameter _parameter = DataDSLJvmModelInferrer.this._jvmTypesBuilder.toParameter(dataInterchange, "importListener", _typeRef); - DataDSLJvmModelInferrer.this._jvmTypesBuilder.<JvmFormalParameter>operator_add(_parameters, _parameter); - final Procedure1<ITreeAppendable> _function = new Procedure1<ITreeAppendable>() { - public void apply(final ITreeAppendable it) { - StringConcatenation _builder = new StringConcatenation(); - String _performSmooks = DataDSLJvmModelInferrer.this.performSmooks(dataInterchange); - _builder.append(_performSmooks, ""); - it.append(_builder); - } - }; - DataDSLJvmModelInferrer.this._jvmTypesBuilder.setBody(it, _function); - } - }; - JvmOperation _method_1 = this._jvmTypesBuilder.toMethod(dataInterchange, "run", _typeRef_1, _function_1); - this._jvmTypesBuilder.<JvmOperation>operator_add(_members_1, _method_1); - EList<JvmMember> _members_2 = type.getMembers(); - JvmTypeReference _typeRef_2 = this._typeReferenceBuilder.typeRef(boolean.class); - final Procedure1<JvmOperation> _function_2 = new Procedure1<JvmOperation>() { - public void apply(final JvmOperation it) { - it.setVisibility(JvmVisibility.PROTECTED); - EList<JvmFormalParameter> _parameters = it.getParameters(); - JvmTypeReference _typeRef = DataDSLJvmModelInferrer.this._typeReferenceBuilder.typeRef(WorkerThreadRunnable.Direction.class); - JvmFormalParameter _parameter = DataDSLJvmModelInferrer.this._jvmTypesBuilder.toParameter(dataInterchange, "direction", _typeRef); - DataDSLJvmModelInferrer.this._jvmTypesBuilder.<JvmFormalParameter>operator_add(_parameters, _parameter); - final Procedure1<ITreeAppendable> _function = new Procedure1<ITreeAppendable>() { - public void apply(final ITreeAppendable it) { - StringConcatenation _builder = new StringConcatenation(); - String _init = DataDSLJvmModelInferrer.this.init(dataInterchange); - _builder.append(_init, ""); - it.append(_builder); - } - }; - DataDSLJvmModelInferrer.this._jvmTypesBuilder.setBody(it, _function); - } - }; - JvmOperation _method_2 = this._jvmTypesBuilder.toMethod(dataInterchange, "init", _typeRef_2, _function_2); - this._jvmTypesBuilder.<JvmOperation>operator_add(_members_2, _method_2); - EList<JvmMember> _members_3 = type.getMembers(); - JvmTypeReference _typeRef_3 = this._typeReferenceBuilder.typeRef(Void.TYPE); - final Procedure1<JvmOperation> _function_3 = new Procedure1<JvmOperation>() { - public void apply(final JvmOperation it) { - EList<JvmFormalParameter> _parameters = it.getParameters(); - JvmTypeReference _typeRef = DataDSLJvmModelInferrer.this._typeReferenceBuilder.typeRef(String.class); - JvmFormalParameter _parameter = DataDSLJvmModelInferrer.this._jvmTypesBuilder.toParameter(dataInterchange, "filePath", _typeRef); - DataDSLJvmModelInferrer.this._jvmTypesBuilder.<JvmFormalParameter>operator_add(_parameters, _parameter); - final Procedure1<ITreeAppendable> _function = new Procedure1<ITreeAppendable>() { - public void apply(final ITreeAppendable it) { - StringConcatenation _builder = new StringConcatenation(); - CharSequence _fileUrl = DataDSLJvmModelInferrer.this.fileUrl(dataInterchange); - _builder.append(_fileUrl, ""); - it.append(_builder); - } - }; - DataDSLJvmModelInferrer.this._jvmTypesBuilder.setBody(it, _function); - } - }; - JvmOperation _method_3 = this._jvmTypesBuilder.toMethod(dataInterchange, "setFileURL", _typeRef_3, _function_3); - this._jvmTypesBuilder.<JvmOperation>operator_add(_members_3, _method_3); - } - - /** - * <p>create URL from filepath or other string.</p> - * - * @param pkg - * the current datainterchange inferred {@link DataInterchange} - * @return code fragment - */ - public CharSequence fileUrl(final DataInterchange dataInterchange) { - StringConcatenation _builder = new StringConcatenation(); - _builder.append("fileURL = null;"); - _builder.newLine(); - _builder.append("String path = filePath;"); - _builder.newLine(); - _builder.append("if\t(filePath.startsWith(\"file://\") && !org.eclipse.osbp.utils.common.SystemInformation.isMacOS()) {"); - _builder.newLine(); - _builder.append("\t"); - _builder.append("path = filePath.substring(\"file://\".length());"); - _builder.newLine(); - _builder.append("}"); - _builder.newLine(); - _builder.append("try {"); - _builder.newLine(); - _builder.append("\t"); - _builder.append("fileURL = new URL(path);"); - _builder.newLine(); - _builder.append("} catch (MalformedURLException e1) {"); - _builder.newLine(); - _builder.append("\t"); - _builder.append("if(e1.getMessage().startsWith(\"unknown protocol\")) {"); - _builder.newLine(); - _builder.append("\t\t"); - _builder.append("try {"); - _builder.newLine(); - _builder.append("\t\t\t"); - _builder.append("fileURL = Paths.get(path).toUri().toURL();"); - _builder.newLine(); - _builder.append("\t\t"); - _builder.append("} catch (MalformedURLException e2) {"); - _builder.newLine(); - _builder.append("\t\t\t"); - _builder.append("log.error(e2.getLocalizedMessage()+e2.getCause());"); - _builder.newLine(); - _builder.append("\t\t"); - _builder.append("}"); - _builder.newLine(); - _builder.append("\t"); - _builder.append("}"); - _builder.newLine(); - _builder.append("}"); - _builder.newLine(); - return _builder; - } - - /** - * init smooks factory to create the core import process. - * setup listeners for UI communication. - * setup persistence layer. - * - * @param pkg - * the current datainterchange inferred {@link DataInterchange} - * @return code fragment - */ - public String init(final DataInterchange dataInterchange) { - EList<DataInterchangeBean> _path = dataInterchange.getPath(); - Iterator<DataInterchangeBean> _iterator = _path.iterator(); - DataInterchangeBean _next = _iterator.next(); - DataInterchangeBean firstEntity = ((DataInterchangeBean) _next); - StringConcatenation _builder = new StringConcatenation(); - _builder.append("if(getEventBroker()!=null) {"); - _builder.newLine(); - _builder.append("\t"); - _builder.append("pollingInterval = UI.getCurrent().getPollInterval();"); - _builder.newLine(); - _builder.append("\t"); - _builder.append("UI.getCurrent().setPollInterval(500);"); - _builder.newLine(); - _builder.append("}"); - _builder.newLine(); - _builder.append("try {"); - _builder.newLine(); - _builder.append("\t"); - _builder.append("transformerFactory.setAttribute(\"indent-number\", 4);"); - _builder.newLine(); - _builder.append("\t"); - _builder.append("transformer = transformerFactory.newTransformer();"); - _builder.newLine(); - _builder.append("\t"); - _builder.append("transformer.setOutputProperty(OutputKeys.INDENT, \"yes\"); "); - _builder.newLine(); - _builder.append("\t"); - _builder.append("transformer.setOutputProperty(OutputKeys.ENCODING, \"UTF-8\");"); - _builder.newLine(); - _builder.append("\t"); - _builder.append("transformer.setOutputProperty(OutputKeys.STANDALONE, \"yes\");"); - _builder.newLine(); - _builder.append("\t"); - _builder.append("transformer.setOutputProperty(OutputKeys.MEDIA_TYPE, \"text/xml\");"); - _builder.newLine(); - _builder.append("\t"); - _builder.newLine(); - _builder.append("\t"); - _builder.append("// init smooks"); - _builder.newLine(); - _builder.append("\t"); - _builder.append("setProgressBarEnabled(true);"); - _builder.newLine(); - _builder.append("\t"); - _builder.append("setProgressIndeterminated(true);"); - _builder.newLine(); - _builder.append("\t"); - _builder.append("if (log.isDebugEnabled()) log.debug(\"initializing smooks factory\");"); - _builder.newLine(); - _builder.append("\t"); - _builder.append("smooksOSGIFactory = new SmooksOSGIFactory(FrameworkUtil.getBundle(this.getClass())); "); - _builder.newLine(); - _builder.append("\t"); - _builder.append("smooks = smooksOSGIFactory.createInstance(FrameworkUtil.getBundle(this.getClass()).getResource(\""); - _builder.append(DSLOutputConfigurationProvider.SMOOKS_OUTPUT_DIRECTORY, "\t"); - _builder.append("/"); - String _name = dataInterchange.getName(); - _builder.append(_name, "\t"); - _builder.append("-\"+direction.toString().toLowerCase()+\".xml\").openStream());"); - _builder.newLineIfNotEmpty(); - _builder.append("\t"); - _builder.append("// prepare execution context"); - _builder.newLine(); - _builder.append("\t"); - _builder.append("executionContext = smooks.createExecutionContext();"); - _builder.newLine(); - _builder.append("\t"); - _builder.append("executionContext.setEventListener(this);"); - _builder.newLine(); - _builder.append("\t"); - _builder.append("// get entity manager"); - _builder.newLine(); - _builder.append("\t"); - _builder.append("if (log.isDebugEnabled()) log.debug(\"opening entity manager to persist smooks results\");"); - _builder.newLine(); - _builder.append("\t"); - _builder.append("getPersistenceService().registerPersistenceUnit(\""); - LEntity _entity = firstEntity.getEntity(); - String _persistenceUnit = _entity.getPersistenceUnit(); - _builder.append(_persistenceUnit, "\t"); - _builder.append("\", "); - LEntity _entity_1 = firstEntity.getEntity(); - QualifiedName _fullyQualifiedName = this._iQualifiedNameProvider.getFullyQualifiedName(_entity_1); - _builder.append(_fullyQualifiedName, "\t"); - _builder.append(".class);"); - _builder.newLineIfNotEmpty(); - _builder.append("\t"); - _builder.append("em = getPersistenceService().getEntityManagerFactory(\""); - LEntity _entity_2 = firstEntity.getEntity(); - String _persistenceUnit_1 = _entity_2.getPersistenceUnit(); - _builder.append(_persistenceUnit_1, "\t"); - _builder.append("\").createEntityManager();"); - _builder.newLineIfNotEmpty(); - { - boolean _isCreateReport = dataInterchange.isCreateReport(); - if (_isCreateReport) { - _builder.append("\t"); - _builder.append("// create a filtering report -- impacts performance"); - _builder.newLine(); - _builder.append("\t"); - _builder.append("if (log.isDebugEnabled()) log.debug(\"reporting is on - impacting performance\");"); - _builder.newLine(); - _builder.append("\t"); - _builder.append("String location = FrameworkUtil.getBundle(this.getClass()).getLocation()+\""); - _builder.append(DSLOutputConfigurationProvider.SMOOKS_OUTPUT_DIRECTORY, "\t"); - _builder.append("/"); - String _name_1 = dataInterchange.getName(); - _builder.append(_name_1, "\t"); - _builder.append("-\"+direction.toString().toLowerCase()+\"-report.html\";"); - _builder.newLineIfNotEmpty(); - _builder.append("\t"); - _builder.append("executionContext.setEventListener(new HtmlReportGenerator(location));"); - _builder.newLine(); - } - } - _builder.append("} catch (Exception e) {"); - _builder.newLine(); - _builder.append("\t"); - _builder.append("if(getEventBroker()!=null) {"); - _builder.newLine(); - _builder.append("\t\t"); - _builder.append("UI.getCurrent().setPollInterval(pollingInterval);"); - _builder.newLine(); - _builder.append("\t"); - _builder.append("}"); - _builder.newLine(); - _builder.append("\t"); - _builder.append("log.error(e.getLocalizedMessage()+e.getCause());"); - _builder.newLine(); - _builder.append("\t"); - _builder.append("return false;"); - _builder.newLine(); - _builder.append("}"); - _builder.newLine(); - _builder.append("if(direction == Direction.EXPORT) {"); - _builder.newLine(); - _builder.append("\t"); - _builder.append("int openTry = 0;"); - _builder.newLine(); - _builder.append("\t"); - _builder.append("file = null;"); - _builder.newLine(); - _builder.append("\t"); - _builder.append("URI uri = null;"); - _builder.newLine(); - _builder.append("\t"); - _builder.append("try {"); - _builder.newLine(); - _builder.append("\t\t"); - _builder.append("uri = fileURL.toURI();"); - _builder.newLine(); - _builder.append("\t"); - _builder.append("} catch (URISyntaxException e) {"); - _builder.newLine(); - _builder.append("\t\t"); - _builder.append("log.error(e.getLocalizedMessage()+e.getCause());"); - _builder.newLine(); - _builder.append("\t\t"); - _builder.append("return false;"); - _builder.newLine(); - _builder.append("\t"); - _builder.append("}"); - _builder.newLine(); - _builder.append("\t"); - _builder.append("do {"); - _builder.newLine(); - _builder.append("\t\t"); - _builder.append("Path path = null;"); - _builder.newLine(); - _builder.append("\t\t"); - _builder.append("path = Paths.get(uri);"); - _builder.newLine(); - _builder.append("\t\t"); - _builder.append("try {"); - _builder.newLine(); - _builder.append("\t\t\t"); - _builder.append("// find a unique name - similar to given"); - _builder.newLine(); - _builder.append("\t\t\t"); - _builder.append("file = Files.newOutputStream(path, StandardOpenOption.CREATE_NEW);"); - _builder.newLine(); - _builder.append("\t\t"); - _builder.append("} catch (FileAlreadyExistsException ae) {"); - _builder.newLine(); - _builder.append("\t\t\t"); - _builder.append("openTry ++;"); - _builder.newLine(); - _builder.append("\t\t\t"); - _builder.append("try {"); - _builder.newLine(); - _builder.append("\t\t\t\t"); - _builder.append("uri = fileURL.toURI();"); - _builder.newLine(); - _builder.append("\t\t\t\t"); - _builder.append("int pos = uri.getPath().lastIndexOf(\'.\');"); - _builder.newLine(); - _builder.append("\t\t\t\t"); - _builder.append("if(pos == -1) {"); - _builder.newLine(); - _builder.append("\t\t\t\t\t"); - _builder.append("uri = new URI(uri.getScheme()+\":\"+uri.getPath()+openTry);"); - _builder.newLine(); - _builder.append("\t\t\t\t"); - _builder.append("} else {"); - _builder.newLine(); - _builder.append("\t\t\t\t\t"); - _builder.append("uri = new URI(uri.getScheme()+\":\"+uri.getPath().substring(0,pos)+openTry+\".\"+uri.getPath().substring(pos+1));"); - _builder.newLine(); - _builder.append("\t\t\t\t"); - _builder.append("}"); - _builder.newLine(); - _builder.append("\t\t\t"); - _builder.append("} catch (URISyntaxException e) {"); - _builder.newLine(); - _builder.append("\t\t\t\t\t"); - _builder.append("log.error(e.getLocalizedMessage()+e.getCause());"); - _builder.newLine(); - _builder.append("\t\t\t\t"); - _builder.append("return false;"); - _builder.newLine(); - _builder.append("\t\t\t"); - _builder.append("}"); - _builder.newLine(); - _builder.append("\t\t"); - _builder.append("} catch (IOException e) {"); - _builder.newLine(); - _builder.append("\t\t\t"); - _builder.append("log.error(e.getLocalizedMessage()+e.getCause());"); - _builder.newLine(); - _builder.append("\t\t\t"); - _builder.append("return false;"); - _builder.newLine(); - _builder.append("\t\t"); - _builder.append("}"); - _builder.newLine(); - _builder.append("\t"); - _builder.append("}while(file == null);"); - _builder.newLine(); - _builder.append("\t"); - _builder.append("out = new BufferedOutputStream(file);"); - _builder.newLine(); - _builder.append("}"); - _builder.newLine(); - _builder.append("return true;"); - _builder.newLine(); - String body = _builder.toString(); - return body; - } - - /** - * use smooks factory to create the core import process. - * setup listeners for UI communication. - * setup persistence layer. - * - * @param pkg - * the current datainterchange inferred {@link DataInterchange} - * @return code fragment - */ - public String performSmooks(final DataInterchange dataInterchange) { - EList<DataInterchangeBean> _path = dataInterchange.getPath(); - Iterator<DataInterchangeBean> _iterator = _path.iterator(); - DataInterchangeBean _next = _iterator.next(); - DataInterchangeBean firstEntity = ((DataInterchangeBean) _next); - StringConcatenation _builder = new StringConcatenation(); - _builder.append("if(!init(getDirection())) {"); - _builder.newLine(); - _builder.append("\t"); - _builder.append("return;"); - _builder.newLine(); - _builder.append("}"); - _builder.newLine(); - _builder.append("try {"); - _builder.newLine(); - _builder.append("\t"); - _builder.append("if(getDirection()==WorkerThreadRunnable.Direction.IMPORT) {"); - _builder.newLine(); - String body = _builder.toString(); - StringConcatenation _builder_1 = new StringConcatenation(); - _builder_1.append(body, ""); - _builder_1.newLineIfNotEmpty(); - _builder_1.append("\t\t"); - _builder_1.append("if\t(importListener != null) {"); - _builder_1.newLine(); - _builder_1.append("\t\t\t"); - _builder_1.append("importListener.notifyInitializationStep(\"datainterchange "); - String _name = dataInterchange.getName(); - String _firstUpper = StringExtensions.toFirstUpper(_name); - _builder_1.append(_firstUpper, "\t\t\t"); - _builder_1.append(" load.\", 0.4, 0.45, 0, 0);"); - _builder_1.newLineIfNotEmpty(); - _builder_1.append("\t\t"); - _builder_1.append("}"); - _builder_1.newLine(); - _builder_1.append("\t\t"); - _builder_1.append("// execute the smooks filtering"); - _builder_1.newLine(); - _builder_1.append("\t\t"); - _builder_1.append("JavaResult result = new JavaResult();"); - _builder_1.newLine(); - _builder_1.append("\t\t"); - _builder_1.append("InputStream in = fileURL.openStream();"); - _builder_1.newLine(); - _builder_1.append("\t\t"); - _builder_1.append("byte[] contents = StreamUtils.readStream(in);"); - _builder_1.newLine(); - _builder_1.append("\t\t"); - _builder_1.append("setLength(contents.length);"); - _builder_1.newLine(); - _builder_1.append("\t\t"); - _builder_1.append("setAvgElementSize("); - { - int _elementSize = dataInterchange.getElementSize(); - boolean _equals = (_elementSize == 0); - if (_equals) { - _builder_1.append("10"); - } else { - int _elementSize_1 = dataInterchange.getElementSize(); - _builder_1.append(_elementSize_1, "\t\t"); - } - } - _builder_1.append(");"); - _builder_1.newLineIfNotEmpty(); - _builder_1.append("\t\t"); - _builder_1.append("StreamSource source = new StreamSource(new ByteArrayInputStream(contents));"); - _builder_1.newLine(); - body = _builder_1.toString(); - EList<DataInterchangeBean> _path_1 = dataInterchange.getPath(); - for (final DataInterchangeBean path : _path_1) { - EList<DataInterchangeLookup> _lookup = path.getLookup(); - for (final DataInterchangeLookup lookup : _lookup) { - boolean _isCached = lookup.isCached(); - if (_isCached) { - StringConcatenation _builder_2 = new StringConcatenation(); - _builder_2.append(body, ""); - _builder_2.newLineIfNotEmpty(); - _builder_2.append("\t\t"); - _builder_2.append("em.setProperty(PersistenceUnitProperties.CACHE_SIZE_+\""); - LEntity _entity = lookup.getEntity(); - QualifiedName _fullyQualifiedName = this._iQualifiedNameProvider.getFullyQualifiedName(_entity); - _builder_2.append(_fullyQualifiedName, "\t\t"); - _builder_2.append("\", \""); - int _cacheSize = lookup.getCacheSize(); - _builder_2.append(_cacheSize, "\t\t"); - _builder_2.append("\");"); - _builder_2.newLineIfNotEmpty(); - body = _builder_2.toString(); - } - } - } - StringConcatenation _builder_3 = new StringConcatenation(); - _builder_3.append(body, ""); - _builder_3.newLineIfNotEmpty(); - _builder_3.append("\t\t"); - _builder_3.append("PersistenceUtil.setDAORegister(executionContext, new EntityManagerRegister(em));"); - _builder_3.newLine(); - _builder_3.append("\t\t"); - _builder_3.append("// execute smooks filtering"); - _builder_3.newLine(); - _builder_3.append("\t\t"); - _builder_3.append("if (log.isDebugEnabled()) log.debug(\"filtering starts\");"); - _builder_3.newLine(); - _builder_3.append("\t\t"); - _builder_3.append("setProgressIndeterminated(false);"); - _builder_3.newLine(); - _builder_3.append("\t\t"); - _builder_3.append("if\t(importListener != null) {"); - _builder_3.newLine(); - _builder_3.append("\t\t\t"); - _builder_3.append("importListener.notifyInitializationStep(\"datainterchange Warehouses load..\", 0.4, 0.47, 0, 0);"); - _builder_3.newLine(); - _builder_3.append("\t\t"); - _builder_3.append("}"); - _builder_3.newLine(); - _builder_3.append("\t\t"); - _builder_3.append("smooks.filterSource(executionContext, source, result);"); - _builder_3.newLine(); - _builder_3.append("\t\t"); - _builder_3.append("if\t(importListener != null) {"); - _builder_3.newLine(); - _builder_3.append("\t\t\t"); - _builder_3.append("importListener.notifyInitializationStep(\"datainterchange Warehouses load...\", 0.4, 0.48, 0, 0);"); - _builder_3.newLine(); - _builder_3.append("\t\t"); - _builder_3.append("}"); - _builder_3.newLine(); - _builder_3.append("\t\t"); - _builder_3.append("if (log.isDebugEnabled()) log.debug(\"smooks filtering finished\");"); - _builder_3.newLine(); - body = _builder_3.toString(); - boolean _isRecordList = firstEntity.isRecordList(); - if (_isRecordList) { - StringConcatenation _builder_4 = new StringConcatenation(); - _builder_4.append(body, ""); - _builder_4.newLineIfNotEmpty(); - _builder_4.append("\t\t"); - _builder_4.append("// retrieve bean list"); - _builder_4.newLine(); - _builder_4.append("\t\t"); - _builder_4.append("List<"); - LEntity _entity_1 = firstEntity.getEntity(); - QualifiedName _fullyQualifiedName_1 = this._iQualifiedNameProvider.getFullyQualifiedName(_entity_1); - _builder_4.append(_fullyQualifiedName_1, "\t\t"); - _builder_4.append("> "); - LEntity _entity_2 = firstEntity.getEntity(); - String _name_1 = _entity_2.getName(); - String _firstLower = StringExtensions.toFirstLower(_name_1); - _builder_4.append(_firstLower, "\t\t"); - _builder_4.append("List = Arrays.asList(("); - LEntity _entity_3 = firstEntity.getEntity(); - QualifiedName _fullyQualifiedName_2 = this._iQualifiedNameProvider.getFullyQualifiedName(_entity_3); - _builder_4.append(_fullyQualifiedName_2, "\t\t"); - _builder_4.append("[]) result.getBean(\""); - LEntity _entity_4 = firstEntity.getEntity(); - String _name_2 = _entity_4.getName(); - _builder_4.append(_name_2, "\t\t"); - _builder_4.append("List\"));"); - _builder_4.newLineIfNotEmpty(); - _builder_4.append("\t\t"); - _builder_4.append("// persist"); - _builder_4.newLine(); - _builder_4.append("\t\t"); - _builder_4.append("em.getTransaction().begin();"); - _builder_4.newLine(); - _builder_4.append("\t\t"); - _builder_4.append("if (log.isDebugEnabled()) log.debug(\"persisting results\");"); - _builder_4.newLine(); - _builder_4.append("\t\t"); - _builder_4.append("int total = "); - LEntity _entity_5 = firstEntity.getEntity(); - String _name_3 = _entity_5.getName(); - String _firstLower_1 = StringExtensions.toFirstLower(_name_3); - _builder_4.append(_firstLower_1, "\t\t"); - _builder_4.append("List.size();"); - _builder_4.newLineIfNotEmpty(); - _builder_4.append("\t\t"); - _builder_4.append("int count = 0;"); - _builder_4.newLine(); - _builder_4.append("\t\t"); - _builder_4.append("long lastStep = System.currentTimeMillis();"); - _builder_4.newLine(); - _builder_4.append("\t\t"); - _builder_4.append("if\t(importListener != null) {"); - _builder_4.newLine(); - _builder_4.append("\t\t\t"); - _builder_4.append("importListener.notifyInitializationStep(\"datainterchange "); - String _name_4 = dataInterchange.getName(); - String _firstUpper_1 = StringExtensions.toFirstUpper(_name_4); - _builder_4.append(_firstUpper_1, "\t\t\t"); - _builder_4.append("\", 0.4, 0.5, count, total);"); - _builder_4.newLineIfNotEmpty(); - _builder_4.append("\t\t"); - _builder_4.append("}"); - _builder_4.newLine(); - _builder_4.append("\t\t"); - _builder_4.append("for("); - LEntity _entity_6 = firstEntity.getEntity(); - QualifiedName _fullyQualifiedName_3 = this._iQualifiedNameProvider.getFullyQualifiedName(_entity_6); - _builder_4.append(_fullyQualifiedName_3, "\t\t"); - _builder_4.append(" "); - LEntity _entity_7 = firstEntity.getEntity(); - String _name_5 = _entity_7.getName(); - String _firstLower_2 = StringExtensions.toFirstLower(_name_5); - _builder_4.append(_firstLower_2, "\t\t"); - _builder_4.append(":"); - LEntity _entity_8 = firstEntity.getEntity(); - String _name_6 = _entity_8.getName(); - String _firstLower_3 = StringExtensions.toFirstLower(_name_6); - _builder_4.append(_firstLower_3, "\t\t"); - _builder_4.append("List) {"); - _builder_4.newLineIfNotEmpty(); - _builder_4.append("\t\t\t"); - _builder_4.append("try {"); - _builder_4.newLine(); - _builder_4.append("\t\t\t\t"); - _builder_4.append("em.persist("); - LEntity _entity_9 = firstEntity.getEntity(); - String _name_7 = _entity_9.getName(); - String _firstLower_4 = StringExtensions.toFirstLower(_name_7); - _builder_4.append(_firstLower_4, "\t\t\t\t"); - _builder_4.append(");"); - _builder_4.newLineIfNotEmpty(); - _builder_4.append("\t\t\t"); - _builder_4.append("}"); - _builder_4.newLine(); - _builder_4.append("\t\t\t"); - _builder_4.append("catch (ConstraintViolationException cve) {"); - _builder_4.newLine(); - _builder_4.append("\t\t\t\t"); - _builder_4.append("log.error(\""); - LEntity _entity_10 = firstEntity.getEntity(); - String _name_8 = _entity_10.getName(); - String _firstLower_5 = StringExtensions.toFirstLower(_name_8); - _builder_4.append(_firstLower_5, "\t\t\t\t"); - _builder_4.append(" #\"+(count+1)+\"/\"+total+\": \"+cve.getLocalizedMessage());"); - _builder_4.newLineIfNotEmpty(); - _builder_4.append("\t\t\t\t"); - _builder_4.append("for\t(ConstraintViolation violation : cve.getConstraintViolations()) {"); - _builder_4.newLine(); - _builder_4.append("\t\t\t\t\t"); - _builder_4.append("Object value = violation.getInvalidValue();"); - _builder_4.newLine(); - _builder_4.append("\t\t\t\t\t"); - _builder_4.append("if\t(value == null) {"); - _builder_4.newLine(); - _builder_4.append("\t\t\t\t\t\t"); - _builder_4.append("value = \"<null>\";"); - _builder_4.newLine(); - _builder_4.append("\t\t\t\t\t"); - _builder_4.append("}"); - _builder_4.newLine(); - _builder_4.append("\t\t\t\t\t"); - _builder_4.append("log.error(\"- property:\""); - _builder_4.newLine(); - _builder_4.append("\t\t\t\t\t\t"); - _builder_4.append("+violation.getLeafBean().toString()+\".\"+violation.getPropertyPath().toString()"); - _builder_4.newLine(); - _builder_4.append("\t\t\t\t\t\t"); - _builder_4.append("+\" value:\'\"+value.toString()"); - _builder_4.newLine(); - _builder_4.append("\t\t\t\t\t\t"); - _builder_4.append("+\" violation:\"+violation.getMessage());"); - _builder_4.newLine(); - _builder_4.append("\t\t\t\t"); - _builder_4.append("}"); - _builder_4.newLine(); - _builder_4.append("\t\t\t"); - _builder_4.append("}"); - _builder_4.newLine(); - _builder_4.append("\t\t\t"); - _builder_4.append("count++;"); - _builder_4.newLine(); - _builder_4.append("\t\t\t"); - _builder_4.append("long thisStep = System.currentTimeMillis();"); - _builder_4.newLine(); - _builder_4.append("\t\t\t"); - _builder_4.append("if\t((importListener != null) && ((count % importListener.getInitializationSubStepNotifySize() == 0) || (thisStep-lastStep > 2500))) {"); - _builder_4.newLine(); - _builder_4.append("\t\t\t\t"); - _builder_4.append("lastStep = System.currentTimeMillis();"); - _builder_4.newLine(); - _builder_4.append("\t\t\t\t"); - _builder_4.append("importListener.notifyInitializationStep(\"datainterchange "); - String _name_9 = dataInterchange.getName(); - String _firstUpper_2 = StringExtensions.toFirstUpper(_name_9); - _builder_4.append(_firstUpper_2, "\t\t\t\t"); - _builder_4.append("\", 0.4, 0.5, count, total);"); - _builder_4.newLineIfNotEmpty(); - _builder_4.append("\t\t\t"); - _builder_4.append("}"); - _builder_4.newLine(); - _builder_4.append("\t\t"); - _builder_4.append("}"); - _builder_4.newLine(); - _builder_4.append("\t\t"); - _builder_4.append("if\t(importListener != null) {"); - _builder_4.newLine(); - _builder_4.append("\t\t\t"); - _builder_4.append("importListener.notifyInitializationStep(\"datainterchange "); - String _name_10 = dataInterchange.getName(); - String _firstUpper_3 = StringExtensions.toFirstUpper(_name_10); - _builder_4.append(_firstUpper_3, "\t\t\t"); - _builder_4.append("\", 0.4, 0.5, count, total);"); - _builder_4.newLineIfNotEmpty(); - _builder_4.append("\t\t"); - _builder_4.append("}"); - _builder_4.newLine(); - _builder_4.append("\t\t"); - _builder_4.append("if (log.isDebugEnabled()) log.debug(\"committing results\");"); - _builder_4.newLine(); - _builder_4.append("\t\t"); - _builder_4.append("em.getTransaction().commit();\t\t\t"); - _builder_4.newLine(); - body = _builder_4.toString(); - } else { - StringConcatenation _builder_5 = new StringConcatenation(); - _builder_5.append(body, ""); - _builder_5.newLineIfNotEmpty(); - _builder_5.append("\t\t"); - _builder_5.append("// retrieve the root bean"); - _builder_5.newLine(); - _builder_5.append("\t\t"); - LEntity _entity_11 = firstEntity.getEntity(); - QualifiedName _fullyQualifiedName_4 = this._iQualifiedNameProvider.getFullyQualifiedName(_entity_11); - _builder_5.append(_fullyQualifiedName_4, "\t\t"); - _builder_5.append(" "); - LEntity _entity_12 = firstEntity.getEntity(); - String _name_11 = _entity_12.getName(); - String _firstLower_6 = StringExtensions.toFirstLower(_name_11); - _builder_5.append(_firstLower_6, "\t\t"); - _builder_5.append(" = ("); - LEntity _entity_13 = firstEntity.getEntity(); - QualifiedName _fullyQualifiedName_5 = this._iQualifiedNameProvider.getFullyQualifiedName(_entity_13); - _builder_5.append(_fullyQualifiedName_5, "\t\t"); - _builder_5.append(") result.getBean(\""); - LEntity _entity_14 = firstEntity.getEntity(); - String _name_12 = _entity_14.getName(); - _builder_5.append(_name_12, "\t\t"); - _builder_5.append("\");"); - _builder_5.newLineIfNotEmpty(); - _builder_5.append("\t\t"); - _builder_5.append("// persist"); - _builder_5.newLine(); - _builder_5.append("\t\t"); - _builder_5.append("em.getTransaction().begin();"); - _builder_5.newLine(); - _builder_5.append("\t\t"); - _builder_5.append("if (log.isDebugEnabled()) log.debug(\"persisting results\");"); - _builder_5.newLine(); - _builder_5.append("\t\t"); - _builder_5.append("em.persist("); - LEntity _entity_15 = firstEntity.getEntity(); - String _name_13 = _entity_15.getName(); - String _firstLower_7 = StringExtensions.toFirstLower(_name_13); - _builder_5.append(_firstLower_7, "\t\t"); - _builder_5.append(");"); - _builder_5.newLineIfNotEmpty(); - _builder_5.append("\t\t"); - _builder_5.append("if (log.isDebugEnabled()) log.debug(\"committing results\");"); - _builder_5.newLine(); - _builder_5.append("\t\t"); - _builder_5.append("em.getTransaction().commit();\t\t\t"); - _builder_5.newLine(); - body = _builder_5.toString(); - } - boolean _isMarkLatest = firstEntity.isMarkLatest(); - if (_isMarkLatest) { - StringConcatenation _builder_6 = new StringConcatenation(); - _builder_6.append(body, ""); - _builder_6.newLineIfNotEmpty(); - _builder_6.append("\t\t"); - _builder_6.append("if (log.isDebugEnabled()) log.debug(\"mark results as latest import\");"); - _builder_6.newLine(); - _builder_6.append("\t\t"); - _builder_6.append("em.setProperty(QueryHints.PESSIMISTIC_LOCK, PessimisticLock.Lock);"); - _builder_6.newLine(); - _builder_6.append("\t\t"); - _builder_6.append("em.getTransaction().begin();"); - _builder_6.newLine(); - _builder_6.append("\t\t"); - _builder_6.append("em.createQuery(\"update "); - LEntity _entity_16 = firstEntity.getEntity(); - String _name_14 = _entity_16.getName(); - _builder_6.append(_name_14, "\t\t"); - _builder_6.append(" set "); - LEntityAttribute _latestProperty = firstEntity.getLatestProperty(); - String _name_15 = _latestProperty.getName(); - _builder_6.append(_name_15, "\t\t"); - _builder_6.append(" = 0\").executeUpdate();"); - _builder_6.newLineIfNotEmpty(); - _builder_6.append("\t\t"); - _builder_6.append("em.createQuery(\"update "); - LEntity _entity_17 = firstEntity.getEntity(); - String _name_16 = _entity_17.getName(); - _builder_6.append(_name_16, "\t\t"); - _builder_6.append(" set "); - LEntityAttribute _latestProperty_1 = firstEntity.getLatestProperty(); - String _name_17 = _latestProperty_1.getName(); - _builder_6.append(_name_17, "\t\t"); - _builder_6.append(" = 1 where "); - _builder_6.append("id= :id\").setParameter(\"id\", "); - LEntity _entity_18 = firstEntity.getEntity(); - String _name_18 = _entity_18.getName(); - String _firstLower_8 = StringExtensions.toFirstLower(_name_18); - _builder_6.append(_firstLower_8, "\t\t"); - _builder_6.append(".getId()).executeUpdate();"); - _builder_6.newLineIfNotEmpty(); - _builder_6.append("\t\t"); - _builder_6.append("if (log.isDebugEnabled()) log.debug(\"committing mark\");"); - _builder_6.newLine(); - _builder_6.append("\t\t"); - _builder_6.append("em.getTransaction().commit();\t\t\t"); - _builder_6.newLine(); - body = _builder_6.toString(); - } - boolean _isRefreshEnabled = dataInterchange.isRefreshEnabled(); - if (_isRefreshEnabled) { - StringConcatenation _builder_7 = new StringConcatenation(); - _builder_7.append(body, ""); - _builder_7.newLineIfNotEmpty(); - _builder_7.append("\t\t"); - _builder_7.append("if(getEventBroker()!=null) {"); - _builder_7.newLine(); - _builder_7.append("\t\t\t"); - _builder_7.append("getEventBroker().send(EventBrokerMsg.REFRESH_VIEW+\""); - String _refresh = dataInterchange.getRefresh(); - _builder_7.append(_refresh, "\t\t\t"); - _builder_7.append("\", \"*\");"); - _builder_7.newLineIfNotEmpty(); - _builder_7.append("\t\t"); - _builder_7.append("}"); - _builder_7.newLine(); - body = _builder_7.toString(); - } - StringConcatenation _builder_8 = new StringConcatenation(); - _builder_8.append(body, ""); - _builder_8.newLineIfNotEmpty(); - _builder_8.append("\t\t"); - _builder_8.append("if (log.isDebugEnabled()) log.debug(\"results persisted\");"); - _builder_8.newLine(); - body = _builder_8.toString(); - EList<DataInterchangeBean> _path_2 = dataInterchange.getPath(); - Iterator<DataInterchangeBean> iter = _path_2.iterator(); - DataInterchangeBean _next_1 = iter.next(); - LEntity root = ((DataInterchangeBean) _next_1).getEntity(); - StringConcatenation _builder_9 = new StringConcatenation(); - _builder_9.append(body, ""); - _builder_9.newLineIfNotEmpty(); - _builder_9.append("\t"); - _builder_9.append("} else {"); - _builder_9.newLine(); - _builder_9.append("\t\t"); - _builder_9.append("if (log.isDebugEnabled()) log.debug(\"prepare export\");"); - _builder_9.newLine(); - _builder_9.append("\t\t"); - _builder_9.append("int pageNumber = 1;"); - _builder_9.newLine(); - _builder_9.append("\t\t"); - _builder_9.append("int pageSize = 1000;"); - _builder_9.newLine(); - _builder_9.append("\t\t"); - _builder_9.append("CriteriaBuilder criteriaBuilder = em.getCriteriaBuilder();"); - _builder_9.newLine(); - _builder_9.append("\t\t "); - _builder_9.newLine(); - _builder_9.append("\t\t"); - _builder_9.append("if (log.isDebugEnabled()) log.debug(\"evaluate root entity count\");"); - _builder_9.newLine(); - _builder_9.append("\t\t"); - _builder_9.append("CriteriaQuery<Long> countQuery = criteriaBuilder.createQuery(Long.class);"); - _builder_9.newLine(); - _builder_9.append("\t\t"); - _builder_9.append("countQuery.select(criteriaBuilder.count(countQuery.from("); - LEntity _entity_19 = firstEntity.getEntity(); - QualifiedName _fullyQualifiedName_6 = this._iQualifiedNameProvider.getFullyQualifiedName(_entity_19); - _builder_9.append(_fullyQualifiedName_6, "\t\t"); - _builder_9.append(".class)));"); - _builder_9.newLineIfNotEmpty(); - _builder_9.append("\t\t"); - _builder_9.append("Long count = em.createQuery(countQuery).getSingleResult();"); - _builder_9.newLine(); - _builder_9.append("\t\t"); - _builder_9.append("if (log.isDebugEnabled()) log.debug(\"root entity count is \"+count.toString());"); - _builder_9.newLine(); - _builder_9.append("\t\t"); - _builder_9.append("setLength(count*"); - { - int _elementSize_2 = dataInterchange.getElementSize(); - boolean _equals_1 = (_elementSize_2 == 0); - if (_equals_1) { - _builder_9.append("10"); - } else { - int _elementSize_3 = dataInterchange.getElementSize(); - _builder_9.append(_elementSize_3, "\t\t"); - } - } - _builder_9.append(");"); - _builder_9.newLineIfNotEmpty(); - _builder_9.append("\t\t"); - _builder_9.append("setAvgElementSize(1);"); - _builder_9.newLine(); - _builder_9.append("\t\t"); - _builder_9.newLine(); - _builder_9.append("\t\t"); - _builder_9.append("CriteriaQuery<"); - LEntity _entity_20 = firstEntity.getEntity(); - QualifiedName _fullyQualifiedName_7 = this._iQualifiedNameProvider.getFullyQualifiedName(_entity_20); - _builder_9.append(_fullyQualifiedName_7, "\t\t"); - _builder_9.append("> criteriaQuery = criteriaBuilder.createQuery("); - LEntity _entity_21 = firstEntity.getEntity(); - QualifiedName _fullyQualifiedName_8 = this._iQualifiedNameProvider.getFullyQualifiedName(_entity_21); - _builder_9.append(_fullyQualifiedName_8, "\t\t"); - _builder_9.append(".class);"); - _builder_9.newLineIfNotEmpty(); - _builder_9.append("\t\t"); - _builder_9.append("Root<"); - LEntity _entity_22 = firstEntity.getEntity(); - QualifiedName _fullyQualifiedName_9 = this._iQualifiedNameProvider.getFullyQualifiedName(_entity_22); - _builder_9.append(_fullyQualifiedName_9, "\t\t"); - _builder_9.append("> from = criteriaQuery.from("); - LEntity _entity_23 = firstEntity.getEntity(); - QualifiedName _fullyQualifiedName_10 = this._iQualifiedNameProvider.getFullyQualifiedName(_entity_23); - _builder_9.append(_fullyQualifiedName_10, "\t\t"); - _builder_9.append(".class);"); - _builder_9.newLineIfNotEmpty(); - _builder_9.append("\t\t"); - _builder_9.append("/* ... not necessary due to eager loading of entities via JPA ... "); - String _buildJoins = this.buildJoins(dataInterchange, iter, root); - _builder_9.append(_buildJoins, "\t\t"); - _builder_9.append(" ...*/"); - _builder_9.newLineIfNotEmpty(); - _builder_9.append("\t\t"); - _builder_9.append("CriteriaQuery<"); - LEntity _entity_24 = firstEntity.getEntity(); - QualifiedName _fullyQualifiedName_11 = this._iQualifiedNameProvider.getFullyQualifiedName(_entity_24); - _builder_9.append(_fullyQualifiedName_11, "\t\t"); - _builder_9.append("> select = criteriaQuery.multiselect(from);"); - _builder_9.newLineIfNotEmpty(); - _builder_9.append("\t\t "); - _builder_9.newLine(); - _builder_9.append("\t\t"); - _builder_9.append("TypedQuery<"); - LEntity _entity_25 = firstEntity.getEntity(); - QualifiedName _fullyQualifiedName_12 = this._iQualifiedNameProvider.getFullyQualifiedName(_entity_25); - _builder_9.append(_fullyQualifiedName_12, "\t\t"); - _builder_9.append("> typedQuery = em.createQuery(select);"); - _builder_9.newLineIfNotEmpty(); - _builder_9.append("\t\t"); - _builder_9.append("setProgressIndeterminated(false);"); - _builder_9.newLine(); - _builder_9.append("\t\t"); - _builder_9.append("while (pageNumber < count.intValue()) {"); - _builder_9.newLine(); - _builder_9.append("\t\t\t"); - _builder_9.append("if (log.isDebugEnabled()) log.debug(\"fetch and process entry \"+pageNumber+\" to \"+(pageNumber+pageSize));"); - _builder_9.newLine(); - _builder_9.append("\t\t "); - _builder_9.append("typedQuery.setFirstResult(pageNumber - 1);"); - _builder_9.newLine(); - _builder_9.append("\t\t "); - _builder_9.append("typedQuery.setMaxResults(pageSize);"); - _builder_9.newLine(); - _builder_9.append("\t\t "); - _builder_9.append("List<"); - LEntity _entity_26 = firstEntity.getEntity(); - QualifiedName _fullyQualifiedName_13 = this._iQualifiedNameProvider.getFullyQualifiedName(_entity_26); - _builder_9.append(_fullyQualifiedName_13, "\t\t "); - _builder_9.append("> queryResults = typedQuery.getResultList();"); - _builder_9.newLineIfNotEmpty(); - _builder_9.append("\t\t\t"); - _builder_9.append("StringWriter writer = new StringWriter();"); - _builder_9.newLine(); - _builder_9.append("\t\t\t"); - _builder_9.append("smooks.filterSource(executionContext, new JavaSource(queryResults), new StreamResult(writer));"); - _builder_9.newLine(); - _builder_9.append("\t\t\t"); - _builder_9.append("out.write(writer.toString().getBytes());"); - _builder_9.newLine(); - _builder_9.append("\t\t "); - _builder_9.append("pageNumber += pageSize;"); - _builder_9.newLine(); - _builder_9.append("\t\t"); - _builder_9.append("}"); - _builder_9.newLine(); - _builder_9.append("\t\t"); - _builder_9.append("if (log.isDebugEnabled()) log.debug(\"export finished\");"); - _builder_9.newLine(); - _builder_9.append("\t"); - _builder_9.append("}"); - _builder_9.newLine(); - body = _builder_9.toString(); - StringConcatenation _builder_10 = new StringConcatenation(); - _builder_10.append(body, ""); - _builder_10.newLineIfNotEmpty(); - _builder_10.append("} catch (Exception e) {"); - _builder_10.newLine(); - _builder_10.append("\t"); - _builder_10.append("log.error(\""); - String _name_19 = dataInterchange.getName(); - _builder_10.append(_name_19, "\t"); - _builder_10.append(": \"+e.getLocalizedMessage()+e.getCause(), e);"); - _builder_10.newLineIfNotEmpty(); - _builder_10.append("} finally {"); - _builder_10.newLine(); - _builder_10.append("\t"); - _builder_10.append("if(file != null) {"); - _builder_10.newLine(); - _builder_10.append("\t\t"); - _builder_10.append("try {"); - _builder_10.newLine(); - _builder_10.append("\t\t\t"); - _builder_10.append("out.close();"); - _builder_10.newLine(); - _builder_10.append("\t\t\t"); - _builder_10.append("file.close();"); - _builder_10.newLine(); - _builder_10.append("\t\t"); - _builder_10.append("} catch (IOException e) {"); - _builder_10.newLine(); - _builder_10.append("\t \t"); - _builder_10.append("log.error(e.getLocalizedMessage()+e.getCause());"); - _builder_10.newLine(); - _builder_10.append("\t\t"); - _builder_10.append("}"); - _builder_10.newLine(); - _builder_10.append("\t"); - _builder_10.append("}"); - _builder_10.newLine(); - _builder_10.append("\t"); - _builder_10.append("smooks.close();"); - _builder_10.newLine(); - _builder_10.append("\t"); - _builder_10.append("if(getEventBroker()!=null) {"); - _builder_10.newLine(); - _builder_10.append("\t\t"); - _builder_10.append("UI.getCurrent().setPollInterval(pollingInterval);"); - _builder_10.newLine(); - _builder_10.append("\t"); - _builder_10.append("}"); - _builder_10.newLine(); - _builder_10.append("\t"); - _builder_10.append("// close everything"); - _builder_10.newLine(); - _builder_10.append("\t"); - _builder_10.append("if (em != null) {"); - _builder_10.newLine(); - _builder_10.append("\t\t"); - _builder_10.append("em.close();"); - _builder_10.newLine(); - _builder_10.append("\t"); - _builder_10.append("}"); - _builder_10.newLine(); - _builder_10.append("\t"); - _builder_10.append("if (log.isDebugEnabled()) log.debug(\"datainterchange finished\");"); - _builder_10.newLine(); - _builder_10.append("}"); - _builder_10.newLine(); - body = _builder_10.toString(); - return body; - } - - /** - * This seems to be not necessary, because JPA seems to load the entities eager itself! - * With this functionality active, the sql result set would contain all root entities multiple times! - */ - @Deprecated - public String buildJoins(final DataInterchange interchange, final Iterator<DataInterchangeBean> iter, final LEntity rootEntity) { - LEntity root = rootEntity; - String body = ""; - boolean _hasNext = iter.hasNext(); - if (_hasNext) { - StringConcatenation _builder = new StringConcatenation(); - _builder.append(body, ""); - _builder.append("from"); - body = _builder.toString(); - } - while (iter.hasNext()) { - { - DataInterchangeBean _next = iter.next(); - LEntity entity = ((DataInterchangeBean) _next).getEntity(); - EList<LEntityFeature> _features = root.getFeatures(); - for (final LEntityFeature f : _features) { - boolean _and = false; - boolean _and_1 = false; - boolean _and_2 = false; - if (!(f instanceof LReference)) { - _and_2 = false; - } else { - boolean _isToMany = this._modelExtensions.isToMany(f); - _and_2 = _isToMany; - } - if (!_and_2) { - _and_1 = false; - } else { - LType _type = this._modelExtensions.type(f); - _and_1 = (_type instanceof LEntity); - } - if (!_and_1) { - _and = false; - } else { - LType _type_1 = this._modelExtensions.type(f); - String _name = this._modelExtensions.toName(_type_1); - String _name_1 = this._modelExtensions.toName(entity); - boolean _equals = _name.equals(_name_1); - _and = _equals; - } - if (_and) { - StringConcatenation _builder_1 = new StringConcatenation(); - _builder_1.append(body, ""); - _builder_1.append(".fetch(\""); - String _name_2 = f.getName(); - _builder_1.append(_name_2, ""); - _builder_1.append("\", JoinType.LEFT)"); - body = _builder_1.toString(); - } - } - root = entity; - } - } - boolean _isEmpty = body.isEmpty(); - boolean _not = (!_isEmpty); - if (_not) { - body = (body + ";"); - } - return body; - } - - public CharSequence localeChanged(final DataInterchangePackage pkg) { - StringConcatenation _builder = new StringConcatenation(); - { - String _title = pkg.getTitle(); - boolean _notEquals = (!Objects.equal(_title, null)); - if (_notEquals) { - _builder.append("if(logo != null) {"); - _builder.newLine(); - _builder.append("\t"); - _builder.append("logo.setValue(dslMetadataService.translate(locale.toLanguageTag(), \""); - String _title_1 = pkg.getTitle(); - _builder.append(_title_1, "\t"); - _builder.append("\"));"); - _builder.newLineIfNotEmpty(); - _builder.append("}"); - _builder.newLine(); - } - } - _builder.append("if(buttons != null) {"); - _builder.newLine(); - _builder.append("\t"); - _builder.append("for(Button button: buttons.keySet()) {"); - _builder.newLine(); - _builder.append("\t\t"); - _builder.append("ArrayList i18nKeys = buttons.get(button);"); - _builder.newLine(); - _builder.append("\t\t"); - _builder.append("button.setCaption(dslMetadataService.translate(locale.toLanguageTag(),(String)i18nKeys.get(1)));"); - _builder.newLine(); - _builder.append("\t\t"); - _builder.append("button.setDescription(dslMetadataService.translate(locale.toLanguageTag(),(String)i18nKeys.get(0))+\" \"+dslMetadataService.translate(locale.toLanguageTag(),(String)i18nKeys.get(2)));"); - _builder.newLine(); - _builder.append("\t"); - _builder.append("}"); - _builder.newLine(); - _builder.append("}"); - return _builder; - } - - public void infer(final EObject dataInterchangePackage, final IJvmDeclaredTypeAcceptor acceptor, final boolean isPreIndexingPhase) { - if (dataInterchangePackage instanceof DataInterchangePackage) { - _infer((DataInterchangePackage)dataInterchangePackage, acceptor, isPreIndexingPhase); - return; - } else if (dataInterchangePackage != null) { - _infer(dataInterchangePackage, acceptor, isPreIndexingPhase); - return; - } else { - throw new IllegalArgumentException("Unhandled parameter types: " + - Arrays.<Object>asList(dataInterchangePackage, acceptor, isPreIndexingPhase).toString()); - } - } -} |