mosgi.console.gui/src/main/java/org/apache/felix/mosgi/console/gui/NodePanel.java

/* 
 * 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.felix.mosgi.console.gui;

import org.apache.felix.mosgi.console.ifc.Plugin;
import org.osgi.framework.Bundle;
import org.osgi.framework.BundleContext;
import org.osgi.framework.BundleException;
import org.osgi.framework.ServiceReference;

import java.beans.PropertyChangeEvent;
import java.beans.PropertyChangeListener;
import java.io.IOException;
import java.net.URLClassLoader;
import java.rmi.server.RMIClassLoader;
import java.rmi.server.RMIClassLoaderSpi;
import java.security.SecureClassLoader;
import java.util.Hashtable;
import java.util.Iterator;
import java.util.Vector;
import java.util.Set;
import javax.swing.event.ChangeListener;
import javax.swing.event.ChangeEvent;
import javax.swing.JTabbedPane;
import java.lang.IllegalStateException;
import javax.management.AttributeNotFoundException;
import javax.management.InstanceNotFoundException;
import javax.management.MBeanException;
import javax.management.MBeanServerConnection;
import javax.management.ObjectName;
import javax.management.ReflectionException;
//import javax.management.MalformedObjectNameException;

public class NodePanel extends JTabbedPane implements PropertyChangeListener, ChangeListener {
  //private String repo;
  private Activator a=null;
  private BundleContext m_context=null;
  
  private Hashtable pluginList=null;

  public NodePanel(Activator activator, BundleContext context){
    this.m_context=context;
    this.a=activator;
    a.addPropertyChangeListener(this);
    this.pluginList=new Hashtable();
    //repo = m_context.getProperty("mosgi.jmxconsole.repository");
    this.addChangeListener(this);
  }

  //////////////////////////////////////
  // ChangeListener Implementation    //
  //////////////////////////////////////
  public void stateChanged(ChangeEvent e){
    //   System.out.println("coucou => "+((JTabbedPane)e.getSource()).getSelectedIndex()+":"+((JTabbedPane)e.getSource()).getSelectedComponent().getName());
    if (this.getSelectedComponent()!=null){
      a.firePropertyChangedEvent(Plugin.PLUGIN_ACTIVATED, null, this.getSelectedComponent().getName());
    }
  }

  public void propertyChange(PropertyChangeEvent event) {
    //System.out.println("   PCE : "+event.getPropertyName());
    if (event.getPropertyName().equals(Plugin.PLUGIN_ADDED)) {
      Plugin cp=(Plugin) event.getNewValue();
      this.add(cp.getName(), cp.getGUI());
      System.out.println("Add gui \""+cp.getName()+"\" into NodePanel"/*+" :: "+cp.getGUI()*/);      
      this.a.addPropertyChangeListener(cp);
      this.pluginList.put(cp.pluginLocation(), cp); 
    }else if(event.getPropertyName().equals(Plugin.PLUGIN_REMOVED)) {
      Plugin cp = (Plugin) event.getNewValue();
      String cpLoc=cp.pluginLocation();
      this.remove(cp.getGUI());
      //this.a.removePropertyChangeListener(cp);
      //this.pluginList.remove(cpLoc);
    }else if(event.getPropertyName().equals(Plugin.EMPTY_NODE)) {
      //System.out.println("******* Debug No node selected");
      this.clean();
    }else if (event.getPropertyName().equals(Plugin.NEW_NODE_SELECTED)) {
      /* Update the tabs (Plugin) in the JTabbedPane (NodePanel) */
      MBeanServerConnection mbsc = (MBeanServerConnection)event.getNewValue();
      String connString = (String) event.getOldValue();
      try {
	this.clean();
        Set ons = mbsc.queryNames( null, null );
        for( Iterator i=ons.iterator(); i.hasNext(); ) {
	  ObjectName name = ( ObjectName )i.next();
          if ( "TabUI".equals(name.getDomain()) ) {
	    /* Get the plugin implementation via a bundle */
	    String tabBundle = (String) mbsc.getAttribute(name, "BundleName");
	    if (tabBundle!=null){
              Plugin p = (Plugin) this.pluginList.get(tabBundle);
              if (p == null){
  	        Bundle b = m_context.installBundle(tabBundle);
	        b.start();
                System.out.println(" - Bundle started: \""+name.toString()+"\" - "+tabBundle);
                //Thread.sleep(5000);
              }else{
                System.out.println(" - Register service plugin: "+p);
                p.registerServicePlugin();
              }

//            ServiceReference[] sr = b.getRegisteredServices();
//            System.out.println(sr);
//            Plugin p;
//            for (int j=0 ; j < sr.length ; j++) {
//              p=(Plugin)m_context.getService(sr[j]);
//              this.add(p.getName(), p.getGUI());
//              this.a.addPropertyChangeListener(p);
//            }

//            System.out.println("Delegation for this");
//            printcl = this.getClass().getClassLoader();
//            while (printcl != null) {
//              System.out.println(printcl);
//              printcl = printcl.getParent();
//            }
//            System.out.println("{bootstrap loader}");
//            System.out.println("");

              /* Get the tab object */
//            Object tabObj = mbsc.getAttribute(name, "Tab");
// 
//            System.out.println("Delegation for tabObj: " + tabObj);
//            printcl = tabObj.getClass().getClassLoader();
//            while (printcl != null) {
//              System.out.println(printcl);
//              printcl = printcl.getParent();
//            }
//            System.out.println("{bootstrap loader}");
//            System.out.println("");
  
//            System.out.println("tabObj.getName(): " + ((fr.inria.ares.managedelements.testprobe.tab.TestProbeTabUI) tabObj).getName());
              
              /* Cast the tab */  
//            Plugin tab = (Plugin)tabObj;
              /* register the tab on the JTabbedPane */
//            this.add(tab.getName(), tab.getGUI());
            } else{
	      System.out.println(" - No bundleName attribute defined for \""+name.toString()+"\". I cannot install tab");
            }
          }
        }
        a.firePropertyChangedEvent(Plugin.NEW_NODE_READY, connString, mbsc);
        a.firePropertyChangedEvent(Plugin.PLUGIN_ACTIVATED, null, this.getComponentAt(0).getName());

      } catch (MBeanException e) {
        System.err.println("MBeanException : "+e);
//    } catch (MalformedObjectNameException e) {
//      System.err.println(e);
      } catch (AttributeNotFoundException e) {
        System.err.println("AttributeNotFoundException : "+e);
      } catch (InstanceNotFoundException e) {
        System.err.println("InstanceNotFoundException : "+e);
      } catch (ReflectionException e) {
        System.err.println("ReflectionException : "+e);
      } catch (IOException e) {
        System.err.println("IOException : "+e);
      } catch (BundleException e) {
        System.err.println("BundleException : "+e);
      } catch (Exception e) {
        System.err.println("Exception : "+e);
      }
//    } catch (java.lang.InterruptedException e) {
//      System.err.println(e);
//    }
    }
  }

  private void clean(){
    this.removeAll();
    Vector pluginList_tmp=new Vector();
    for ( Iterator i=pluginList.keySet().iterator(); i.hasNext();) {
      Object o=i.next();
      pluginList_tmp.add(o);
    }
    for ( int i = 0 ; i < pluginList_tmp.size() ; i++) {
      Plugin p=(Plugin) pluginList.get(pluginList_tmp.elementAt(i));
      try {
        p.unregisterServicePlugin();
      } catch (Exception ex) {
	//System.out.println("\""+p.getName()+"\" : "+ex);
      }
    } 
  }

}