[gatein-commits] gatein SVN: r964 - in portal/branches/wsrp-integration/component/wsrp/src/main/java/org/gatein/portal/wsrp/state: producer and 2 other directories.

Monday, 7 December 2009


Author: chris.laprun(a)jboss.com
Date: 2009-12-07 13:05:05 -0500 (Mon, 07 Dec 2009)
New Revision: 964

Added:
  
portal/branches/wsrp-integration/component/wsrp/src/main/java/org/gatein/portal/wsrp/state/producer/registrations/
  
portal/branches/wsrp-integration/component/wsrp/src/main/java/org/gatein/portal/wsrp/state/producer/registrations/JCRRegistrationPersistenceManager.java
  
portal/branches/wsrp-integration/component/wsrp/src/main/java/org/gatein/portal/wsrp/state/producer/registrations/mapping/
  
portal/branches/wsrp-integration/component/wsrp/src/main/java/org/gatein/portal/wsrp/state/producer/registrations/mapping/ConsumerCapabilitiesMapping.java
  
portal/branches/wsrp-integration/component/wsrp/src/main/java/org/gatein/portal/wsrp/state/producer/registrations/mapping/ConsumerGroupMapping.java
  
portal/branches/wsrp-integration/component/wsrp/src/main/java/org/gatein/portal/wsrp/state/producer/registrations/mapping/ConsumerMapping.java
  
portal/branches/wsrp-integration/component/wsrp/src/main/java/org/gatein/portal/wsrp/state/producer/registrations/mapping/ConsumersAndGroupsMapping.java
  
portal/branches/wsrp-integration/component/wsrp/src/main/java/org/gatein/portal/wsrp/state/producer/registrations/mapping/RegistrationMapping.java
  
portal/branches/wsrp-integration/component/wsrp/src/main/java/org/gatein/portal/wsrp/state/producer/registrations/mapping/RegistrationPropertiesMapping.java
Modified:
  
portal/branches/wsrp-integration/component/wsrp/src/main/java/org/gatein/portal/wsrp/state/consumer/mapping/RegistrationPropertyMapping.java
Log:
- First pass implementation of consumer registrations on the producer side should be done
but not tested.

Modified:
portal/branches/wsrp-integration/component/wsrp/src/main/java/org/gatein/portal/wsrp/state/consumer/mapping/RegistrationPropertyMapping.java
===================================================================
---
portal/branches/wsrp-integration/component/wsrp/src/main/java/org/gatein/portal/wsrp/state/consumer/mapping/RegistrationPropertyMapping.java	2009-12-07
15:44:44 UTC (rev 963)
+++
portal/branches/wsrp-integration/component/wsrp/src/main/java/org/gatein/portal/wsrp/state/consumer/mapping/RegistrationPropertyMapping.java	2009-12-07
18:05:05 UTC (rev 964)
@@ -23,6 +23,7 @@
 
 package org.gatein.portal.wsrp.state.consumer.mapping;
 
+import org.chromattic.api.annotations.MappedBy;
 import org.chromattic.api.annotations.NodeMapping;
 import org.chromattic.api.annotations.OneToOne;
 import org.chromattic.api.annotations.Property;
@@ -51,7 +52,7 @@
    public abstract void setValue(String value);
 
    @OneToOne
-   @RelatedMappedBy("description")
+   @MappedBy("description")
    public abstract RegistrationPropertyDescriptionMapping getDescription();
 
    // todo: this should really be an enum�

Added:
portal/branches/wsrp-integration/component/wsrp/src/main/java/org/gatein/portal/wsrp/state/producer/registrations/JCRRegistrationPersistenceManager.java
===================================================================
---
portal/branches/wsrp-integration/component/wsrp/src/main/java/org/gatein/portal/wsrp/state/producer/registrations/JCRRegistrationPersistenceManager.java	
                       (rev 0)
