plugins/org.eclipse.egf.producer/src/org/eclipse/egf/producer/internal/manager/ActivityManager.java

/**
 * Copyright (c) 2009-2010 Thales Corporate Services S.A.S.
 * 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:
 * Thales Corporate Services S.A.S - initial API and implementation
 */
package org.eclipse.egf.producer.internal.manager;

import org.eclipse.egf.common.helper.EMFHelper;
import org.eclipse.egf.core.producer.InvocationException;
import org.eclipse.egf.core.producer.context.ProductionContext;
import org.eclipse.egf.model.fcore.Activity;
import org.eclipse.egf.model.fcore.Contract;
import org.eclipse.egf.model.fcore.ContractMode;
import org.eclipse.egf.model.fcore.Invocation;
import org.eclipse.egf.model.fcore.InvocationContract;
import org.eclipse.egf.model.fcore.ModelElement;
import org.eclipse.egf.model.helper.ActivityCycleFinder;
import org.eclipse.egf.producer.EGFProducerPlugin;
import org.eclipse.egf.producer.l10n.ProducerMessages;
import org.eclipse.egf.producer.manager.IActivityManager;
import org.eclipse.egf.producer.manager.IModelElementManager;
import org.eclipse.emf.common.util.BasicDiagnostic;
import org.eclipse.emf.common.util.Diagnostic;
import org.eclipse.osgi.util.NLS;
import org.osgi.framework.Bundle;

/**
 * @author Xavier Maysonnave
 * 
 */
public abstract class ActivityManager<P extends Activity> extends ModelElementManager<P, Contract> implements IActivityManager<P> {

  public ActivityManager(P activity) throws InvocationException {
    super(activity);
    // Diagnose Cycle
    ActivityCycleFinder finder = new ActivityCycleFinder(activity);
    ModelElement element = finder.getFirstRepetition();
    if (element != null) {
      throw new InvocationException(NLS.bind("Activity cycle detected in ''{0}''", EMFHelper.getText(element))); //$NON-NLS-1$
    }
  }

  public ActivityManager(Bundle bundle, P activity) throws InvocationException {
    super(bundle, activity);
    // Diagnose Cycle
    ActivityCycleFinder finder = new ActivityCycleFinder(activity);
    ModelElement element = finder.getFirstRepetition();
    if (element != null) {
      throw new InvocationException(NLS.bind("Activity cycle detected in ''{0}''", EMFHelper.getText(element))); //$NON-NLS-1$
    }
  }

  public <M extends Invocation> ActivityManager(IModelElementManager<M, InvocationContract> parent, P activity) throws InvocationException {
    super(parent, activity);
  }

  @Override
  protected BasicDiagnostic checkInputElement(boolean runtime) throws InvocationException {
    BasicDiagnostic diagnostic = getDiagnostic(getElement(), runtime);
    BasicDiagnostic containerDiagnostic = null;
    ProductionContext<P, Contract> context = getInternalProductionContext();
    // Diagnose Mandatory In and In_Out Contract
    for (Contract contract : getElement().getContracts(ContractMode.IN)) {
      if (contract.isMandatory()) {
        // Check whether or not we face a contract set at runtime
        if (runtime == false && context.isSetAtRuntime(contract.getName())) {
          continue;
        }
        // Check Mandatory Value
        Object value = null;
        try {
          value = context.getInputValue(contract.getName(), contract.getType().getType());
        } catch (InvocationException ie) {
          if (ie.getCause() != null) {
            throw ie;
          }
        }
        if (value == null) {
          if (containerDiagnostic == null) {
            containerDiagnostic = getDiagnostic(contract.getContractContainer(), runtime);
          }
          containerDiagnostic.add(new BasicDiagnostic(Diagnostic.ERROR, EGFProducerPlugin.getDefault().getPluginID(), 0, NLS.bind("Value is mandatory for ''{0}''", EMFHelper.getText(contract)), //$NON-NLS-1$
              new Object[] { contract }));
        }
      }
    }
    // containerDiagnostic should be added at the end otherwise, the severity code is not propagated to the parent.
    if (containerDiagnostic != null) {
      diagnostic.add(containerDiagnostic);
    }
    return diagnostic;
  }

  @Override
  protected BasicDiagnostic checkOutputElement(BasicDiagnostic diagnostic) throws InvocationException {
    BasicDiagnostic containerDiagnostic = null;
    ProductionContext<P, Contract> context = getInternalProductionContext();
    // Diagnose Mandatory Out and In_Out Contract
    for (Contract contract : getElement().getContracts(ContractMode.OUT)) {
      if (contract.isMandatory()) {
        // Check Mandatory Value
        Object value = null;
        try {
          value = context.getOutputValue(contract.getName(), contract.getType().getType());
        } catch (InvocationException ie) {
          if (ie.getCause() != null) {
            throw ie;
          }
        }
        if (value == null) {
          if (containerDiagnostic == null) {
            containerDiagnostic = getDiagnostic(contract.getContractContainer(), true);
          }
          containerDiagnostic.add(new BasicDiagnostic(Diagnostic.ERROR, EGFProducerPlugin.getDefault().getPluginID(), 0, NLS.bind(ProducerMessages.ActivityManager_mandatory_value, EMFHelper.getText(contract)), new Object[] { contract }));
        }
      }
    }
    // containerDiagnostic should be added at the end otherwise, the severity code is not propagated to the parent.
    if (containerDiagnostic != null) {
      diagnostic.add(containerDiagnostic);
    }
    return diagnostic;
  }

  @Override
  public void initializeContext() throws InvocationException {
    // Get Context
    ProductionContext<P, Contract> context = getInternalProductionContext();
    // Clear Context
    context.clear();
    // Set Context
    for (Contract contract : getElement().getContracts()) {
      // Should not happen, anyway ignore
      if (contract.getType() == null) {
        continue;
      }
      // Populate
      ModelElementManager.populateContext(context, getBundle(), contract, contract.getMode(), contract.getType(), contract.getType().getValue());
    }
  }

}