ProfileMigration.java

Go to the documentation of this file.

/*
 * Turró i Cutiller Foundation. License notice.
 * Copyright (C) 2021 Lluis Turró Cutiller <http://www.turro.org/>
 *
 * This program is free software: you can redistribute it and/or modify
 * it under the terms of the GNU Affero General Public License as published by
 * the Free Software Foundation, either version 3 of the License, or
 * (at your option) any later version.
 *
 * This program 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 Affero General Public License for more details.
 *
 * You should have received a copy of the GNU Affero General Public License
 * along with this program.  If not, see <http://www.gnu.org/licenses/>.
 */
 
package org.turro.contacts.profile;
 
import java.util.stream.Stream;
import org.turro.contacts.BusinessRelation;
import org.turro.contacts.Connector;
import org.turro.contacts.Contact;
import org.turro.contacts.db.ContactsPU;
import org.turro.jpa.Dao;
import org.turro.jpa.DaoUtil;
import org.turro.www.directory.EditDataControl;
 
public class ProfileMigration {
  
  public static void migrate() {
    ProfileMigration migration = new ProfileMigration();
    if(migration.isNecessary()) {
      migration.start();
    }
  }
 
  private boolean isNecessary() {
    Dao dao = new ContactsPU();
    return (DaoUtil.isEmpty(dao, "Connector", "where x.description = ?", Profile.PHONE) && 
           !DaoUtil.isEmpty(dao, "Connector", "where x.description = ?", EditDataControl.PHONE_DIRECTORY)) ||
           (DaoUtil.isEmpty(dao, "Connector", "where x.description = ?", Profile.NETWORK) && 
           !DaoUtil.isEmpty(dao, "Connector", "where x.description = ?", EditDataControl.NETWORK_DIRECTORY));
  }
 
  private void start() {
    Dao dao = new ContactsPU();
    try(Stream<Connector> connectors = new ContactsPU().stream(Connector.class, "select c from Connector c")) {
      connectors.forEach((connector) -> {
        if(EditDataControl.PHONE_DIRECTORY.equals(connector.getDescription())) {
          Connector con = new Connector();
          con.setContact(connector.getContact());
          con.setDescription(Profile.PHONE);
          con.setValue(connector.getValue());
          con.setOnlyOwner(false);
          saveIfDontExists(dao, con);
        } else if(EditDataControl.NETWORK_DIRECTORY.equals(connector.getDescription())) {
          Connector con = new Connector();
          con.setContact(connector.getContact());
          con.setDescription(Profile.NETWORK);
          con.setValue(connector.getValue());
          con.setOnlyOwner(false);
          saveIfDontExists(dao, con);
        } else if(EditDataControl.POSITION_DIRECTORY.equals(connector.getDescription())) {
          Contact c = connector.getContact();
          if(c.getBusinessRelations().size() == 1) {
            BusinessRelation br = c.getBusinessRelations().iterator().next();
            br.setDescription(connector.getValue());
            dao.saveObject(br);
          }
        }
      });
    }
  }
 
  private void saveIfDontExists(Dao dao, Connector con) {
    if(DaoUtil.isEmpty(dao, "Connector", "where x.description = ? and x.contact = ?", con.getDescription(), con.getContact())) {
      dao.saveObject(con);
    }
  }
 
}