AnonymousCtrl.java

Go to the documentation of this file.

/*
 * Turró i Cutiller Foundation. License notice.
 * Copyright (C) 2020 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.anonymous;
 
import java.io.IOException;
import java.util.HashMap;
import java.util.Map;
import java.util.logging.Level;
import java.util.logging.Logger;
import org.apache.commons.mail.EmailException;
import org.turro.action.Actions;
import org.turro.action.Contacts;
import org.turro.action.MailSenders;
import org.turro.annotation.ElephantPlugin;
import org.turro.auth.Authentication;
import org.turro.collections.KeyValueMap;
import org.turro.elephant.context.ElephantContext;
import org.turro.elephant.context.IConstructor;
import org.turro.elephant.direct.AbstractDirectContentCtrl;
import org.turro.elephant.direct.DirectContent;
import org.turro.entities.Entities;
import org.turro.json.Jsons;
import org.turro.marker.ElephantMarker;
import org.turro.plugin.contacts.IContact;
import org.turro.util.IdGenerator;
import org.turro.ws.service.WsConstants;
import org.turro.ws.service.p2p.P2PServer;
import org.turro.ws.service.p2p.P2Ps;
import org.zkoss.lang.Strings;
 
@ElephantPlugin(label="anonymous-ctrl")
@DirectContent(identifier="anonymous-action")
public class AnonymousCtrl extends AbstractDirectContentCtrl {
 
  public AnonymousCtrl() {
    super("widgets/anonymous");
    setNeedsUser(true);
  }
 
  public String renderMailContainer(IConstructor constructor, IContact recipe, Object entity) {
    return renderQuestionContainer(constructor, recipe, entity, "mail");
  }
  
  public String renderMailContainer(IConstructor constructor, IContact recipe, Object entity, String template) {
    return renderMailContainer(constructor, recipe.getName(), recipe.getEmail(), entity, template);
  }
  
  public String renderMailContainer(IConstructor constructor, String recipeName, String recipeMail, Object entity) {
    return renderMailContainer(constructor, recipeName, recipeMail, entity, "mail");
  }
  
  public String renderMailContainer(IConstructor constructor, String recipeName, String recipeMail, Object entity, String template) {
    IContact contact = Authentication.getIContact();
    ElephantMarker marker = new ElephantMarker(constructor);
    String containerId = "cic_" + IdGenerator.generate();
    marker.put("containerId", containerId);
    KeyValueMap values = new KeyValueMap();
    values.put("type", "mail-form");
    values.put("senderName", contact.getName());
    values.put("senderMail", contact.getEmail());
    values.put("recipeName", recipeName);
    values.put("recipeMail", recipeMail);
    values.put("entityPath", Entities.getController(entity).getPath());
    values.put("containerId", containerId);
    marker.put("askLink", getAjaxUrl(containerId, values));
    return marker.parse(getTmplRoot(), template);
  }
  
  public String renderQuestionContainer(IConstructor constructor, IContact recipe, Object entity) {
    return renderQuestionContainer(constructor, recipe, entity, "question");
  }
  
  public String renderQuestionContainer(IConstructor constructor, IContact recipe, Object entity, String template) {
    ElephantMarker marker = new ElephantMarker(constructor);
    String containerId = "cic_" + IdGenerator.generate();
    marker.put("containerId", containerId);
    KeyValueMap values = new KeyValueMap();
    values.put("type", "question-form");
    values.put("answerer", recipe.getId());
    values.put("questioner", Authentication.getIContact().getId());
    values.put("entityPath", Entities.getController(entity).getPath());
    values.put("containerId", containerId);
    marker.put("askLink", getAjaxUrl(containerId, values));
    return marker.parse(getTmplRoot(), template);
  }
  
  public void renderAnswerForm(IConstructor constructor) {
    execute(constructor);
  }
  
  public String createAnswerLink(IConstructor constructor, IContact recipe, Object entity) {
    KeyValueMap values = new KeyValueMap();
    values.put("type", "render-answer");
    values.put("answerer", Authentication.getIContact().getId());
    values.put("questioner", recipe.getId());
    values.put("entityPath", Entities.getController(entity).getPath());
    return createLinkTo("/user/widgets/anonymous", values);
  }
  
  /* IEntityCtrl */
 
  @Override
  protected void prepareCleanMarker(ElephantMarker marker, KeyValueMap map) {
    // nothing to do
  }
  
  @Override
  protected void prepareMarker(ElephantMarker marker) {
    // nothing to do
  }
  
  /* IDirectContent */
 
  @Override
  protected String getIdentifier() {
    return AnonymousCtrl.class.getAnnotation(DirectContent.class).identifier();
  }
 
  @Override
  protected void doExecute(IConstructor constructor, KeyValueMap map) {
    String type = map.get("type");
    if("question-form".equals(type)) {
      renderQuestionForm(constructor, map);
    } else if("answer-form".equals(type)) {
      renderAnswerForm(constructor, map);
    } else if("send-question".equals(type)) {
      try {
        processQuestion(constructor, map);
      } catch (EmailException ex) {
        Logger.getLogger(AnonymousCtrl.class.getName()).log(Level.SEVERE, ElephantContext.logMsg(null), ex);
      }
    } else if("send-answer".equals(type)) {
      try {
        processAnswer(constructor, map);
      } catch (EmailException ex) {
        Logger.getLogger(AnonymousCtrl.class.getName()).log(Level.SEVERE, ElephantContext.logMsg(null), ex);
      }
    } else if("mail-form".equals(type)) {
      renderMailForm(constructor, map);
    } else if("send-mail".equals(type)) {
      try {
        processMail(constructor, map);
      } catch (EmailException ex) {
        Logger.getLogger(AnonymousCtrl.class.getName()).log(Level.SEVERE, ElephantContext.logMsg(null), ex);
      }
    } else if("p2pmail-form".equals(type)) {
      renderP2PMailForm(constructor, map);
    } else if("send-p2pmail".equals(type)) {
      try {
        processP2PMail(constructor, map);
      } catch (EmailException ex) {
        Logger.getLogger(AnonymousCtrl.class.getName()).log(Level.SEVERE, ElephantContext.logMsg(null), ex);
      }
    }
  }
 
  private void renderMailForm(IConstructor constructor, KeyValueMap map) {
    ElephantMarker marker = getCleanMarkerFrom(constructor);
    addContainerId(marker, false);
    marker.putAll(map);
    marker.put("newMailLink", getAjaxSubmitUrl(map.get("containerId")));
    try {
      constructor.getResponse().setContentType("text/html");
      constructor.getResponse().setCharacterEncoding(ElephantContext.getEncoding());
      marker.process(getTmplRoot(), "mail-form", constructor.getResponse().getWriter());
    } catch (IOException ex) {
      Logger.getLogger(AnonymousCtrl.class.getName()).log(Level.SEVERE, ElephantContext.logMsg(null), ex);
    }
  }
 
  private void renderP2PMailForm(IConstructor constructor, KeyValueMap map) {
    ElephantMarker marker = getCleanMarkerFrom(constructor);
    addContainerId(marker, false);
    marker.putAll(map);
    marker.put("newP2PMailLink", getAjaxSubmitUrl(map.get("containerId")));
    try {
      constructor.getResponse().setContentType("text/html");
      constructor.getResponse().setCharacterEncoding(ElephantContext.getEncoding());
      marker.process(getTmplRoot(), "p2pmail-form", constructor.getResponse().getWriter());
    } catch (IOException ex) {
      Logger.getLogger(AnonymousCtrl.class.getName()).log(Level.SEVERE, ElephantContext.logMsg(null), ex);
    }
  }
 
  private void renderQuestionForm(IConstructor constructor, KeyValueMap map) {
    ElephantMarker marker = getCleanMarkerFrom(constructor);
    addContainerId(marker, false);
    marker.putAll(map);
    marker.put("newQuestionLink", getAjaxSubmitUrl(map.get("containerId")));
    try {
      constructor.getResponse().setContentType("text/html");
      constructor.getResponse().setCharacterEncoding(ElephantContext.getEncoding());
      marker.process(getTmplRoot(), "question-form", constructor.getResponse().getWriter());
    } catch (IOException ex) {
      Logger.getLogger(AnonymousCtrl.class.getName()).log(Level.SEVERE, ElephantContext.logMsg(null), ex);
    }
  }
 
  private void renderAnswerForm(IConstructor constructor, KeyValueMap map) {
    ElephantMarker marker = getCleanMarkerFrom(constructor);
    addContainerId(marker, false);
    marker.putAll(map);
    marker.process(getTmplRoot(), "answer-form");
  }
 
  private void processMail(IConstructor constructor, KeyValueMap map) throws EmailException {
    String reason = Entities.getController(map.get("entityPath")).getName();
    String comment = map.get("comment");
    if(!Strings.isBlank(comment)) {
      Map args = new HashMap();
      args.put("reason", reason);
      args.put("comment", comment);
      args.put("senderName", map.get("senderMame"));
      args.put("senderMail", map.get("senderMail"));
      MailSenders.getPool()
              .addUser(map.get("recipeName"), map.get("recipeMail"))
              .setRoot("/anonymous")
              .putAll(args)
              .sendTemplate("send-mail", ElephantContext.getSiteName() + ": " + reason);
    }
  }
  
  private void processP2PMail(IConstructor constructor, KeyValueMap map) throws EmailException {
    String comment = map.get("comment");
    if(!Strings.isBlank(comment)) {
      Map args = new HashMap();
      args.put("reason", map.get("reason"));
      args.put("comment", comment);
      args.put("senderName", map.get("senderMame"));
      args.put("senderMail", map.get("senderMail"));
      // Change to Jsons
      Jsons ud = P2Ps.getP2PData(map.get("serverDomain"), map.get(Long.class, "memberId"),
              P2PServer.P2P_SERVICE, WsConstants.USER_DATA, Jsons.object().add("userId", map.get("userId")));
      MailSenders.getPool()
              .addUser(map.get("recipeName"), ud.getString("userEmail"))
              .setRoot("/anonymous")
              .putAll(args)
              .sendTemplate("send-p2pmail", ElephantContext.getSiteName() + ": " + map.get("reason"));
    }
  }
 
 
  private void processQuestion(IConstructor constructor, KeyValueMap map) throws EmailException {
    String reason = Entities.getController(map.get("entityPath")).getName();
    IContact answerer = Contacts.getContactById(map.get("answerer"));
    String comment = map.get("comment");
    if(!Strings.isBlank(comment)) {
      Map args = new HashMap();
      args.put("reason", reason);
      args.put("comment", comment);
      map.put("type", "answer-form");
      args.put("answerLink", createLinkTo("/user/widgets/anonymous", 
              new KeyValueMap(Actions.addEmailAndDays(map, answerer.getEmail(), 15))));
      MailSenders.getPool()
              .addContact(answerer)
              .setRoot("/anonymous")
              .putAll(args)
              .sendTemplate("send-question", ElephantContext.getSiteName() + ": " + reason);
    }
  }
 
  private void processAnswer(IConstructor constructor, KeyValueMap map) throws EmailException {
    String reason = Entities.getController(map.get("entityPath")).getName();
    String comment = map.get("comment");
    if(!Strings.isBlank(comment)) {
      MailSenders.getPool()
              .addContact(Contacts.getContactById(map.get("questioner")))
              .setRoot("/anonymous")
              .put("reason", reason)
              .put("comment", comment)
              .sendTemplate("send-answer", ElephantContext.getSiteName() + ": " + reason);
    }
  }
 
}