authenticationutil.java

jxta官方例程

/*
*  Copyright (c) 2001 Sun Microsystems, Inc.  All rights
*  reserved.
*
*  Redistribution and use in source and binary forms, with or withouta
*  modification, are permitted provided that the following conditions
*  are met:
*
*  1. Redistributions of sourcec 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.
*  ===================================================tre=================
*
*  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/>.
*
*
*  $Id: AuthenticationUtil.java,v 1.8 2005/11/15 19:29:44 nano Exp $
*/

package net.jxta.myjxta.util;

import net.jxta.myjxta.MyJXTA;
import net.jxta.myjxta.View;
import net.jxta.myjxta.ui.AuthenticationPanel;

import net.jxta.credential.AuthenticationCredential;
import net.jxta.endpoint.MessageTransport;
import net.jxta.exception.PeerGroupException;
import net.jxta.exception.ProtocolNotSupportedException;
import net.jxta.membership.MembershipService;
import net.jxta.peergroup.PeerGroup;

import net.jxta.impl.membership.pse.StringAuthenticator;

import javax.swing.JDialog;
import javax.swing.JFrame;

import java.util.ResourceBundle;

import org.apache.log4j.Level;
import org.apache.log4j.Logger;

/**
 *
 * @version $Id: AuthenticationUtil.java,v 1.8 2005/11/15 19:29:44 nano Exp $
 *
 * @author james todd [gonzo at jxta dot org]
 */

public class AuthenticationUtil {
    
//    private static final String INTERACTIVE_AUTHENTICATOR =
//        "InteractiveAuthentication";
    private static final String STRING_AUTHENTICATOR = "StringAuthentication";
    private static final String AUTHENTICATION = STRING_AUTHENTICATOR;
    private static final String JXTA_TLS_TRANSPORT = "jxtatls";
    private static final ResourceBundle STRINGS = Resources.getStrings();
    private static final Logger LOG = Logger.getLogger(AuthenticationUtil.class.getName());
    
    public static PeerGroup getTLSPeerGroup(Group g) {
        return getTLSPeerGroup(g != null ? g.getPeerGroup() : null);
    }
    
    public static PeerGroup getTLSPeerGroup(PeerGroup pg) {
        if (LOG.isEnabledFor(Level.INFO)) {
            LOG.info("getTLSPeerGroup");
        }
        
        MessageTransport tls =
            pg.getEndpointService().getMessageTransport(JXTA_TLS_TRANSPORT);
        PeerGroup tlspg = null;
        
        if (tls != null) {
            tlspg = tls.getEndpointService().getGroup();
        }
        
        if (LOG.isEnabledFor(Level.INFO)) {
            LOG.info("tls group: " +
                (tlspg != null ? tlspg.getPeerGroupName() : null));
        }
        
        return tlspg;
    }
    
    public static boolean isAuthenticated(Group g) {
        return isAuthenticated(g != null ? g.getPeerGroup() : null);
    }
    
    public static boolean isAuthenticated(PeerGroup pg) {
        if (LOG.isEnabledFor(Level.INFO)) {
            LOG.info("isAuthenticated");
        }

        boolean isAuthenticated = false;
            
        try {
            isAuthenticated =
                (pg.getMembershipService().getDefaultCredential() != null);
        } catch (PeerGroupException pge) {
            if (LOG.isEnabledFor(Level.INFO)) {
                LOG.info("no default credential", pge);
            }
        }
        
        if (LOG.isEnabledFor(Level.INFO)) {
            LOG.info("is authenticated: " + pg.getPeerGroupName() +
                " " + isAuthenticated);
        }
        
        return isAuthenticated;
    }

    public static boolean authenticate(View v, Group g, MyJXTA m) {
        return authenticate(v, g != null ? g.getPeerGroup() : null , m);
    }
    
    public static boolean authenticate(View v, PeerGroup pg, MyJXTA m) {
        if (LOG.isEnabledFor(Level.INFO)) {
            LOG.info("authenticate");
        }
        
        boolean isAuthenticated = false;
        String status = null;
        
        status = STRINGS.getString("status.group.authenticate") +
            ": " + pg.getPeerGroupName();

        m.setStatus(status);

        if (LOG.isEnabledFor(Level.INFO)) {
            LOG.info(status);
        }

        isAuthenticated = authenticate(v, pg);
        
        if (isAuthenticated(pg)) {
            status = STRINGS.getString("status.group.authenticated") +
                ": " + pg.getPeerGroupName();

            m.setStatus(status);

            if (LOG.isEnabledFor(Level.INFO)) {
                LOG.info(status);
            }
        } else {
            if (LOG.isEnabledFor(Level.INFO)) {
                LOG.info("can't authenticate");
            }
        }
        
        return isAuthenticated;
    }
    
