Fixed zookeeper node delete with failed code generation

Author: computate

src/main/java/org/computate/frFR/java/EcrireToutesClasses.java

@@ -194,6 +194,7 @@ else if(BooleanUtils.isTrue(partEstEntite)) {
 						ecrireGenApiServiceImpl1(langueNom);
 						ecrireGenApiServiceImpl2(langueNom);
 						ecrireGenApiServiceImpl3(langueNom);
+						ecrireGenApiServiceImpl4(langueNom);
 						ecrireApiServiceImpl(langueNom);
 					}
 				}

src/main/java/org/computate/frFR/java/RegarderRepertoire.java

@@ -592,9 +592,10 @@ private void regarderClasseEvenement(Message<Object> message) {
 			Promise<Void> promise = Promise.promise();
 			String zookeeperNodeName = null;
 			Stat zookeeperStat = null;
+			String cheminCompletStr = null;
 			try {
 				JsonObject body = ((JsonObject)message.body()).getJsonObject("context").getJsonObject("params").getJsonObject("body");
-				String cheminCompletStr = body.getString("cheminComplet");
+				cheminCompletStr = body.getString("cheminComplet");
 				LOG.debug(String.format("Received request on the event bus: %s", cheminCompletStr));
 				Path cheminComplet = Path.of(cheminCompletStr);
 				zookeeperStat = new Stat();
@@ -613,14 +614,16 @@ private void regarderClasseEvenement(Message<Object> message) {
 
 				executeur.setWorkingDirectory(repertoireTravail);
 				executeur.execute(ligneCommande); 
-				zookeeper.delete(zookeeperNodeName, zookeeperStat.getVersion());
 				String classeNomSimple = StringUtils.substringBeforeLast(cheminComplet.getFileName().toString(), ".");
 				String log = String.format(classeLangueConfig.getString(I18n.str_chemin_absolu), classeNomSimple);
 				LOG.info(log);
 				promise.complete();
 			} catch(Exception ex) {
 				if(!(ex instanceof KeeperException.NodeExistsException))
-					LOG.error("Une Problème d'exécution de RegarderRepertoire. ", ex);
+					LOG.error(String.format(classeLangueConfig.getString(I18n.str_UneProblemeExecutionRegarderRepertoire), cheminCompletStr), ex);
+				promise.fail(ex);
+			} finally {
+				zookeeper.delete(zookeeperNodeName, zookeeperStat.getVersion());
 			}
 			return promise.future();
 		});
@@ -826,7 +829,7 @@ public void start(Promise<Void> startPromise) throws Exception {
 			connectionLatch.await();
 			Stat zookeeperStat = new Stat();
 			try {
-				zookeeper.create(String.format("/%s", ZOOKEEPER_ROOT_PATH), "reserved".getBytes(), ZooDefs.Ids.OPEN_ACL_UNSAFE, CreateMode.EPHEMERAL, zookeeperStat);
+				zookeeper.create(String.format("/%s", ZOOKEEPER_ROOT_PATH), "reserved".getBytes(), ZooDefs.Ids.OPEN_ACL_UNSAFE, CreateMode.PERSISTENT, zookeeperStat);
 			} catch(KeeperException.NodeExistsException ex) {
 				LOG.info(String.format("The zookeeper root node already exists: %s", String.format("/%s", ZOOKEEPER_ROOT_PATH)));
 			}