SetServerURI.java

Go to the documentation of this file.

/*
 * Project: Server for annotations sharing
 * Author: Ing. Jaroslav Dytrych idytrych@fit.vutbr.cz
 * File: SetServerURI.java
 * Description: Backbean for page for setting of server URI
 */

/**
 * @file SetServerURI.java
 *
 * @brief Backbean for page for setting of server URI
 */

package cz.vutbr.fit.knot.annotations.web;

import cz.vutbr.fit.knot.annotations.app.AppBean;
import cz.vutbr.fit.knot.annotations.app.Constants;
import cz.vutbr.fit.knot.annotations.entity.AnnotType;
import cz.vutbr.fit.knot.annotations.entity.AnnotTypeAttr;
import cz.vutbr.fit.knot.annotations.entity.Annotation;
import cz.vutbr.fit.knot.annotations.entity.ServerSetting;
import cz.vutbr.fit.knot.annotations.entity.StoredDocument;
import cz.vutbr.fit.knot.annotations.entity.TypeAttrOnto;
import cz.vutbr.fit.knot.annotations.modules.StoryscopeInterface.SubscribedItem;
import cz.vutbr.fit.knot.annotations.modules.suggestionManager.Suggestion;
import java.io.Serializable;
import java.util.Iterator;
import java.util.List;
import javax.faces.bean.ManagedBean;
import javax.faces.bean.SessionScoped;
import javax.persistence.EntityManager;
import javax.persistence.EntityTransaction;
import javax.persistence.Query;

/**
 * Backbean for page with administration of users
 *
 * @brief Backbean for administration of users
 * @author idytrych
 */
@ManagedBean
@SessionScoped
public class SetServerURI implements Serializable {
  
  /**
   * Value of New URI field in form
   */
  private String newURI = null;
  /**
   * Error message displayed in form
   */
  private String errorMessage = "";
  
  /**
   * Constructor
   */
  public SetServerURI() {
  }

  /**
   * Gets user selected in the table
   *
   * @return Returns user selected in the table
   */
  public String getCurrentUri() {
    return AppBean.getServerUri();
  }

  /**
   * Gets value for New URI field
   * 
   * @return Returns value for new URI field
   */
  public String getNewUri() {
    return newURI;
  }

  /**
   * Sets value for New URI field
   * 
   * @param newURI Value for New URI field
   */
  public void setNewUri(String newURI) {
    this.newURI = newURI;
  }
  
