package org.jboss.resource.security;
import java.security.acl.Group;
import java.security.Principal;
import java.security.PrivilegedExceptionAction;
import java.security.AccessController;
import java.security.PrivilegedActionException;
import java.util.Map;
import javax.resource.spi.security.PasswordCredential;
import javax.security.auth.Subject;
import javax.security.auth.callback.CallbackHandler;
import javax.security.auth.login.LoginException;
import javax.management.ObjectName;
import javax.management.MBeanServer;
import org.jboss.security.SimplePrincipal;
import org.jboss.logging.Logger;
public class JaasSecurityDomainIdentityLoginModule
extends AbstractPasswordCredentialLoginModule
{
private static final Logger log = Logger.getLogger(JaasSecurityDomainIdentityLoginModule.class);
private String username;
private String password;
private ObjectName jaasSecurityDomain;
public void initialize(Subject subject, CallbackHandler handler,
Map sharedState, Map options)
{
super.initialize(subject, handler, sharedState, options);
username = (String) options.get("username");
if( username == null )
{
username = (String) options.get("userName");
if( username == null )
{
throw new IllegalArgumentException("The user name is a required option");
}
}
password = (String) options.get("password");
if( password == null )
{
throw new IllegalArgumentException("The password is a required option");
}
String name = (String) options.get("jaasSecurityDomain");
if( name == null )
{
throw new IllegalArgumentException("The jaasSecurityDomain is a required option");
}
try
{
jaasSecurityDomain = new ObjectName(name);
}
catch(Exception e)
{
throw new IllegalArgumentException("Invalid jaasSecurityDomain: " + e.getMessage());
}
}
public boolean login() throws LoginException
{
log.trace("login called");
if( super.login() == true )
return true;
super.loginOk = true;
return true;
}
public boolean commit() throws LoginException
{
Principal principal = new SimplePrincipal(username);
SubjectActions.addPrincipals(subject, principal);
sharedState.put("javax.security.auth.login.name", username);
try
{
char[] decodedPassword = DecodeAction.decode(password,
jaasSecurityDomain, getServer());
PasswordCredential cred = new PasswordCredential(username, decodedPassword);
cred.setManagedConnectionFactory(getMcf());
SubjectActions.addCredentials(subject, cred);
}
catch(Exception e)
{
log.debug("Failed to decode password", e);
throw new LoginException("Failed to decode password: " + e.getMessage());
}
return true;
}
public boolean abort()
{
username = null;
password = null;
return true;
}
protected Principal getIdentity()
{
log.trace("getIdentity called, username=" + username);
Principal principal = new SimplePrincipal(username);
return principal;
}
protected Group[] getRoleSets() throws LoginException
{
Group[] empty = new Group[0];
return empty;
}
private static class DecodeAction implements PrivilegedExceptionAction
{
String password;
ObjectName jaasSecurityDomain;
MBeanServer server;
DecodeAction(String password, ObjectName jaasSecurityDomain,
MBeanServer server)
{
this.password = password;
this.jaasSecurityDomain = jaasSecurityDomain;
this.server = server;
}
public Object run() throws Exception
{
Object[] args = {password};
String[] sig = {String.class.getName()};
byte[] secret = (byte[]) server.invoke(jaasSecurityDomain,
"decode64", args, sig);
String secretPassword = new String(secret, "UTF-8");
return secretPassword.toCharArray();
}
static char[] decode(String password, ObjectName jaasSecurityDomain,
MBeanServer server)
throws Exception
{
DecodeAction action = new DecodeAction(password, jaasSecurityDomain, server);
try
{
char[] decode = (char[]) AccessController.doPrivileged(action);
return decode;
}
catch(PrivilegedActionException e)
{
throw e.getException();
}
}
}
}