ProposalSet.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.proposal;
 
import java.io.File;
import java.io.Serializable;
import java.util.List;
import java.util.TreeSet;
import org.turro.action.Plugins;
import org.turro.auth.Authentication;
import org.turro.command.Command;
import org.turro.command.Context;
import org.turro.contacts.Contact;
import org.turro.elephant.context.Application;
import org.turro.elephant.impl.util.Serializer;
import org.turro.file.FileWrapper;
import org.turro.plugin.IPlugin;
import org.turro.plugin.contacts.IContact;
 
public class ProposalSet extends TreeSet<ContactProposal> implements Serializable {
 
  private static final long serialVersionUID = 1;
 
  public void loadFromVCards(Application app, final Command command) {
    final IPlugin plugin = Plugins.loadImplementation(IPlugin.class, "vcard");
    if(plugin != null) {
      plugin.setData("constructor", app.getConstructor());
      if(command != null) {
        FileWrapper fw = new FileWrapper((File) plugin.getData("importFolder"));
        fw.upload(new Command() {
          @Override
          public Object execute(Context context) {
            addProposals(plugin);
            command.execute(context);
            return null;
          }
        });
        return;
      } else {
        addProposals(plugin);
      }
    }
  }
 
  private void addProposals(IPlugin plugin) {
    List<Contact> l = (List<Contact>) plugin.getData("import");
    IContact ic = Authentication.getIContact();
    for(Contact c : l) {
      add(new ContactProposal(c, "VCard Import [" + ic.getName() + "]"));
    }
    l = (List<Contact>) plugin.getData("importcsv");
    for(Contact c : l) {
      add(new ContactProposal(c, "CSV Import [" + ic.getName() + "]"));
    }
  }
 
  public static void serialize(Application app, ProposalSet instance) {
    if(app.isInRole("contact-proposal:list")) {
      Serializer.serialize("/proposals/data.ser", instance);
    } else if(app.isInRole("contact-proposal:import")) {
      Serializer.serialize("/proposals/imported/" + Authentication.getIContact().getId() + ".ser", instance);
    }
  }
 
  public static ProposalSet deserialize(Application app) {
    ProposalSet result = new ProposalSet();
    if(app.isInRole("contact-proposal:list")) {
      ProposalSet ps = (ProposalSet) Serializer.deserialize("/proposals/data.ser");
      if(ps != null) result.addAll(ps);
      File[] fs = Serializer.getFiles("/proposals/imported");
      if(fs != null) {
        for(File f : fs) {
          ps = (ProposalSet) Serializer.deserialize(f);
          if(ps != null) result.addAll(ps);
          f.delete();
        }
      }
      ProposalSet.serialize(app, result);
    } else if(app.isInRole("contact-proposal:import")) {
      ProposalSet ps = (ProposalSet) Serializer.deserialize("/proposals/imported/" + Authentication.getIContact().getId() + ".ser");
      if(ps != null) result.addAll(ps);
    }
    return result;
  }
 
}