    public static boolean authenticate(View v, Group g) {
        return authenticate(v, g != null ? g.getPeerGroup() : null);
    }
    
    public static boolean authenticate(View v, PeerGroup pg) {
        return authenticate(v, pg, null, null);
    }
    
    public static boolean authenticate(View v, PeerGroup pg,
        String keyStorePassword, String identityPassword) {
        return authenticate(v, pg, keyStorePassword, identityPassword, true);
    }

    public static boolean authenticate(View v, PeerGroup pg,
        String keyStorePassword, String identityPassword, boolean join) {
        boolean isAuthenticated = isAuthenticated(pg);
        // xxx: assumption that ks pwd == id pwd
        String pwd = v.getConfig() != null ? v.getConfig().getPassword() : null;
        
        if (pwd != null) {
            if (keyStorePassword == null ||
                keyStorePassword.trim().length() == 0) {
                keyStorePassword = pwd;
            }

            if (identityPassword == null ||
                identityPassword.trim().length() == 0) {
                identityPassword = pwd;
            }
        }
        
        if (! isAuthenticated) {
            if (keyStorePassword != null &&
                identityPassword != null) {
                MembershipService ms = pg.getMembershipService();
                AuthenticationCredential ac = new AuthenticationCredential(pg,
                    AUTHENTICATION, null);
                StringAuthenticator sa = null;

                try {
                    sa = (StringAuthenticator)ms.apply(ac);
                } catch (ProtocolNotSupportedException pnse) {
                } catch (PeerGroupException pge) {
                }

                sa.setAuth1_KeyStorePassword(keyStorePassword);
                sa.setAuth2Identity(pg.getPeerID());
                sa.setAuth3_IdentityPassword(identityPassword);

                isAuthenticated = sa.isReadyForJoin();
                
                if (isAuthenticated &&
                    join) {
                    try {
                        ms.join(sa);
                    } catch (PeerGroupException pge) {
                    }
                }
            } else {
                AuthenticationPanel ap = new AuthenticationPanel(v, pg);
                JDialog jd = new JDialog((JFrame)v,
                    STRINGS.getString("title.identity.login"), true);

                jd.getContentPane().add(ap);
                jd.pack();
                
                if (v != null) {
                    jd.setLocationRelativeTo((JFrame)v);
                }
                
                ap.requestFocus();
                jd.setVisible(true);

                if (! ap.isCanceled()) {
                    isAuthenticated = ap.isReadyForJoin();

                    if (isAuthenticated &&
                        join) {
                        try {
                            ap.join();
                        } catch (PeerGroupException pge) {
                        }
                    }
                }

                ap = null;
                jd = null;  
            }
        }
        
        return isAuthenticated;
    }
    
//    public static boolean authenticate(PeerGroup pg) {        
//        if (LOG.isEnabledFor(Level.INFO)) {
//            LOG.info("authenticate");
//        }
//        
//        boolean isAuthenticated = false;
//        
//        if (! isAuthenticated(pg)) {
//            if (LOG.isEnabledFor(Level.INFO)) {
//                LOG.info("authenticating group: " +
//                    pg.getPeerGroupName());
//            }
//                
//            MembershipService ms = pg.getMembershipService();
//            AuthenticationCredential ac = new AuthenticationCredential(pg,
//                    "InteractiveAuthetnication", null);
//            InteractiveAuthenticator ia = null;
//            
//            try {
//                ia = (InteractiveAuthenticator)ms.apply(ac);
//            } catch (ProtocolNotSupportedException pnse) {
//                if (LOG.isEnabledFor(Level.ERROR)) {
//                    LOG.error("apply membership", pnse);
//                }
//            } catch (PeerGroupException pge) {
//                if (LOG.isEnabledFor(Level.ERROR)) {
//                    LOG.error("apply membership", pge);
//                }
//            }
//
//            if (ia != null &&
//                ia.interact() &&
//                ia.isReadyForJoin()) {
//                if (LOG.isEnabledFor(Level.INFO)) {
//                    LOG.info("joining membership");
//                }
//                
//                try {
//                    ms.join(ia);
//                    isAuthenticated = true;
//                } catch (PeerGroupException pge) {
//                    if (LOG.isEnabledFor(Level.ERROR)) {
//                        LOG.error("apply membership", pge);
//                    }   
//                }
//            } else {
//                if (LOG.isEnabledFor(Level.INFO)) {
//                    LOG.info("can't interact with membership");
//                }
//            }
//        } else {
//            if (LOG.isEnabledFor(Level.INFO)) {
//                LOG.info("already authenticated");
//            }
//        }
//        
//        return isAuthenticated;
//    }
}