/*
* Jitsi, the OpenSource Java VoIP and Instant Messaging client.
*
* Distributable under LGPL license.
* See terms of license at gnu.org.
*/
package net.java.sip.communicator.impl.muc;
import java.util.*;
import net.java.sip.communicator.service.contactsource.*;
import net.java.sip.communicator.service.credentialsstorage.*;
import net.java.sip.communicator.service.customcontactactions.*;
import net.java.sip.communicator.service.globaldisplaydetails.*;
import net.java.sip.communicator.service.gui.*;
import net.java.sip.communicator.service.muc.*;
import net.java.sip.communicator.service.protocol.*;
import net.java.sip.communicator.util.*;
import org.jitsi.service.configuration.*;
import org.jitsi.service.resources.*;
import org.osgi.framework.*;
/**
* The activator for the chat room contact source bundle.
*
* @author Hristo Terezov
*/
public class MUCActivator
implements BundleActivator
{
/**
* The Logger used by the
* MUCActivator class for logging output.
*/
private static final Logger logger
= Logger.getLogger(MUCActivator.class);
/**
* The bundle context.
*/
static BundleContext bundleContext = null;
/**
* The configuration service.
*/
private static ConfigurationService configService;
/**
* Providers of contact info.
*/
private static List chatRoomProviders;
/**
* The chat room contact source.
*/
private static final ChatRoomContactSourceService chatRoomContactSource
= new ChatRoomContactSourceService();
/**
* The resource service.
*/
private static ResourceManagementService resources = null;
/**
* The MUC service.
*/
private static MUCServiceImpl mucService;
/**
* The account manager.
*/
private static AccountManager accountManager;
/**
* The alert UI service.
*/
private static AlertUIService alertUIService;
/**
* The credential storage service.
*/
private static CredentialsStorageService credentialsService;
/**
* The custom actions service.
*/
private static MUCCustomContactActionService mucCustomActionService;
/**
* The UI service.
*/
private static UIService uiService = null;
/**
* Listens for ProtocolProviderService registrations.
*/
private static ProtocolProviderRegListener protocolProviderRegListener
= null;
/**
* The global display details service instance.
*/
private static GlobalDisplayDetailsService globalDisplayDetailsService;
/**
* Starts this bundle.
*
* @param context the bundle context where we register and obtain services.
*/
public void start(BundleContext context) throws Exception
{
bundleContext = context;
bundleContext.registerService(
ContactSourceService.class.getName(),
chatRoomContactSource,
null);
mucService = new MUCServiceImpl();
bundleContext.registerService(
MUCService.class.getName(),
mucService,
null);
mucCustomActionService = new MUCCustomContactActionService();
bundleContext.registerService(
CustomContactActionsService.class.getName(),
mucCustomActionService,
null);
}
public void stop(BundleContext context) throws Exception
{
if(protocolProviderRegListener != null)
{
bundleContext.removeServiceListener(protocolProviderRegListener);
}
if(chatRoomProviders != null)
chatRoomProviders.clear();
}
/**
* Returns the MUC service instance.
* @return the MUC service instance.
*/
public static MUCServiceImpl getMUCService()
{
return mucService;
}
/**
* Returns the chat room contact source.
*
* @return the chat room contact source
*/
public static ChatRoomContactSourceService getContactSource()
{
return chatRoomContactSource;
}
/**
* Returns a reference to the ResourceManagementService implementation
* currently registered in the bundle context or null if no such
* implementation was found.
*
* @return a reference to a ResourceManagementService implementation
* currently registered in the bundle context or null if no such
* implementation was found.
*/
public static ResourceManagementService getResources()
{
if (resources == null)
{
resources
= ServiceUtils.getService(
bundleContext, ResourceManagementService.class);
}
return resources;
}
/**
* Returns the ConfigurationService obtained from the bundle
* context.
* @return the ConfigurationService obtained from the bundle
* context
*/
public static ConfigurationService getConfigurationService()
{
if(configService == null)
{
configService
= ServiceUtils.getService(
bundleContext,
ConfigurationService.class);
}
return configService;
}
/**
* Returns the AccountManager obtained from the bundle context.
* @return the AccountManager obtained from the bundle context
*/
public static AccountManager getAccountManager()
{
if(accountManager == null)
{
accountManager
= ServiceUtils.getService(bundleContext, AccountManager.class);
}
return accountManager;
}
/**
* Returns the AlertUIService obtained from the bundle
* context.
* @return the AlertUIService obtained from the bundle
* context
*/
public static AlertUIService getAlertUIService()
{
if(alertUIService == null)
{
alertUIService
= ServiceUtils.getService(
bundleContext,
AlertUIService.class);
}
return alertUIService;
}
/**
* Returns a reference to a CredentialsStorageService implementation
* currently registered in the bundle context or null if no such
* implementation was found.
*
* @return a currently valid implementation of the
* CredentialsStorageService.
*/
public static CredentialsStorageService getCredentialsStorageService()
{
if (credentialsService == null)
{
credentialsService
= ServiceUtils.getService(
bundleContext, CredentialsStorageService.class);
}
return credentialsService;
}
/**
* Returns a list of all currently registered providers.
*
* @return a list of all currently registered providers
*/
public static List getChatRoomProviders()
{
if (chatRoomProviders != null)
return chatRoomProviders;
chatRoomProviders = new LinkedList();
protocolProviderRegListener = new ProtocolProviderRegListener();
bundleContext.addServiceListener(protocolProviderRegListener);
ServiceReference[] serRefs = null;
try
{
// get all registered provider factories
serRefs
= bundleContext.getServiceReferences(
ProtocolProviderFactory.class.getName(),
null);
}
catch (InvalidSyntaxException e)
{
logger.error("LoginManager : " + e);
}
if (serRefs != null)
{
for (ServiceReference serRef : serRefs)
{
ProtocolProviderFactory providerFactory
= (ProtocolProviderFactory)
bundleContext.getService(serRef);
ProtocolProviderService protocolProvider;
for (AccountID accountID
: providerFactory.getRegisteredAccounts())
{
serRef = providerFactory.getProviderForAccount(accountID);
protocolProvider
= (ProtocolProviderService) bundleContext
.getService(serRef);
handleProviderAdded(protocolProvider);
}
}
}
return chatRoomProviders;
}
/**
* Listens for ProtocolProviderService registrations.
*/
private static class ProtocolProviderRegListener
implements ServiceListener
{
/**
* Handles service change events.
*/
public void serviceChanged(ServiceEvent event)
{
ServiceReference serviceRef = event.getServiceReference();
// if the event is caused by a bundle being stopped, we don't want to
// know
if (serviceRef.getBundle().getState() == Bundle.STOPPING)
{
return;
}
Object service = bundleContext.getService(serviceRef);
// we don't care if the source service is not a protocol provider
if (!(service instanceof ProtocolProviderService))
{
return;
}
switch (event.getType())
{
case ServiceEvent.REGISTERED:
handleProviderAdded((ProtocolProviderService) service);
break;
case ServiceEvent.UNREGISTERING:
handleProviderRemoved((ProtocolProviderService) service);
break;
}
}
}
/**
* Handles the registration of a new ProtocolProviderService. Adds
* the given protocolProvider to the list of queried providers.
*
* @param protocolProvider the ProtocolProviderService to add
*/
private static void handleProviderAdded(
ProtocolProviderService protocolProvider)
{
if (protocolProvider.getOperationSet(
OperationSetMultiUserChat.class) != null
&& !chatRoomProviders.contains(protocolProvider))
{
chatRoomProviders.add(protocolProvider);
}
}
/**
* Handles the un-registration of a ProtocolProviderService.
* Removes the given protocolProvider from the list of queried
* providers.
*
* @param protocolProvider the ProtocolProviderService to remove
*/
private static void handleProviderRemoved(
ProtocolProviderService protocolProvider)
{
if (chatRoomProviders.contains(protocolProvider))
chatRoomProviders.remove(protocolProvider);
}
/**
* Returns the UIService obtained from the bundle
* context.
* @return the UIService obtained from the bundle
* context
*/
public static UIService getUIService()
{
if(uiService == null)
{
uiService
= ServiceUtils.getService(
bundleContext,
UIService.class);
}
return uiService;
}
/**
* Returns the GlobalDisplayDetailsService obtained from the bundle
* context.
* @return the GlobalDisplayDetailsService obtained from the bundle
* context
*/
public static GlobalDisplayDetailsService getGlobalDisplayDetailsService()
{
if(globalDisplayDetailsService == null)
{
globalDisplayDetailsService
= ServiceUtils.getService(
bundleContext,
GlobalDisplayDetailsService.class);
}
return globalDisplayDetailsService;
}
}