| 12
 3
 4
 5
 6
 7
 8
 9
 10
 11
 12
 13
 14
 15
 16
 17
 18
 19
 20
 21
 22
 23
 24
 25
 26
 27
 28
 29
 30
 31
 32
 33
 34
 35
 36
 37
 38
 39
 40
 41
 42
 43
 44
 45
 46
 47
 48
 49
 50
 51
 52
 53
 54
 55
 56
 57
 58
 59
 60
 61
 62
 63
 64
 65
 66
 67
 68
 69
 70
 71
 72
 73
 74
 75
 76
 77
 78
 79
 80
 81
 82
 83
 84
 85
 86
 87
 88
 89
 90
 91
 92
 93
 94
 95
 96
 97
 98
 99
 100
 101
 102
 103
 104
 105
 106
 107
 108
 109
 110
 111
 112
 113
 114
 115
 116
 117
 118
 119
 120
 121
 122
 123
 124
 125
 126
 127
 128
 129
 130
 131
 132
 133
 134
 135
 136
 137
 138
 139
 140
 141
 142
 143
 144
 145
 146
 147
 148
 149
 150
 151
 152
 153
 154
 155
 156
 157
 158
 159
 160
 161
 162
 163
 164
 165
 166
 167
 168
 
 | /*
* JBoss, Home of Professional Open Source
* Copyright 2005, JBoss Inc., and individual contributors as indicated
* by the @authors tag. See the copyright.txt in the distribution for a
* full listing of individual contributors.
*
* This is free software; you can redistribute it and/or modify it
* under the terms of the GNU Lesser General Public License as
* published by the Free Software Foundation; either version 2.1 of
* the License, or (at your option) any later version.
*
* This software 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
* Lesser General Public License for more details.
*
* You should have received a copy of the GNU Lesser General Public
* License along with this software; if not, write to the Free
* Software Foundation, Inc., 51 Franklin St, Fifth Floor, Boston, MA
* 02110-1301 USA, or see the FSF site: http://www.fsf.org.
*/
package org.jboss.ws.extensions.security;
import java.security.PrivateKey;
import java.security.PublicKey;
import java.security.cert.X509Certificate;
import java.util.HashMap;
import org.apache.xml.security.keys.KeyInfo;
import org.jboss.util.NotImplementedException;
import org.jboss.ws.extensions.security.element.BinarySecurityToken;
import org.jboss.ws.extensions.security.element.DirectReference;
import org.jboss.ws.extensions.security.element.KeyIdentifier;
import org.jboss.ws.extensions.security.element.Reference;
import org.jboss.ws.extensions.security.element.SecurityTokenReference;
import org.jboss.ws.extensions.security.element.X509IssuerSerial;
import org.jboss.ws.extensions.security.element.X509Token;
import org.jboss.ws.extensions.security.exception.SecurityTokenUnavailableException;
import org.jboss.ws.extensions.security.exception.WSSecurityException;
import org.w3c.dom.Element;
/**
 * <code>KeyResolver</code> is responsible for locating security tokens
 * within a WS-Security message.
 *
 * @author <a href="mailto:jason.greene@jboss.com">Jason T. Greene</a>
 * @version $Revision: 5034 $
 */
public class KeyResolver
{
   private HashMap<String, BinarySecurityToken> tokenCache = new HashMap<String, BinarySecurityToken>();
   private SecurityStore store;
   public KeyResolver(SecurityStore store)
   {
      this.store = store;
   }
   private SecurityTokenReference extractSecurityTokenReference(KeyInfo info) throws WSSecurityException
   {
      Element child = Util.getFirstChildElement(info.getElement());
      if (child == null)
         throw new WSSecurityException("Empty KeyInfo");
      if (! child.getLocalName().equals("SecurityTokenReference"))
         throw new WSSecurityException("KeyInfo did not contain expected SecurityTokenReference, instead got: " + child.getLocalName());
      return new SecurityTokenReference(child);
   }
   public void cacheToken(BinarySecurityToken token)
   {
      tokenCache.put(token.getId(), token);
   }
   public BinarySecurityToken resolve(SecurityTokenReference reference) throws WSSecurityException
   {
      Reference ref = reference.getReference();
      if (ref instanceof DirectReference)
      {
         DirectReference direct = (DirectReference) ref;
         return resolveDirectReference(direct);
      }
      else if (ref instanceof KeyIdentifier)
      {
         KeyIdentifier identifier = (KeyIdentifier) ref;
         return resolveKeyIdentifier(identifier);
      }
      else if (ref instanceof X509IssuerSerial)
      {
         X509IssuerSerial issuerSerial = (X509IssuerSerial) ref;
         return resolveX509IssuerSerial(issuerSerial);
      }
      throw new NotImplementedException("Currently only DirectReference is supported!");
   }
   private BinarySecurityToken resolveDirectReference(DirectReference direct) throws WSSecurityException
   {
      String id = direct.getUri().substring(1);
      BinarySecurityToken token = tokenCache.get(id);
      if (token == null)
         throw new SecurityTokenUnavailableException("Could not resolve token id: " + id);
      return token;
   }
   private BinarySecurityToken resolveKeyIdentifier(KeyIdentifier identifier) throws WSSecurityException
   {
      // Support only SKI at the moment
      X509Certificate cert = store.getCertificateBySubjectKeyIdentifier(identifier.getIdentifier());
      if (cert == null)
         throw new SecurityTokenUnavailableException("Could not locate certificate by key identifier");
      return new X509Token(cert, identifier.getDocument());
   }
   private BinarySecurityToken resolveX509IssuerSerial(X509IssuerSerial issuerSerial) throws WSSecurityException
   {
      X509Certificate cert = store.getCertificateByIssuerSerial(issuerSerial.getIssuer(), issuerSerial.getSerial());
     if (cert == null)
        throw new SecurityTokenUnavailableException("Could not locate certificate by issuer and serial number");
     return new X509Token(cert, issuerSerial.getDocument());
   }
   public X509Certificate resolveCertificate(SecurityTokenReference reference) throws WSSecurityException
   {
      BinarySecurityToken token = resolve(reference);
      if (! (token instanceof X509Token))
         throw new WSSecurityException("Expected X509Token, cache contained: " + token.getClass().getName());
      return ((X509Token)token).getCert();
   }
   public PublicKey resolvePublicKey(SecurityTokenReference reference) throws WSSecurityException
   {
      return resolveCertificate(reference).getPublicKey();
   }
   public PrivateKey resolvePrivateKey(SecurityTokenReference reference) throws WSSecurityException
   {
      return store.getPrivateKey(resolveCertificate(reference));
   }
   public BinarySecurityToken resolve(KeyInfo info) throws WSSecurityException
   {
      return resolve(extractSecurityTokenReference(info));
   }
   public X509Certificate resolveCertificate(KeyInfo info) throws WSSecurityException
   {
      return resolveCertificate(extractSecurityTokenReference(info));
   }
   public PublicKey resolvePublicKey(KeyInfo info) throws WSSecurityException
   {
      return resolvePublicKey(extractSecurityTokenReference(info));
   }
   public PrivateKey resolvePrivateKey(KeyInfo info) throws WSSecurityException
   {
      return resolvePrivateKey(extractSecurityTokenReference(info));
   }
}
 |