DefaultContact.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.contacts.util;
 
import java.io.Serializable;
import java.util.ArrayList;
import java.util.Collection;
import java.util.Collections;
import java.util.Date;
import java.util.HashMap;
import java.util.List;
import java.util.Locale;
import java.util.Map;
import java.util.Objects;
import java.util.Optional;
import java.util.Set;
import java.util.logging.Level;
import java.util.logging.Logger;
import org.turro.string.Strings;
import org.turro.action.Plugins;
import org.turro.actor.Actors;
import org.turro.annotation.ElephantContact;
import org.turro.auth.Authentication;
import org.turro.collections.KeyValueMap;
import org.turro.contacts.BusinessRelation;
import org.turro.contacts.Comment;
import org.turro.contacts.Connector;
import org.turro.contacts.Contact;
import org.turro.contacts.ContactType;
import org.turro.contacts.Syndication;
import org.turro.contacts.db.ContactsPU;
import org.turro.contacts.relation.FuzzyRelationTypes;
import org.turro.contacts.relation.Relations;
import org.turro.contacts.zul.menu.ContactMenu;
import org.turro.elephant.context.Application;
import org.turro.elephant.context.ElephantContext;
import org.turro.elephant.db.WhereClause;
import org.turro.elephant.security.IUser;
import org.turro.entities.ContactEntities;
import org.turro.entities.Faces;
import org.turro.file.util.FileAttach;
import org.turro.i18n.Locales;
import org.turro.jpa.Dao;
import org.turro.plugin.contacts.CompoundId;
import org.turro.plugin.contacts.IContact;
import org.turro.plugin.contacts.IProfile;
import org.turro.plugin.contacts.IRelations;
import org.turro.security.ContactPermissions;
import org.turro.security.FlatPermissions;
import org.turro.security.Permissions;
import org.turro.security.SocialGroups;
import org.turro.string.Words;
import org.turro.util.CompareUtil;
 
@ElephantContact(priority=1)
public class DefaultContact implements IContact, Serializable, Comparable<IContact> {
 
  protected Contact contact = null;
 
  public DefaultContact() {
  }
 
  public DefaultContact(Object object) {
    this.contact = (Contact) object;
  }
  
  public DefaultContact(Contact contact) {
    this.contact = contact;
  }
  
  @Override
  public Object loadById(String id) {
    setContact(null);
    if(!Strings.isBlank(id)) {
      setContact(new ContactsPU().find(Contact.class, id));
    }
    return contact;
  }
 
  @Override
  public Object loadByLogin(String login) {
    setContact((Contact) new ContactsPU().getSingleResultOrNull(
            "select c from Contact as c where c.login = ? or c.id = ?", 
            new String[] { login, login }));
    return contact;
  }
 
  @Override
  public Object loadLogged(Application app) {
    IUser user = app.getConstructor().getUser();
    if(user instanceof IContact) {
      setContact((Contact) ((IContact) user).getContact());
      return user;
    } else {
      return user != null ? loadByLogin(app.getConstructor().getUser().getId()) : null;
    }
  }
 
  @Override
  public Object getContact() {
    return contact;
  }
 
  @Override
  public void setContact(Object contact) {
    this.contact = (Contact) contact;
    //_roles = null;
    _syndications = null;
  }
  
  @Override
  public String getId() {
    return contact != null ? contact.getId() : null;
  }
 
  @Override
  public String getGlobalId() {
    return contact != null ? contact.getGlobalIdentifier() : null;
  }
 
  @Override
  public String getGrouping() {
    return contact != null ? contact.getGrouping() : null;
  }
 
  @Override
  public String getDeepGrouping() {
    Contact business = contact;
    while(business != null) {
      if(!Strings.isBlank(business.getGrouping())) {
        return business.getGrouping();
      }
      business = business.getBusiness();
    }
    return null;
  }
  
  @Override
  public String getLogin() {
    return contact != null ? contact.getLogin() : null;
  }
  
  @Override
  public String getName() {
    return contact != null ? contact.getName().trim() : "";
  }
 
  @Override
  public String getFriendly() {
    return contact != null ? contact.getFriendly().trim() : "";
  }
 
