org.argeo.cms/src/org/argeo/cms/internal/runtime/CmsStateImpl.java

   1 package org.argeo.cms.internal.runtime;
   2
   3 import java.net.InetAddress;
   4 import java.net.URL;
   5 import java.net.UnknownHostException;
   6
   7 import javax.security.auth.login.Configuration;
   8
   9 import org.argeo.api.cms.CmsLog;
  10 import org.argeo.api.cms.CmsState;
  11 import org.argeo.cms.auth.ident.IdentClient;
  12 import org.argeo.cms.internal.osgi.CmsShutdown;
  13 import org.osgi.framework.Constants;
  14
  15 /**
  16  * Implementation of a {@link CmsState}, initialising the required services.
  17  */
  18 public class CmsStateImpl implements CmsState {
  19         private final static CmsLog log = CmsLog.getLog(CmsStateImpl.class);
  20 //      private final BundleContext bc = FrameworkUtil.getBundle(CmsState.class).getBundleContext();
  21
  22 //      private static CmsStateImpl instance;
  23
  24 //      private ExecutorService internalExecutorService;
  25
  26         // REFERENCES
  27         private Long availableSince;
  28
  29 //      private ThreadGroup threadGroup = new ThreadGroup("CMS");
  30 //      private List<Runnable> stopHooks = new ArrayList<>();
  31
  32         private String stateUuid;
  33 //      private final boolean cleanState;
  34         private String hostname;
  35
  36         public void start() {
  37 //              instance = this;
  38
  39                 Runtime.getRuntime().addShutdownHook(new CmsShutdown());
  40 //              this.internalExecutorService = Executors.newFixedThreadPool(Runtime.getRuntime().availableProcessors());
  41
  42                 try {
  43                         initSecurity();
  44 //                      initArgeoLogger();
  45 //                      initNode();
  46
  47                         if (log.isTraceEnabled())
  48                                 log.trace("CMS State started");
  49
  50                         this.stateUuid = KernelUtils.getFrameworkProp(Constants.FRAMEWORK_UUID);
  51 //              this.cleanState = stateUuid.equals(frameworkUuid);
  52                         try {
  53                                 this.hostname = InetAddress.getLocalHost().getHostName();
  54                         } catch (UnknownHostException e) {
  55                                 log.error("Cannot set hostname: " + e);
  56                         }
  57
  58                         availableSince = System.currentTimeMillis();
  59                         if (log.isDebugEnabled())
  60                                 // log.debug("## CMS starting... stateUuid=" + this.stateUuid + (cleanState ? "
  61                                 // (clean state) " : " "));
  62                                 log.debug("## CMS starting... (" + stateUuid + ")");
  63
  64 //              initI18n();
  65 //              initServices();
  66
  67                 } catch (RuntimeException e) {
  68                         log.error("## FATAL: CMS activator failed", e);
  69                 }
  70         }
  71
  72         private void initSecurity() {
  73                 if (System.getProperty(KernelConstants.JAAS_CONFIG_PROP) == null) {
  74                         String jaasConfig = KernelConstants.JAAS_CONFIG;
  75                         URL url = getClass().getResource(jaasConfig);
  76                         // System.setProperty(KernelConstants.JAAS_CONFIG_PROP,
  77                         // url.toExternalForm());
  78                         KernelUtils.setJaasConfiguration(url);
  79                 }
  80                 // explicitly load JAAS configuration
  81                 Configuration.getConfiguration();
  82         }
  83
  84 //      private void initI18n() {
  85 //              Object defaultLocaleValue = KernelUtils.getFrameworkProp(CmsConstants.I18N_DEFAULT_LOCALE);
  86 //              defaultLocale = defaultLocaleValue != null ? new Locale(defaultLocaleValue.toString())
  87 //                              : new Locale(ENGLISH.getLanguage());
  88 //              locales = LocaleUtils.asLocaleList(KernelUtils.getFrameworkProp(CmsConstants.I18N_LOCALES));
  89 //      }
  90
  91         private void initServices() {
  92                 // JTA
  93 //              String tmType = KernelUtils.getFrameworkProp(CmsConstants.TRANSACTION_MANAGER,
  94 //                              CmsConstants.TRANSACTION_MANAGER_SIMPLE);
  95 //              if (CmsConstants.TRANSACTION_MANAGER_SIMPLE.equals(tmType)) {
  96 //                      initSimpleTransactionManager();
  97 //              } else if (CmsConstants.TRANSACTION_MANAGER_BITRONIX.equals(tmType)) {
  98 ////                    initBitronixTransactionManager();
  99 //                      throw new UnsupportedOperationException(
 100 //                                      "Bitronix is not supported anymore, but could be again if there is enough interest.");
 101 //              } else {
 102 //                      throw new IllegalArgumentException("Usupported transaction manager type " + tmType);
 103 //              }
 104
 105                 // POI
 106 //              POIXMLTypeLoader.setClassLoader(CTConnection.class.getClassLoader());
 107
 108                 // Tika
 109 //              OpenDocumentParser odfParser = new OpenDocumentParser();
 110 //              bc.registerService(Parser.class, odfParser, new Hashtable());
 111 //              PDFParser pdfParser = new PDFParser();
 112 //              bc.registerService(Parser.class, pdfParser, new Hashtable());
 113 //              OOXMLParser ooxmlParser = new OOXMLParser();
 114 //              bc.registerService(Parser.class, ooxmlParser, new Hashtable());
 115 //              TesseractOCRParser ocrParser = new TesseractOCRParser();
 116 //              ocrParser.setLanguage("ara");
 117 //              bc.registerService(Parser.class, ocrParser, new Hashtable());
 118
 119 //              // JCR
 120 //              RepositoryServiceFactory repositoryServiceFactory = new RepositoryServiceFactory();
 121 //              stopHooks.add(() -> repositoryServiceFactory.shutdown());
 122 //              Activator.registerService(ManagedServiceFactory.class, repositoryServiceFactory,
 123 //                              LangUtils.dict(Constants.SERVICE_PID, NodeConstants.NODE_REPOS_FACTORY_PID));
 124 //
 125 //              NodeRepositoryFactory repositoryFactory = new NodeRepositoryFactory();
 126 //              Activator.registerService(RepositoryFactory.class, repositoryFactory, null);
 127
 128                 // Security
 129 //              NodeUserAdmin userAdmin = new NodeUserAdmin(CmsConstants.ROLES_BASEDN, CmsConstants.TOKENS_BASEDN);
 130 //              stopHooks.add(() -> userAdmin.destroy());
 131 //              Activator.registerService(ManagedServiceFactory.class, userAdmin,
 132 //                              LangUtils.dict(Constants.SERVICE_PID, CmsConstants.NODE_USER_ADMIN_PID));
 133
 134         }
 135
 136 //      private void initSimpleTransactionManager() {
 137 //              SimpleTransactionManager transactionManager = new SimpleTransactionManager();
 138 //              Activator.registerService(WorkControl.class, transactionManager, null);
 139 //              Activator.registerService(WorkTransaction.class, transactionManager, null);
 140 ////            Activator.registerService(TransactionManager.class, transactionManager, null);
 141 ////            Activator.registerService(UserTransaction.class, transactionManager, null);
 142 //              // TODO TransactionSynchronizationRegistry
 143 //      }
 144
 145 //      private void initBitronixTransactionManager() {
 146 //              // TODO manage it in a managed service, as startup could be long
 147 //              ServiceReference<TransactionManager> existingTm = bc.getServiceReference(TransactionManager.class);
 148 //              if (existingTm != null) {
 149 //                      if (log.isDebugEnabled())
 150 //                              log.debug("Using provided transaction manager " + existingTm);
 151 //                      return;
 152 //              }
 153 //
 154 //              if (!TransactionManagerServices.isTransactionManagerRunning()) {
 155 //                      bitronix.tm.Configuration tmConf = TransactionManagerServices.getConfiguration();
 156 //                      tmConf.setServerId(UUID.randomUUID().toString());
 157 //
 158 //                      Bundle bitronixBundle = FrameworkUtil.getBundle(bitronix.tm.Configuration.class);
 159 //                      File tmBaseDir = bitronixBundle.getDataFile(KernelConstants.DIR_TRANSACTIONS);
 160 //                      File tmDir1 = new File(tmBaseDir, "btm1");
 161 //                      tmDir1.mkdirs();
 162 //                      tmConf.setLogPart1Filename(new File(tmDir1, tmDir1.getName() + ".tlog").getAbsolutePath());
 163 //                      File tmDir2 = new File(tmBaseDir, "btm2");
 164 //                      tmDir2.mkdirs();
 165 //                      tmConf.setLogPart2Filename(new File(tmDir2, tmDir2.getName() + ".tlog").getAbsolutePath());
 166 //              }
 167 //              BitronixTransactionManager transactionManager = getTransactionManager();
 168 //              stopHooks.add(() -> transactionManager.shutdown());
 169 //              BitronixTransactionSynchronizationRegistry transactionSynchronizationRegistry = getTransactionSynchronizationRegistry();
 170 //              // register
 171 //              bc.registerService(TransactionManager.class, transactionManager, null);
 172 //              bc.registerService(UserTransaction.class, transactionManager, null);
 173 //              bc.registerService(TransactionSynchronizationRegistry.class, transactionSynchronizationRegistry, null);
 174 //              if (log.isDebugEnabled())
 175 //                      log.debug("Initialised default Bitronix transaction manager");
 176 //      }
 177
 178         public void stop() {
 179                 if (log.isDebugEnabled())
 180                         log.debug("CMS stopping...  (" + this.stateUuid + ")");
 181 //              new GogoShellKiller().start();
 182
 183                 // In a different thread in order to avoid interruptions
 184 //              Thread stopHookThread = new Thread(() -> applyStopHooks(), "Apply Argeo Stop Hooks");
 185 //              stopHookThread.start();
 186 //              try {
 187 //                      stopHookThread.join(10 * 60 * 1000);
 188 //              } catch (InterruptedException e) {
 189 //                      // silent
 190 //              }
 191
 192 //              internalExecutorService.shutdown();
 193
 194                 long duration = ((System.currentTimeMillis() - availableSince) / 1000) / 60;
 195                 log.info("## ARGEO CMS STOPPED after " + (duration / 60) + "h " + (duration % 60) + "min uptime ##");
 196         }
 197
 198         /** Apply shutdown hoos in reverse order. */
 199 //      private void applyStopHooks() {
 200 ////            for (int i = stopHooks.size() - 1; i >= 0; i--) {
 201 ////                    try {
 202 ////                            stopHooks.get(i).run();
 203 ////                    } catch (Exception e) {
 204 ////                            log.error("Could not run shutdown hook #" + i);
 205 ////                    }
 206 ////            }
 207 //              // Clean hanging Gogo shell thread
 208 //              new GogoShellKiller().start();
 209 //
 210 ////            instance = null;
 211 //      }
 212
 213 //      @Override
 214 //      public boolean isClean() {
 215 //              return cleanState;
 216 //      }
 217
 218         @Override
 219         public Long getAvailableSince() {
 220                 return availableSince;
 221         }
 222
 223         /*
 224          * ACCESSORS
 225          */
 226         public String getHostname() {
 227                 return hostname;
 228         }
 229
 230         /*
 231          * STATIC
 232          */
 233         public static IdentClient getIdentClient(String remoteAddr) {
 234                 if (!IdentClient.isDefaultAuthdPassphraseFileAvailable())
 235                         return null;
 236                 // TODO make passphrase more configurable
 237                 return new IdentClient(remoteAddr);
 238         }
 239 }