+++
portal/branches/wsrp-integration/component/wsrp/src/main/java/org/gatein/portal/wsrp/state/producer/registrations/JCRRegistrationPersistenceManager.java	2009-12-07
18:05:05 UTC (rev 964)
@@ -0,0 +1,163 @@
+/*
+* JBoss, a division of Red Hat
+* Copyright 2008, Red Hat Middleware, LLC, and individual contributors as indicated
+* by the @authors tag. See the copyright.txt in the distribution for a
+* full listing of individual contributors.
+*
+* 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.gatein.portal.wsrp.state.producer.registrations;
+
+import org.chromattic.api.ChromatticSession;
+import org.exoplatform.container.ExoContainer;
+import org.gatein.portal.wsrp.state.JCRPersister;
+import
org.gatein.portal.wsrp.state.producer.registrations.mapping.ConsumerCapabilitiesMapping;
+import org.gatein.portal.wsrp.state.producer.registrations.mapping.ConsumerGroupMapping;
+import org.gatein.portal.wsrp.state.producer.registrations.mapping.ConsumerMapping;
+import
org.gatein.portal.wsrp.state.producer.registrations.mapping.ConsumersAndGroupsMapping;
+import org.gatein.portal.wsrp.state.producer.registrations.mapping.RegistrationMapping;
+import org.gatein.registration.ConsumerGroup;
+import org.gatein.registration.Registration;
+import org.gatein.registration.RegistrationException;
+import org.gatein.registration.impl.RegistrationPersistenceManagerImpl;
+import org.gatein.registration.spi.ConsumerGroupSPI;
+import org.gatein.registration.spi.ConsumerSPI;
+import org.gatein.registration.spi.RegistrationSPI;
+
+import java.util.ArrayList;
+import java.util.Collections;
+import java.util.List;
+import java.util.Map;
+
+/**
+ * @author <a href="mailto:chris.laprun@jboss.com">Chris
Laprun</a>
+ * @version $Revision$
+ */
+public class JCRRegistrationPersistenceManager extends
RegistrationPersistenceManagerImpl
+{
+   private JCRPersister persister;
+   private ConsumersAndGroupsMapping mappings;
+
+   public JCRRegistrationPersistenceManager(ExoContainer container, String workspaceName,
String repositoryName) throws Exception
+   {
+      persister = new JCRPersister(container, workspaceName, repositoryName);
+
+      List<Class> mappingClasses = new ArrayList<Class>(5);
+      Collections.addAll(mappingClasses, ConsumersAndGroupsMapping.class,
ConsumerMapping.class, ConsumerGroupMapping.class,
+         RegistrationMapping.class, ConsumerCapabilitiesMapping.class);
+
+      persister.initializeBuilderFor(mappingClasses);
+
+      ChromatticSession session = persister.getSession();
+      mappings = session.findByPath(ConsumersAndGroupsMapping.class,
ConsumersAndGroupsMapping.NODE_NAME);
+      if(mappings == null)
+      {
+         session.insert(ConsumersAndGroupsMapping.class,
ConsumersAndGroupsMapping.NODE_NAME);
+      }
+      persister.closeSession(session);
+
+      for (ConsumerGroupMapping cgm : mappings.getConsumerGroups().values())
+      {
+         internalAddConsumerGroup(cgm.toConsumerGroup(this));
+      }
+
+      for (ConsumerMapping cm : mappings.getConsumers().values())
+      {
+         internalAddConsumer(cm.toConsumer(this));
+      }
+   }
+
+   @Override
+   protected RegistrationSPI internalRemoveRegistration(String registrationId)
+   {
+      Registration registration = getRegistration(registrationId);
+      remove(registration.getPersistentKey(), RegistrationMapping.class);
+      
+      return super.internalRemoveRegistration(registrationId);
+   }
+
+   @Override
+   protected RegistrationSPI internalCreateRegistration(ConsumerSPI consumer, Map
registrationProperties)
+   {
+      ChromatticSession session = persister.getSession();
+      ConsumerMapping cm = session.findById(ConsumerMapping.class,
consumer.getPersistentKey());
+      RegistrationMapping rm = cm.createRegistration();
+      RegistrationSPI registration = newRegistrationSPI(consumer, registrationProperties,
rm.getPersistentKey());
+      rm.initFrom(registration);
+      persister.closeSession(session);
+
+      return registration;
+   }
+
+   @Override
+   protected ConsumerSPI internalRemoveConsumer(String consumerId)
+   {
+      remove(consumerId, ConsumerMapping.class);
+
+      return super.internalRemoveConsumer(consumerId);
+   }
+
+   private void remove(String id, Class clazz)
+   {
+      ChromatticSession session = persister.getSession();
+      session.remove(session.findById(clazz, id));
+      persister.closeSession(session);
+   }
+
+   @Override
+   protected ConsumerSPI internalCreateConsumer(String consumerId, String consumerName)
+   {
+      ConsumerSPI consumer = super.internalCreateConsumer(consumerId, consumerName);
+
+      ChromatticSession session = persister.getSession();
+      ConsumerMapping cm = mappings.createConsumer(consumerId);
+      cm.initFrom(consumer);
+      persister.closeSession(session);
+
+      return consumer;
+   }
+
+   @Override
+   protected ConsumerGroupSPI internalRemoveConsumerGroup(String name)
+   {
+      try
+      {
+         ConsumerGroup group = getConsumerGroup(name);
+         remove(group.getPersistentKey(), ConsumerGroupMapping.class);
+      }
+      catch (RegistrationException e)
+      {
+         throw new IllegalArgumentException("Couldn't remove ConsumerGroup
'" + name + "'", e);
+      }
+
+      return super.internalRemoveConsumerGroup(name);
+   }
+
+   @Override
+   protected ConsumerGroupSPI internalCreateConsumerGroup(String name)
+   {
+      ConsumerGroupSPI group = super.internalCreateConsumerGroup(name);
+
+      ChromatticSession session = persister.getSession();
+      ConsumerGroupMapping cgm = mappings.createConsumerGroup(name);
+      group.setPersistentKey(cgm.getPersistentKey());
+      cgm.initFrom(group);
+      persister.closeSession(session);
+
+      return group;
+   }
+}

Added:
portal/branches/wsrp-integration/component/wsrp/src/main/java/org/gatein/portal/wsrp/state/producer/registrations/mapping/ConsumerCapabilitiesMapping.java
===================================================================
---
portal/branches/wsrp-integration/component/wsrp/src/main/java/org/gatein/portal/wsrp/state/producer/registrations/mapping/ConsumerCapabilitiesMapping.java	
                       (rev 0)
+++
portal/branches/wsrp-integration/component/wsrp/src/main/java/org/gatein/portal/wsrp/state/producer/registrations/mapping/ConsumerCapabilitiesMapping.java	2009-12-07
18:05:05 UTC (rev 964)
@@ -0,0 +1,46 @@
+/*
+* JBoss, a division of Red Hat
+* Copyright 2008, Red Hat Middleware, LLC, and individual contributors as indicated
+* by the @authors tag. See the copyright.txt in the distribution for a
+* full listing of individual contributors.
+*
+* 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.gatein.portal.wsrp.state.producer.registrations.mapping;
+
+import org.chromattic.api.annotations.NodeMapping;
+import org.gatein.registration.ConsumerCapabilities;
+
+/**
+ * @author <a href="mailto:chris.laprun@jboss.com">Chris
Laprun</a>
+ * @version $Revision$
+ */
+@NodeMapping(name = ConsumerCapabilitiesMapping.NODE_NAME)
+public class ConsumerCapabilitiesMapping
+{
+   public static final String NODE_NAME = "wsrp:consumercapabilities";
+
+   public void initFrom(ConsumerCapabilities capabilities)
+   {
+
+   }
+
+   public ConsumerCapabilities toConsumerCapabilities()
+   {
+      return null;  // todo: implement
+   }
+}

Added:
portal/branches/wsrp-integration/component/wsrp/src/main/java/org/gatein/portal/wsrp/state/producer/registrations/mapping/ConsumerGroupMapping.java
===================================================================
---
portal/branches/wsrp-integration/component/wsrp/src/main/java/org/gatein/portal/wsrp/state/producer/registrations/mapping/ConsumerGroupMapping.java	
                       (rev 0)
+++
portal/branches/wsrp-integration/component/wsrp/src/main/java/org/gatein/portal/wsrp/state/producer/registrations/mapping/ConsumerGroupMapping.java	2009-12-07
18:05:05 UTC (rev 964)
@@ -0,0 +1,110 @@
+/*
+* JBoss, a division of Red Hat
+* Copyright 2008, Red Hat Middleware, LLC, and individual contributors as indicated
+* by the @authors tag. See the copyright.txt in the distribution for a
+* full listing of individual contributors.
+*
+* 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.gatein.portal.wsrp.state.producer.registrations.mapping;
+
+import org.chromattic.api.RelationshipType;
+import org.chromattic.api.annotations.FindById;
+import org.chromattic.api.annotations.Id;
+import org.chromattic.api.annotations.ManyToOne;
+import org.chromattic.api.annotations.MappedBy;
+import org.chromattic.api.annotations.NodeMapping;
+import org.chromattic.api.annotations.OneToMany;
+import org.chromattic.api.annotations.Property;
+import org.chromattic.api.annotations.RelatedMappedBy;
+import org.gatein.common.util.ParameterValidation;
+import
org.gatein.portal.wsrp.state.producer.registrations.JCRRegistrationPersistenceManager;
+import org.gatein.registration.Consumer;
+import org.gatein.registration.ConsumerGroup;
+import org.gatein.registration.RegistrationException;
+import org.gatein.registration.RegistrationStatus;
+import org.gatein.registration.spi.ConsumerGroupSPI;
+
+import java.util.Collection;
+
+/**
+ * @author <a href="mailto:chris.laprun@jboss.com">Chris
Laprun</a>
+ * @version $Revision$
+ */
+@NodeMapping(name = ConsumerGroupMapping.NODE_NAME)
+public abstract class ConsumerGroupMapping
+{
+   public static final String NODE_NAME = "wsrp:consumergroup";
+
+   @OneToMany(type = RelationshipType.PATH)
+   @RelatedMappedBy("group")
+   public abstract Collection<ConsumerMapping> getConsumers();
+
+   @Property(name = "name")
+   public abstract String getName();
+   public abstract void setName(String name);
+
+   @Property(name = "status")
+   public abstract RegistrationStatus getStatus();
+   public abstract void setStatus(RegistrationStatus status);
+
+   @Id
+   public abstract String getPersistentKey();
+
+   @FindById
+   public abstract ConsumerMapping findConsumerById(String id);
+
+   public void initFrom(ConsumerGroup group)
+   {
+      setName(group.getName());
+      setStatus(group.getStatus());
+
+      try
+      {
+         for (Consumer consumer : group.getConsumers())
+         {
+            String id = consumer.getPersistentKey();
+            ConsumerMapping cm = findConsumerById(id);
+            ParameterValidation.throwIllegalArgExceptionIfNull(cm, "ConsumerMapping
(no such mapping with id: " + id + ")");
+            cm.initFrom(consumer);
+            getConsumers().add(cm);
+         }
+      }
+      catch (RegistrationException e)
+      {
+         throw new RuntimeException(e);
+      }
+   }
+
+   public ConsumerGroupSPI toConsumerGroup(JCRRegistrationPersistenceManager
persistenceManager) throws RegistrationException
+   {
+      ConsumerGroupSPI group = persistenceManager.newConsumerGroupSPI(getName());
+      group.setStatus(getStatus());
+
+      for (ConsumerMapping cm : getConsumers())
+      {
+         Consumer consumer = persistenceManager.getConsumerById(cm.getPersistentKey());
+         if(consumer == null)
+         {
+            consumer = cm.toConsumer(persistenceManager);
+         }
+
+         group.addConsumer(consumer);
+      }
+      return group;
+   }
+}

Added:
portal/branches/wsrp-integration/component/wsrp/src/main/java/org/gatein/portal/wsrp/state/producer/registrations/mapping/ConsumerMapping.java
===================================================================
---
portal/branches/wsrp-integration/component/wsrp/src/main/java/org/gatein/portal/wsrp/state/producer/registrations/mapping/ConsumerMapping.java	
                       (rev 0)
+++
portal/branches/wsrp-integration/component/wsrp/src/main/java/org/gatein/portal/wsrp/state/producer/registrations/mapping/ConsumerMapping.java	2009-12-07
18:05:05 UTC (rev 964)
@@ -0,0 +1,152 @@
+/*
+* JBoss, a division of Red Hat
+* Copyright 2008, Red Hat Middleware, LLC, and individual contributors as indicated
+* by the @authors tag. See the copyright.txt in the distribution for a
+* full listing of individual contributors.
+*
+* 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.gatein.portal.wsrp.state.producer.registrations.mapping;
+
+import org.chromattic.api.RelationshipType;
+import org.chromattic.api.annotations.Create;
+import org.chromattic.api.annotations.FindById;
+import org.chromattic.api.annotations.Id;
+import org.chromattic.api.annotations.ManyToOne;
+import org.chromattic.api.annotations.MappedBy;
+import org.chromattic.api.annotations.NodeMapping;
+import org.chromattic.api.annotations.OneToMany;
+import org.chromattic.api.annotations.OneToOne;
+import org.chromattic.api.annotations.Property;
+import org.chromattic.api.annotations.RelatedMappedBy;
+import
org.gatein.portal.wsrp.state.producer.registrations.JCRRegistrationPersistenceManager;
+import org.gatein.registration.Consumer;
+import org.gatein.registration.ConsumerGroup;
+import org.gatein.registration.Registration;
+import org.gatein.registration.RegistrationException;
+import org.gatein.registration.RegistrationStatus;
+import org.gatein.registration.spi.ConsumerSPI;
+
+import java.util.Map;
+
+/**
+ * @author <a href="mailto:chris.laprun@jboss.com">Chris
Laprun</a>
+ * @version $Revision$
+ */
+@NodeMapping(name = ConsumerMapping.NODE_NAME)
+public abstract class ConsumerMapping
+{
+   public static final String NODE_NAME = "wsrp:consumer";
+
+   @Id
+   public abstract String getPersistentKey();
+
+   @Property(name = "name")
+   public abstract String getName();
+
+   public abstract void setName(String name);
+
+   @Property(name = "id")
+   public abstract String getId();
+
+   public abstract void setId(String id);
+
+   @Property(name = "consumeragent")
+   public abstract String getConsumerAgent();
+
+   public abstract void setConsumerAgent(String consumerAgent);
+
+   @Property(name = "status")
+   public abstract RegistrationStatus getStatus();
+
+   public abstract void setStatus(RegistrationStatus status);
+
+   @OneToMany(type = RelationshipType.PATH)
+   @RelatedMappedBy("consumer")
+   public abstract Map<String, RegistrationMapping> getRegistrations();
+
+   @Create
+   public abstract RegistrationMapping createRegistration();
+
+   @ManyToOne(type = RelationshipType.PATH)
+   @MappedBy("group")
+   public abstract ConsumerGroupMapping getGroup();
+
+   public abstract void setGroup(ConsumerGroupMapping group);
+
+   @OneToOne
+   @MappedBy("capabilities")
+   public abstract ConsumerCapabilitiesMapping getCapabilities();
+
+   @FindById
+   public abstract ConsumerGroupMapping findGroupById(String id);
+
+   public void initFrom(Consumer consumer)
+   {
+      setName(consumer.getName());
+      setConsumerAgent(consumer.getConsumerAgent());
+      setStatus(consumer.getStatus());
+
+      ConsumerGroup group = consumer.getGroup();
+      if (group != null)
+      {
+         ConsumerGroupMapping cgm = findGroupById(group.getPersistentKey());
+         setGroup(cgm);
+      }
+
+      ConsumerCapabilitiesMapping ccm = getCapabilities();
+      ccm.initFrom(consumer.getCapabilities());
+
+      try
+      {
+         Map<String, RegistrationMapping> rms = getRegistrations();
+         for (Registration reg : consumer.getRegistrations())
+         {
+            RegistrationMapping rm = createRegistration();
+            rm.initFrom(reg);
+            rms.put(reg.getRegistrationHandle(), rm);
+         }
+      }
+      catch (RegistrationException e)
+      {
+         throw new RuntimeException(e);
+      }
+   }
+
+   public ConsumerSPI toConsumer(JCRRegistrationPersistenceManager persistenceManager)
throws RegistrationException
+   {
+      ConsumerSPI consumer = persistenceManager.newConsumerSPI(getId(), getName());
+      consumer.setConsumerAgent(getConsumerAgent());
+      consumer.setStatus(getStatus());
+      consumer.setPersistentKey(getPersistentKey());
+
+      consumer.setCapabilities(getCapabilities().toConsumerCapabilities());
+
+      ConsumerGroupMapping cgm = getGroup();
+      if (cgm != null)
+      {
+         consumer.setGroup(persistenceManager.getConsumerGroup(cgm.getName()));
+      }
+
+      for (RegistrationMapping rm : getRegistrations().values())
+      {
+         consumer.addRegistration(rm.toRegistration(persistenceManager, consumer));
+      }
+
+      return consumer;
+   }
+}

Added:
portal/branches/wsrp-integration/component/wsrp/src/main/java/org/gatein/portal/wsrp/state/producer/registrations/mapping/ConsumersAndGroupsMapping.java
===================================================================
---
portal/branches/wsrp-integration/component/wsrp/src/main/java/org/gatein/portal/wsrp/state/producer/registrations/mapping/ConsumersAndGroupsMapping.java	
                       (rev 0)
+++
portal/branches/wsrp-integration/component/wsrp/src/main/java/org/gatein/portal/wsrp/state/producer/registrations/mapping/ConsumersAndGroupsMapping.java	2009-12-07
18:05:05 UTC (rev 964)
@@ -0,0 +1,51 @@
+/*
+* JBoss, a division of Red Hat
+* Copyright 2008, Red Hat Middleware, LLC, and individual contributors as indicated
+* by the @authors tag. See the copyright.txt in the distribution for a
+* full listing of individual contributors.
+*
+* 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.gatein.portal.wsrp.state.producer.registrations.mapping;
+
+import org.chromattic.api.annotations.Create;
+import org.chromattic.api.annotations.NodeMapping;
+import org.chromattic.api.annotations.OneToMany;
+
+import java.util.Map;
+
+/**
+ * @author <a href="mailto:chris.laprun@jboss.com">Chris
Laprun</a>
+ * @version $Revision$
+ */
+@NodeMapping(name = ConsumersAndGroupsMapping.NODE_NAME)
+public abstract class ConsumersAndGroupsMapping
+{
+   public static final String NODE_NAME = "wsrp:consumersandgroups";
+
+   @OneToMany
+   public abstract Map<String, ConsumerMapping> getConsumers();
+
+   @OneToMany
+   public abstract Map<String, ConsumerGroupMapping> getConsumerGroups();
+
+   @Create
+   public abstract ConsumerMapping createConsumer(String id);
+
+   @Create
+   public abstract ConsumerGroupMapping createConsumerGroup(String name);
+}

Added:
portal/branches/wsrp-integration/component/wsrp/src/main/java/org/gatein/portal/wsrp/state/producer/registrations/mapping/RegistrationMapping.java
===================================================================
---
portal/branches/wsrp-integration/component/wsrp/src/main/java/org/gatein/portal/wsrp/state/producer/registrations/mapping/RegistrationMapping.java	
                       (rev 0)
+++
portal/branches/wsrp-integration/component/wsrp/src/main/java/org/gatein/portal/wsrp/state/producer/registrations/mapping/RegistrationMapping.java	2009-12-07
18:05:05 UTC (rev 964)
@@ -0,0 +1,96 @@
+/*
+* JBoss, a division of Red Hat
+* Copyright 2008, Red Hat Middleware, LLC, and individual contributors as indicated
+* by the @authors tag. See the copyright.txt in the distribution for a
+* full listing of individual contributors.
+*
+* 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.gatein.portal.wsrp.state.producer.registrations.mapping;
+
+import org.chromattic.api.RelationshipType;
+import org.chromattic.api.annotations.FindById;
+import org.chromattic.api.annotations.Id;
+import org.chromattic.api.annotations.ManyToOne;
+import org.chromattic.api.annotations.MappedBy;
+import org.chromattic.api.annotations.NodeMapping;
+import org.chromattic.api.annotations.OneToOne;
+import org.chromattic.api.annotations.Property;
+import
org.gatein.portal.wsrp.state.producer.registrations.JCRRegistrationPersistenceManager;
+import org.gatein.registration.Registration;
+import org.gatein.registration.RegistrationException;
+import org.gatein.registration.RegistrationStatus;
+import org.gatein.registration.spi.ConsumerSPI;
+import org.gatein.registration.spi.RegistrationSPI;
+
+import javax.xml.namespace.QName;
+import java.util.Collections;
+import java.util.HashMap;
+import java.util.Map;
+
+/**
+ * @author <a href="mailto:chris.laprun@jboss.com">Chris
Laprun</a>
+ * @version $Revision$
+ */
+@NodeMapping(name = RegistrationMapping.NODE_NAME)
+public abstract class RegistrationMapping
+{
+   public static final String NODE_NAME = "wsrp:registration";
+
+   @Id
+   public abstract String getPersistentKey();
+
+   @ManyToOne(type = RelationshipType.PATH)
+   @MappedBy("consumer")
+   public abstract ConsumerMapping getConsumer();
+
+   @Property(name = "status")
+   public abstract RegistrationStatus getStatus();
+   public abstract void setStatus(RegistrationStatus status);
+
+   @Property(name = "registrationhandle")
+   public abstract String getRegistrationHandle();
+   public abstract void setRegistrationHandle(String handle);
+
+   @OneToOne
+   @MappedBy("properties")
+   public abstract RegistrationPropertiesMapping getProperties();
+
+   @FindById
+   public abstract ConsumerMapping findConsumerById(String id);
+
+   public void initFrom(Registration registration)
+   {
+      setStatus(registration.getStatus());
+      setRegistrationHandle(registration.getRegistrationHandle());
+
+      getProperties().initFrom(registration.getProperties());
+
+      ConsumerMapping cm = findConsumerById(registration.getConsumer().getId());
+      cm.getRegistrations().put(registration.getPersistentKey(), this);
+   }
+
+   public RegistrationSPI toRegistration(JCRRegistrationPersistenceManager
persistenceManager, ConsumerSPI consumer) throws RegistrationException
+   {
+      ConsumerMapping cm = getConsumer();
+
+      RegistrationSPI reg = persistenceManager.newRegistrationSPI(consumer,
getProperties().toPropMap(), getPersistentKey());
+      reg.setStatus(getStatus());
+      reg.setRegistrationHandle(getRegistrationHandle());
+      return reg;
+   }
+}

Added:
portal/branches/wsrp-integration/component/wsrp/src/main/java/org/gatein/portal/wsrp/state/producer/registrations/mapping/RegistrationPropertiesMapping.java
===================================================================
---
portal/branches/wsrp-integration/component/wsrp/src/main/java/org/gatein/portal/wsrp/state/producer/registrations/mapping/RegistrationPropertiesMapping.java	
                       (rev 0)
+++
portal/branches/wsrp-integration/component/wsrp/src/main/java/org/gatein/portal/wsrp/state/producer/registrations/mapping/RegistrationPropertiesMapping.java	2009-12-07
18:05:05 UTC (rev 964)
@@ -0,0 +1,73 @@
+/*
+* JBoss, a division of Red Hat
+* Copyright 2008, Red Hat Middleware, LLC, and individual contributors as indicated
+* by the @authors tag. See the copyright.txt in the distribution for a
+* full listing of individual contributors.
+*
+* 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.gatein.portal.wsrp.state.producer.registrations.mapping;
+
+import org.chromattic.api.annotations.NodeMapping;
+import org.chromattic.api.annotations.Properties;
+
+import javax.xml.namespace.QName;
+import java.util.Collections;
+import java.util.HashMap;
+import java.util.Map;
+
+/**
+ * @author <a href="mailto:chris.laprun@jboss.com">Chris
Laprun</a>
+ * @version $Revision$
+ */
+@NodeMapping(name = RegistrationPropertiesMapping.NODE_NAME)
+public abstract class RegistrationPropertiesMapping
+{
+   public static final String NODE_NAME = "wsrp:registrationproperties";
+
+   @Properties
+   public abstract Map<String, String> getProperties();
+
+   public Map<QName, Object> toPropMap()
+   {
+      Map<QName, Object> properties = Collections.emptyMap();
+      Map<String, String> propMap = getProperties();
+      if (!propMap.isEmpty())
+      {
+         properties = new HashMap<QName, Object>(propMap.size());
+         for (Map.Entry<String, String> entry : propMap.entrySet())
+         {
+            properties.put(QName.valueOf(entry.getKey()), entry.getValue());
+         }
+      }
+
+      return properties;
+   }
+
+   public void initFrom(Map<QName, Object> properties)
+   {
+      if(properties != null)
+      {
+         Map<String, String> map = getProperties();
+
+         for (Map.Entry<QName, Object> entry : properties.entrySet())
+         {
+            map.put(entry.getKey().toString(), entry.getValue().toString());
+         }
+      }
+   }
+}


    

2024

2023

2022

2021

2020

2019

2018

2017

2016

2015

2014

2013

2012

2011

2010

2009

[gatein-commits] gatein SVN: r964 - in portal/branches/wsrp-integration/component/wsrp/src/main/java/org/gatein/portal/wsrp/state: producer and 2 other directories.