  @Override
  public String getFormal() {
    return contact != null ? contact.getFormal().trim() : "";
  }
 
  @Override
  public String getFullName() {
    return contact != null ? contact.getFullName().trim() : "";
  }
 
  @Override
  public String getTradeName() {
    return contact != null ? contact.getTradeName().trim() : "";
  }
 
  @Override
  public String getEmail() {
    return getConnector(IUser.CONNECTOR_EMAIL);
  }
 
  @Override
  public Locale getLocale() {
    return contact != null ? contact.getLocale() : null;
  }
 
  @Override
  public String getConnector(String id) {
    if(contact != null) {
      for(Connector connector : contact.getConnectors()) {
        if(id.equalsIgnoreCase(connector.getDescription())) {
          return connector.getValue();
        }
      }
    }
    return null;
  }
 
  @Override
  public List<String> getConnectorList(String id) {
    ArrayList<String> list = new ArrayList<>();
    if(contact != null) {
      for(Connector connector : contact.getConnectors()) {
        if(id.equalsIgnoreCase(connector.getDescription())) {
          list.add(connector.getValue());
        }
      }
    }
    return list;
  }
 
  /* Relations */
  
  private IRelations _companies, _staff;
  
  @Override
  public IRelations getCompanyRelations() {
    if(_companies == null) _companies = Relations.companies(this);
    return _companies;
  }
 
  @Override
  public IRelations getStaffRelations() {
    if(_staff == null) _staff = Relations.staff(this);
    return _staff;
  }
 
  @Override
  public List<IContact> getRelations(String id) {
    List<IContact> list = new ArrayList<>();
    if(contact != null) {
      for(BusinessRelation relation : contact.getBusinessSet()) {
        if(id.equalsIgnoreCase(relation.getDescription())) {
          list.add(relation.getBusiness().getIContact());
        }
      }
    }
    return list;
  }
 
  @Override
  public List<IContact> getRelations() {
    List<IContact> list = new ArrayList<>();
    if(contact != null) {
      for(BusinessRelation relation : contact.getBusinessSet()) {
        list.add(relation.getBusiness().getIContact());
      }
      for(BusinessRelation relation : contact.getWorkerSet()) {
        list.add(relation.getContact().getIContact());
      }
    }
    return list;
  }
 
  @Override
  public IContact getBusiness() {
    if(contact != null) {
      Contact b = contact.getBusiness();
      if(b != null) {
        return b.getIContact();
      }
    }
    return null;
  }
 
  @Override
  public List<IContact> getBusinessList() {
    org.turro.plugin.contacts.ContactList list = new org.turro.plugin.contacts.ContactList();
    if(contact != null) {
      for(Contact c : contact.getBusinessList()) {
        if(!c.getId().equals(contact.getId())) {
          list.add(c.getIContact());
        }
      }
    }
    return list;
  }
 
  @Override
  public List<IContact> getCoworkers() {
    org.turro.plugin.contacts.ContactList list = new org.turro.plugin.contacts.ContactList();
    if(contact != null) {
      for(Contact c : contact.getCoworkers()) {
        if(!c.getId().equals(contact.getId())) {
          list.add(c.getIContact());
        }
      }
    }
    return list;
  }
 
  @Override
  public List<IContact> getCoworkers(IContact business) {
    org.turro.plugin.contacts.ContactList list = new org.turro.plugin.contacts.ContactList();
    if(contact != null) {
      for(Contact c : contact.getCoworkers((Contact) business.getContact())) {
        if(!c.getId().equals(contact.getId())) {
          list.add(c.getIContact());
        }
      }
    }
    return list;
  }
 
  @Override
  public boolean isInBusiness(IContact worker) {
    return getCoworkers().contains(worker);
  }
 
  @Override
  public void setConnector(String id, String value) {
    if(contact != null) {
      for(Connector connector : contact.getConnectors()) {
        if(id.equalsIgnoreCase(connector.getDescription())) {
          connector.setValue(value);
          return;
        }
      }
      Connector connector = new Connector();
      connector.setOwner(contact.getOwner());
      connector.setOnlyOwner(false);
      connector.setContact(contact);
      connector.setDescription(id);
      connector.setValue(value);
      contact.getConnectors().add(connector);
    }
  }
 
