ProposalListbox.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.zul.proposal;
 
import java.io.IOException;
import java.util.Collection;
import java.util.Iterator;
import java.util.List;
import java.util.logging.Level;
import java.util.logging.Logger;
import java.util.stream.Collectors;
import org.turro.command.Command;
import org.turro.command.Context;
import org.turro.contacts.Contact;
import org.turro.contacts.ContactType;
import org.turro.contacts.form.ContactWrapper;
import org.turro.contacts.proposal.ContactProposal;
import org.turro.contacts.proposal.GenericAttribute;
import org.turro.contacts.proposal.ProposalSet;
import org.turro.contacts.social.SocialGroupValue;
import org.turro.elephant.context.Application;
import org.turro.elephant.context.ElephantContext;
import org.turro.elephant.util.Messages;
import org.turro.security.SocialGroups;
import org.zkoss.zul.Listbox;
import org.zkoss.zul.Listitem;
 
public class ProposalListbox extends Listbox {
 
  private final ProposalSet proposals;
  private Collection<SocialGroupValue> socialGroups;
  private ContactType type;
 
  public ProposalListbox() {
    proposals = ProposalSet.deserialize(Application.getApplication());
    addProposalItems();
  }
 
  public void setSocialGroups(Collection<SocialGroupValue> socialGroups) {
    this.socialGroups = socialGroups;
  }
 
  public void setType(ContactType type) {
    this.type = type;
  }
 
  public void importVCard() throws InterruptedException, IOException {
    Application app = Application.getApplication();
    proposals.loadFromVCards(app, new Command() {
      @Override
      public Object execute(Context context) {
        addProposalItems();
        ProposalSet.serialize(Application.getApplication(), proposals);
        return null;
      }
    });
  }
 
  public void processSingle(ContactProposal proposal) throws InterruptedException, Exception {
    Iterator<Listitem> it = getItems().iterator();
    boolean done = false;
    while(it.hasNext()) {
      Listitem li = it.next();
      if(done) {
        li.setSelected(true);
        break;
      } else if(li.getValue().equals(proposal)) {
        ContactProposal cp = (ContactProposal) li.getValue();
        processProposal(cp);
        proposals.remove(cp);
        it.remove();
        done = true;
      }
    }
    ProposalSet.serialize(Application.getApplication(), proposals);
  }
 
  public void processSelected() throws InterruptedException, Exception {
    Messages.confirmProcess().show(() -> {
      Iterator<Listitem> it = getItems().iterator();
      while(it.hasNext()) {
        Listitem li = it.next();
        if(li.isSelected()) {
          ContactProposal cp = (ContactProposal) li.getValue();
          if(!cp.isNoAction()) {
            try {
              processProposal(cp);
              proposals.remove(cp);
              it.remove();
            } catch (Exception ex) {
              Logger.getLogger(ProposalListbox.class.getName()).log(Level.SEVERE, ElephantContext.logMsg(null), ex);
            }
          }
        }
      }
      ProposalSet.serialize(Application.getApplication(), proposals);
    });
  }
 
  public void deleteSelected() throws InterruptedException {
    Messages.confirmDeletion().show(() -> {
      Iterator<Listitem> it = getItems().iterator();
      while(it.hasNext()) {
        Listitem li = it.next();
        if(li.isSelected()) {
          proposals.remove((ContactProposal) li.getValue());
          it.remove();
        }
      }
      ProposalSet.serialize(Application.getApplication(), proposals);
    });
  }
 
  private void addProposalItems() {
    getItems().clear();
    for(ContactProposal cp : proposals) {
      Listitem li = new Listitem(cp.getDescription(), cp);
      if(cp.isDuplicated()) {
        li.setSclass("duplicated");
      } else if(cp.isProbablyNew()) {
        li.setSclass("probablynew");
      }
      appendChild(li);
    }
  }
 
  private void processProposal(ContactProposal cp) throws Exception {
    if(cp != null) {
      Contact destination = cp.getDestination();
      if(destination != null) {
        for(GenericAttribute ga : cp.getAttributes()) {
          if(ga.isActive()) {
            ga.addToContact(destination);
          }
        }
        saveDestination(destination);
      } else {
        cp.clearInactiveAttributes();
        saveDestination(cp.getProposal());
      }
    }
  }
 
  private void saveDestination(Contact destination) throws Exception {
    if(type != null) destination.setType(type);
    SocialGroups.syndicate(List.of(destination), 
            socialGroups.stream().map(sgv -> sgv.getKey()).collect(Collectors.toSet()), 
            null);
    new ContactWrapper(destination).save();
  }
  
}