/***
 * Coalevo Project
 * http://www.coalevo.net
 *
 * (c) Verein zur Foerderung der Internetkommunikation, Austria
 * http://www.vfi.or.at
 *
 * Licensed 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 net.coalevo.datasource.impl;

import net.coalevo.datasource.service.DataSourceService;
import net.coalevo.foundation.model.Messages;
import net.coalevo.foundation.service.MessageResourceService;
import net.coalevo.logging.model.LogProxy;
import org.osgi.framework.BundleActivator;
import org.osgi.framework.BundleContext;
import org.slf4j.Logger;
import org.slf4j.Marker;
import org.slf4j.MarkerFactory;

/**
 * Implements the bundles activator.
 * <p/>
 *
 * @author Dieter Wimberger (wimpi)
 * @version @version@ (@date@)
 */
public class Activator
    implements BundleActivator {

  private static Marker c_LogMarker;
  private static LogProxy c_Log;

  private static Messages c_BundleMessages;
  private static ServiceMediator c_Services;

  private DataSourceServiceImpl m_DataSourceService;

  private Thread m_StartThread;

  public void start(final BundleContext bundleContext)
      throws Exception {
    if (m_StartThread != null && m_StartThread.isAlive()) {
      throw new Exception();
    }

    m_StartThread = new Thread(new Runnable() {
      public void run() {
        try {
          //1. Log
          c_LogMarker = MarkerFactory.getMarker(Activator.class.getName());
          c_Log = new LogProxy();
          c_Log.activate(bundleContext);

          //2. Services
          c_Services = new ServiceMediator();
          c_Services.activate(bundleContext);


          //3. Bundle Messages
          MessageResourceService mrs =
              c_Services.getMessageResourceService(ServiceMediator.WAIT_UNLIMITED);

          if (mrs == null) {
            log().error(c_LogMarker, "MessageResourceService unavailable.");
            return;
          }
          c_BundleMessages = mrs.getBundleMessages(bundleContext.getBundle());
          if (c_BundleMessages == null) {
            log().error(c_LogMarker, "Bundle Message Resources could not be resolved.");
            return;
          }

          //4. DataSource Services
          m_DataSourceService = new DataSourceServiceImpl();
          m_DataSourceService.activate(bundleContext);
          bundleContext.registerService(
              DataSourceService.class.getName(),
              m_DataSourceService,
              null
          );
          log().info(c_LogMarker, c_BundleMessages.get("Activator.activation.service", "service", "DataSourceService"));
          
        } catch (Exception ex) {
          log().error("start()", ex);
        }
        log().info(c_BundleMessages.get("Activator.started"));
      }//run
    }//Runnable
    );//Thread
    m_StartThread.setContextClassLoader(this.getClass().getClassLoader());
    m_StartThread.start();
  }//start

  public void stop(BundleContext bundleContext)
      throws Exception {
    if (m_StartThread != null && m_StartThread.isAlive()) {
      m_StartThread.join();
      m_StartThread = null;
    }
    if (m_DataSourceService != null) {
      m_DataSourceService.deactivate();
      m_DataSourceService = null;
    }
    if (c_Services != null) {
      c_Services.deactivate();
      c_Services = null;
    }
    if(c_Log != null) {
      c_Log.deactivate();
      c_Log = null;
    }
    
    c_LogMarker = null;
    c_BundleMessages = null;
  }//stop

  public static Messages getMessages() {
    return c_BundleMessages;
  }//getMessages

  /**
   * Return the bundles logger.
   *
   * @return the <tt>Logger</tt>.
   */
  public static Logger log() {
    return c_Log;
  }//log


}//class Activator