package org.argeo.cms.internal.kernel;
   
   import javax.jcr.Repository;
   import javax.naming.ldap.LdapName;
   
   import org.apache.commons.logging.Log;
   import org.apache.commons.logging.LogFactory;
   import org.argeo.api.NodeConstants;
   import org.argeo.api.NodeInstance;
  import org.argeo.cms.CmsException;
  import org.osgi.framework.BundleContext;
  import org.osgi.framework.FrameworkUtil;
  import org.osgi.framework.ServiceReference;
  import org.osgi.util.tracker.ServiceTracker;
  
  public class CmsInstance implements NodeInstance {
  	private final Log log = LogFactory.getLog(getClass());
  	private final BundleContext bc = FrameworkUtil.getBundle(getClass()).getBundleContext();
  
  	private EgoRepository egoRepository;
  
  	public CmsInstance() {
  		initTrackers();
  	}
  
  	private void initTrackers() {
  		// node repository
  		new ServiceTracker<Repository, Repository>(bc, Repository.class, null) {
  			@Override
  			public Repository addingService(ServiceReference<Repository> reference) {
  				Object cn = reference.getProperty(NodeConstants.CN);
  				if (cn != null && cn.equals(NodeConstants.EGO_REPOSITORY)) {
  					egoRepository = (EgoRepository) bc.getService(reference);
  					if (log.isTraceEnabled())
  						log.trace("Home repository is available");
  				}
  				return super.addingService(reference);
  			}
  
  			@Override
  			public void removedService(ServiceReference<Repository> reference, Repository service) {
  				super.removedService(reference, service);
  				egoRepository = null;
  			}
  
  		}.open();
  	}
  
  	public void shutdown() {
  
  	}
  
  	@Override
  	public void createWorkgroup(LdapName dn) {
  		if (egoRepository == null)
  			throw new CmsException("Ego repository is not available");
  		// TODO add check that the group exists
  		egoRepository.createWorkgroup(dn);
  	}
  
  }