elephant/src/main/java/org/turro/plugin/contacts/MailContact.java

Go to the documentation of this file.

/*
 * Turró i Cutiller Foundation. License notice.
 * Copyright (C) 2011 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.plugin.contacts;
 
import java.util.Date;
import java.util.HashSet;
import java.util.List;
import java.util.Set;
import java.util.logging.Level;
import java.util.logging.Logger;
import java.util.regex.Matcher;
import java.util.regex.Pattern;
import org.amic.util.string.Strings;
import org.turro.action.Actions;
import org.turro.action.Contacts;
import org.turro.elephant.context.ElephantContext;
import org.turro.elephant.context.HeadlessApplication;
import org.turro.elephant.security.IUser;
import org.turro.mail.impl.MailPool;
import org.turro.mail.impl.MessagePool;
 
public class MailContact {
 
  private IContact contact;
  private String link, message, exParam;
 
  public MailContact(IContact contact, String link, String message, String exParam) {
    this.contact = contact;
    this.link = link;
    this.message = message;
    this.exParam = exParam;
  }
 
  public String getMessage(Date validUntil, String comment) {
    if(contact == null) return null;
    
    if(message.indexOf("{linkTmpSes}") > -1) {
      try {
//      String key = createTmpKey(validUntil);
//      String server = ElephantContext.getServerUrl("http") +
//              (exParam == null ? "?" : exParam + "&") + "tmpses=" + key;
        String server = ElephantContext.getServerUrl("http") + "?" +
                Actions.createAction(contact.getConnector(IUser.CONNECTOR_EMAIL), exParam);
        message = message.replaceAll("\\{linkTmpSes\\}", "<a style=\"color:inherit\" href=\"" + server + "\">" + link + "</a>");
      } catch (Exception ex) {
        Logger.getLogger(MailContact.class.getName()).log(Level.SEVERE, ElephantContext.logMsg(null), ex);
      }
    }
    message = processWebLiveLinks(validUntil, message);
    message = processWebLinks(message);
    message = processLinkMacros(message);
    message = processImgWidth(message);
 
    message = message.replaceAll("\\{email\\}", contact.getEmail())
             .replaceAll("\\{name\\}", contact.getName())
             .replaceAll("\\{comment\\}", comment);
 
    String serverBase = ElephantContext.getServerBase("http");
    return message.replaceAll("href=\\'(?![a-z]+:)(\\/?)\\/?([^\\']*)\\'", "href=\\'" + serverBase + "$1$2\\'")
                   .replaceAll("src=\\'(?![a-z]+:)(\\/?)\\/?([^\\']*)\\'", "src=\\'" + serverBase + "$1$2\\'")
                   .replaceAll("href=\\\"(?![a-z]+:)(\\/?)\\/?([^\\\"]*)\\\"", "href=\\\"" + serverBase + "$1$2\\\"")
                   .replaceAll("src=\\\"(?![a-z]+:)(\\/?)\\/?([^\\\"]*)\\\"", "src=\\\"" + serverBase + "$1$2\\\"");
  }
 
  public String getEmail() {
    return getEmail(contact);
  }
 
//  public String createTmpKey(Date validUntil) {
//    if(validUntil == null) {
//      validUntil = new Date(new Date().getTime() + (2L * 24L * 60L * 60L * 1000L));
//    }
//    IUser user = ContextFactory.getUser(HeadlessApplication.getInstance().getConstructor());
//    if (user.impersonate(contact.getId())) {
//      return user.createTmpKey(validUntil);
//    }
//    return null;
//  }
 
  public static String getEmail(IContact contact) {
    if (contact == null) {
      return null;
    }
    String email = contact.getConnector(IUser.CONNECTOR_EMAIL);
    return email == null ? null : (!Contacts.isValidEmail(email) ? null : email);
  }
 
  public static void sendToIPlayers(List<IContact> contacts, String link, String subject,
          String message, String comment, ILinkSolver exParam, String implementation) {
    MailPool mp = (MailPool) HeadlessApplication.getInstance().getImplementation(implementation);
    if(mp != null) {
      mp.setEncoding(ElephantContext.getEncoding());
      mp.addCssFile(ElephantContext.getRealPath("/_internal/css/mail.css"));
 
      Set<MailContact> emails = new HashSet<>();
      for(IContact contact : contacts) {
        emails.add(new MailContact(contact, link, message, exParam != null ? exParam.getLink(contact) : null));
      }
      for(MailContact mc : emails) {
        mp.addToPool(null, mc.getEmail(), null, subject, mc.getMessage(null, comment), "text/html");
      }
      mp.sendPool();
    }
  }
 
  public static void poolToIPlayers(List<IContact> contacts, String link,
          String message, String comment, ILinkSolver exParam, MessagePool pool) {
    Set<MailContact> emails = new HashSet<>();
    for(IContact contact : contacts) {
      emails.add(new MailContact(contact, link, message, exParam != null ? exParam.getLink(contact) : null));
    }
    for(MailContact mc : emails) {
      pool.addMessage(mc.getEmail(), mc.getMessage(null, comment));
    }
  }
 
  @Override
  public boolean equals(Object obj) {
    if (obj == null) {
      return false;
    }
    if (getClass() != obj.getClass()) {
      return false;
    }
    final MailContact other = (MailContact) obj;
    if (this.contact.getId() != other.contact.getId() && (this.contact.getId() == null || !this.contact.getId().equals(other.contact.getId()))) {
      return false;
    }
    return true;
  }
 
  @Override
  public int hashCode() {
    int hash = 7;
    hash = 31 * hash + (this.contact != null && this.contact.getId() != null ? this.contact.getId().hashCode() : 0);
    return hash;
  }
  
  public static String createLink(String text, String path, boolean live) {
    if(!Strings.isBlank(text)) {
      StringBuilder sb = new StringBuilder((live ? "{livelink:" : "{link:"));
      sb.append(text.replaceAll("\\:", "&colon;").replaceAll("\\}", "&endkey;"));
      if(!Strings.isBlank(path)) {
        sb.append(":");
        sb.append(path);
      }
      sb.append("}");
      return sb.toString();
    }
    return "";
  }
 
  public static String processLinkMacros(String text) {
    if(!Strings.isBlank(text)) {
      return text.replaceAll("\\&colon\\;", ":").replaceAll("\\&endkey\\;", "}");
    }
    return "";
  }
  
  private String nextParamSep(String params) {
    if(params.indexOf("?") > -1) {
      return "&";
    }
    return "?";
  }
 
  private String processWebLiveLinks(Date validUntil, String message) {
 
    if(message.contains("{livelink")) {
      Pattern pat = Pattern.compile(LIVE_LINK_PATTERN);
      Matcher mat = pat.matcher(message);
      StringBuffer result = new StringBuffer();
      while(mat.find()) {
        try {
//          String key = createTmpKey(validUntil);
          String currParam = exParam;
          if(mat.groupCount() > 1 && !Strings.isBlank(mat.group(2))) {
            currParam = (currParam == null ? "" : currParam) + mat.group(2);
          }
//        String server = ElephantContext.getServerUrl("http") +
//              (currParam == null ? "" : currParam + nextParamSep(currParam)) + "tmpses=" + key;
          currParam = currParam == null ? "" : currParam + nextParamSep(currParam);
          String server = ElephantContext.getServerUrl("http") + "?" +
                  Actions.createAction(contact.getConnector(IUser.CONNECTOR_EMAIL), currParam);
          mat.appendReplacement(result, "<a href=\"" + server + "\">" + mat.group(1) + "</a>");
        } catch (Exception ex) {
          Logger.getLogger(MailContact.class.getName()).log(Level.SEVERE, ElephantContext.logMsg(null), ex);
        }
      }
      mat.appendTail(result);
      return result.toString();
    }
    return message;
 
  }
 
  private String processWebLinks(String message) {
 
    if(message.contains("{link")) {
      Pattern pat = Pattern.compile(LINK_PATTERN);
      Matcher mat = pat.matcher(message);
      StringBuffer result = new StringBuffer();
      while(mat.find()) {
        try {
          String currParam = exParam;
          if(mat.groupCount() > 1 && !Strings.isBlank(mat.group(2))) {
            currParam = (currParam == null ? "" : currParam) + mat.group(2);
          }
//        String server = ElephantContext.getServerUrl("http") +
//              (currParam == null ? "" : currParam);
          currParam = currParam == null ? "" : currParam;
          String server = ElephantContext.getServerUrl("http") + "?" +
                  Actions.createAction(contact.getConnector(IUser.CONNECTOR_EMAIL), currParam);
          mat.appendReplacement(result, "<a href=\"" + server + "\">" + mat.group(1) + "</a>");
        } catch (Exception ex) {
          Logger.getLogger(MailContact.class.getName()).log(Level.SEVERE, ElephantContext.logMsg(null), ex);
        }
      }
      mat.appendTail(result);
      return result.toString();
    }
    return message;
 
  }
 
  private static final String LIVE_LINK_PATTERN = "\\{livelink\\:([^\\:\\}]*)\\:?([^\\:\\}]*)\\}";
  private static final String LINK_PATTERN = "\\{link\\:([^\\:\\}]*)\\:?([^\\:\\}]*)\\}";
 
  private String processImgWidth(String message) {
    return message.replaceAll("\\<img ", "<img style=\"width:100%\" ");
  }
}