| /* |
| * Licensed to the Apache Software Foundation (ASF) under one |
| * or more contributor license agreements. See the NOTICE file |
| * distributed with this work for additional information |
| * regarding copyright ownership. The ASF licenses this file |
| * to you under the Apache License, Version 2.0 (the |
| * "License"); you may not use this file except in compliance |
| * with the License. You may obtain a copy of the License at |
| * |
| * http://www.apache.org/licenses/LICENSE-2.0 |
| * |
| * Unless required by applicable law or agreed to in writing, |
| * software distributed under the License is distributed on an |
| * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY |
| * KIND, either express or implied. See the License for the |
| * specific language governing permissions and limitations |
| * under the License. |
| */ |
| |
| package org.apache.uima.dde.internal.provider; |
| |
| import java.util.ArrayList; |
| import java.util.List; |
| |
| import org.apache.uima.UIMAFramework; |
| import org.apache.uima.aae.deployment.AEDeploymentConstants; |
| import org.apache.uima.aae.deployment.AEDeploymentDescription; |
| import org.apache.uima.aae.deployment.AEDeploymentMetaData; |
| import org.apache.uima.aae.deployment.AsyncAEErrorConfiguration; |
| import org.apache.uima.aae.deployment.AsyncAggregateErrorConfiguration; |
| import org.apache.uima.aae.deployment.AsyncPrimitiveErrorConfiguration; |
| import org.apache.uima.aae.deployment.CollectionProcessCompleteErrors; |
| import org.apache.uima.aae.deployment.GetMetadataErrors; |
| import org.apache.uima.aae.deployment.ProcessCasErrors; |
| import org.apache.uima.aae.deployment.RemoteAEDeploymentMetaData; |
| import org.apache.uima.aae.deployment.impl.AEDelegates_Impl; |
| import org.apache.uima.aae.deployment.impl.AsyncAggregateErrorConfiguration_Impl; |
| import org.apache.uima.aae.deployment.impl.GetMetadataErrors_Impl; |
| import org.apache.uima.analysis_engine.AnalysisEngineDescription; |
| import org.apache.uima.resource.ResourceSpecifier; |
| import org.apache.uima.tools.debug.util.Trace; |
| import org.apache.uima.util.InvalidXMLException; |
| import org.eclipse.jface.viewers.IStructuredContentProvider; |
| import org.eclipse.jface.viewers.ITreeContentProvider; |
| import org.eclipse.jface.viewers.Viewer; |
| |
| |
| public class DDTreeContentProvider implements IStructuredContentProvider, ITreeContentProvider { |
| private static final Object[] EMPTY_ARRAY = new Object[0]; |
| |
| public Object[] getChildren(Object parent) { |
| Object[] objs = null; |
| int count = 0; |
| if (parent instanceof AEDeploymentMetaData) { |
| AEDeploymentMetaData metaData = (AEDeploymentMetaData) parent; |
| |
| // if (metaData.getAsyncAEErrorConfiguration() == null) { |
| // // Create a new Error Config |
| // if (metaData.getResourceSpecifier() != null) { |
| // ResourceSpecifier rs = metaData.getResourceSpecifier(); |
| // if (rs instanceof AnalysisEngineDescription) { |
| // Class cls; |
| // if (((AnalysisEngineDescription) rs).isPrimitive()) { |
| // // Prmitive |
| // cls = AsyncPrimitiveErrorConfiguration.class; |
| // } else { |
| // // Aggregate |
| // cls = AsyncAggregateErrorConfiguration.class; |
| // } |
| // |
| // Object obj = UIMAFramework.getResourceSpecifierFactory().createObject(cls); |
| // if (obj != null) { |
| // Trace.err("OK to create " + cls.getName() + " for " + metaData.getKey()); |
| // metaData.setAsyncAEErrorConfiguration((AsyncAEErrorConfiguration) obj); |
| // } else { |
| // Trace.err("CANNOT create " + cls.getName() + " for " + metaData.getKey()); |
| // } |
| // } else { |
| // Trace.bug("Should be AnalysisEngineDescription: " + rs.getClass().getName()); |
| // } |
| // } else { |
| // Trace.bug("ResourceSpecifier == null for " + metaData.getKey()); |
| // } |
| // } |
| |
| if (metaData.isAsync()) { |
| if (metaData.getDelegates() != null) { |
| List list = metaData.getDelegates().getDelegates(); |
| return list.toArray(); |
| } |
| } |
| } else if (parent instanceof RemoteAEDeploymentMetaData) { |
| RemoteAEDeploymentMetaData metaData = (RemoteAEDeploymentMetaData) parent; |
| |
| } else if (parent instanceof AEDelegates_Impl) { |
| return ((AEDelegates_Impl) parent).getDelegates().toArray(); |
| |
| } else if (parent instanceof AsyncAggregateErrorConfiguration) { |
| AsyncAggregateErrorConfiguration errorConfig = (AsyncAggregateErrorConfiguration) parent; |
| |
| } else if (parent instanceof GetMetadataErrors) { |
| GetMetadataErrors getMetadataErrors = (GetMetadataErrors) parent; |
| objs = new Object[3]; |
| objs[0] = "MaxRetries: " + getMetadataErrors.getMaxRetries(); |
| objs[1] = "Timeout: " + getMetadataErrors.getTimeout(); |
| objs[2] = "Error Action: " + getMetadataErrors.getErrorAction(); |
| return objs; |
| |
| } else if (parent instanceof ProcessCasErrors) { |
| ProcessCasErrors processCasErrors = (ProcessCasErrors) parent; |
| objs = new Object[6]; |
| objs[0] = "MaxRetries: " + processCasErrors.getMaxRetries(); |
| objs[1] = "Timeout: " + processCasErrors.getTimeout(); |
| objs[2] = "ContinueOnRetryFailure: " + processCasErrors.isContinueOnRetryFailure(); |
| objs[3] = "Threshold Count: " + processCasErrors.getThresholdCount(); |
| objs[4] = "Threshold Window: " + processCasErrors.getThresholdWindow(); |
| objs[5] = "Threshold Action: " + processCasErrors.getThresholdAction(); |
| return objs; |
| |
| } else if (parent instanceof CollectionProcessCompleteErrors) { |
| CollectionProcessCompleteErrors completeErrors = (CollectionProcessCompleteErrors) parent; |
| objs = new Object[2]; |
| objs[0] = "Timeout: " + completeErrors.getTimeout(); |
| objs[1] = "Additional Error Action: " + completeErrors.getAdditionalErrorAction(); |
| return objs; |
| |
| } else if (parent instanceof AsyncPrimitiveErrorConfiguration) { |
| AsyncPrimitiveErrorConfiguration errorConfig = (AsyncPrimitiveErrorConfiguration) parent; |
| |
| if (errorConfig.hasImport()) { |
| String importBy = "import "; |
| if (errorConfig.isImportByLocation()) { |
| importBy += " location=" + errorConfig.getImportedDescriptor(); |
| } else { |
| importBy += " name=" + errorConfig.getImportedDescriptor(); |
| } |
| objs = new Object[1]; |
| objs[0] = importBy; |
| return objs; |
| } |
| |
| if (errorConfig.getGetMetadataErrors() != null) { |
| ++count; |
| } |
| |
| if (errorConfig.getProcessCasErrors() != null) { |
| ++count; |
| } |
| |
| if (errorConfig.getCollectionProcessCompleteErrors() != null) { |
| ++count; |
| } |
| |
| objs = new Object[count]; |
| int index = 0; |
| if (errorConfig.getGetMetadataErrors() != null) { |
| objs[index++] = errorConfig.getGetMetadataErrors(); |
| } |
| |
| if (errorConfig.getProcessCasErrors() != null) { |
| objs[index++] = errorConfig.getProcessCasErrors(); |
| } |
| |
| if (errorConfig.getCollectionProcessCompleteErrors() != null) { |
| objs[index++] = errorConfig.getCollectionProcessCompleteErrors(); |
| } |
| return objs; |
| } |
| |
| return EMPTY_ARRAY; |
| } |
| |
| public Object getParent(Object element) { |
| return null; |
| } |
| |
| public boolean hasChildren(Object parent) { |
| return getChildren(parent).length > 0; |
| } |
| |
| public Object[] getElements(Object inputElement) { |
| if (inputElement instanceof AEDeploymentDescription) { |
| AEDeploymentMetaData metaData = null; |
| try { |
| metaData = ((AEDeploymentDescription) inputElement).getAeService() |
| .getAnalysisEngineDeploymentMetaData(); |
| // if (metaData != null && metaData.getAsyncAEErrorConfiguration() == null) { |
| // // Create a new Error Config |
| // Object obj = UIMAFramework.getResourceSpecifierFactory().createObject( |
| // AsyncAggregateErrorConfiguration.class); |
| // if (obj != null) { |
| // Trace.err("OK to create AsyncAEErrorConfiguration for " + metaData.getKey()); |
| // metaData.setAsyncAEErrorConfiguration((AsyncAggregateErrorConfiguration) obj); |
| // } else { |
| // Trace.err("Cannot create AsyncAggregateErrorConfiguration"); |
| // } |
| // } else { |
| // Trace.err("NO AEDeploymentMetaData"); |
| // } |
| } catch (InvalidXMLException e) { |
| // TODO Auto-generated catch block |
| e.printStackTrace(); |
| } |
| if (metaData != null) { |
| Object[] objs = new Object[1]; |
| objs[0] = metaData; |
| return objs; |
| } |
| } |
| Trace.err("inputElement: " + inputElement.getClass().getName()); |
| return EMPTY_ARRAY; // Should NOT return "null" |
| } |
| |
| public void dispose() { |
| // TODO Auto-generated method stub |
| } |
| |
| public void inputChanged(Viewer viewer, Object oldInput, Object newInput) { |
| // if (newInput != null) { |
| // Trace.err("newInput: " + newInput.getClass().getName()); |
| // } |
| } |
| |
| } |
