SignUpCtrl.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.contacts.zul.register;
 
import java.util.HashMap;
import java.util.List;
import java.util.logging.Level;
import java.util.logging.Logger;
import org.turro.string.Strings;
import org.apache.commons.mail.EmailException;
import org.turro.action.IRegisterCallback;
import org.turro.annotation.ElephantPlugin;
import org.turro.auth.Authentication;
import org.turro.collections.KeyValueMap;
import org.turro.contacts.SignUp;
import org.turro.contacts.db.ContactsPU;
import org.turro.elephant.context.Application;
import org.turro.elephant.context.ElephantContext;
import org.turro.elephant.context.IConstructor;
import org.turro.elephant.direct.AbstractDirectEntityCtrl;
import org.turro.elephant.direct.DirectContent;
import org.turro.i18n.I_;
import org.turro.jpa.Dao;
import org.turro.mail.sender.MailPool;
import org.turro.marker.ElephantMarker;
 
@ElephantPlugin(label="signup-ctrl")
@DirectContent(identifier="signup-action")
public class SignUpCtrl extends AbstractDirectEntityCtrl {
 
  public SignUpCtrl() {
    super("widgets/auth", "user");
  }
 
  /* IEntityCtrl */
  
  @Override
  protected void prepareMarker(ElephantMarker marker) {
    marker.put("type", "sign-up");
    marker.put("actionLink", createFormAction());
  }
  
  /* IDirectContent */
 
  @Override
  protected String getIdentifier() {
    return SignUpCtrl.class.getAnnotation(DirectContent.class).identifier();
  }
 
  @Override
  protected void doExecute(IConstructor constructor, KeyValueMap map) {
    String type = map.get("type");
    if("sign-up".equals(type)) {
      processSignUp(constructor, map);
    }
  }
  
  @Override
  protected void prepareCleanMarker(ElephantMarker marker, KeyValueMap map) {
    throw new UnsupportedOperationException("Not supported yet.");
  }
 
  private void processSignUp(IConstructor constructor, KeyValueMap map) {
    if(isValidMap(map)) {
      SignUp su = new SignUp();
      su.setName(map.get("name"));
      su.setEmail(map.get("email"));
      su.setComment(map.get("comment"));
      if(su.isValid()) {
        SignUp pending = existPending(su.getEmail());
        if(pending != null) {
          sendEmail(pending);
        } else if(existEmail(su.getEmail())) {
          Authentication.sendReminder(constructor, su.getName(), su.getEmail());
        } else {
          su.setValueMap(keepValues(map));
          su = new ContactsPU().saveObject(su);
          sendEmail(su);
        }
      }
    }
  }
 
  private boolean isValidMap(KeyValueMap map) {
    return !Strings.isBlank(map.get("name")) && !Strings.isBlank(map.get("email"));
  }
  
  private SignUp existPending(String email) {
    Dao dao = new ContactsPU();
    List l = dao.getResultList(
            "select c from SignUp c where c.email = ? and confirmed = FALSE",
            new Object[] { email }
    );
    return !l.isEmpty() ? (SignUp) l.get(0) : null;
  }
 
  private static boolean existEmail(String email) {
    Dao dao = new ContactsPU();
    List l = dao.getResultList(
            "select c from Connector c where c.value = ?",
            new Object[] { email }
    );
    if(l.isEmpty()) {
      l = dao.getResultList(
              "select c from SignUp c where c.email = ? and confirmed = TRUE",
              new Object[] { email }
      );
    }
    return !l.isEmpty();
  }
 
  private void sendEmail(SignUp signUp) {
    try {
      new MailPool()
              .addUser(signUp.getName(), signUp.getEmail())
              .put("signUp", signUp)
              .sendTemplate("sign-pending", I_.get("Email pending to confirm") + " : " + ElephantContext.getSiteName());
      IRegisterCallback regcall = (IRegisterCallback) Application.getApplication().getConstructor()
              .getSessionAttribute(IRegisterCallback.REGISTER_CALLBACK_KEY);
      if(regcall != null) {
        regcall.onRegister(signUp.getEmail());
      }
    } catch (EmailException ex) {
      Logger.getLogger(SignUpCtrl.class.getName()).log(Level.SEVERE, null, ex);
    }
  }
 
  private String keepValues(KeyValueMap map) {
    HashMap<String, String> keep = new HashMap<>();
    for(String key : map.keySet()) {
      if(key.startsWith("su_")) {
        keep.put(key, map.get(key));
      }
    }
    return keep.isEmpty() ? null : KeyValueMap.format(keep);
  }
 
}