/**  Copyright (c) 2001 Sun Microsystems, Inc.  All rights*  reserved.**  Redistribution and use in source and binary forms, with or without*  modification, are permitted provided that the following conditions*  are met:**  1. Redistributions of source code must retain the above copyright*  notice, this list of conditions and the following disclaimer.**  2. Redistributions in binary form must reproduce the above copyright*  notice, this list of conditions and the following discalimer in*  the documentation and/or other materials provided with the*  distribution.**  3. The end-user documentation included with the redistribution,*  if any, must include the following acknowledgment:*  "This product includes software developed by the*  Sun Microsystems, Inc. for Project JXTA."*  Alternately, this acknowledgment may appear in the software itself,*  if and wherever such third-party acknowledgments normally appear.**  4. The names "Sun", "Sun Microsystems, Inc.", "JXTA" and "Project JXTA"*  must not be used to endorse or promote products derived from this*  software without prior written permission. For written*  permission, please contact Project JXTA at http://www.jxta.org.**  5. Products derived from this software may not be called "JXTA",*  nor may "JXTA" appear in their name, without prior written*  permission of Sun.**  THIS SOFTWARE IS PROVIDED ``AS IS'' AND ANY EXPRESSED OR IMPLIED*  WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE IMPLIED WARRANTIES*  OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE ARE*  DISCLAIMED.  IN NO EVENT SHALL THE APACHE SOFTWARE FOUNDATION OR*  ITS CONTRIBUTORS BE LIABLE FOR ANY DIRECT, INDIRECT, INCIDENTAL,*  SPECIAL, EXEMPLARY, OR CONSEQUENTIAL DAMAGES (INCLUDING, BUT NOT*  LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES; LOSS OF*  USE, DATA, OR PROFITS; OR BUSINESS INTERRUPTION) HOWEVER CAUSED AND*  ON ANY THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY,*  OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT*  OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF*  SUCH DAMAGE.*  ====================================================================**  This software consists of voluntary contributions made by many*  individuals on behalf of Project JXTA.  For more*  information on Project JXTA, please see*  <http://www.jxta.org/>.**  This license is based on the BSD license adopted by the Apache Foundation.**  $Id: UnicastSecurePipeAdvCommand.java,v 1.3 2007/05/22 06:15:29 nano Exp $*/package net.jxta.myjxta.plugins.secureonetoone;import net.jxta.document.MimeMediaType;import net.jxta.document.StructuredDocument;import net.jxta.document.StructuredTextDocument;import net.jxta.endpoint.MessageElement;import net.jxta.endpoint.TextDocumentMessageElement;import net.jxta.logging.Logging;import net.jxta.myjxta.dialog.Dialog;import net.jxta.myjxta.dialog.DialogManager;import net.jxta.myjxta.dialog.DialogMessage;import net.jxta.myjxta.dialog.OneToOneDialog;import net.jxta.myjxta.dialog.commands.AbstractCommand;import net.jxta.myjxta.util.CredentialUtil;import net.jxta.myjxta.util.Group;import net.jxta.peergroup.PeerGroup;import net.jxta.pipe.PipeService;import net.jxta.protocol.PipeAdvertisement;import java.util.logging.Level;import java.util.logging.Logger;/** * @author james todd [gonzo at jxta dot org] * @version $Id: UnicastSecurePipeAdvCommand.java,v 1.3 2007/05/22 06:15:29 nano Exp $ */public class UnicastSecurePipeAdvCommand        extends AbstractCommand {    public static final String ID = "net.jxta.myjxta.dialog.commands.UnicastSecurePipeAdvCommand";    public static final String PIPE = "pipe";    private static final Logger LOG = Logger.getLogger(UnicastSecurePipeAdvCommand.class.getName());    public String getId() {        if (Logging.SHOW_INFO && LOG.isLoggable(Level.INFO)) {            LOG.info("returning id: " + ID);        }        return ID;    }    public boolean process(Dialog dialog, DialogMessage msg) {        if (Logging.SHOW_INFO && LOG.isLoggable(Level.INFO)) {            LOG.info("process: " + (msg != null ? msg.toString()                    : null));        }        String cmd = msg != null ? msg.getCommand() : null;        Group g = dialog.getGroup();        PeerGroup pg = g.getPeerGroup();        DialogMessage dm = new DialogMessage(pg.getPeerName(), null,                pg.getPeerGroupID().toString(), pg.getPeerGroupName());        if (cmd != null &&                cmd.length() > 0) {            if (Logging.SHOW_INFO && LOG.isLoggable(Level.INFO)) {                LOG.info("processing command: " + cmd);            }            setCommand(cmd);            MessageElement c = msg.getMessageElement(CredentialCommand.CREDENTIAL);            if (CredentialUtil.importCredential(c, g, dialog.getMyJXTA())) {                StructuredDocument d = getPipeAdv(g);                TextDocumentMessageElement te = d != null ? new TextDocumentMessageElement(PIPE, (StructuredTextDocument) d, null) :                        null;                if (te != null) {                    setReply("pipe:" + PIPE);                    setStatus(true);                    dm.setCommand(getResponse());                    dm.addMessageElement(PIPE, te);                    if (Logging.SHOW_INFO && LOG.isLoggable(Level.INFO)) {                        LOG.info("results: " + dm);                    }                } else {                    if (Logging.SHOW_SEVERE && LOG.isLoggable(Level.SEVERE)) {                        LOG.severe("can\'t construct document");                    }                }            } else {                if (Logging.SHOW_INFO && LOG.isLoggable(Level.INFO)) {                    LOG.info("certificate not imported");                }            }        } else {            if (Logging.SHOW_SEVERE && LOG.isLoggable(Level.SEVERE)) {                LOG.severe("invalid command: " + cmd);            }        }        if (Logging.SHOW_INFO && LOG.isLoggable(Level.INFO)) {            LOG.info("dispatching: " + (dm.toString()));        }        dialog.dispatch(dm);        if (Logging.SHOW_INFO && LOG.isLoggable(Level.INFO)) {            LOG.info("dispatching: " + getStatus());        }        return getStatus();    }    private StructuredDocument getPipeAdv(Group g) {        if (Logging.SHOW_INFO && LOG.isLoggable(Level.INFO)) {            LOG.info("getPipeAdvl");        }        String pn = Dialog.getDialogNamer(OneToOneDialog.class).                getDialogName(g.getPeerGroup().getPeerName());        PipeAdvertisement pa = DialogManager.getInstance(g, pn,                PipeService.UnicastSecureType).getPipeAdv(g.getPeerGroup());        return (StructuredDocument) pa.getDocument(MimeMediaType.XMLUTF8);    }}