Source code: com/sample/addressbook/controller/contact/ContactModifyController.java

   /*
    * ContactModifyController.java
    *
    * Copyright (c) 2001, 2002 Aendvari, Ltd. All Rights Reserved.
    *
    * See the file LICENSE for terms of use.
    *
    */
   
  package com.sample.addressbook.controller.contact;
  
  import java.util.ArrayList;
  import java.util.Collection;
  
  import javax.servlet.*;
  import javax.servlet.http.*;
  
  import com.aendvari.satyr.servlet.*;
  import com.aendvari.satyr.servlet.gateway.tethys.*;
  
  import com.aendvari.griffin.util.XmlUtil;
  import com.aendvari.griffin.bean.transform.BeanTransformer;
  
  import com.aendvari.common.model.*;
  import com.aendvari.common.notices.Notices;
  
  import com.aendvari.tethys.context.*;
  import com.aendvari.tethys.context.model.*;
  
  import com.aendvari.tethys.tag.context.*;
  import com.aendvari.tethys.tag.model.*;
  
  import com.aendvari.cerberus.component.descriptor.ComponentDescriptor;
  
  import com.aendvari.cerberus.component.assembly.AssembledComponent;
  import com.aendvari.cerberus.component.assembly.AssemblyContext;
  
  import com.aendvari.hermes.broker.*;
  import com.aendvari.hermes.broker.http.*;
  
  import com.sample.addressbook.Names;
  import com.sample.addressbook.dumbdb.*;
  
  import com.sample.addressbook.model.contact.data.Contact;
  
  import com.sample.addressbook.controller.contact.validation.ContactValidation;
  
  import com.sample.addressbook.controller.components.EmailAddressesController;
  
  
  /**
   * <p>Prepares for displaying/submitting a contact for editing.</p>
   *
   * @author  Scott Milne
   *
   */
  
  public class ContactModifyController implements AssembledComponent
  {
    protected ComponentDescriptor descriptor;
    protected String model;
    protected String errorMessages;
    protected String emailAddressesFormModel;
    protected String associatesFormModel;
  
  
    /* Constructors. */
  
  
    /**
     * Constructs a <code>ContactModifyController</code> instance.
     *
     */
  
    public ContactModifyController()
    {
    }
  
    /**
     * Creates the component based on the provided descriptor.
     *
     * The {@link AssemblyContext} object is transient and should not be retained
     * by the component.
     *
     * The {@link ComponentDescriptor} may be retained by the component.
     *
     * @param    context            The {@link AssemblyContext} for this component.
     * @param    descriptor          The {@link ComponentDescriptor} for this component.
     *
     */
  
    public void createComponent(AssemblyContext context, ComponentDescriptor descriptor)
    {
      MessageBrokerConnection connection = context.getMessageBroker().createConnection();
  
      // subscribe to the topic associated with the "prepare" message
      connection.subscribe(descriptor.getMessage("prepare").getTopic(), new ContactPrepareListener());
  
      // subscribe to the topic associated with the "copyform" message
     connection.subscribe(descriptor.getMessage("copyform").getTopic(), new ContactCopyFormListener());
 
     // subscribe to the topic associated with the "submit" message
     connection.subscribe(descriptor.getMessage("submit").getTopic(), new ContactSubmitListener());
 
     // subscribe to the topic associated with the "close" message
     connection.subscribe(descriptor.getMessage("close").getTopic(), new ContactCloseListener());
 
     // store descriptor
     this.descriptor = descriptor;
 
     // retrieve information
     model = descriptor.getAttribute("model").getValue();
     errorMessages = descriptor.getAttribute("errorMessages").getValue();
     emailAddressesFormModel = descriptor.getAttribute("emailAddressesFormModel").getValue();
     associatesFormModel = descriptor.getAttribute("associatesFormModel").getValue();
   }
 
   class ContactPrepareListener implements MessageListener
   {
     public void onMessage(Message message)
     {
       // retrieve web objects
       HttpServletRequest request = HttpMessageBrokerContext.getRequest(message.getContext());
       HttpServletResponse response = HttpMessageBrokerContext.getResponse(message.getContext());
       HttpSession session = HttpMessageBrokerContext.getSession(message.getContext());
 
       // get view model
       ModelTree modelTree = ServletModelUtil.getModelTree(session);
 
       // get the contact node
       ModelNode contactNode = modelTree.getNode(modelTree.getRootNode(), model);
 
       // get the id from the form data
       String contactId = message.getProperties().getString("itemId");
 
       // get the email addresses form node
       ModelNode emfNode = modelTree.getNode(modelTree.getRootNode(), emailAddressesFormModel);
 
       // get the associations form node
       ModelNode assocNode = modelTree.getNode(modelTree.getRootNode(), associatesFormModel);
 
       // get the db instance
       DumbDB db = DumbDB.getDumbDB(request, Names.Constants.DumbDB);
 
       // get the contact from the db
       Contact contactData = (Contact)db.getObjectById(contactId);
 
       // just in case
       if (contactData != null)
       {
         // load the node with "data" (from the bean)
         try
         {
           BeanTransformer.beanToModel( contactData, contactNode, true );
         }
         catch( Exception exception )
         {
           exception.printStackTrace();
         }
 
 
         //
         // Emails
         //
 
         // now extract the contact email addresses into the address form
         EmailAddressesController.EmailAddressesForm addresses =
           new EmailAddressesController.EmailAddressesForm();
 
         // set the emails into the addresses form
         addresses.setEmailList(contactData.getBasic().getEmail());
 
         // load the node with "data" (from the bean)
         try
         {
           BeanTransformer.beanToModel( addresses, emfNode, true );
         }
         catch( Exception exception )
         {
           exception.printStackTrace();
         }
 
 
         //
         // Associations
         //
 
         // now extract the contact email addresses into the address form
         ContactAssociatesController.AssociatesForm associatesForm =
           new ContactAssociatesController.AssociatesForm();
 
         // set the emails into the addresses form
         associatesForm.setAssociateList(contactData.getAssociates());
 
         // load the node with "data" (from the bean)
         try
         {
           BeanTransformer.beanToModel( associatesForm, assocNode, true );
         }
         catch( Exception exception )
         {
           exception.printStackTrace();
         }
 
 
         //
         // Completion
         //
 
         // ok we're done preparing, so send the message for display
         MessageBrokerConnection connection = message.getContext().createConnection();
 
         // get the "display" topic"
         String display = descriptor.getMessage("display").getTopic();
 
         // create the success message and send it
         Message displayMessage = connection.createMessage();
         MessageTopic topic = connection.getTopic(display);
         connection.publish(topic, displayMessage);
       }
     }
   }
 
   class ContactSubmitListener implements MessageListener
   {
     public void onMessage(Message message)
     {
       // retrieve web objects
       HttpServletRequest request = HttpMessageBrokerContext.getRequest(message.getContext());
       HttpServletResponse response = HttpMessageBrokerContext.getResponse(message.getContext());
       HttpSession session = HttpMessageBrokerContext.getSession(message.getContext());
 
       // get view model
       ModelTree modelTree = ServletModelUtil.getModelTree(session);
 
       // get the node that is holding the form data
       ModelNode messageNode = modelTree.getNode(modelTree.getRootNode(), model);
 
       // retrieve node to update
       ModelUtil.osmToModel(message.getProperties(), null, messageNode, false);
 
       // validation the form data
       Notices validationErrorMessages = ContactValidation.validate( messageNode );
 
       // were any messages produced
       if (validationErrorMessages != null && validationErrorMessages.getNotices("*",true).size() > 0)
       {
         // ok we're done preparing, so send the message for display
         MessageBrokerConnection connection = message.getContext().createConnection();
 
         // create the success message and send it
         Message responseMessage = connection.createMessage();
 
         // set the error message list into the message
         responseMessage.getProperties().setObject(
           errorMessages,
           validationErrorMessages
         );
 
         // get the "display" topic"
         String display = descriptor.getMessage("display").getTopic();
 
         // create the topic and public the message
         MessageTopic topic = connection.getTopic(display);
         connection.publish(topic, responseMessage);
       }
       // otherwise, continue with the modify
       else
       {
         // ok, we're done, send the message to go back to the main page
         MessageBrokerConnection connection = message.getContext().createConnection();
 
         // get the "next" topic
         String next = descriptor.getMessage("next").getTopic();
 
         // create the success message and send it
         Message displayMessage = connection.createMessage();
         MessageTopic topic = connection.getTopic(next);
         connection.publish(topic, displayMessage);
       }
     }
   }
 
   class ContactCopyFormListener implements MessageListener
   {
     public void onMessage(Message message)
     {
       // retrieve web objects
       HttpServletRequest request = HttpMessageBrokerContext.getRequest(message.getContext());
       HttpServletResponse response = HttpMessageBrokerContext.getResponse(message.getContext());
       HttpSession session = HttpMessageBrokerContext.getSession(message.getContext());
 
       // get view model
       ModelTree modelTree = ServletModelUtil.getModelTree(session);
 
       // get the node that is holding the form data
       ModelNode messageNode = modelTree.getNode(modelTree.getRootNode(), model);
 
       // update the DOM with the form data
       ModelUtil.osmToModel(message.getProperties(), "MainForm", messageNode, false);
     }
   }
 
   class ContactCloseListener implements MessageListener
   {
     public void onMessage(Message message)
     {
       // retrieve web objects
       HttpServletRequest request = HttpMessageBrokerContext.getRequest(message.getContext());
       HttpServletResponse response = HttpMessageBrokerContext.getResponse(message.getContext());
       HttpSession session = HttpMessageBrokerContext.getSession(message.getContext());
 
       // get view model
       ModelTree modelTree = ServletModelUtil.getModelTree(session);
       ModelNode modelNode = modelTree.getNode(modelTree.getRootNode(), model);
 
       // update the DOM with the form data
       ModelUtil.osmToModel(message.getProperties(), null, modelNode, false);
 
       // get the id node
       ModelNode idNode = modelTree.getNode(modelNode, "id/text()");
 
       // get the email addresses form node
       ModelNode emfNode = modelTree.getNode(modelTree.getRootNode(), emailAddressesFormModel);
 
       // get the associations form node
       ModelNode assocNode = modelTree.getNode(modelTree.getRootNode(), associatesFormModel);
 
       // get the id of the contact to use
       String contactId = idNode.getNodeValue();
 
       // validation the form data
       Notices validationErrorMessages = ContactValidation.validate( modelNode );
 
       // were any messages produced
       if (validationErrorMessages != null && validationErrorMessages.getNotices("*",true).size() > 0)
       {
         // ok we're done preparing, so send the message for display
         MessageBrokerConnection connection = message.getContext().createConnection();
 
         // create the success message and send it
         Message responseMessage = connection.createMessage();
 
         // set the error message list into the message
         responseMessage.getProperties().setObject(
           errorMessages,
           validationErrorMessages
         );
 
         // get the "display" topic"
         String display = descriptor.getMessage("display").getTopic();
 
         // create the topic and public the message
         MessageTopic topic = connection.getTopic(display);
         connection.publish(topic, responseMessage);
       }
       // otherwise, continue with the modify
       else
       {
         // get the db instance
         DumbDB db = DumbDB.getDumbDB(request, Names.Constants.DumbDB);
 
         // get the current contact from the db
         Contact contactBean = (Contact)db.getObjectById(contactId);
 
         // just in case
         if (contactBean != null)
         {
           // update contact bean with DOM data
           try
           {
             contactBean =
               (Contact)BeanTransformer.updateBeanFromModel( contactBean, modelNode );
           }
           catch(Exception ex)
           {
             ex.printStackTrace();
           }
 
 
           //
           // Email Addresses
           //
 
           // update the email addresses bean with the DOM data
           EmailAddressesController.EmailAddressesForm emailAddressesForm =
             new EmailAddressesController.EmailAddressesForm();
 
           try
           {
             emailAddressesForm =
               (EmailAddressesController.EmailAddressesForm)
                 BeanTransformer.updateBeanFromModel( emailAddressesForm, emfNode );
           }
           catch(Exception ex)
           {
             ex.printStackTrace();
           }
 
           // update the contact bean emails list with the form data
           contactBean.getBasic().setEmail(emailAddressesForm.getEmailList());
 
 
           //
           // Associations
           //
 
           // update the associations list with the DOM data
           ContactAssociatesController.AssociatesForm assocForm =
             new ContactAssociatesController.AssociatesForm();
 
           try
           {
             assocForm =
               (ContactAssociatesController.AssociatesForm)
                 BeanTransformer.updateBeanFromModel( assocForm, assocNode );
           }
           catch(Exception ex)
           {
             ex.printStackTrace();
           }
 
           // update the contact bean, setting the associations
           contactBean.setAssociates(assocForm.getAssociateList());
 
 
           //
           // save to db
           //
 
           // send the contact to the db
           db.updateObjectById(contactId, contactBean);
 
           // ok we're done preparing, so send the message for display
           MessageBrokerConnection connection = message.getContext().createConnection();
 
           // get the "next" topic
           String next = descriptor.getMessage("next").getTopic();
 
           // create the success message and send it
           Message displayMessage = connection.createMessage();
           MessageTopic topic = connection.getTopic(next);
           connection.publish(topic, displayMessage);
         }
       }
     }
   }
 }