View Javadoc
1   /*
2    *  Licensed to the Apache Software Foundation (ASF) under one
3    *  or more contributor license agreements.  See the NOTICE file
4    *  distributed with this work for additional information
5    *  regarding copyright ownership.  The ASF licenses this file
6    *  to you under the Apache License, Version 2.0 (the
7    *  "License"); you may not use this file except in compliance
8    *  with the License.  You may obtain a copy of the License at
9    *  
10   *    https://www.apache.org/licenses/LICENSE-2.0
11   *  
12   *  Unless required by applicable law or agreed to in writing,
13   *  software distributed under the License is distributed on an
14   *  "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
15   *  KIND, either express or implied.  See the License for the
16   *  specific language governing permissions and limitations
17   *  under the License. 
18   *  
19   */
20  package org.apache.directory.api.ldap.schema.loader;
21  
22  
23  import java.io.ByteArrayInputStream;
24  import java.io.IOException;
25  import java.util.HashMap;
26  import java.util.Map;
27  import java.util.jar.JarEntry;
28  import java.util.jar.JarInputStream;
29  
30  import org.apache.directory.api.i18n.I18n;
31  import org.apache.directory.api.ldap.model.entry.Attribute;
32  import org.apache.directory.api.ldap.model.entry.Value;
33  import org.apache.directory.api.ldap.model.exception.LdapException;
34  import org.apache.directory.api.ldap.model.exception.LdapInvalidAttributeValueException;
35  import org.apache.directory.api.ldap.model.message.ResultCodeEnum;
36  import java.io.ByteArrayOutputStream;
37  import java.io.InputStream;
38  
39  
40  /**
41   * A class loader that loads classes from an attribute within an entry.
42   * 
43   * @author <a href="mailto:dev@directory.apache.org">Apache Directory Project</a>
44   */
45  public class AttributeClassLoader extends ClassLoader
46  {
47      /** The attribute. */
48      private Attribute attribute;
49  
50  
51      /**
52       * Instantiates a new attribute class loader.
53       */
54      public AttributeClassLoader()
55      {
56          super( AttributeClassLoader.class.getClassLoader() );
57      }
58  
59  
60      /**
61       * Sets the attribute.
62       *
63       * @param attribute the new attribute
64       * @throws LdapException if the attribute is not binary.
65       */
66      public void setAttribute( Attribute attribute ) throws LdapException
67      {
68          if ( attribute.isHumanReadable() )
69          {
70              throw new LdapInvalidAttributeValueException( ResultCodeEnum.CONSTRAINT_VIOLATION,
71                  I18n.err( I18n.ERR_16007_BINARY_REQUIRED ) );
72          }
73  
74          this.attribute = attribute;
75      }
76      
77      
78      /**
79       * Read data from a jar, and write them into a byte[]
80       * 
81       * @param input The Stream we will load the Attribute from
82       * @return A byte[] containing the Attribute
83       * @throws IOException If the stream can't be read
84       */
85      private static byte[] getBytes( InputStream input ) throws IOException 
86      {
87          ByteArrayOutputStream result = new ByteArrayOutputStream();
88  
89          byte[] buf = new byte[2048];
90          int bytesRead = input.read( buf );
91  
92          while ( bytesRead != -1 ) 
93          {
94              result.write( buf, 0, bytesRead );
95              bytesRead = input.read( buf );
96          }
97        
98          result.flush();
99          result.close();
100         
101         return result.toByteArray();
102     }
103 
104     
105     /**
106      * Load classes from a jar
107      *  
108      * @param jarBytes The jar bytes
109      * @return A map containing the read classes
110      * @throws IOException If the stream can't be read
111      */
112     private Map<String, Class<?>> loadClasses( byte[] jarBytes ) throws IOException 
113     {
114         Map<String, Class<?>> map = new HashMap<>();
115         
116         try ( JarInputStream jis = new JarInputStream( new ByteArrayInputStream( jarBytes ) ) ) 
117         {
118             JarEntry entry;
119             boolean isJar = false;
120             
121             while ( ( entry = jis.getNextJarEntry() ) != null ) 
122             {
123                 String fileName = entry.getName();
124                 isJar = true;
125                 
126                 // Just consider the files ending with .class
127                 if ( fileName.endsWith( ".class" ) )
128                 {
129                     String className = fileName.substring( 0,  fileName.length() - ".class".length() ).replace( '/', '.' );
130                     byte[] classBytes = getBytes( jis );
131                     
132                     Class<?> clazz = defineClass( className, classBytes, 0, classBytes.length );
133                     map.put( className, clazz );
134                 }
135             }
136             
137             if ( !isJar )
138             {
139                 return null;
140             }
141         }
142 
143         return map;
144     }
145 
146 
147     /**
148      * {@inheritDoc}
149      */
150     @Override
151     public Class<?> findClass( String name ) throws ClassNotFoundException
152     {
153         byte[] classBytes;
154 
155         Value value = attribute.get();
156 
157         if ( value.isHumanReadable() )
158         {
159             throw new ClassNotFoundException( I18n.err( I18n.ERR_16008_AT_ACCESS_FAILURE ) );
160         }
161 
162         classBytes = value.getBytes();
163 
164         // May be we are dealing with a JAR ?
165         try 
166         {
167             Map<String, Class<?>> classes = loadClasses( classBytes );
168             
169             if ( classes == null )
170             {
171                 // May be a simple class ?
172                 return defineClass( name, classBytes, 0, classBytes.length );
173             }
174             
175             for ( Map.Entry<String, Class<?>> entry : classes.entrySet() )
176             {
177                 if ( entry.getKey().contains( name ) )
178                 {
179                     return entry.getValue();
180                 }
181             }
182         }
183         catch ( IOException ioe )
184         {
185             // Ok, may be a pure class
186             return defineClass( name, classBytes, 0, classBytes.length );
187         }
188         
189         return null;
190     }
191 }