/**
* Copyright (C) 2009 eXo Platform SAS.
*
* This is free software; you can redistribute it and/or modify it
* under the terms of the GNU Lesser General Public License as
* published by the Free Software Foundation; either version 2.1 of
* the License, or (at your option) any later version.
*
* This software is distributed in the hope that it will be useful,
* but WITHOUT ANY WARRANTY; without even the implied warranty of
* MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU
* Lesser General Public License for more details.
*
* You should have received a copy of the GNU Lesser General Public
* License along with this software; if not, write to the Free
* Software Foundation, Inc., 51 Franklin St, Fifth Floor, Boston, MA
* 02110-1301 USA, or see the FSF site: http://www.fsf.org.
*/
package org.exoplatform.portal.pom.config;
import org.exoplatform.commons.utils.IOUtil;
import org.exoplatform.commons.utils.LazyPageList;
import org.exoplatform.container.configuration.ConfigurationManager;
import org.exoplatform.portal.application.PortletPreferences;
import org.exoplatform.portal.config.Query;
import org.exoplatform.portal.config.model.Application;
import org.exoplatform.portal.config.model.ApplicationState;
import org.exoplatform.portal.config.model.ApplicationType;
import org.exoplatform.portal.config.model.CloneApplicationState;
import org.exoplatform.portal.config.model.Container;
import org.exoplatform.portal.config.model.ModelObject;
import org.exoplatform.portal.config.model.PersistentApplicationState;
import org.exoplatform.portal.config.model.TransientApplicationState;
import org.exoplatform.portal.pom.config.tasks.DashboardTask;
import org.exoplatform.portal.pom.config.tasks.PageNavigationTask;
import org.exoplatform.portal.pom.config.tasks.PageTask;
import org.exoplatform.portal.pom.config.tasks.PortalConfigTask;
import org.exoplatform.portal.pom.config.tasks.PortletPreferencesTask;
import org.exoplatform.portal.pom.config.tasks.PreferencesTask;
import org.exoplatform.portal.pom.config.tasks.SearchTask;
import org.exoplatform.portal.pom.data.DashboardData;
import org.exoplatform.portal.pom.data.ModelChange;
import org.exoplatform.portal.pom.data.ModelDataStorage;
import org.exoplatform.portal.pom.data.NavigationData;
import org.exoplatform.portal.pom.data.NavigationKey;
import org.exoplatform.portal.pom.data.PageData;
import org.exoplatform.portal.pom.data.PageKey;
import org.exoplatform.portal.pom.data.PortalData;
import org.exoplatform.portal.pom.data.PortalKey;
import org.jibx.runtime.BindingDirectory;
import org.jibx.runtime.IBindingFactory;
import org.jibx.runtime.IUnmarshallingContext;
import org.jibx.runtime.impl.UnmarshallingContext;
import java.io.ByteArrayInputStream;
import java.util.Comparator;
import java.util.List;
import java.util.UUID;
/**
* @author <a href="mailto:julien.viet@exoplatform.com">Julien Viet</a>
* @version $Revision$
*/
public class POMDataStorage implements ModelDataStorage
{
/** . */
private final POMSessionManager pomMgr;
/** . */
private ConfigurationManager confManager_;
public POMDataStorage(POMSessionManager pomMgr, ConfigurationManager confManager)
{
this.pomMgr = pomMgr;
this.confManager_ = confManager;
}
public PortalData getPortalConfig(PortalKey key) throws Exception
{
return pomMgr.execute(new PortalConfigTask.Load(key));
}
public void create(PortalData config) throws Exception
{
pomMgr.execute(new PortalConfigTask.Save(config, false));
}
public void save(PortalData config) throws Exception
{
pomMgr.execute(new PortalConfigTask.Save(config, true));
}
public void remove(PortalData config) throws Exception
{
pomMgr.execute(new PortalConfigTask.Remove(config.getKey()));
}
public PageData getPage(PageKey key) throws Exception
{
return pomMgr.execute(new PageTask.Load(key));
}
public PageData clonePage(PageKey key, PageKey cloneKey) throws Exception
{
return pomMgr.execute(new PageTask.Clone(key, cloneKey, true));
}
public void remove(PageData page) throws Exception
{
pomMgr.execute(new PageTask.Remove(page));
}
public void create(PageData page) throws Exception
{
pomMgr.execute(new PageTask.Save(page));
}
public List<ModelChange> save(PageData page) throws Exception
{
PageTask.Save task = new PageTask.Save(page);
pomMgr.execute(task);
return task.getChanges();
}
public NavigationData getPageNavigation(NavigationKey key) throws Exception
{
return pomMgr.execute(new PageNavigationTask.Load(key));
}
public void save(NavigationData navigation) throws Exception
{
pomMgr.execute(new PageNavigationTask.Save(navigation, true));
}
public void create(NavigationData navigation) throws Exception
{
pomMgr.execute(new PageNavigationTask.Save(navigation, false));
}
public void remove(NavigationData navigation) throws Exception
{
pomMgr.execute(new PageNavigationTask.Remove(navigation));
}
public void save(PortletPreferences portletPreferences) throws Exception
{
pomMgr.execute(new PortletPreferencesTask.Save(portletPreferences));
}
public <S> String getId(ApplicationState<S> state) throws Exception
{
String contentId;
if (state instanceof TransientApplicationState)
{
TransientApplicationState tstate = (TransientApplicationState)state;
contentId = tstate.getContentId();
}
else if (state instanceof PersistentApplicationState)
{
PersistentApplicationState pstate = (PersistentApplicationState)state;
contentId = pomMgr.execute(new PreferencesTask.GetContentId<S>(pstate.getStorageId()));
}
else if (state instanceof CloneApplicationState)
{
CloneApplicationState cstate = (CloneApplicationState)state;
contentId = pomMgr.execute(new PreferencesTask.GetContentId<S>(cstate.getStorageId()));
}
else
{
throw new AssertionError();
}
//
return contentId;
}
public <S> S load(ApplicationState<S> state, ApplicationType<S> type) throws Exception
{
Class<S> clazz = type.getContentType().getStateClass();
if (state instanceof TransientApplicationState)
{
TransientApplicationState<S> transientState = (TransientApplicationState<S>)state;
S prefs = transientState.getContentState();
return prefs != null ? prefs : null;
}
else if (state instanceof CloneApplicationState)
{
PreferencesTask.Load<S> load = new PreferencesTask.Load<S>(((CloneApplicationState<S>)state).getStorageId(), clazz);
return pomMgr.execute(load);
}
else
{
PreferencesTask.Load<S> load = new PreferencesTask.Load<S>(((PersistentApplicationState<S>)state).getStorageId(), clazz);
return pomMgr.execute(load);
}
}
public <S> ApplicationState<S> save(ApplicationState<S> state, S preferences) throws Exception
{
if (state instanceof TransientApplicationState)
{
throw new AssertionError("Does not make sense");
}
else
{
if (state instanceof PersistentApplicationState)
{
PreferencesTask.Save<S> save =
new PreferencesTask.Save<S>(((PersistentApplicationState<S>)state).getStorageId(), preferences);
pomMgr.execute(save);
}
else
{
PreferencesTask.Save<S> save =
new PreferencesTask.Save<S>(((CloneApplicationState<S>)state).getStorageId(), preferences);
pomMgr.execute(save);
}
return state;
}
}
public PortletPreferences getPortletPreferences(String windowID) throws Exception
{
return pomMgr.execute(new PortletPreferencesTask.Load(windowID));
}
public <T> LazyPageList<T> find(Query<T> q) throws Exception
{
return find(q, null);
}
public <T> LazyPageList<T> find(Query<T> q, Comparator<T> sortComparator) throws Exception
{
Class<T> type = q.getClassType();
if (PageData.class.equals(type))
{
return (LazyPageList<T>)pomMgr.execute(new SearchTask.FindPage((Query<PageData>)q));
}
else if (NavigationData.class.equals(type))
{
return (LazyPageList<T>)pomMgr.execute(new SearchTask.FindNavigation((Query<NavigationData>)q));
}
else if (PortletPreferences.class.equals(type))
{
return (LazyPageList<T>)pomMgr.execute(new SearchTask.FindPortletPreferences((Query<PortletPreferences>)q));
}
else if (PortalData.class.equals(type))
{
return (LazyPageList<T>)pomMgr.execute(new SearchTask.FindSite((Query<PortalData>)q));
}
else if (PortalKey.class.equals(type) && "portal".equals(q.getOwnerType()))
{
return (LazyPageList<T>)pomMgr.execute(new SearchTask.FindSiteKey((Query<PortalKey>)q));
}
else
{
throw new UnsupportedOperationException("Could not perform search on query " + q);
}
}
/**
* This is a hack and should be removed, it is only used temporarily.
* This is because the objects are loaded from files and don't have name.
*/
private void generateStorageName(ModelObject obj)
{
if (obj instanceof Container)
{
for (ModelObject child : ((Container)obj).getChildren())
{
generateStorageName(child);
}
}
else if (obj instanceof Application)
{
obj.setStorageName(UUID.randomUUID().toString());
}
}
public DashboardData loadDashboard(String dashboardId) throws Exception
{
return pomMgr.execute(new DashboardTask.Load(dashboardId));
}
public void saveDashboard(DashboardData dashboard) throws Exception
{
pomMgr.execute(new DashboardTask.Save(dashboard));
}
public Container getSharedLayout() throws Exception
{
String path = "war:/conf/portal/portal/sharedlayout.xml";
String out = IOUtil.getStreamContentAsString(confManager_.getInputStream(path));
ByteArrayInputStream is = new ByteArrayInputStream(out.getBytes("UTF-8"));
IBindingFactory bfact = BindingDirectory.getFactory(Container.class);
UnmarshallingContext uctx = (UnmarshallingContext)bfact.createUnmarshallingContext();
uctx.setDocument(is, null, "UTF-8", false);
Container container = (Container)uctx.unmarshalElement();
generateStorageName(container);
return container;
}
public void save() throws Exception
{
pomMgr.execute(new POMTask<Object>()
{
public Object run(POMSession session) throws Exception
{
session.save();
return null;
}
});
}
}