org.eclipse.osee.ote.client.msg/src/org/eclipse/osee/ote/client/msg/core/internal/state/UnresolvedState.java

/*******************************************************************************
 * Copyright (c) 2004, 2007 Boeing.
 * 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:
 *     Boeing - initial API and implementation
 *******************************************************************************/
package org.eclipse.osee.ote.client.msg.core.internal.state;

import java.util.HashSet;
import java.util.Set;
import java.util.logging.Level;

import org.eclipse.osee.framework.logging.OseeLog;
import org.eclipse.osee.ote.client.msg.core.db.AbstractMessageDataBase;
import org.eclipse.osee.ote.client.msg.core.db.MessageInstance;
import org.eclipse.osee.ote.client.msg.core.internal.MessageSubscription;
import org.eclipse.osee.ote.message.Message;
import org.eclipse.osee.ote.message.enums.DataType;
import org.eclipse.osee.ote.message.tool.MessageMode;

/**
 * @author Ken J. Aguilar
 */
public class UnresolvedState extends AbstractSubscriptionState {

   private DataType type;

   private final String msgClassName;
   private MessageInstance instance = null;

   public UnresolvedState(String msgClassName, MessageSubscription subscription, DataType type, MessageMode mode) {
      super(subscription, type, mode);
      this.type = type;
      this.msgClassName = msgClassName;
   }

   public UnresolvedState(String msgClassName, AbstractSubscriptionState previousState) {
      super(previousState);
      this.msgClassName = msgClassName;
   }

   @Override
   public Message getMessage() {
      return instance != null ? instance.getMessage() : null;
   }

   @Override
   public String getMsgClassName() {
      return msgClassName;
   }

   @Override
   public ISubscriptionState onMessageDbFound(AbstractMessageDataBase msgDB) {
      try {
    	  DataType requestedType = getMemType();
          if (requestedType == null && getSubscription().getRequestedDataType() != null) {
        	  instance = msgDB.acquireInstance(msgClassName, getMode(), getSubscription().getRequestedDataType());        	           	 
          } else {
        	  instance = msgDB.acquireInstance(msgClassName, getMode(), requestedType);        	  
          }

         this.type = instance.getType();
         getSubscription().notifyResolved();
         return new InactiveState(instance, msgDB, this);
      } catch (Exception e) {
    	 // Yes we do need to log this
         OseeLog.log(UnresolvedState.class, Level.SEVERE, "problems acquring instance for " + getMsgClassName());
         getSubscription().notifyInvalidated();
         return this;
      }

   }

   @Override
   public DataType getMemType() {
      return type;
   }

   @Override
   public ISubscriptionState onMessageDbClosing(AbstractMessageDataBase msgDb) {
      return this;
   }

   @Override
   public ISubscriptionState onActivated() {
      return this;
   }

   @Override
   public ISubscriptionState onDeactivated() {
      return this;
   }

   @Override
   public Set<DataType> getAvailableTypes() {
      return new HashSet<DataType>();
   }

   @Override
   public boolean isActive() {
      return false;
   }

   @Override
   public boolean isResolved() {
      return instance != null;
   }
}