  /**
   * Action listener for save button
   *
   * @return Returns page outcome (identificator of next page or null to stay here)
   */
  public String btnSaveAction() {
    if(!SessionManager.getSession().isLoggedIn()){
      return "login";
    }
    errorMessage = "";
    
    if (newURI == null || newURI.isEmpty()) {
      errorMessage = errorMessage + MessageProvider.getMessage("uriCanNotBeEmpty") + " ";
      return null;
    }
    
    String oldURI = AppBean.getServerUri();
    AppBean.setServerUri(newURI);  // set new URI
    
    EntityManager em = AppBean.getPersistenceManager().getEM();
    EntityTransaction transaction = em.getTransaction();
    try {
      transaction.begin();
      
      Query q = em.createNamedQuery("Annotation.findAll");
      List aList = q.getResultList();
      if (aList != null && !aList.isEmpty()) {
        Iterator aIt = aList.iterator();
        while (aIt.hasNext()) {
          Annotation a = (Annotation) aIt.next();
          String src = a.getSource();
          String aid = a.getAuthorIdStr();
          if (src != null && src.startsWith(oldURI)) {
            src = newURI + src.substring(oldURI.length(), src.length());
            a.setSource(src);
          }
          if (aid != null && aid.startsWith(oldURI)) {
            aid = newURI + aid.substring(oldURI.length(), src.length());
            a.setAuthorIdStr(aid);
          }
          em.merge(a);
        }
      }
      
      q = em.createNamedQuery("AnnotType.findAll");
      aList = q.getResultList();
      if (aList != null && !aList.isEmpty()) {
        Iterator aIt = aList.iterator();
        while (aIt.hasNext()) {
          AnnotType a = (AnnotType) aIt.next();
          String uri = a.getUri();
          String oUri = a.getUriInOntology();
          if (uri != null && uri.startsWith(oldURI)) {
            uri = newURI + uri.substring(oldURI.length(), uri.length());
            a.setUri(uri);
          }
          if (oUri != null && oUri.startsWith(oldURI)) {
            oUri = newURI + oUri.substring(oldURI.length(), oUri.length());
            a.setUriInOntology(oUri);
          }
          em.merge(a);
        }
      }
      
      q = em.createNamedQuery("AnnotTypeAttr.findAll");
      aList = q.getResultList();
      if (aList != null && !aList.isEmpty()) {
        Iterator aIt = aList.iterator();
        while (aIt.hasNext()) {
          AnnotTypeAttr a = (AnnotTypeAttr) aIt.next();
          String oUri = a.getUriInOntology();
          if (oUri != null && oUri.startsWith(oldURI)) {
            oUri = newURI + oUri.substring(oldURI.length(), oUri.length());
            a.setUriInOntology(oUri);
          }
          em.merge(a);
        }
      }
      
      q = em.createNamedQuery("StoredDocument.findAll");
      aList = q.getResultList();
      if (aList != null && !aList.isEmpty()) {
        Iterator aIt = aList.iterator();
        while (aIt.hasNext()) {
          StoredDocument d = (StoredDocument) aIt.next();
          String oUri = d.getUri();
          if (oUri != null && oUri.startsWith(oldURI)) {
            oUri = newURI + oUri.substring(oldURI.length(), oUri.length());
            d.setUri(oUri);
          }
          em.merge(d);
        }
      }
      
      q = em.createNamedQuery("StoredDocument.findAll");
      aList = q.getResultList();
      if (aList != null && !aList.isEmpty()) {
        Iterator aIt = aList.iterator();
        while (aIt.hasNext()) {
          SubscribedItem i = (SubscribedItem) aIt.next();
          String oUri = i.getSource();
          if (oUri != null && oUri.startsWith(oldURI)) {
            oUri = newURI + oUri.substring(oldURI.length(), oUri.length());
            i.setSource(oUri);
          }
          em.merge(i);
        }
      }
      
      q = em.createNamedQuery("Suggestion.findAll");
      aList = q.getResultList();
      if (aList != null && !aList.isEmpty()) {
        Iterator aIt = aList.iterator();
        while (aIt.hasNext()) {
          Suggestion a = (Suggestion) aIt.next();
          String src = a.getSource();
          String aid = a.getAuthorIdStr();
          if (src != null && src.startsWith(oldURI)) {
            src = newURI + src.substring(oldURI.length(), src.length());
            a.setSource(src);
          }
          if (aid != null && aid.startsWith(oldURI)) {
            aid = newURI + aid.substring(oldURI.length(), src.length());
            a.setAuthorIdStr(aid);
          }
          em.merge(a);
        }
      }
      
      q = em.createNamedQuery("TypeAttrOnto.findAll");
      aList = q.getResultList();
      if (aList != null && !aList.isEmpty()) {
        Iterator aIt = aList.iterator();
        while (aIt.hasNext()) {
          TypeAttrOnto a = (TypeAttrOnto) aIt.next();
          String oUri = a.getUriInOntology();
          if (oUri != null && oUri.startsWith(oldURI)) {
            oUri = newURI + oUri.substring(oldURI.length(), oUri.length());
            a.setUriInOntology(oUri);
          }
          em.merge(a);
        }
      }
      
      q = em.createNamedQuery("ServerSetting.findByName");
      q.setParameter("name", Constants.SERVER_URI_SETTING_NAME);
      aList = q.getResultList();
      ServerSetting s = null;
      if (aList != null && !aList.isEmpty()) {
        s = (ServerSetting) aList.get(0);
        s.setSettingValue(newURI);
      } else {
        s = new ServerSetting(Constants.SERVER_URI_SETTING_NAME, newURI);
      }
      em.merge(s);
      
      em.flush();
      transaction.commit();
    } catch (Exception e) {
      transaction.rollback();
      AppBean.setServerUri(oldURI);
      errorMessage = errorMessage + MessageProvider.getMessage("dbError") + " ";
      return null;
    } finally {
      em.close();
    }

    return "serverSettingList";
  }  // btnSaveAction()
  
  /**
   * Action listener for cancel button
   *
   * @return Returns page outcome (identificator of next page or null to stay here)
   */
  public String btnCancelAction() {
    if(!SessionManager.getSession().isLoggedIn()){
      return "login";
    } else return "serverSettingList";
  }

  /**
   * Gets error message displayed in form
   * @return Returns error message displayed in form
   */
  public String getErrorMessage() {
    return errorMessage;
  }

}  // public class SetServerURI