  @Override
  public void setName(String value) {
    if(contact != null) {
      contact.setName(value);
      contact.getComplexName().setFull(value);
    }
  }
 
  @Override
  public void setPassword(String newValue, String repeatValue) {
    if(newValue != null && newValue.trim().length() > 0 && newValue.equals(repeatValue)) {
      try {
        contact.setPass1(ElephantContext.encrypt(newValue));
      } catch (Exception ex) {
        Logger.getLogger(DefaultContact.class.getName()).log(Level.SEVERE, ElephantContext.logMsg(null), ex);
      }
    }
  }
 
  @Override
  public void applyChanges() {
    try {
      new org.turro.contacts.form.ContactWrapper(contact).save();
    } catch (Exception ex) {
      Logger.getLogger(DefaultContact.class.getName()).log(Level.SEVERE, ElephantContext.logMsg(null), ex);
    }
  }
 
  @Override
  public boolean isValid() {
    return contact != null;
  }
 
  @Override
  public boolean checkPassword(String password) {
    try {
      return ElephantContext.encrypt(password).equals(contact.getPass1());
    } catch (Exception ex) {
      Logger.getLogger(DefaultContact.class.getName()).log(Level.SEVERE, ElephantContext.logMsg(null), ex);
    }
    return false;
  }
 
  public boolean checkPassword2(String password) {
    try {
      return ElephantContext.encrypt(password).equals(contact.getPass2());
    } catch (Exception ex) {
      Logger.getLogger(DefaultContact.class.getName()).log(Level.SEVERE, ElephantContext.logMsg(null), ex);
    }
    return false;
  }
 
  @Override
  public String getCommentValue(String key) {
    String comment = null, lang = key + Application.getUsedLocale();
    for(Comment c : contact.getComments()) {
      if(!Strings.isBlank(c.getComment()) && c.getComment().startsWith(lang)) {
        comment = c.getComment().substring(lang.length());
        break;
      }
    }
    if(org.turro.string.Strings.isBlank(comment)) {
      lang = key + "#";
      for(Comment c : contact.getComments()) {
        if(!Strings.isBlank(c.getComment()) && c.getComment().startsWith(lang)) {
          comment = c.getComment().substring(lang.length());
          break;
        }
      }
    }
    return comment;
  }
 
  @Override
  public Object getObject(String key) {
    return contact.getObject(key);
  }
 
  @Override
  public void setObject(String key, Serializable value) {
    contact.setObject(key, value);
  }
 
  @Override
  public boolean isWebUser() {
    return contact == null ? false : (!contact.isDeactivated() && contact.isWebUser());
  }
 
  @Override
  public boolean isWebapp() {
    return contact == null ? false : contact.isWebapp();
  }
 
  @Override
  public boolean isUserMenu() {
    return contact == null ? false : contact.isUserMenu();
  }
 
  @Override
  public boolean isDeactivated() {
    return contact == null ? true : contact.isDeactivated();
  }
 
  private ArrayList<String> _syndications = null;
 
  @Override
  public List<String> getSyndications() {
    if(_syndications == null) {
      _syndications = new ArrayList<>();
      for(Syndication s : contact.getSyndications()) {
        _syndications.add(s.getName());
      }
    }
    return _syndications;
  }
 
  private FlatPermissions _permissions = null;
  
  @Override
  public FlatPermissions getPermissions() {
    if(_permissions == null) {
      _permissions = new ContactPermissions(this);
    }
    return _permissions;
  }
 
  @Override
  public void resetPermissions() {
    _permissions = null;
  }
 
  @Override
  public IUser getAsUser() {
    return this;
  }
 
  @Override
  public boolean acceptsLang(String lang) {
    return Locales.checkLanguage(contact.getLocale(), lang);
  }
 
  @Override
  public List<IContact> loadByPartialName(String name) {
    return loadByPartialName(name, null);
  }
 
