GeneralInstanceProperties.java

  1. /*
  2.  * GovWay - A customizable API Gateway 
  3.  * https://govway.org
  4.  * 
  5.  * Copyright (c) 2005-2025 Link.it srl (https://link.it). 
  6.  * 
  7.  * This program is free software: you can redistribute it and/or modify
  8.  * it under the terms of the GNU General Public License version 3, as published by
  9.  * the Free Software Foundation.
  10.  *
  11.  * This program is distributed in the hope that it will be useful,
  12.  * but WITHOUT ANY WARRANTY; without even the implied warranty of
  13.  * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
  14.  * GNU General Public License for more details.
  15.  *
  16.  * You should have received a copy of the GNU General Public License
  17.  * along with this program.  If not, see <http://www.gnu.org/licenses/>.
  18.  *
  19.  */


  22. package org.openspcoop2.pdd.config;

  24. import java.io.ByteArrayInputStream;
  25. import java.io.File;
  26. import java.io.InputStream;
  27. import java.lang.reflect.Constructor;
  28. import java.lang.reflect.Method;
  29. import java.net.URI;
  30. import java.net.URL;
  31. import java.util.ArrayList;
  32. import java.util.Enumeration;
  33. import java.util.List;
  34. import java.util.Properties;
  35. import java.util.jar.Attributes;
  36. import java.util.jar.JarEntry;
  37. import java.util.jar.JarFile;
  38. import java.util.jar.Manifest;

  40. import org.openspcoop2.pdd.core.CostantiPdD;
  41. import org.openspcoop2.utils.io.JarUtilities;
  42. import org.openspcoop2.utils.io.ZipUtilities;
  43. import org.openspcoop2.utils.resources.FileSystemUtilities;
  44. import org.slf4j.Logger;

  46. /**
  47. * GeneralInstanceProperties
  48. *
  49. * @author Andrea Poli (apoli@link.it)
  50.  * @author $Author$
  51.  * @version $Rev$, $Date$
  52. */

  54. public class GeneralInstanceProperties {

  56.     private File archiveFile = null;
  57.     
  58.     private int RESULT_LENGTH = 8;
  59.     
  60.     
  61.     public Object[] reads(Logger log){
  62.         
  63.         
  64.         // Properties
  65.         Object[] oR = readLoadProperties(log);
  66.         if(oR!=null){
  67.             return oR;
  68.         }
  69.         
  70.         
  71.         // La ricerca viene attivata SOLO se la proprieta' e' presente e assume il valore true
  72.         boolean lookup = false;
  73.         
  74.         String properties = System.getenv(CostantiPdD.OPENSPCOOP2_LOOKUP);
  75.         if(properties!=null && "true".equalsIgnoreCase(properties)){
  76.             lookup = true;
  77.         }
  78.         
  79.         if(properties==null){
  80.             properties = System.getProperty(CostantiPdD.OPENSPCOOP2_LOOKUP);
  81.             if(properties!=null && "true".equalsIgnoreCase(properties)){
  82.                 lookup = true;
  83.             }
  84.         }
  85.         
  86.         if(!lookup){
  87.             return null;
  88.         }       
  89.         
  90.         // Lookup
  91.         File fClasspath = null;
  92.         try{
  93.             URL urlClasspath = GeneralInstanceProperties.class.getResource("/govway.log4j2.properties");
  94.             if(urlClasspath!=null){
  95.                 URI uri = urlClasspath.toURI();
  96.                 String uriS = uri.toString();
  97.                 if(uriS.startsWith("vfsfile:")){
  98.                     // jboss 5
  99.                     uriS = uriS.substring("vfsfile:".length());
  100.                 }
  101.                 else if(uriS.startsWith("vfszip:")){
  102.                     // jboss 5
  103.                     uriS = uriS.substring("vfszip:".length());
  104.                 }
  105.                 else if(uriS.contains(":")){
  106.                     // jboss 4
  107.                     String [] tmp = uriS.split(":");
  108.                     if(tmp.length>1){
  109.                         uriS = tmp[1].trim();
  110.                     }
  111.                 }
  112.                 File f = (new File(uriS)).getParentFile();
  113.                 if(f!=null){                    
  114.                     // OpenSPCoop.ear/properties/govway.log4j2.properties
  115.                     // openspcoop.war/WEB-INF/classes/govway.log4j2.properties
  116.                     if("properties".equals(f.getName())){
  117.                         fClasspath = f.getParentFile().getParentFile();
  118.                     }else if("classes".equals(f.getName())){
  119.                         fClasspath = f.getParentFile().getParentFile().getParentFile();
  120.                     }
  121.                 }
  122.             }
  123.         }catch(Exception e){
  124.             e.printStackTrace(System.err);
  125.         }
  126.         if(fClasspath!=null){
  127.             
  128.             List<File> files = new ArrayList<File>();
  129.             findArchives(log, fClasspath, files);
  130.                         
  131.             if(files.size()<=0){
  132.                 
  133.                 // JBOSS
  134.                 String dir = fClasspath.getName();
  135.                 fClasspath = fClasspath.getParentFile();
  136.                 if(fClasspath!=null){
  137.                     if("tmp".equalsIgnoreCase(fClasspath.getName())){
  138.                         fClasspath = fClasspath.getParentFile();
  139.                         if(fClasspath!=null){
  140.                             fClasspath = new File(fClasspath,dir);
  141.                             findArchives(log, fClasspath, files);
  142.                         }
  143.                     }
  144.                     else if("deploy".equalsIgnoreCase(dir)){
  145.                         if(fClasspath!=null){
  146.                             fClasspath = new File(fClasspath,"tmp");
  147.                             if(fClasspath.exists() && fClasspath.canRead()){
  148.                                 fClasspath = new File(fClasspath,"deploy");
  149.                                 if(fClasspath.exists() && fClasspath.canRead()){
  150.                                     findArchives(log, fClasspath, files);
  151.                                 }
  152.                             }
  153.                         }
  154.                     }
  155.                 }
  156.                 
  157.             }
  158.             
  159.             for (int i = 0; i < files.size(); i++) {
  160.                 Object[] o = null;
  161.                 this.archiveFile = files.get(i);
  162.                 if(this.archiveFile.isFile()){
  163.                     log.debug("Archive ["+this.archiveFile.getAbsolutePath()+"] find in classpath");
  164.                     o = readFile(this.archiveFile,log);
  165.                 }
  166.                 else{
  167.                     log.debug("Directory ["+this.archiveFile.getAbsolutePath()+"] find in classpath");
  168.                     o = readDir(this.archiveFile,log);
  169.                 }
  170.                 if(o!=null){
  171.                     return o;
  172.                 }
  173.             }
  174.             
  175.         }
  176.         
  177.         
  178.         
  179.         return null;
  180.     }
  181.     
  182.     private Object[] readLoadProperties(Logger log){
  183.         try{
  184.             
  185.             String loaderP = System.getenv(CostantiPdD.OPENSPCOOP2_LOADER);
  186.             if(loaderP==null){
  187.                 loaderP = System.getProperty(CostantiPdD.OPENSPCOOP2_LOADER);
  188.             }
  189.             if(loaderP==null){
  190.                 InputStream is = GeneralInstanceProperties.class.getResourceAsStream("/op2loader.properties");
  191.                 if(is!=null){
  192.                     try{
  193.                         Properties p = new Properties();
  194.                         p.load(is);
  195.                         loaderP = p.getProperty("loader");
  196.                         if(loaderP!=null){
  197.                             loaderP=loaderP.trim();
  198.                         }
  199.                     }finally{
  200.                         try{
  201.                             is.close();
  202.                         }catch(Exception eClose){
  203.                             // close
  204.                         }
  205.                     }
  206.                 }
  207.             }
  208.             if(loaderP == null){
  209.                 return null;
  210.             }
  211.             
  212.             // Loader
  213.             Method method = this.getClass().getClassLoader().getClass().getMethod("loadClass", String.class);
  214.             Object c = method.invoke(this.getClass().getClassLoader(), loaderP);
  215.             
  216.             java.lang.ClassLoader loader = null;
  217.             if(c!=null){
  218.                 Constructor<?> constructor = ((Class<?>)c).getConstructor(java.lang.ClassLoader.class);
  219.                 loader = (java.lang.ClassLoader) constructor.newInstance(this.getClass().getClassLoader());
  220.             }
  221.             if(loader==null){
  222.                 throw new Exception("Loader ["+loaderP+"] non caricato");
  223.             }
  224.             
  225.             // Metodo per properties
  226.             Method methodProperties = null;
  227.             try{
  228.                 methodProperties = loader.getClass().getMethod("getClassProperties");
  229.             }catch(Throwable e){
  230.                 // ingore
  231.             }
  232.             if(methodProperties!=null){
  233.                 Object result = methodProperties.invoke(loader);
  234.                 if(result!=null && (result instanceof String) ){
  235.                     Object[] o = readProperties(log, ((String)result), loader, "getClassProperties");
  236.                     if(o!=null){
  237.                         return o;
  238.                     }
  239.                 }
  240.             }
  241.             
  242.             // Proprieta' inserite nel sistema
  243.             String tipo = "systemProperties";
  244.             String properties = System.getenv(CostantiPdD.OPENSPCOOP2_LOADER_PROPERTIES);
  245.             if(properties==null){
  246.                 tipo = "javaProperties";
  247.                 properties = System.getProperty(CostantiPdD.OPENSPCOOP2_LOADER_PROPERTIES);
  248.             }
  249.             if(properties == null){
  250.                 throw new Exception("Trovata proprieta' per loader ma non sono state fornite le properties");
  251.             }
  252.             
  253.             Object[] o = readProperties(log, properties, loader, tipo);
  254.             if(o!=null){
  255.                 return o;
  256.             }
  257.             
  258.             throw new Exception("Trovata proprieta' per loader ma non sono state fornite correttamente le properties");
  259.             
  260.         }catch(Exception e){
  261.             e.printStackTrace(System.out);
  262.             log.debug("LoadProperties ERROR",e);
  263.         }
  264.         catch(Throwable e){
  265.             e.printStackTrace(System.out);
  266.             log.debug("LoadProperties ERROR",e);
  267.         }
  268.         
  269.         return null;
  270.     }
  271.     
  272.     private Object[] readProperties(Logger log,String properties,java.lang.ClassLoader loader,String tipoRicerca) throws Exception{
  273.         String [] split = null;
  274.         if(properties.contains(",")){
  275.             split = properties.split(",");
  276.         }else if(properties.contains(":")){
  277.             split = properties.split(":");
  278.         }else if(properties.contains(";")){
  279.             split = properties.split(";");
  280.         }else if(properties.contains(" ")){
  281.             split = properties.split(" ");
  282.         }else{
  283.             throw new Exception("Trovata proprieta' per loader ma non sono state fornite correttamente le properties");
  284.         }
  285.         if(split==null || split.length!=(this.RESULT_LENGTH-1)){
  286.             throw new Exception("Trovata proprieta' per loader ma non sono state fornite correttamente le properties");
  287.         }
  288.         
  289.         // Verifico properties
  290.         Properties opP = null;
  291.         Properties clP = null;
  292.         Properties pddP = null;
  293.         Properties configP = null;
  294.         Properties logP = null;
  295.         Properties msgDiagP = null;
  296.         Properties cacheP = null;
  297.         for (int i = 0; i < split.length; i++) {
  298.             String v = split[i].trim();
  299.             try{
  300.                 //System.out.println("V["+v+"]");
  301.                 //System.out.println("CLASS["+this.getClass().getName()+"]");
  302.                 //System.out.println("CLASS2["+this.getClass().getClassLoader().getClass().getName()+"]");
  303.                 //Method method = this.getClass().getClassLoader().getClass().getMethod("loadClass", String.class);
  304.                 Method method = ClassLoader.class.getMethod("loadClass", String.class);
  305.                 //System.out.println("AfterMethod");
  306.                 Object find = method.invoke(this.getClass().getClassLoader(), ClassLoader.class.getName());
  307.                 //System.out.println("Find ["+find+"]");
  308.                 //if(find!=null){
  309.                 //  System.out.println("Find ["+find.getClass().getName()+"]");
  310.                 //}
  311.                 //System.out.println("LOADER ["+loader.getClass().getName()+"]");
  312.                 find = method.invoke(loader, Properties.class.getName());
  313.                 //System.out.println("PropInterface ["+find+"]");
  314.                 //if(find!=null){
  315.                 //  System.out.println("PropInterface ["+find.getClass().getName()+"]");
  316.                 //}
  317.                 Object c = method.invoke(loader, v);
  318.                 if(c==null){
  319.                     throw new Exception("Proprieta' ["+v+"] non trovata");
  320.                 }
  321.                 if(((Class<?>)find).isAssignableFrom(((Class<?>)c))){
  322.                     Constructor<?> constructor = ((Class<?>)c).getConstructor();
  323.                     Properties p = (Properties) constructor.newInstance();
  324.                     Object type = p.get("type");
  325.                     if(type==null){
  326.                         throw new Exception("Proprieta' ["+v+"] con type non definito");
  327.                     }
  328.                     if("openspcoop".equals(type)){
  329.                         opP = p;
  330.                     }
  331.                     else if("className".equals(type)){
  332.                         clP = p;
  333.                     }
  334.                     else if("pdd".equals(type)){
  335.                         pddP = p;
  336.                     }
  337.                     else if("logger".equals(type)){
  338.                         logP = p;
  339.                     }
  340.                     else if("config".equals(type)){
  341.                         configP = p;
  342.                     }
  343.                     else if("msgDiagnostici".equals(type)){
  344.                         msgDiagP = p;
  345.                     }
  346.                     else if("cache".equals(type)){
  347.                         cacheP = p;
  348.                     }
  349.                     else{
  350.                         throw new Exception("Proprieta' ["+v+"] con type non corretto");
  351.                     }
  352.                 }else{
  353.                     throw new Exception("Proprieta' ["+v+"] di tipo non corretto");
  354.                 }
  355.             }catch(Exception e){
  356.                 throw new Exception("Trovata proprieta' per loader ma non sono state fornite correttamente le properties. Errore durante la lookup della properties ["+v+"]: "+e.getMessage(),e);
  357.             }catch(Throwable e){
  358.                 throw new Exception("Trovata proprieta' per loader ma non sono state fornite correttamente le properties. Errore durante la lookup della properties ["+v+"]: "+e.getMessage(),e);
  359.             }
  360.         }
  361.         if(opP!=null && clP!=null && pddP!=null && logP!=null && configP!=null && msgDiagP!=null && cacheP!=null){
  362.             Object [] o = new Object[this.RESULT_LENGTH];
  363.             o[0]=loader;
  364.             o[1]=opP;
  365.             o[2]=clP;
  366.             o[3]=pddP;
  367.             o[4]=logP;
  368.             o[5]=configP;
  369.             o[6]=msgDiagP;
  370.             o[7]=cacheP;
  371.             for (int i = 0; i < o.length; i++) {
  372.                 log.debug("Class ("+tipoRicerca+") ["+i+"]=["+o[i].getClass().getName()+"]");
  373.             }
  374.             log.debug("Loader find ("+tipoRicerca+")");
  375.             return o;
  376.         }
  377.         
  378.         return null;
  379.     }
  380.     
  381.     private void findArchives(Logger log,File fClasspath,List<File> files){
  382.         log.debug("Search libraries in classpath ["+fClasspath.getAbsolutePath()+"] ...");
  383.         
  384.         if(fClasspath.isFile()){
  385.             log.debug("Classpath is file");
  386.             return;
  387.         }
  388.         if(fClasspath.canRead()==false){
  389.             log.debug("Classpath is not readable");
  390.             return;
  391.         }
  392.         
  393.         File [] f = fClasspath.listFiles();
  394.         if(f!=null){
  395.             for (int i = 0; i < f.length; i++) {
  396.                 
  397.                 if(f[i].canRead()==false){
  398.                     continue;
  399.                 }
  400.                 if(f[i].isFile()){
  401.                     if(checkFile(f[i])){
  402.                         log.debug("Find archive ["+f[i].getAbsolutePath()+"]");
  403.                         files.add(f[i]);
  404.                     }
  405.                 }
  406.                 else if(f[i].isDirectory()){
  407.                     if(checkDir(f[i])){
  408.                         log.debug("Find dir ["+f[i].getAbsolutePath()+"]");
  409.                         files.add(f[i]);
  410.                     }
  411.                 }
  412.             }
  413.         }
  414.         log.debug("Search libraries in classpath ["+fClasspath.getAbsolutePath()+"]: find "+files.size());
  415.     }
  416.     
  417.     private boolean checkFile(File file)
  418.     {
  419.         if (!file.exists ()) 
  420.             return false;
  421.         if (!file.canRead()) 
  422.             return false;
  423.         if (file.isDirectory()) 
  424.             return false;
  425.         try{
  426.             JarFile archive = JarUtilities.getJar(file, false); 
  427.             if(archive==null){
  428.                 return false;
  429.             }
  430.             Manifest manifest = archive.getManifest();
  431.             return checkManifest(manifest);
  432.             
  433.         }catch(Exception e){
  434.             return false;
  435.         }
  436.         
  437.     }
  438.     private boolean checkDir(File dir){
  439.         
  440.         try{
  441.         
  442.             if(!dir.canRead()){
  443.                 return false;
  444.             }
  445.             File [] childs = dir.listFiles();
  446.             if(childs==null || childs.length<=0){
  447.                 return false;
  448.             }
  449.             for (int i = 0; i < childs.length; i++) {
  450.                 if(!childs[i].canRead()){
  451.                     continue;
  452.                 }
  453.                 if(!childs[i].isDirectory()){
  454.                     continue;
  455.                 }
  456.                 if("META-INF".equals(childs[i].getName())==false){
  457.                     continue;
  458.                 }
  459.                 File [] childsInterni = childs[i].listFiles();
  460.                 if(childsInterni==null || childsInterni.length<=0){
  461.                     return false;
  462.                 }
  463.                 for (int j = 0; j < childsInterni.length; j++) {
  464.                     if(!childsInterni[j].canRead()){
  465.                         continue;
  466.                     }
  467.                     if(!childsInterni[j].isFile()){
  468.                         continue;
  469.                     }
  470.                     if("MANIFEST.MF".equals(childsInterni[j].getName())==false){
  471.                         continue;
  472.                     }
  473.                     byte[] m = FileSystemUtilities.readBytesFromFile(childsInterni[j]);
  474.                     if(m==null){
  475.                         return false;
  476.                     }
  477.                     Manifest manifest = new Manifest(new ByteArrayInputStream(m));
  478.                     return checkManifest(manifest);
  479.                 }
  480.             }
  481.             
  482.             return false;
  483.             
  484.         }catch(Exception e){
  485.             return false;
  486.         }
  487.     }
  488.     
  489.     private boolean checkManifest(Manifest manifest){
  490.         if(manifest==null){
  491.             return false;
  492.         }
  493.         if(manifest.getMainAttributes()==null){
  494.             return false;
  495.         }
  496.         
  497.         Attributes attributes = manifest.getMainAttributes();
  498.         if(attributes.size()<2){
  499.             return false;
  500.         }
  501.         
  502.         String attrProduct = attributes.getValue("product-name");
  503.         if(CostantiPdD.OPENSPCOOP2.equals(attrProduct)==false){
  504.             return false;
  505.         }
  506.         
  507.         String attrCopyright = attributes.getValue("copyright");
  508.         if(attrCopyright==null){
  509.             return false;
  510.         }
  511.         if(attrCopyright.contains("Link.it srl (https://link.it). All rights reserved.")==false){
  512.             return false;
  513.         }
  514.         return true;
  515.     }
  516.     
  517.     
  518.     
  519.     private Object[] readFile(File file,Logger log)
  520.     {
  521.         if (!file.exists ()){
  522.             log.debug("File ["+file.getAbsolutePath()+"] not exist");
  523.             return null;
  524.         }
  525.         if (!file.canRead()) {
  526.             log.debug("File ["+file.getAbsolutePath()+"] not readable");
  527.             return null;
  528.         }
  529.         if (file.isDirectory()) {
  530.             log.debug("File ["+file.getAbsolutePath()+"] is directory");
  531.             return null;
  532.         }
  533.         try{
  534.             JarFile archive = JarUtilities.getJar(file, false); 
  535.             if(archive==null){
  536.                 log.debug("File ["+file.getAbsolutePath()+"] is not jar archive");
  537.                 return null;
  538.             }
  539.             
  540.             Enumeration<JarEntry> entries = null;
  541.             java.lang.ClassLoader loader = null;
  542.             String parentDirLoader = null;
  543.             
  544.             // Class
  545.             entries = archive.entries();
  546.             while (entries.hasMoreElements()){
  547.                 JarEntry entry = entries.nextElement ();
  548.                 String extension = "";
  549.                 if( entry.getName().contains(".")){
  550.                     extension = entry.getName().substring(entry.getName().lastIndexOf('.')+1, entry.getName().length());
  551.                 }
  552.                 String nome = entry.getName ().replaceAll("/", ".");
  553.                 if(extension!=null){
  554.                     extension = "."+extension;
  555.                     nome = nome.substring(0,nome.length()-extension.length());
  556.                 }
  557.                 
  558.                 if(nome.endsWith(".")){
  559.                     // directory
  560.                     continue;
  561.                 }
  562.             
  563.                 try{
  564.                     Method method = this.getClass().getClassLoader().getClass().getMethod("loadClass", String.class);
  565.                     Object find = method.invoke(this.getClass().getClassLoader(), ClassLoader.class.getName());
  566.                     Object c = null;
  567.                     try{
  568.                         c = method.invoke(this.getClass().getClassLoader(), nome);
  569.                     }catch(Throwable e){
  570.                         // ignore
  571.                     }
  572.                     if(c!=null){
  573.                         if(((Class<?>)find).isAssignableFrom(((Class<?>)c))){
  574.                             Constructor<?> constructor = ((Class<?>)c).getConstructor(java.lang.ClassLoader.class);
  575.                             loader = (java.lang.ClassLoader) constructor.newInstance(this.getClass().getClassLoader());
  576.                             parentDirLoader = nome.split("\\.")[0].trim()+".";
  577.                             break;
  578.                         }
  579.                     }
  580.                 }catch(Exception e){
  581.                     // ignore
  582.                 }
  583.             }
  584.             if(loader!=null){
  585.                 log.debug("Loader find (loadClass)");
  586.             }
  587.             
  588.             // Bytes
  589.             if(loader==null){
  590.                 entries = archive.entries();
  591.                 while (entries.hasMoreElements()){
  592.                     JarEntry entry = entries.nextElement ();
  593.                     String extension = "";
  594.                     if( entry.getName().contains(".")){
  595.                         extension = entry.getName().substring(entry.getName().lastIndexOf('.')+1, entry.getName().length());
  596.                     }
  597.                     String nome = entry.getName ().replaceAll("/", ".");
  598.                     if(extension!=null){
  599.                         extension = "."+extension;
  600.                         nome = nome.substring(0,nome.length()-extension.length());
  601.                     }
  602.                     
  603.                     if(nome.endsWith(".")){
  604.                         // directory
  605.                         continue;
  606.                     }
  607.                     
  608.                     byte[] entryBytes = null;
  609.                     try{
  610.                         entryBytes = JarUtilities.getEntry(file, entry.getName());
  611.                     }catch(Throwable e){
  612.                         // ignore
  613.                     }
  614.                     try{
  615.                         ResourceFinder finder = new ResourceFinder(this.getClass().getClassLoader());
  616.                         Object c = null;
  617.                         try{
  618.                             c = finder.loadResource(nome, entryBytes);
  619.                         }catch(Throwable e){
  620.                             // ignore
  621.                         }
  622.                         if(c!=null){
  623.                             Method method = this.getClass().getClassLoader().getClass().getMethod("loadClass", String.class);
  624.                             Object find = method.invoke(this.getClass().getClassLoader(), ClassLoader.class.getName());
  625.                             if(((Class<?>)find).isAssignableFrom(((Class<?>)c))){
  626.                                 Constructor<?> constructor = ((Class<?>)c).getConstructor(java.lang.ClassLoader.class,JarFile.class,String.class, File.class);
  627.                                 parentDirLoader = nome.split("\\.")[0].trim()+".";
  628.                                 loader = (java.lang.ClassLoader) constructor.newInstance(this.getClass().getClassLoader(),archive,parentDirLoader,this.archiveFile);
  629.                                 break;
  630.                             }
  631.                         }
  632.                     }catch(Exception e){
  633.                         // ignore
  634.                     }
  635.                 }
  636.                 if(loader!=null){
  637.                     log.debug("Loader find (ResourceFinder)");
  638.                 }
  639.             }
  640.             
  641.             // Jar
  642.             if(loader==null){
  643.                 entries = archive.entries();
  644.                 while (entries.hasMoreElements()){
  645.                     JarEntry entry = entries.nextElement ();
  646.                     String extension = "";
  647.                     if( entry.getName().contains(".")){
  648.                         extension = entry.getName().substring(entry.getName().lastIndexOf('.')+1, entry.getName().length());
  649.                     }
  650.                     String nome = entry.getName ().replaceAll("/", ".");
  651.                     if(extension!=null){
  652.                         extension = "."+extension;
  653.                         nome = nome.substring(0,nome.length()-extension.length());
  654.                     }
  655.                     
  656.                     if(nome.endsWith(".")){
  657.                         // directory
  658.                         continue;
  659.                     }
  660.                     
  661.                     byte[] entryBytes = null;
  662.                     try{
  663.                         entryBytes = JarUtilities.getEntry(file, entry.getName());
  664.                     }catch(Throwable e){
  665.                         // ignore
  666.                     }
  667.                     
  668.                     if(entryBytes!=null){
  669.                         File tmp = null;
  670.                         try{                            
  671.                             tmp = FileSystemUtilities.createTempFile("PddInterceptor", "PddInterceptor");
  672.                             FileSystemUtilities.writeFile(tmp, entryBytes);
  673.                             if(JarUtilities.isJar(tmp, false)){
  674.                                 if(checkFile(tmp)){
  675.                                     Object [] o = readFile(tmp,log);
  676.                                     if(o!=null){
  677.                                         return o;
  678.                                     }
  679.                                 }
  680.                             }
  681.                         }catch(Throwable e){
  682.                             // ignore
  683.                         }
  684.                         finally{
  685.                             try{
  686.                                 FileSystemUtilities.deleteDir(tmp);
  687.                                 tmp.deleteOnExit();
  688.                             }catch(Exception e){
  689.                                 // ignore
  690.                             }
  691.                         }
  692.                     }           
  693.                 }
  694.             }
  695.             
  696.             // Unzip jar per verifica dir interne
  697.             if(loader==null){
  698.                 File tmp = null;
  699.                 try{            
  700.                     tmp = FileSystemUtilities.createTempFile("PddInterceptor", "PddInterceptor");
  701.                     if(!tmp.delete()) {
  702.                         // ignore
  703.                     }
  704.                     ZipUtilities.unzipFile(file.getAbsolutePath(), tmp.getAbsolutePath());
  705.                     Object [] o = readDir(tmp,log);
  706.                     if(o!=null){
  707.                         return o;
  708.                     }
  709.                 }catch(Throwable e){
  710.                     // ignore
  711.                 }
  712.                 finally{
  713.                     try{
  714.                         FileSystemUtilities.deleteDir(tmp);
  715.                         tmp.deleteOnExit();
  716.                     }catch(Exception e){
  717.                         // ignore
  718.                     }
  719.                 }
  720.             }
  721.             
  722.             
  723.             // Loader
  724.             if(loader!=null){
  725.                                             
  726.                 // Verifico properties
  727.                 entries = archive.entries();
  728.                 Properties opP = null;
  729.                 Properties clP = null;
  730.                 Properties pddP = null;
  731.                 Properties configP = null;
  732.                 Properties logP = null;
  733.                 Properties msgDiagP = null;
  734.                 Properties cacheP = null;
  735.                 while (entries.hasMoreElements()){
  736.                     JarEntry entry = entries.nextElement ();
  737.                     String extension = "";
  738.                     if( entry.getName().contains(".")){
  739.                         extension = entry.getName().substring(entry.getName().lastIndexOf('.')+1, entry.getName().length());
  740.                     }
  741.                     String nome = entry.getName ().replaceAll("/", ".");
  742.                     if(extension!=null){
  743.                         extension = "."+extension;
  744.                         nome = nome.substring(0,nome.length()-extension.length());
  745.                     }
  746.                     if(nome.equals(loader.getClass().getName())==false && !".".equals(extension) && nome.startsWith(parentDirLoader)){
  747.                         Object find = null;
  748.                         Object c = null;
  749.                         try{
  750.                             log.debug("Load ["+nome+"]...");
  751.                             Method method = loader.getClass().getMethod("loadClass", String.class);
  752.                             find = method.invoke(loader, Properties.class.getName());
  753.                             c = method.invoke(loader, nome);
  754.                             log.debug("Load ["+nome+"] OK");
  755.                             if(find==null){
  756.                                 throw new Exception("find null");
  757.                             }
  758.                             if(c==null){
  759.                                 throw new Exception("c null");
  760.                             }
  761.                         }catch(Exception e){
  762.                             log.debug("Load ["+nome+"] ERROR",e);
  763.                         }
  764.                         catch(Throwable e){
  765.                             log.debug("Load ["+nome+"] ERROR",e);
  766.                         }
  767.                         if(find!=null && c!=null){
  768.                             try{
  769.                                 if(((Class<?>)find).isAssignableFrom(((Class<?>)c))){
  770.                                     Constructor<?> constructor = ((Class<?>)c).getConstructor();
  771.                                     Properties properties = (Properties) constructor.newInstance();
  772.                                     Object type = properties.get("type");
  773.                                     if(type==null){
  774.                                         continue;
  775.                                     }
  776.                                     else if("openspcoop".equals(type)){
  777.                                         opP = properties;
  778.                                     }
  779.                                     else if("className".equals(type)){
  780.                                         clP = properties;
  781.                                     }
  782.                                     else if("pdd".equals(type)){
  783.                                         pddP = properties;
  784.                                     }
  785.                                     else if("logger".equals(type)){
  786.                                         logP = properties;
  787.                                     }
  788.                                     else if("config".equals(type)){
  789.                                         configP = properties;
  790.                                     }
  791.                                     else if("msgDiagnostici".equals(type)){
  792.                                         msgDiagP = properties;
  793.                                     }
  794.                                     else if("cache".equals(type)){
  795.                                         cacheP = properties;
  796.                                     }
  797.                                 }
  798.                             }catch(Exception e){
  799.                                 log.debug("Loader instance ["+nome+"] error: "+e.getMessage(),e);
  800.                             }
  801.                             catch(Throwable e){
  802.                                 log.debug("Loader instance ["+nome+"] error: "+e.getMessage(),e);
  803.                             }
  804.                         }
  805.                     }           
  806.                 }
  807.                 if(opP!=null && clP!=null && pddP!=null && logP!=null && configP!=null && msgDiagP!=null && cacheP!=null){
  808.                     Object [] o = new Object[this.RESULT_LENGTH];
  809.                     o[0]=loader;
  810.                     o[1]=opP;
  811.                     o[2]=clP;
  812.                     o[3]=pddP;
  813.                     o[4]=logP;
  814.                     o[5]=configP;
  815.                     o[6]=msgDiagP;
  816.                     o[7]=cacheP;
  817.                     for (int i = 0; i < o.length; i++) {
  818.                         log.debug("Class ["+i+"]=["+o[i].getClass().getName()+"]");
  819.                     }
  820.                     return o;
  821.                 }
  822.             }
  823.             
  824.         } catch (RuntimeException e) {
  825.             return null;
  826.         } catch (Exception e) {
  827.             return null;
  828.         }
  829.         
  830.         return null;
  831.     }
  832.     
  833.         
  834.     private Object[] readDir(File file,Logger log)
  835.     {
  836.         if(file==null) {
  837.             log.debug("File is null");
  838.             return null;
  839.         }
  840.         
  841.         if (!file.exists ()) {
  842.             log.debug("File (DIR) ["+file.getAbsolutePath()+"] not exist");
  843.             return null;
  844.         }
  845.         if (!file.canRead()) {
  846.             log.debug("File (DIR) ["+file.getAbsolutePath()+"] not readable");
  847.             return null;
  848.         }
  849.         if (file.isFile()) {
  850.             log.debug("File (DIR) ["+file.getAbsolutePath()+"] is directory");
  851.             return null;
  852.         }
  853.         
  854.         File[] childs = file.listFiles();
  855.         if(childs!=null && childs.length>0){
  856.             
  857.             java.lang.ClassLoader loader = null;
  858.             String parentDirLoader = null;          
  859.             
  860.             // Chiamate ricorsive
  861.             for (int i = 0; i < childs.length; i++) {
  862.                 
  863.                 if(childs[i]!=null) {
  864.                     if(childs[i].isDirectory()){
  865.                         
  866.                         // Check if is war/ear
  867.                         File [] f = childs[i].listFiles();
  868.                         if(f!=null && f.length>0){
  869.                             
  870.                             File [] childsInterni = childs[i].listFiles();
  871.                             File WEB_LIB = null;
  872.                             File WEB_CLASSES = null;
  873.                             File EAR = null;
  874.                             
  875.                             if("WEB-INF".equals(childs[i].getName())){
  876.                                 for (int k = 0; k < childsInterni.length; k++) {
  877.                                     if("lib".equals(childsInterni[k].getName())){
  878.                                         WEB_LIB = childsInterni[k];
  879.                                     }
  880.                                     if("classes".equals(childsInterni[k].getName())){
  881.                                         WEB_CLASSES = childsInterni[k];
  882.                                     }
  883.                                 }
  884.                             }
  885.                             else if("META-INF".equals(childs[i].getName())){
  886.                                 for (int k = 0; k < childsInterni.length; k++) {
  887.                                     if("application.xml".equals(childsInterni[k].getName())){
  888.                                         EAR = childs[i];
  889.                                     }
  890.                                 }
  891.                             }
  892.                             
  893.                             if(WEB_LIB!=null || WEB_CLASSES!=null || EAR!=null){
  894.                                 // dir
  895.                                 if(WEB_LIB!=null){
  896.                                     Object[] o = null;
  897.                                     try{
  898.                                         o = readDir(WEB_LIB,log);
  899.                                     }catch(Throwable e){
  900.                                         // ignore
  901.                                     }
  902.                                     if(o!=null)
  903.                                         return o;   
  904.                                 }
  905.                                 
  906.                                 if(WEB_CLASSES!=null){
  907.                                     Object[] o = null;
  908.                                     try{
  909.                                         o = readDir(WEB_CLASSES,log);
  910.                                     }catch(Throwable e){
  911.                                         // ignore
  912.                                     }
  913.                                     if(o!=null)
  914.                                         return o;   
  915.                                 }
  916.                                 
  917.                                 if(WEB_LIB!=null || WEB_CLASSES!=null){
  918.                                     Object[] o = null;
  919.                                     try{
  920.                                         o = readDir(childs[i],log);
  921.                                     }catch(Throwable e){
  922.                                         // ignore
  923.                                     }
  924.                                     if(o!=null)
  925.                                         return o;   
  926.                                 }
  927.                                 
  928.                                 if(EAR!=null){
  929.                                     Object[] o = null;
  930.                                     try{
  931.                                         o = readDir(EAR,log);
  932.                                     }catch(Throwable e){
  933.                                         // ignore
  934.                                     }
  935.                                     if(o!=null)
  936.                                         return o;   
  937.                                 }
  938.                             }
  939.                             
  940.                             // Provo ad utilizzare direttamente la directory
  941.                             Object[] o = null;
  942.                             try{
  943.                                 o = readDir(childs[i],log);
  944.                             }catch(Throwable e){
  945.                                 // ignore
  946.                             }
  947.                             if(o!=null)
  948.                                 return o;   
  949.                             
  950.                         }
  951.                     }
  952.                 }
  953.             }
  954.             
  955.             List<String> entries = new ArrayList<>();
  956.             List<byte[]> entriesBytes = new ArrayList<byte[]>();
  957.             
  958.             // Inizializzo List
  959.             for (int i = 0; i < childs.length; i++) {
  960.                 
  961.                 if(childs[i]!=null) {
  962.                     if(childs[i].isDirectory()){
  963.                         
  964.                         // Check if is war/ear
  965.                         File [] f = childs[i].listFiles();
  966.                         if(f!=null && f.length>0){
  967.                 
  968.                             // Utilizzo i files
  969.                             File [] childsEntries = file.listFiles();
  970.                             try{
  971.                                 if(childsEntries!=null){
  972.                                     for (int j = 0; j < childsEntries.length; j++) {
  973.                                         buildEntryNames(childsEntries[j], null, entries,entriesBytes);
  974.                                     }
  975.                                 }
  976.                             }catch(Exception e){
  977.                                 // ignore
  978.                             }
  979.                         }
  980.                     }
  981.                     else{
  982.                         try{
  983.                             entries.add(childs[i].getName());
  984.                             entriesBytes.add(FileSystemUtilities.readBytesFromFile(childs[i]));
  985.                         }catch(Exception e){
  986.                             // ignore
  987.                         }
  988.                     }
  989.                 }
  990.             }
  991.             
  992.             
  993.             // Class
  994.             for (int k = 0; k < entries.size(); k++) {
  995.                     
  996.                 String extension = "";
  997.                 if( entries.get(k).contains(".")){
  998.                     extension = entries.get(k).substring(entries.get(k).lastIndexOf('.')+1, entries.get(k).length());
  999.                 }
  1000.                 String nome = entries.get(k).replaceAll("/", ".");
  1001.                 if(extension!=null){
  1002.                     extension = "."+extension;
  1003.                     nome = nome.substring(0,nome.length()-extension.length());
  1004.                 }
  1005.                 
  1006.                 try{
  1007.                     Method method = this.getClass().getClassLoader().getClass().getMethod("loadClass", String.class);
  1008.                     Object find = method.invoke(this.getClass().getClassLoader(), ClassLoader.class.getName());
  1009.                     Object c = null;
  1010.                     try{
  1011.                         c = method.invoke(this.getClass().getClassLoader(), nome);
  1012.                     }catch(Throwable e){
  1013.                         // ignore
  1014.                     }
  1015.                     if(((Class<?>)find).isAssignableFrom(((Class<?>)c))){
  1016.                         Constructor<?> constructor = ((Class<?>)c).getConstructor(java.lang.ClassLoader.class);
  1017.                         loader = (java.lang.ClassLoader) constructor.newInstance(this.getClass().getClassLoader());
  1018.                         parentDirLoader = nome.split("\\.")[0].trim()+".";
  1019.                         break;
  1020.                     }
  1021.                 }catch(Throwable e){
  1022.                     // ignore
  1023.                 }
  1024.             }
  1025.             if(loader!=null){
  1026.                 log.debug("Loader DIR find (loadClass)");
  1027.             }
  1028.             
  1029.             
  1030.             
  1031.             if(loader==null){
  1032.                 // Bytes 
  1033.                 for (int k = 0; k < entries.size(); k++) {
  1034.                         
  1035.                     String extension = "";
  1036.                     if( entries.get(k).contains(".")){
  1037.                         extension = entries.get(k).substring(entries.get(k).lastIndexOf('.')+1, entries.get(k).length());
  1038.                     }
  1039.                     String nome = entries.get(k).replaceAll("/", ".");
  1040.                     if(extension!=null){
  1041.                         extension = "."+extension;
  1042.                         nome = nome.substring(0,nome.length()-extension.length());
  1043.                     }
  1044.                     
  1045.                     try{
  1046.                         Method method = this.getClass().getClassLoader().getClass().getMethod("loadClass", String.class);
  1047.                         Object find = method.invoke(this.getClass().getClassLoader(), ClassLoader.class.getName());
  1048.                         Object c = null;
  1049.                         try{
  1050.                             ResourceFinder finder = new ResourceFinder(this.getClass().getClassLoader());
  1051.                             c = finder.loadResource(nome, entriesBytes.get(k));
  1052.                         }catch(Throwable e){
  1053.                             // ignore
  1054.                         }
  1055.                         if(c!=null){
  1056.                             if(((Class<?>)find).isAssignableFrom(((Class<?>)c))){
  1057.                                 Constructor<?> constructor = ((Class<?>)c).getConstructor(java.lang.ClassLoader.class,java.util.List.class,java.util.List.class,String.class, File.class);
  1058.                                 parentDirLoader = nome.split("\\.")[0].trim()+".";
  1059.                                 loader = (java.lang.ClassLoader) constructor.newInstance(this.getClass().getClassLoader(),entries,entriesBytes,parentDirLoader,this.archiveFile);
  1060.                                 break;
  1061.                             }
  1062.                         }
  1063.                     }catch(Throwable e){
  1064.                         // ignore
  1065.                     }
  1066.                 }
  1067.                 if(loader!=null){
  1068.                     log.debug("Loader DIR find (ResourceFinder)");
  1069.                 }
  1070.             }
  1071.             
  1072.             
  1073.             if(loader==null){
  1074.                 
  1075.                 // Jar 
  1076.                 for (int k = 0; k < entries.size(); k++) {
  1077.                         
  1078.                     if(entriesBytes.get(k)!=null){
  1079.                         File tmp = null;
  1080.                         try{
  1081.                             tmp = FileSystemUtilities.createTempFile("PddInterceptor", "PddInterceptor");
  1082.                             FileSystemUtilities.writeFile(tmp, entriesBytes.get(k));
  1083.                             if(JarUtilities.isJar(tmp, false)){
  1084.                                 if(checkFile(tmp)){
  1085.                                     Object [] o = readFile(tmp,log);
  1086.                                     if(o!=null){
  1087.                                         return o;
  1088.                                     }
  1089.                                 }
  1090.                             }
  1091.                         }catch(Throwable e){
  1092.                             // ignore
  1093.                         }
  1094.                         finally{
  1095.                             try{
  1096.                                 FileSystemUtilities.deleteDir(tmp);
  1097.                                 tmp.deleteOnExit();
  1098.                             }catch(Exception e){
  1099.                                 // ignore
  1100.                             }
  1101.                         }
  1102.                     }       

  1104.                 }
  1105.             }
  1106.             
  1107.             
  1108.             // Loader trovato
  1109.             if(loader!=null){
  1110.                                 
  1111.                 // Verifico properties
  1112.                 Properties opP = null;
  1113.                 Properties clP = null;
  1114.                 Properties pddP = null;
  1115.                 Properties configP = null;
  1116.                 Properties logP = null;
  1117.                 Properties msgDiagP = null;
  1118.                 Properties cacheP = null;
  1119.                 for (int k = 0; k < entries.size(); k++) {
  1120.                     
  1121.                     String entryName = entries.get(k);
  1122.                     String extension = "";
  1123.                     if( entryName.contains(".")){
  1124.                         extension = entryName.substring(entryName.lastIndexOf('.')+1, entryName.length());
  1125.                     }
  1126.                     String nome = entryName.replaceAll("/", ".");
  1127.                     if(extension!=null){
  1128.                         extension = "."+extension;
  1129.                         nome = nome.substring(0,nome.length()-extension.length());
  1130.                     }
  1131.                     if(nome.equals(loader.getClass().getName())==false && !".".equals(extension) && nome.startsWith(parentDirLoader) ){
  1132.                         Object find = null;
  1133.                         Object c = null;
  1134.                         //Throwable cE = null;
  1135.                         try{
  1136.                             log.debug("Load (DIR) ["+nome+"]...");
  1137.                             Method method = loader.getClass().getMethod("loadClass", String.class);
  1138.                             find = method.invoke(loader, Properties.class.getName());
  1139.                             c = method.invoke(loader, nome);
  1140.                             log.debug("Load (DIR) ["+nome+"] OK");
  1141.                             if(find==null){
  1142.                                 throw new Exception("find null");
  1143.                             }
  1144.                             if(c==null){
  1145.                                 throw new Exception("c null");
  1146.                             }
  1147.                         }catch(Exception e){
  1148.                             log.debug("Loader (DIR) instance ["+nome+"] error: "+e.getMessage(),e);
  1149.                         }
  1150.                         catch(Throwable e){
  1151.                             log.debug("Loader (DIR) instance ["+nome+"] error: "+e.getMessage(),e);
  1152.                         }
  1153.                         if(find!=null && c!=null){
  1154.                             try{
  1155.                                 if(((Class<?>)find).isAssignableFrom(((Class<?>)c))){
  1156.                                     Constructor<?> constructor = ((Class<?>)c).getConstructor();
  1157.                                     Properties properties = (Properties) constructor.newInstance();
  1158.                                     Object type = properties.get("type");
  1159.                                     if(type==null){
  1160.                                         continue;
  1161.                                     }
  1162.                                     else if("openspcoop".equals(type)){
  1163.                                         opP = properties;
  1164.                                     }
  1165.                                     else if("className".equals(type)){
  1166.                                         clP = properties;
  1167.                                     }
  1168.                                     else if("pdd".equals(type)){
  1169.                                         pddP = properties;
  1170.                                     }
  1171.                                     else if("logger".equals(type)){
  1172.                                         logP = properties;
  1173.                                     }
  1174.                                     else if("config".equals(type)){
  1175.                                         configP = properties;
  1176.                                     }
  1177.                                     else if("msgDiagnostici".equals(type)){
  1178.                                         msgDiagP = properties;
  1179.                                     }
  1180.                                     else if("cache".equals(type)){
  1181.                                         cacheP = properties;
  1182.                                     }
  1183.                                 }
  1184.                             }catch(Exception e){
  1185.                                 log.debug("Loader (DIR) instance ["+nome+"] error: "+e.getMessage(),e);
  1186.                             }
  1187.                             catch(Throwable e){
  1188.                                 log.debug("Loader (DIR) instance ["+nome+"] error: "+e.getMessage(),e);
  1189.                             }
  1190.                         }
  1191.                     }           
  1192.                 }
  1193.                 if(opP!=null && clP!=null && pddP!=null && logP!=null && configP!=null && msgDiagP!=null && cacheP!=null){
  1194.                     Object [] o = new Object[this.RESULT_LENGTH];
  1195.                     o[0]=loader;
  1196.                     o[1]=opP;
  1197.                     o[2]=clP;
  1198.                     o[3]=pddP;
  1199.                     o[4]=logP;
  1200.                     o[5]=configP;
  1201.                     o[6]=msgDiagP;
  1202.                     o[7]=cacheP;
  1203.                     for (int i = 0; i < o.length; i++) {
  1204.                         log.debug("Class (DIR) ["+i+"]=["+o[i].getClass().getName()+"]");
  1205.                     }
  1206.                     return o;
  1207.                 }
  1208.             }
  1209.         }
  1210.         
  1211.         return null;
  1212.     }
  1213.     
  1214.     private void buildEntryNames(File file,String prefix,List<String> files,List<byte[]> entriesBytes) throws Exception{
  1215.         
  1216.         String name = null;
  1217.         if(prefix!=null){
  1218.             name = prefix+"."+file.getName();
  1219.         }
  1220.         else{
  1221.             name = file.getName();
  1222.         }
  1223.         
  1224.         if(file.isFile()){
  1225.             files.add(name);
  1226.             entriesBytes.add(FileSystemUtilities.readBytesFromFile(file));
  1227.             return;
  1228.         }
  1229.         else if(file.isDirectory()){
  1230.             File [] childs = file.listFiles();
  1231.             if(childs!=null){
  1232.                 for (int i = 0; i < childs.length; i++) {
  1233.                     buildEntryNames(childs[i],name,files,entriesBytes);
  1234.                 }
  1235.             }
  1236.         }else{
  1237.             return;
  1238.         }
  1239.     }
  1240.     
  1241. }
Created with JaCoCo 0.8.8.202204050719