MailProviderMigration.java

Go to the documentation of this file.

/*
 * Turró i Cutiller Foundation. License notice.
 * Copyright (C) 2022 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.mail.provider;
 
import java.util.ArrayList;
import java.util.HashSet;
import java.util.List;
import java.util.Set;
import org.turro.collections.KeyValueMap;
import org.turro.elephant.context.ElephantContext;
import org.turro.elephant.context.HeadlessApplication;
import org.turro.elephant.impl.context.ContextFactory;
import org.turro.mail.impl.MailMessagePool;
import org.turro.mail.impl.MailPool;
import org.turro.string.Strings;
 
public class MailProviderMigration {
 
  public static MailProviderSet migrate() {
    Set<String> ids = new HashSet<>();
    MailProviderSet set = new MailProviderSet();
    List<String> names = new ArrayList<>();
    names.add("IMailMessagePool");
    names.addAll(ContextFactory.getImplementationNamesByType("IMailMessagePool"));
    names.forEach((s) -> {
      MailMessagePool pool = (MailMessagePool) HeadlessApplication.getInstance().getImplementation((String) s);
      MailProvider provider = new MailProvider();
      KeyValueMap attrs = pool.getAttributes();
      String id = ((String) s).substring(((String) s).indexOf("_") + 1);
      if("IMailMessagePool".equals(id)) id = MailProviders.GENERIC;
      if(!ids.contains(id)) {
        provider.setId(id);
        provider.setHostname(attrs.get("mailhost"));
        provider.setPort(attrs.get(Integer.class, "port", null));
        provider.setTls(attrs.get(Boolean.class, "tls", false));
        provider.setSsl(attrs.get(Boolean.class, "ssl", false));
        provider.setUser(attrs.get(String.class, "user", null));
        provider.setPassword(attrs.get(String.class, "cryptpass", null));
        if(Strings.isBlank(provider.getPassword())) {
          provider.setPassword(ElephantContext.encrypt(attrs.get(String.class, "password", null)));
        }
        provider.setFrom(MailRecipient.of(attrs.get(String.class, "from", null)));
        provider.clearEmpties();
        set.addProvider(provider);
        ids.add(id);
      }
    });
    ContextFactory.getImplementationNamesByType("IMailPool").forEach((s) -> {
      MailPool pool = (MailPool) HeadlessApplication.getInstance().getImplementation((String) s);
      MailProvider provider = new MailProvider();
      KeyValueMap attrs = pool.getAttributes();
      String id = ((String) s).substring(((String) s).indexOf("_") + 1);
      if(!ids.contains(id)) {
        provider.setId(id);
        provider.setHostname(attrs.get("mailhost"));
        provider.setPort(attrs.get(Integer.class, "port", null));
        provider.setTls(attrs.get(Boolean.class, "tls", false));
        provider.setSsl(attrs.get(Boolean.class, "ssl", false));
        provider.setUser(attrs.get(String.class, "user", null));
        provider.setPassword(attrs.get(String.class, "cryptpass", null));
        if(Strings.isBlank(provider.getPassword())) {
          provider.setPassword(ElephantContext.encrypt(attrs.get(String.class, "password", null)));
        }
        provider.setFrom(MailRecipient.of(attrs.get(String.class, "from", null)));
        provider.clearEmpties();
        set.addProvider(provider);
        ids.add(id);
      }
    });
    return set;
  }
  
}