  @Override
  public List<IContact> loadByPartialName(String name, KeyValueMap kvm) {
    ArrayList<IContact> list = new ArrayList<IContact>();
    if(name != null && name.trim().length() > 2) {
      ContactEntities ce = new ContactEntities();
      for(Contact c : ((Collection<Contact>) ce.getEntitites("contact", name, 0, kvm))) {
        list.add(c.getIContact());
      }
    }
    return list;
  }
 
  @Override
  public IContact loadByName(String name) {
    Contact c = (Contact) new ContactsPU().getSingleResultOrNull(
            "select c from Contact as c where c.name = ?", 
            new String[] { name });
    return c == null ? null : c.getIContact();
  }
 
  @Override
  public IContact loadByEmail(String email) {
    Contact c = (Contact) new ContactsPU().getSingleResultOrNull(
            "select c.contact from Connector as c where c.description = ? and c.value = ?", 
            new String[] { IUser.CONNECTOR_EMAIL, email });
    return (c == null || c.isDeactivated()) ? null : c.getIContact();
  }
 
  public static String fullName(String contactId) {
    Object o = new ContactsPU().getSingleResult(
            "select name from Contact contact " +
            "where contact.id = ?",
            new Object[] {
              contactId
            });
    return (String) o;
  }
 
  @Override
  public void setAttribute(String key, Object value) {
    contact.setAttribute(key, value);
  }
 
  @Override
  public Object getAttribute(String key) {
    return contact.getAttribute(key);
  }
 
  @Override
  public List<IContact> getBySyndication(String syndication) {
    ArrayList<IContact> list = new ArrayList<>();
    if(!Strings.isBlank(syndication)) {
      if("hhrr".equals(syndication)) {
        list.addAll(getHHRR());
      } else if("student".equals(syndication)) {
        list.addAll(getStudents());
      } else {
        for(Contact c : (List<Contact>) new ContactsPU().getResultList(
                  "select s.contact from Syndication as s where s.name = ?", 
                  new String[] { syndication })) {
          list.add(c.getIContact());
        }
      }
    }
    return list;
  }
 
  @Override
  public List<IContact> getByRole(String role) {
    ArrayList<IContact> list = new ArrayList<>();
    if(!Strings.isBlank(role)) {
      List<String> syndicationNames = List.copyOf(Permissions.getSecurityGroupIdsBy(role));
      WhereClause wc = new WhereClause();
      wc.addClause("select distinct syndication.contact from Syndication as syndication");
      wc.addClause("where syndication.name in (:syndicationNames)");
      wc.addNamedValue("syndicationNames", syndicationNames);
      for(Contact c : (List<Contact>) new ContactsPU().getResultList(wc)) {
        list.add(c.getIContact());
      }
    }
    return list;
  }
 
  @Override
  public List<IContact> getByGrouping(String grouping) {
    return getByGrouping(Collections.singletonList(grouping));
  }
 
  @Override
  public List<IContact> getByGrouping(List<String> groupings) {
    ArrayList<IContact> list = new ArrayList<>();
    if(groupings != null && !groupings.isEmpty()) {
      WhereClause wc = new WhereClause();
      wc.addClause("select contact from Contact as contact");
      wc.addClause("where contact.grouping in (:groupings)");
      wc.addNamedValue("groupings", groupings);
      for(Contact c : (List<Contact>) new ContactsPU().getResultList(wc)) {
        list.add(c.getIContact());
      }
    }
    return list;
  }
 
  @Override
  public List<IContact> getCompanies() {
    ArrayList<IContact> list = new ArrayList<>();
    WhereClause wc = new WhereClause();
    wc.addClause("select contact from Contact as contact");
    wc.addClause("where contact.type = :type");
    wc.addNamedValue("type", ContactType.CONTACT_COMPANY);
    for(Contact c : (List<Contact>) new ContactsPU().getResultList(wc)) {
      list.add(c.getIContact());
    }
    return list;
  }
 
  @Override
  public List<IContact> getCenters() {
    ArrayList<IContact> list = new ArrayList<>();
    WhereClause wc = new WhereClause();
    wc.addClause("select contact from Contact as contact");
    wc.addClause("where contact.type = :type");
    wc.addNamedValue("type", ContactType.CONTACT_LEARNINGCENTER);
    for(Contact c : (List<Contact>) new ContactsPU().getResultList(wc)) {
      list.add(c.getIContact());
    }
    return list;
  }
 
