PropertiesScriptBuilder.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.  */

  21. package org.openspcoop2.core.commons;

  23. import java.io.ByteArrayOutputStream;
  24. import java.io.File;
  25. import java.util.Arrays;
  26. import java.util.HashMap;
  27. import java.util.Iterator;
  28. import java.util.Map;

  30. import org.openspcoop2.utils.resources.FileSystemUtilities;

  32. /**
  33.  * PropertiesScriptBuilder
  34.  *
  35.  * @author Poli Andrea (apoli@link.it)
  36.  * @author $Author$
  37.  * @version $Rev$, $Date$
  38.  */
  39. public class PropertiesScriptBuilder {

  41.     public static void main(String[] args) throws Exception {
  42.         // Metodo utilizzato dal setup antinstaller
  43.         
  44.         String sourceDir = (String) args[0];
  45.         
  46.         String destDir = (String) args[1];
  47.         
  48.         String distDir = (String) args[2];
  49.         
  50.         String versionePrecedente = null;
  51.         String versioneAttuale = null;
  52.         if(args.length>3){
  53.             versionePrecedente = (String) args[3];
  54.             versioneAttuale = (String) args[4];
  55.         }

  57.         // NOTA: Non far stampare niente, viene usato come meccanismo di check per vedere se l'esecuzione e' andata a buon fine

  59.         //System.out.println("versionePrecedente ["+versionePrecedente+"]");
  60.         //System.out.println("versioneAttuale ["+versioneAttuale+"]");
  61.         //System.out.println("tipoDatabase ["+tipoDatabase+"]");

  63.         
  64.         
  65.         build_Aggiornamento(new File(sourceDir),new File(destDir), new File(distDir),
  66.                 versionePrecedente, versioneAttuale);

  68.     }
  69.         
  70.     private static void build_Aggiornamento(File sourceDir, File destDir,  File distDir,
  71.             String precedenteVersione, String versioneAttuale) throws Exception {

  73.         
  74.         if(sourceDir.exists()==false){
  75.             throw new Exception("Source dir ["+sourceDir.getAbsolutePath()+"] not exists");
  76.         }
  77.         if(sourceDir.canRead()==false){
  78.             throw new Exception("Source dir ["+sourceDir.getAbsolutePath()+"] cannot read");
  79.         }

  81.         if(destDir.exists()==false){
  82.             throw new Exception("Dest dir ["+destDir.getAbsolutePath()+"] not exists");
  83.         }
  84.         if(destDir.canWrite()==false){
  85.             throw new Exception("Dest dir ["+destDir.getAbsolutePath()+"] cannot write");
  86.         }
  87.         
  88.         if(distDir.exists()==false){
  89.             throw new Exception("Dest dir ["+destDir.getAbsolutePath()+"] not exists");
  90.         }
  91.         if(distDir.canWrite()==false){
  92.             throw new Exception("Dest dir ["+destDir.getAbsolutePath()+"] cannot write");
  93.         }
  94.         
  95.         if(precedenteVersione==null){
  96.             throw new Exception("Precedente versione non fornita");
  97.         }
  98.         if(precedenteVersione.contains(".")==false){
  99.             throw new Exception("Precedente versione in un formato non corretto ["+precedenteVersione+"] ('.' not found)");
  100.         }
  101.         int indexOfFirstPoint = precedenteVersione.indexOf(".");
  102.         if(indexOfFirstPoint<=0){
  103.             throw new Exception("Precedente versione in un formato non corretto ["+precedenteVersione+"] ('.' not found with index)");
  104.         }
  105.         String productVersionString = precedenteVersione.substring(0, indexOfFirstPoint);
  106.         int productVersion = -1;
  107.         try{
  108.             productVersion = Integer.parseInt(productVersionString);
  109.         }catch(Exception e){
  110.             throw new Exception("Precedente versione in un formato non corretto ["+precedenteVersione+"] (productVersion:"+productVersionString+"): "+e.getMessage(),e);
  111.         }
  112.         int indexOfSecondPoint = precedenteVersione.indexOf(".",indexOfFirstPoint+1);
  113.         if(indexOfSecondPoint<=0 || indexOfSecondPoint<=indexOfFirstPoint){
  114.             throw new Exception("Precedente versione in un formato non corretto ["+precedenteVersione+"] (second '.' not found)");
  115.         }
  116.         String majorVersionString = precedenteVersione.substring(indexOfFirstPoint+1, indexOfSecondPoint);
  117.         int majorVersion = -1;
  118.         try{
  119.             majorVersion = Integer.parseInt(majorVersionString);
  120.         }catch(Exception e){
  121.             throw new Exception("Precedente versione in un formato non corretto ["+precedenteVersione+"] (majorVersion:"+majorVersionString+"): "+e.getMessage(),e);
  122.         }
  123.         if(precedenteVersione.length()<=indexOfSecondPoint){
  124.             throw new Exception("Precedente versione in un formato non corretto ["+precedenteVersione+"] (length)");
  125.         }
  126.         String minorVersionString = precedenteVersione.substring(indexOfSecondPoint+1,precedenteVersione.length());
  127.         int minorVersion = -1;
  128.         try{
  129.             minorVersion = Integer.parseInt(minorVersionString);
  130.         }catch(Exception e){
  131.             //throw new Exception("Precedente versione in un formato non corretto ["+precedenteVersione+"] (minorVersion:"+minorVersionString+"): "+e.getMessage(),e);
  132.             // Potrebbe essere una BUILD VERSION
  133.             if(minorVersionString.contains("_")){
  134.                 String newMinor = minorVersionString.split("_")[0];
  135.                 try{
  136.                     minorVersion = Integer.parseInt(newMinor);
  137.                 }catch(Exception eInternal){
  138.                     throw new Exception("Precedente versione in un formato non corretto ["+precedenteVersione+"] (minorVersion:"+minorVersionString+" minorVersionBuildNumber:"+newMinor+"): "+eInternal.getMessage(),eInternal);
  139.                 }
  140.             }
  141.             else{
  142.                 throw new Exception("Precedente versione in un formato non corretto ["+precedenteVersione+"] (minorVersion:"+minorVersionString+"): "+e.getMessage(),e);
  143.             }
  144.             
  145.         }
  146.         //System.out.println(productVersion+"."+majorVersion+"."+minorVersion);
  147.         
  148.         
  149.         int tmpMajorVersion = majorVersion;
  150.         int tmpMinorVersion = minorVersion;
  151.         
  152.         Map<String, Boolean> configCreateFileFromDist = new HashMap<String, Boolean>();
  153.         Map<String, ByteArrayOutputStream> configCreateFileDiff = new HashMap<>();
  154.         
  155.         
  156.         while(true){
  157.             
  158.             String actualVersion = productVersion+"."+tmpMajorVersion+"."+tmpMinorVersion;
  159.             String nextVersion = productVersion+"."+tmpMajorVersion+"."+(tmpMinorVersion+1);
  160.             File version = new File(sourceDir,"upgrade_"+actualVersion+"_to_"+nextVersion);
  161.             //System.out.println("CHECK ["+version.getAbsolutePath()+"] ["+version.exists()+"]");
  162.             if(version.exists()){
  163.                 if(version.canRead()==false){
  164.                     throw new Exception("Source version dir ["+version.getAbsolutePath()+"] cannot read");
  165.                 }
  166.                 
  167.                 _create_Aggiornamento(version, destDir,
  168.                         configCreateFileFromDist, configCreateFileDiff,
  169.                         nextVersion);
  170.                 
  171.                 tmpMinorVersion++;
  172.             }
  173.             else{
  174.                 // check upgrade to major version +1
  175.                 actualVersion = productVersion+"."+tmpMajorVersion+".x";
  176.                 nextVersion = productVersion+"."+(tmpMajorVersion+1)+".0";
  177.                 version = new File(sourceDir,"upgrade_"+actualVersion+"_to_"+nextVersion);
  178.                 //System.out.println("CHECK UPGRADE ["+version.getAbsolutePath()+"] ["+version.exists()+"]");
  179.                 if(version.exists()){
  180.                     if(version.canRead()==false){
  181.                         throw new Exception("Source version dir ["+version.getAbsolutePath()+"] cannot read");
  182.                     }
  183.                     
  184.                     _create_Aggiornamento(version, destDir, 
  185.                             configCreateFileFromDist, configCreateFileDiff,
  186.                             nextVersion);
  187.                     
  188.                     tmpMajorVersion++;
  189.                     tmpMinorVersion=0;
  190.                 }
  191.                 else{
  192.                     break;
  193.                 }
  194.             }
  195.             
  196.         }
  197.         
  198.         if(configCreateFileFromDist.size()>0) {
  199.             Iterator<String> it = configCreateFileFromDist.keySet().iterator();
  200.             while (it.hasNext()) {
  201.                 String id = (String) it.next();
  202.                 String fileName = id + ".properties";
  203.                 
  204.                 File[] files = distDir.listFiles();
  205.                 if(files!=null && files.length>0) {
  206.                     // Prima esamino i file properties interi poi i diff
  207.                     for(File distFile : files) {
  208.                         if(distFile.getName().equals(fileName)) {
  209.                             File fOut = new File(destDir, fileName);
  210.                             FileSystemUtilities.copy(distFile, fOut);
  211.                             break;
  212.                         }
  213.                     }
  214.                 }
  215.             }
  216.         }
  217.         
  218.         if(configCreateFileDiff.size()>0) {
  219.             Iterator<String> it = configCreateFileDiff.keySet().iterator();
  220.             while (it.hasNext()) {
  221.                 String id = (String) it.next();
  222.                 String fileName = id + ".diff";
  223.                 
  224.                 File fOut = new File(destDir, fileName);
  225.                 ByteArrayOutputStream bout = configCreateFileDiff.get(id);
  226.                 bout.flush();
  227.                 bout.close();
  228.                 FileSystemUtilities.writeFile(fOut, bout.toByteArray());

  230.             }
  231.         }
  232.         
  233.     }
  234.     
  235.     private static void _create_Aggiornamento(File sourceDir, File destDir, 
  236.             Map<String, Boolean> configCreateFileFromDist , Map<String, ByteArrayOutputStream> configCreateFileDiff ,
  237.             String nextVersion) throws Exception {
  238.                         
  239.         //System.out.println("CHECK.... source ["+sourceDir.getAbsolutePath()+"]");
  240.         
  241.         File[] files = sourceDir.listFiles();
  242.         if(files!=null && files.length>0) {
  243.             
  244.             // Prima esamino i file properties interi poi i diff
  245.             for(File upgradeDir : files) {
  246.                 if(upgradeDir.isDirectory() && (
  247.                         upgradeDir.getName().equals("core") || upgradeDir.getName().equals("protocolli")
  248.                         )) {
  249.                     
  250.                     File[] fileChilds = upgradeDir.listFiles();
  251.                     if(fileChilds!=null && fileChilds.length>0) {
  252.                         
  253.                         Arrays.sort(fileChilds); // sono ordinati per data
  254.                         
  255.                         for(File upgradeFile : fileChilds) {
  256.                             if(upgradeFile.getName().endsWith(".properties")) {
  257.                                 String key = upgradeFile.getName().substring(0, upgradeFile.getName().indexOf(".properties"));
  258.                                 if(configCreateFileFromDist.containsKey(key)==false) {
  259.                                     //System.out.println("ADDD PROPERTIES ["+key+"]");
  260.                                     configCreateFileFromDist.put(key, true);
  261.                                 }
  262.                             }
  263.                         }
  264.                     }
  265.                     
  266.                 }
  267.                 
  268.             }
  269.             
  270.             Arrays.sort(files); // sono ordinati per data
  271.             for(File upgradeDir : files) {
  272.                 
  273.                 if(upgradeDir.isDirectory() && (
  274.                         upgradeDir.getName().equals("core") || upgradeDir.getName().equals("protocolli")
  275.                         )) {
  276.                     
  277.                     File[] fileChilds = upgradeDir.listFiles();
  278.                     if(fileChilds!=null && fileChilds.length>0) {

  280.                         Arrays.sort(fileChilds); // sono ordinati per data
  281.                         
  282.                         for(File diffFile : fileChilds) {
  283.                 
  284.                             if(diffFile.getName().endsWith(".diff")) {
  285.                                 
  286.                                 String data= ".YYYY-MM-DD.diff";
  287.                                 //System.out.println("DIFF NAME ["+diffFile.getName()+"]");
  288.                                 String key = diffFile.getName().substring(0, (diffFile.getName().length()-data.length()));
  289.                                 //System.out.println("DIFF KEY ["+key+"]");
  290.                                 if(configCreateFileFromDist.containsKey(key)==false) {
  291.                                     
  292.                                     //System.out.println("ADDD DIFF");
  293.                                     
  294.                                     ByteArrayOutputStream bout = null;
  295.                                     if(configCreateFileDiff.containsKey(key)) {
  296.                                         bout = configCreateFileDiff.get(key);
  297.                                     }
  298.                                     else {
  299.                                         bout = new ByteArrayOutputStream();
  300.                                         configCreateFileDiff.put(key, bout);
  301.                                     }
  302.                                     
  303.                                     _createAggiornamento(diffFile, bout);   
  304.                                 }
  305.                             }
  306.                             
  307.                         }
  308.                     }
  309.                 }
  310.             }
  311.             
  312.         }

  314.     }
  315.     
  316.     private static void _createAggiornamento(File diffFile, ByteArrayOutputStream bout) throws Exception{
  317.         
  318.         byte[] b = FileSystemUtilities.readBytesFromFile(diffFile);
  319.         if(bout.size()>0){
  320.             bout.write("\n\n".getBytes());
  321.         }
  322.         bout.write(b);
  323.     }
  324.     
  325. }
Created with JaCoCo 0.8.8.202204050719