  @Override
  public List<IContact> getHHRR() {
    ArrayList<IContact> list = new ArrayList<>();
    WhereClause wc = new WhereClause();
    wc.addClause("select contact from Contact as contact");
    wc.addClause("left outer join contact.businessRelations relation");
    FuzzyRelationTypes.isHHRR(wc, "where", "relation");
    for(Contact c : (List<Contact>) new ContactsPU().getResultList(wc)) {
      list.add(c.getIContact());
    }
    return list;
  }
  
  @Override
  public List<IContact> getStudents() {
    ArrayList<IContact> list = new ArrayList<>();
    WhereClause wc = new WhereClause();
    wc.addClause("select contact from Contact as contact");
    wc.addClause("left outer join contact.businessRelations relation");
    FuzzyRelationTypes.isStudent(wc, "where", "relation");
    for(Contact c : (List<Contact>) new ContactsPU().getResultList(wc)) {
      list.add(c.getIContact());
    }
    return list;
  }
  
  @Override
  public void startContactFromValues(KeyValueMap values) {
    Contact newContact = new Contact();
    if(values.containsKey("name")) {
      newContact.setName(values.get(String.class, "name"));
    }
    if(values.containsKey("email")) {
      Connector connector = new Connector();
      connector.setContact(newContact);
      connector.setDescription(IUser.CONNECTOR_EMAIL);
      connector.setValue(values.get(String.class, "email"));
      newContact.getConnectors().add(connector);
    }
    ContactMenu.showContact(newContact);
  }
 
  @Override
  public void syndicate(String syndicationName, boolean syndicate) {
    Dao dao = new ContactsPU();
    if(syndicate) {
      SocialGroups.syndicate(List.of(contact), Set.of(syndicationName), null);
    } else {
      SocialGroups.unsyndicate(List.of(contact), Set.of(syndicationName), null);
    }
    setContact(dao.saveObject(contact));
    SocialGroups.checkInheritance(List.of(contact), dao);
  }
 
  @Override
  public String getFace() {
    FileAttach fileAttach = new FileAttach(ContactsPU.getObjectPath(contact));
    String faceFile = fileAttach.getPublicFile("/profile/face.png", false);
    return !Strings.isBlank(faceFile) ? faceFile : null;
  }
 
  @Override
  public Faces getFaces() {
    return Faces.of(this);
  }
 
  @Override
  public IProfile getProfile() {
    return contact.getProfile();
  }
 
  @Override
  public boolean isAdmin() {
    return getSyndications().contains("brightside_admin");
  }
 
  @Override
  public boolean isUser() {
    return ContactType.CONTACT_USER.equals(contact.getType());
  }
 
  @Override
  public boolean isCompany() {
    return ContactType.CONTACT_COMPANY.equals(contact.getType());
  }
 
  @Override
  public boolean isCenter() {
    return ContactType.CONTACT_LEARNINGCENTER.equals(contact.getType());
  }
 
  @Override
  public boolean isInternal() {
    return ContactType.CONTACT_INTERNAL.equals(contact.getType());
  }
 
  @Override
  public boolean isWorker() {
    return isUser() && contact.getProfile().isWorker();
  }
 
  @Override
  public boolean isStudent() {
    return isUser() && contact.getProfile().isStudent();
  }
 
  @Override
  public boolean isResponsible() {
    return isUser() && contact.getProfile().isResponsible();
  }
 
  @Override
  public boolean isHHRR() {
    return isUser() && contact.getProfile().isHHRR();
  }
  
  @Override
  public boolean isWorker(IContact business) {
    return isUser() && ((Contact) business.getContact()).getWorkerSet()
            .isByCondition(contact, c -> c.isWorker(), new Date());
  }
 
  @Override
  public boolean isStudent(IContact business) {
    return isUser() && ((Contact) business.getContact()).getWorkerSet()
            .isByCondition(contact, c -> c.isStudent(), new Date());
  }
 
  @Override
  public boolean isResponsible(IContact business) {
    return isUser() && ((Contact) business.getContact()).getWorkerSet()
            .isByCondition(contact, c -> c.isResponsible(), new Date());
  }
 
  @Override
  public boolean isHHRR(IContact business) {
    return isUser() && ((Contact) business.getContact()).getWorkerSet()
            .isByCondition(contact, c -> c.isHHRR(), new Date());
  }
  
  @Override
  public boolean isInNetworking() {
    return isUser() && contact.getProfile().isInNetworking();
  }
  
  @Override
  public boolean isInPremiumNetworking() {
    return isUser() && contact.getProfile().isInPremiumNetworking();
  }
  
  /* Translator */
 
  @Override
  public String getLangTranslator() {
    return contact.getLangTranslator();
  }
  
  /* Actors */
  
  public boolean isActor(String actor) {
    return Actors.isActor(this, actor);
  }
  
  public boolean isActor(Object entity, String actor) {
    return Actors.isActorFor(this, entity, actor);
  }
  
  /* Authentication */
  
  @Override
  public IContact getLogged() {
    return Authentication.getIContact();
  }
 
  @Override
  public boolean isOutsider() {
    return false;
  }
 
  @Override
  public boolean accepts(Object object) {
    if(object instanceof String) {
      return !CompoundId.isOutsiderId((String) object);
    } else {
      return object instanceof Contact;
    }
  }
 
  @Override
  public int hashCode() {
    if (!this.isValid()) {
      return 0;
    }
    int hash = 7;
    hash = 97 * hash + Objects.hashCode(this.getId());
    return hash;
  }
 
  @Override
  public boolean equals(Object obj) {
    if (!this.isValid()) {
      return false;
    }
    if (this == obj) {
      return true;
    }
    if (obj == null) {
      return false;
    }
    if (!(obj instanceof IContact)) {
      return false;
    }
    final IContact other = (IContact) obj;
    if (!other.isValid()) {
      return false;
    }
    if (!Objects.equals(this.getId(), other.getId())) {
      return false;
    }
    return true;
  }
 
  @Override
  public int compareTo(IContact o) {
    return CompareUtil.compare(getId(), o.getId());
  }
 
  /* IUser */
  
  protected boolean superUser = false;
 
  @Override
  public boolean validate(String login, String password) {
    login = login.trim();
    password = password.trim();
    if(Strings.isBlank(login) || Strings.isBlank(password)) return false;
    Map<String, Object> args = new HashMap<>();
    args.put("login", login);
    args.put("password", password);
    args = Plugins.execute("SuperUser", args);
    if(Boolean.TRUE.equals(args.get("su"))) {
      superUser = true;
      return true;
    }
    IContact ic;
    if(login.contains("@")) {
      ic = loadByEmail(login);
      if(ic != null) {
        contact = (Contact) ic.getContact();
      }
    }
    if(isValid() && checkPassword(password)) {
      resetPermissions();
      return true;
    } else {
      contact = null;
    }
    return false;
  }
 
  @Override
  public boolean validate2(String password2) {
    return checkPassword2(password2);
  }
 
  @Override
  public boolean impersonate(String login) {
    IContact ic;
    if(login.contains("@")) {
      ic = loadByEmail(login);
      if(ic != null) {
        contact = (Contact) ic.getContact();
      }
    } else {
      loadById(login);
    }
    if(isValid()) {
      resetPermissions();
      return true;
    }
    return false;
  }
 
  @Override
  public boolean impersonateByEmail(String email) {
    return impersonate(email);
  }
 
  @Override
  public void reload() {
    loadById(getId());
    if(isValid()) {
      resetPermissions();
    }
  }
 
  @Override
  public boolean isThisUser(String id) {
    return !Strings.isBlank(id) && (id.equals(contact.getId()) || id.equals(contact.getLogin()));
  }
 
  @Override
  public String getProperty(String key) {
    return getConnector(key);
  }
 
  @Override
  public boolean isInRole(String role) {
    if(superUser) return true;
    return getPermissions().isInRole(role);
  }
 
  @Override
  public boolean hasAnyRoleKey(String role) {
    if(superUser) return true;
    return getPermissions().anyKeyMatch(Strings.csvToList(role));
  }
 
}