Set new master version for Dublin
[policy/engine.git] / BRMSGateway / src / main / java / org / onap / policy / brms / api / BrmsPush.java
1 /*-
2  * ============LICENSE_START=======================================================
3  * ONAP Policy Engine
4  * ================================================================================
5  * Copyright (C) 2017-2018 AT&T Intellectual Property. All rights reserved.
6  * Modified Copyright (C) 2018 Samsung Electronics Co., Ltd.
7  * ================================================================================
8  * Licensed under the Apache License, Version 2.0 (the "License");
9  * you may not use this file except in compliance with the License.
10  * You may obtain a copy of the License at
11  *
12  *      http://www.apache.org/licenses/LICENSE-2.0
13  *
14  * Unless required by applicable law or agreed to in writing, software
15  * distributed under the License is distributed on an "AS IS" BASIS,
16  * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
17  * See the License for the specific language governing permissions and
18  * limitations under the License.
19  * ============LICENSE_END=========================================================
20  */
21
22 package org.onap.policy.brms.api;
23
24 import com.att.nsa.cambria.client.CambriaBatchingPublisher;
25 import com.att.nsa.cambria.client.CambriaClientBuilders;
26 import com.att.nsa.cambria.client.CambriaClientBuilders.PublisherBuilder;
27 import com.fasterxml.jackson.core.JsonProcessingException;
28
29 import java.io.File;
30 import java.io.FileInputStream;
31 import java.io.FileOutputStream;
32 import java.io.IOException;
33 import java.io.InputStream;
34 import java.io.Writer;
35 import java.net.URL;
36 import java.nio.channels.Channels;
37 import java.nio.channels.ReadableByteChannel;
38 import java.nio.charset.StandardCharsets;
39 import java.nio.file.Files;
40 import java.nio.file.Path;
41 import java.nio.file.Paths;
42 import java.security.GeneralSecurityException;
43 import java.util.ArrayList;
44 import java.util.Arrays;
45 import java.util.Collections;
46 import java.util.Enumeration;
47 import java.util.HashMap;
48 import java.util.List;
49 import java.util.Map;
50 import java.util.Properties;
51 import java.util.UUID;
52 import java.util.concurrent.TimeUnit;
53 import java.util.jar.JarEntry;
54 import java.util.jar.JarFile;
55 import java.util.regex.Pattern;
56
57 import javax.persistence.EntityManager;
58 import javax.persistence.EntityManagerFactory;
59 import javax.persistence.EntityTransaction;
60 import javax.persistence.Persistence;
61 import javax.persistence.TypedQuery;
62 import javax.ws.rs.ProcessingException;
63
64 import org.apache.commons.io.FileUtils;
65 import org.apache.commons.lang.StringEscapeUtils;
66 import org.apache.maven.model.Dependency;
67 import org.apache.maven.model.DeploymentRepository;
68 import org.apache.maven.model.DistributionManagement;
69 import org.apache.maven.model.Model;
70 import org.apache.maven.model.io.xpp3.MavenXpp3Writer;
71 import org.apache.maven.shared.invoker.DefaultInvocationRequest;
72 import org.apache.maven.shared.invoker.DefaultInvoker;
73 import org.apache.maven.shared.invoker.InvocationRequest;
74 import org.apache.maven.shared.invoker.InvocationResult;
75 import org.apache.maven.shared.invoker.Invoker;
76 import org.codehaus.plexus.util.IOUtil;
77 import org.codehaus.plexus.util.WriterFactory;
78 import org.eclipse.persistence.config.PersistenceUnitProperties;
79 import org.onap.policy.api.PEDependency;
80 import org.onap.policy.api.PolicyException;
81 import org.onap.policy.brms.api.nexus.NexusRestSearchParameters;
82 import org.onap.policy.brms.api.nexus.NexusRestWrapper;
83 import org.onap.policy.brms.api.nexus.NexusRestWrapperException;
84 import org.onap.policy.brms.api.nexus.pojo.NexusArtifact;
85 import org.onap.policy.brms.entity.BrmsGroupInfo;
86 import org.onap.policy.brms.entity.BrmsPolicyInfo;
87 import org.onap.policy.brms.entity.DependencyInfo;
88 import org.onap.policy.common.im.IntegrityMonitor;
89 import org.onap.policy.common.logging.eelf.MessageCodes;
90 import org.onap.policy.common.logging.eelf.PolicyLogger;
91 import org.onap.policy.common.logging.flexlogger.FlexLogger;
92 import org.onap.policy.common.logging.flexlogger.Logger;
93 import org.onap.policy.utils.BackUpHandler;
94 import org.onap.policy.utils.BackUpMonitor;
95 import org.onap.policy.utils.BusPublisher;
96 import org.onap.policy.utils.PolicyUtils;
97 import org.onap.policy.xacml.api.XACMLErrorConstants;
98
99 /**
100  * BRMSPush: Application responsible to push policies to the BRMS PDP Policy Repository (PR). Mavenize and push policy
101  * to PR
102  *
103  * @version 1.0
104  */
105
106 public class BrmsPush {
107     private static final String GROUP_NAMES = "groupNames";
108     private static final String DROOLS_APPS_TEMPLATE_GROUP =
109             "org.onap.policy.drools-applications.controlloop.templates";
110     private static final String DROOLS_APPS_MODEL_GROUP =
111             "org.onap.policy.drools-applications.controlloop.common.model-impl";
112     private static final String META_INF = "META-INF";
113     private static final String KMODULE_XML_FILE = "kmodule.xml";
114     private static final String POM_XML_FILE = "pom.xml";
115     private static final String VERSION_0_1_0 = "0.1.0";
116     private static final String RULES = "rules";
117     private static final String RESOURCES = "resources";
118     private static final Logger LOGGER = FlexLogger.getLogger(BrmsPush.class.getName());
119     private static final String PROJECTSLOCATION = "RuleProjects";
120     private static final String[] GOALS = { "clean", "deploy" };
121     private static final String DEFAULT_VERSION = "1.4.0-SNAPSHOT";
122     private static final String DEPENDENCY_FILE = "dependency.json";
123     private static final String BRMSPERSISTENCE = "brmsEclipselink.persistencexml";
124
125     private static Map<String, String> modifiedGroups = new HashMap<>();
126     private static IntegrityMonitor im;
127     private static BackUpMonitor bm;
128     private String defaultName = null;
129     private String repId = null;
130     private String repName = null;
131     private List<String> repUrlList = null;
132     private String repUserName = null;
133     private String repPassword = null;
134     private String policyKeyId = null;
135     private boolean createFlag = false;
136     private String uebList = null;
137     private List<String> dmaapList = null;
138     private String pubTopic = null;
139     private PublisherBuilder pubBuilder = null;
140     protected BusPublisher publisher = null;
141     private Long uebDelay = Long.parseLong("20");
142     private Long dmaapDelay = Long.parseLong("5000");
143     private String notificationType = null;
144     private List<ControllerPojo> controllers;
145     private Map<String, ArrayList<Object>> groupMap = new HashMap<>();
146     private final Map<String, String> policyMap = new HashMap<>();
147     private String brmsdependencyversion;
148     private EntityManager em;
149     private boolean syncFlag = false;
150
151     /**
152      * Responsible to push policies to the BRMS PDP Policy Repository (PR).
153      *
154      * @param propertiesFile the properties file
155      * @param handler the {@link BackUpHandler}
156      * @throws PolicyException PolicyException related to the operation
157      */
158     public BrmsPush(final String propertiesFile, final BackUpHandler handler) throws PolicyException {
159         if (propertiesFile == null || handler == null) {
160             throw new PolicyException("Error no propertiesFile or handler");
161         }
162         final Properties config = new Properties();
163         final Path file = Paths.get(propertiesFile);
164         if (Files.notExists(file)) {
165             LOGGER.error(XACMLErrorConstants.ERROR_DATA_ISSUE + "Config File doesn't Exist in the specified Path "
166                     + file.toString());
167             throw new PolicyException(XACMLErrorConstants.ERROR_DATA_ISSUE
168                     + "Config File doesn't Exist in the specified Path " + file.toString());
169         } else {
170             if (file.toString().endsWith(".properties")) {
171                 // Grab the Properties.
172                 setProperty(file, config, handler);
173             }
174         }
175     }
176
177     private void setProperty(final Path file, final Properties config, final BackUpHandler handler)
178             throws PolicyException {
179         InputStream in;
180         try {
181             in = new FileInputStream(file.toFile());
182             config.load(in);
183         } catch (final IOException e) {
184             LOGGER.error(
185                     XACMLErrorConstants.ERROR_DATA_ISSUE + "Data/File Read Error while reading from the property file.",
186                     e);
187             throw new PolicyException(XACMLErrorConstants.ERROR_DATA_ISSUE
188                     + "Data/File Read Error while reading from the property file.");
189         }
190         LOGGER.info("Trying to set up IntegrityMonitor");
191         String resourceName = null;
192         try {
193             LOGGER.info("Trying to set up IntegrityMonitor");
194             resourceName = config.getProperty("RESOURCE_NAME");
195             if (resourceName == null) {
196                 LOGGER.warn("RESOURCE_NAME is missing setting default value. ");
197                 resourceName = "brmsgw_pdp01";
198             }
199             resourceName = resourceName.trim();
200             setIntegrityMonitor(IntegrityMonitor.getInstance(resourceName, config));
201         } catch (final Exception e) {
202             LOGGER.error("Error starting Integerity Monitor: " + e);
203         }
204         LOGGER.info("Trying to set up BackUpMonitor");
205         try {
206             setBackupMonitor(BackUpMonitor.getInstance(BackUpMonitor.ResourceNode.BRMS.toString(), resourceName, config,
207                     handler));
208         } catch (final Exception e) {
209             LOGGER.error("Error starting BackUpMonitor: " + e);
210         }
211         if (!config.containsKey(BRMSPERSISTENCE)) {
212             config.setProperty(PersistenceUnitProperties.ECLIPSELINK_PERSISTENCE_XML, "META-INF/persistenceBRMS.xml");
213         } else {
214             config.setProperty(PersistenceUnitProperties.ECLIPSELINK_PERSISTENCE_XML,
215                     config.getProperty(BRMSPERSISTENCE, "META-INF/persistenceBRMS.xml"));
216         }
217         final EntityManagerFactory emf = Persistence.createEntityManagerFactory("BRMSGW", config);
218         em = emf.createEntityManager();
219         defaultName = config.getProperty("defaultName");
220         if (defaultName == null) {
221             LOGGER.error(
222                     XACMLErrorConstants.ERROR_DATA_ISSUE + "defaultName property is missing from the property file ");
223             throw new PolicyException(
224                     XACMLErrorConstants.ERROR_DATA_ISSUE + "defaultName property is missing from the property file");
225         }
226         defaultName = defaultName.trim();
227         repId = config.getProperty("repositoryID");
228         if (repId == null) {
229             LOGGER.error(
230                     XACMLErrorConstants.ERROR_DATA_ISSUE + "repositoryID property is missing from the property file ");
231             throw new PolicyException(
232                     XACMLErrorConstants.ERROR_DATA_ISSUE + "repositoryID property is missing from the property file ");
233         }
234         repId = repId.trim();
235         repName = config.getProperty("repositoryName");
236         if (repName == null) {
237             LOGGER.error(XACMLErrorConstants.ERROR_DATA_ISSUE
238                     + "repositoryName property is missing from the property file ");
239             throw new PolicyException(XACMLErrorConstants.ERROR_DATA_ISSUE
240                     + "repositoryName property is missing from the property file ");
241         }
242         repName = repName.trim();
243         final String repUrl = config.getProperty("repositoryURL");
244         if (repUrl == null) {
245             LOGGER.error(
246                     XACMLErrorConstants.ERROR_DATA_ISSUE + "repositoryURL property is missing from the property file ");
247             throw new PolicyException(
248                     XACMLErrorConstants.ERROR_DATA_ISSUE + "repositoryURL property is missing from the property file ");
249         }
250         if (repUrl.contains(",")) {
251             repUrlList = new ArrayList<>(Arrays.asList(repUrl.trim().split(",")));
252         } else {
253             repUrlList = new ArrayList<>();
254             repUrlList.add(repUrl);
255         }
256         repUserName = config.getProperty("repositoryUsername");
257         repPassword = config.getProperty("repositoryPassword");
258         if (repUserName == null || repPassword == null) {
259             LOGGER.error(XACMLErrorConstants.ERROR_DATA_ISSUE
260                     + "repostoryUserName and respositoryPassword properties are required.");
261             throw new PolicyException(XACMLErrorConstants.ERROR_DATA_ISSUE
262                     + "repostoryUserName and respositoryPassword properties are required.");
263         }
264         repUserName = repUserName.trim();
265         repPassword = repPassword.trim();
266         policyKeyId = config.getProperty("policyKeyID");
267         if (policyKeyId == null) {
268             LOGGER.error(
269                     XACMLErrorConstants.ERROR_DATA_ISSUE + "policyKeyID property is missing from the property file ");
270             throw new PolicyException(
271                     XACMLErrorConstants.ERROR_DATA_ISSUE + "policyKeyID property is missing from the property file ");
272         }
273         policyKeyId = policyKeyId.trim();
274         final String syncF = config.getProperty("sync", "false").trim();
275         syncFlag = Boolean.parseBoolean(syncF);
276         if (syncFlag) {
277             PolicyLogger.info("SYNC Flag is turned ON. DB will be given Priority.");
278         }
279         brmsdependencyversion = config.getProperty("brms.dependency.version");
280         if (brmsdependencyversion == null) {
281             LOGGER.error(XACMLErrorConstants.ERROR_DATA_ISSUE
282                     + "brmsdependencyversion property is missing from the property file, Using default Version.");
283             brmsdependencyversion = DEFAULT_VERSION;
284         }
285         brmsdependencyversion = brmsdependencyversion.trim();
286         readGroups(config);
287
288         // Setup Publisher
289         notificationType = config.getProperty("NOTIFICATION_TYPE");
290         if ("dmaap".equalsIgnoreCase(notificationType)) {
291
292             LOGGER.info("Notification Type being used is DMaaP... creating instance of BusPublisher.");
293             // Setting up the Publisher for DMaaP MR
294             String dmaapServers = config.getProperty("NOTIFICATION_SERVERS");
295             pubTopic = config.getProperty("NOTIFICATION_TOPIC");
296             final String aafLogin = config.getProperty("CLIENT_ID").trim();
297             final String aafPassword = config.getProperty("CLIENT_KEY").trim();
298
299             if (dmaapServers == null || pubTopic == null) {
300                 LOGGER.error(
301                         XACMLErrorConstants.ERROR_DATA_ISSUE + "DMaaP properties are missing from the property file ");
302                 throw new PolicyException(
303                         XACMLErrorConstants.ERROR_DATA_ISSUE + "DMaaP properties are missing from the property file ");
304             }
305
306             dmaapServers = dmaapServers.trim();
307             pubTopic = pubTopic.trim();
308
309             if (dmaapServers.contains(",")) {
310                 dmaapList = new ArrayList<>(Arrays.asList(dmaapServers.split("\\s*,\\s*")));
311             } else {
312                 dmaapList = new ArrayList<>();
313                 dmaapList.add(dmaapServers);
314             }
315
316             this.publisher =
317                     new BusPublisher.DmaapPublisherWrapper(this.dmaapList, this.pubTopic, aafLogin, aafPassword);
318
319             String notificationDelay = config.getProperty("NOTIFICATION_DELAY");
320             if (notificationDelay != null && !notificationDelay.isEmpty()) {
321                 notificationDelay = notificationDelay.trim();
322                 try {
323                     dmaapDelay = Long.parseLong(notificationDelay);
324                 } catch (final NumberFormatException e) {
325                     LOGGER.error("DMAAP_DELAY not a long format number" + e);
326                 }
327             }
328             LOGGER.info("DMAAP BusPublisher is created.");
329
330         } else {
331             LOGGER.info("Notification Type being used is UEB... creating instance of PublisherBuilder.");
332             // Setting up the Publisher for UEB
333             uebList = config.getProperty("NOTIFICATION_SERVERS");
334             pubTopic = config.getProperty("NOTIFICATION_TOPIC");
335             if (uebList == null || pubTopic == null) {
336                 LOGGER.error(
337                         XACMLErrorConstants.ERROR_DATA_ISSUE + "UEB properties are missing from the property file ");
338                 throw new PolicyException(
339                         XACMLErrorConstants.ERROR_DATA_ISSUE + "UEB properties are missing from the property file ");
340             }
341             uebList = uebList.trim();
342             pubTopic = pubTopic.trim();
343             pubBuilder = new CambriaClientBuilders.PublisherBuilder();
344             pubBuilder.usingHosts(uebList).onTopic(pubTopic).usingHttps(true);
345             String apiKey = config.getProperty("UEB_API_KEY");
346             String apiSecret = config.getProperty("UEB_API_SECRET");
347             if (apiKey != null && !apiKey.isEmpty() && apiSecret != null && !apiSecret.isEmpty()) {
348                 apiKey = apiKey.trim();
349                 apiSecret = apiSecret.trim();
350                 pubBuilder.authenticatedBy(apiKey, apiSecret);
351             }
352             String notificationDelay = config.getProperty("NOTIFICATION_DELAY");
353             if (notificationDelay != null && !notificationDelay.isEmpty()) {
354                 notificationDelay = notificationDelay.trim();
355                 try {
356                     uebDelay = Long.parseLong(notificationDelay);
357                 } catch (final NumberFormatException e) {
358                     LOGGER.error("UEB_DELAY not a long format number" + e);
359                 }
360             }
361             LOGGER.info("UEB PublisherBuilder is created.");
362
363         }
364
365     }
366
367     private static void setBackupMonitor(final BackUpMonitor instance) {
368         bm = instance;
369     }
370
371     private static void setIntegrityMonitor(final IntegrityMonitor instance) {
372         im = instance;
373     }
374
375     /**
376      * Will Initialize the variables required for BRMSPush.
377      */
378     public void initiate(final boolean flag) {
379         resetModifiedGroups();
380         controllers = new ArrayList<>();
381         try {
382             bm.updateNotification();
383         } catch (final Exception e) {
384             LOGGER.error("Error while updating Notification: " + e.getMessage(), e);
385         }
386         if (flag) {
387             syncGroupInfo();
388         }
389     }
390
391     public void resetDs() {
392         resetModifiedGroups();
393         controllers = new ArrayList<>();
394     }
395
396     private static void resetModifiedGroups() {
397         modifiedGroups = new HashMap<>();
398     }
399
400     /**
401      * Will Add rules to projects. Creates necessary folders if required.
402      */
403     public void addRule(final String name, final String rule, final Map<String, String> responseAttributes) {
404         // 1 check the response Attributes and determine if this belongs to any projects.
405         // 2 if not create folder
406         // 3 create pom.
407         // 4 copy the rule.
408         // 5 store the groups that have been updated.
409         String ksessionName = null;
410         String selectedName = null;
411         if (!responseAttributes.isEmpty()) {
412             // Pick selected Value
413             String userControllerName = null;
414             final ArrayList<PEDependency> userDependencies = new ArrayList<>();
415             for (final Map.Entry<String, String> entry : responseAttributes.entrySet()) {
416                 final String key = entry.getKey();
417                 final String value = entry.getValue();
418                 if (key.equals(policyKeyId)) {
419                     selectedName = value;
420                 }
421                 // kmodule configurations
422                 else if ("kSessionName".equals(key)) {
423                     ksessionName = value;
424                 }
425                 // Check User Specific values.
426                 if ("$controller:".equals(key)) {
427                     userControllerName = getUserControllerName(key, value);
428                 } else if ("$dependency$".equals(key) && value.startsWith("[") && value.endsWith("]")) {
429                     updateUserDependencies(userDependencies, value);
430                 }
431             }
432             if (userControllerName != null) {
433                 // Adding custom dependencies here.
434                 final ArrayList<Object> values = groupMap.get(userControllerName);
435                 values.add(userDependencies);
436                 groupMap.put(userControllerName, values);
437                 selectedName = userControllerName;
438             }
439         }
440         // If no Match then pick Default.
441         if (selectedName == null) {
442             selectedName = defaultName;
443         }
444         if (groupMap.containsKey(selectedName)) {
445             // If the key is not got as parameters set by the user, setting the default value for
446             // kSessionName as
447             // closedLoop
448             if (ksessionName == null) {
449                 LOGGER.info("kSessionName is null, selectedName is  : " + selectedName);
450                 if (selectedName.equalsIgnoreCase(defaultName)) {
451                     ksessionName = "closedloop";
452                 } else {
453                     ksessionName = "closedloop-" + selectedName;
454                 }
455             }
456             // create directories if missing.
457             manageProject(selectedName, ksessionName, name, rule);
458
459             // Will check for Create Later after generating the Pom.
460             addModifiedGroup(selectedName, "update");
461         }
462     }
463
464     private String getUserControllerName(final String key, final String value) {
465         String userControllerName = null;
466         // Check User Specific values.
467         try {
468             final PEDependency dependency = PolicyUtils.jsonStringToObject(value, PEDependency.class);
469             userControllerName = key.replaceFirst("$controller:", "");
470             LOGGER.info("addRule: userControllerName - " + userControllerName + ", dependency: - " + dependency);
471             addToGroup(userControllerName, dependency);
472         } catch (final Exception e) {
473             LOGGER.error(XACMLErrorConstants.ERROR_PROCESS_FLOW + "Error while resolving Controller: " + e);
474         }
475         return userControllerName;
476     }
477
478     private void updateUserDependencies(final ArrayList<PEDependency> userDependencies, String value) {
479         // update the user dependencies supplied as parameter to this method
480         value = value.substring(1, value.length() - 1).trim();
481         final List<String> dependencyStrings = Arrays.asList(value.split(Pattern.quote("},{")));
482         for (final String dependencyString : dependencyStrings) {
483             try {
484                 userDependencies.add(PolicyUtils.jsonStringToObject(dependencyString, PEDependency.class));
485             } catch (final Exception e) {
486                 LOGGER.error(XACMLErrorConstants.ERROR_PROCESS_FLOW + "Error while resolving Dependencies: " + e);
487             }
488         }
489     }
490
491     private void syncGroupInfo() {
492         // Sync DB to JMemory.
493         final EntityTransaction et = em.getTransaction();
494         try {
495             et.begin();
496             final TypedQuery<BrmsGroupInfo> groupInfoQuery =
497                     em.createQuery("select b from BrmsGroupInfo AS b", BrmsGroupInfo.class);
498             final List<BrmsGroupInfo> groupInfoResult = groupInfoQuery.getResultList();
499             if (groupInfoResult.size() != groupMap.size()) {
500                 for (final BrmsGroupInfo brmsGroupInfo : groupInfoResult) {
501                     final PEDependency dependency = new PEDependency();
502                     dependency.setArtifactId(brmsGroupInfo.getArtifactId());
503                     dependency.setGroupId(brmsGroupInfo.getGroupId());
504                     dependency.setVersion(brmsGroupInfo.getVersion());
505                     final ArrayList<Object> values = new ArrayList<>();
506                     values.add(dependency);
507                     groupMap.put(brmsGroupInfo.getControllerName(), values);
508                 }
509             }
510
511             final TypedQuery<BrmsPolicyInfo> policyInfoQuery =
512                     em.createQuery("select g from BrmsPolicyInfo AS g", BrmsPolicyInfo.class);
513             final List<BrmsPolicyInfo> policyInfoResult = policyInfoQuery.getResultList();
514             if (policyInfoResult.size() != policyMap.size()) {
515                 for (final BrmsPolicyInfo brmsPolicyInfo : policyInfoResult) {
516                     policyMap.put(brmsPolicyInfo.getPolicyName(),
517                             brmsPolicyInfo.getControllerName().getControllerName());
518                 }
519             }
520             et.commit();
521             LOGGER.info("Updated Local Memory values with values from database.");
522         } catch (final Exception exception) {
523             LOGGER.error("Unable to sync group info", exception);
524             et.rollback();
525             throw exception;
526         }
527     }
528
529     private void manageProject(final String selectedName, final String ksessionName, final String name,
530             final String rule) {
531         // Check if the Project is in Sync. If not get the latest Version.
532         syncProject(selectedName);
533         createProject(PROJECTSLOCATION + File.separator + getArtifactId(selectedName) + File.separator + "src"
534                 + File.separator + "main" + File.separator + RESOURCES, ksessionName);
535         copyDataToFile(PROJECTSLOCATION + File.separator + getArtifactId(selectedName) + File.separator + "src"
536                 + File.separator + "main" + File.separator + RESOURCES + File.separator + RULES + File.separator + name
537                 + ".drl", rule);
538         addToPolicy(name, selectedName);
539     }
540
541     /*
542      * Add Policy to JMemory and DataBase.
543      */
544     private void addToPolicy(final String policyName, final String controllerName) {
545
546         final EntityTransaction et = em.getTransaction();
547         try {
548             et.begin();
549             boolean create = false;
550             final TypedQuery<BrmsPolicyInfo> policyInfoQuery =
551                     em.createQuery("select b from BrmsPolicyInfo as b where b.policyName = :pn", BrmsPolicyInfo.class);
552             policyInfoQuery.setParameter("pn", policyName);
553             final List<BrmsPolicyInfo> policyInfoResultList = policyInfoQuery.getResultList();
554             BrmsPolicyInfo brmsPolicyInfo = new BrmsPolicyInfo();
555             if (!policyInfoResultList.isEmpty()) {
556                 // Already exists.
557                 brmsPolicyInfo = policyInfoResultList.get(0);
558                 if (!brmsPolicyInfo.getControllerName().getControllerName().equals(controllerName)) {
559                     create = true;
560                 }
561             } else {
562                 create = true;
563             }
564             if (create) {
565                 final TypedQuery<BrmsGroupInfo> groupInfoQuery = em.createQuery(
566                         "select b from BrmsGroupInfo as b where b.controllerName = :cn", BrmsGroupInfo.class);
567                 groupInfoQuery.setParameter("cn", controllerName);
568                 final List<BrmsGroupInfo> groupInfoResultList = groupInfoQuery.getResultList();
569                 BrmsGroupInfo brmsGroupInfo = new BrmsGroupInfo();
570                 if (!groupInfoResultList.isEmpty()) {
571                     brmsGroupInfo = groupInfoResultList.get(0);
572                 }
573                 brmsPolicyInfo.setPolicyName(policyName);
574                 brmsPolicyInfo.setControllerName(brmsGroupInfo);
575                 em.persist(brmsPolicyInfo);
576                 em.flush();
577             }
578             et.commit();
579
580             policyMap.put(policyName, controllerName);
581         } catch (final Exception exception) {
582             LOGGER.error("Unable add policy to database", exception);
583             et.rollback();
584             throw exception;
585         }
586     }
587
588     private void syncProject(final String selectedName) {
589         final boolean projectExists = checkProject(selectedName);
590         if (projectExists) {
591             String version;
592             version = getVersion(selectedName);
593             if (version == null) {
594                 LOGGER.error("Error getting local version for the given Controller Name:" + selectedName
595                         + " going with Default value");
596                 version = VERSION_0_1_0;
597             }
598             final String nextVersion = incrementVersion(version);
599             final boolean outOfSync = checkRemoteSync(selectedName, nextVersion);
600             if (!outOfSync) {
601                 return;
602             }
603         }
604         // We are out of Sync or Project is not Present.
605         downloadProject(selectedName);
606     }
607
608     private void downloadProject(final String selectedName) {
609         final NexusArtifact artifact = getLatestArtifactFromNexus(selectedName);
610         if (artifact == null) {
611             return;
612         }
613         final String dirName = getDirectoryName(selectedName);
614         URL website;
615         final String fileName = "rule.jar";
616         try {
617             website = new URL(artifact.getUrlPath() + ".jar");
618             try (ReadableByteChannel rbc = Channels.newChannel(website.openStream());
619                     FileOutputStream fos = new FileOutputStream(fileName)) {
620                 fos.getChannel().transferFrom(rbc, 0, Long.MAX_VALUE);
621                 extractJar(fileName, dirName);
622                 new File(fileName).delete();
623             } catch (final IOException e) {
624                 LOGGER.error("Error while downloading the project to File System. " + e.getMessage(), e);
625             }
626
627         } catch (final IOException e1) {
628             LOGGER.error("Error while retrieve the artifact. " + e1.getMessage(), e1);
629         }
630     }
631
632     private void extractJar(final String jarFileName, final String artifactId) {
633         try (JarFile jar = new JarFile(jarFileName)) {
634             final Enumeration<?> enumEntries = jar.entries();
635             while (enumEntries.hasMoreElements()) {
636                 parseJarContents(artifactId, jar, enumEntries);
637             }
638         } catch (final IOException e) {
639             LOGGER.info("exception Occured" + e);
640         }
641     }
642
643     private void parseJarContents(final String artifactId, final JarFile jar, final Enumeration<?> enumEntries) {
644         final JarEntry jarEntry = (JarEntry) enumEntries.nextElement();
645         File file = null;
646         final String fileName = jarEntry.getName().substring(jarEntry.getName().lastIndexOf("/") + 1);
647         if (jarEntry.getName().endsWith(".drl")) {
648             final String path = PROJECTSLOCATION + File.separator + artifactId + File.separator + "src" + File.separator
649                     + "main" + File.separator + RESOURCES + File.separator + RULES;
650             new File(path).mkdirs();
651             if (syncFlag && policyMap.containsKey(fileName.replace(".drl", ""))) {
652                 file = new File(path + File.separator + fileName);
653             } else {
654                 file = new File(path + File.separator + fileName);
655             }
656         } else if (jarEntry.getName().endsWith(POM_XML_FILE)) {
657             final String path = PROJECTSLOCATION + File.separator + artifactId;
658             new File(path).mkdirs();
659             file = new File(path + File.separator + fileName);
660         } else if (jarEntry.getName().endsWith(KMODULE_XML_FILE)) {
661             final String path = PROJECTSLOCATION + File.separator + artifactId + File.separator + "src" + File.separator
662                     + "main" + File.separator + RESOURCES + File.separator + META_INF;
663             new File(path).mkdirs();
664             file = new File(path + File.separator + fileName);
665         }
666         if (file != null) {
667             try (InputStream is = jar.getInputStream(jarEntry); FileOutputStream fos = new FileOutputStream(file)) {
668                 while (is.available() > 0) {
669                     fos.write(is.read());
670                 }
671                 LOGGER.info(fileName + " Created..");
672             } catch (final IOException e) {
673                 LOGGER.info("exception Occured" + e);
674             }
675         }
676     }
677
678     private NexusArtifact getLatestArtifactFromNexus(final String selectedName) {
679         final List<NexusArtifact> artifacts = getArtifactFromNexus(selectedName, null);
680         int bigNum = 0;
681         int smallNum = 0;
682         NexusArtifact result = null;
683         for (final NexusArtifact artifact : artifacts) {
684             final int majorVal =
685                     Integer.parseInt(artifact.getVersion().substring(0, artifact.getVersion().indexOf(".")));
686             final int minorVal = Integer.parseInt(artifact.getVersion()
687                     .substring(artifact.getVersion().indexOf(".") + 1, artifact.getVersion().lastIndexOf(".")));
688             if (majorVal > bigNum) {
689                 bigNum = majorVal;
690                 smallNum = minorVal;
691             }
692             if ((bigNum == majorVal) && (minorVal > smallNum)) {
693                 smallNum = minorVal;
694             }
695             if (bigNum == majorVal && minorVal == smallNum) {
696                 result = artifact;
697             }
698         }
699         return additionalNexusLatestCheck(selectedName, result);
700     }
701
702     // Additional Check due to Limitations from Nexus API to check if the artifact is the latest.
703     private NexusArtifact additionalNexusLatestCheck(final String selectedName, final NexusArtifact result) {
704         if (result == null) {
705             return result;
706         }
707         final String nextVersion = incrementVersion(result.getVersion());
708         final List<NexusArtifact> artifact = getArtifactFromNexus(selectedName, nextVersion);
709         return artifact.isEmpty() ? result : additionalNexusLatestCheck(selectedName, artifact.get(0));
710     }
711
712     private boolean checkRemoteSync(final String selectedName, final String version) {
713         final List<NexusArtifact> artifacts = getArtifactFromNexus(selectedName, version);
714         return artifacts.isEmpty() ? false : true;
715     }
716
717     private List<NexusArtifact> getArtifactFromNexus(final String selectedName, final String version) {
718         NexusRestWrapper restWrapper = null;
719         int index = 0;
720         boolean flag = false;
721         while (index < repUrlList.size()) {
722             try {
723                 final String repUrl = repUrlList.get(0);
724                 restWrapper =
725                         new NexusRestWrapper(repUrl.substring(0, repUrl.indexOf(repUrl.split(":[0-9]+\\/nexus")[1])),
726                                 repUserName, repPassword);
727                 final NexusRestSearchParameters searchParameters = new NexusRestSearchParameters();
728                 searchParameters.useFilterSearch(getGroupId(selectedName), getArtifactId(selectedName), version, null,
729                         null);
730
731                 final List<NexusArtifact> resultList = restWrapper.findArtifact(searchParameters).getArtifactList();
732                 if (resultList != null) {
733                     flag = true;
734                     return resultList;
735                 }
736             } catch (NexusRestWrapperException | ProcessingException e) {
737                 LOGGER.error(XACMLErrorConstants.ERROR_DATA_ISSUE + "Connection to remote Nexus has failed. "
738                         + e.getMessage(), e);
739             } finally {
740                 if (null != restWrapper) {
741                     restWrapper.close();
742                 }
743                 if (!flag) {
744                     Collections.rotate(repUrlList, -1);
745                     index++;
746                 }
747             }
748         }
749         return new ArrayList<>();
750     }
751
752     private String incrementVersion(final String version) {
753         int majorVal = Integer.parseInt(version.substring(0, version.indexOf(".")));
754         int minorVal = Integer.parseInt(version.substring(version.indexOf(".") + 1, version.lastIndexOf(".")));
755         if (minorVal >= 9) {
756             majorVal += 1;
757             minorVal = 0;
758         } else {
759             minorVal += 1;
760         }
761         return majorVal + "." + minorVal + version.substring(version.lastIndexOf("."));
762     }
763
764     private boolean checkProject(final String selectedName) {
765         return new File(PROJECTSLOCATION + File.separator + getDirectoryName(selectedName)).exists();
766     }
767
768     private String getDirectoryName(final String selectedName) {
769         return getArtifactId(selectedName);
770     }
771
772     /**
773      * Will Push policies to the PolicyRepo.
774      *
775      * @throws PolicyException PolicyException related to the operation
776      */
777     public void pushRules() throws PolicyException {
778         // Check how many groups have been updated.
779         // Invoke their Maven process.
780         try {
781             im.startTransaction();
782         } catch (final Exception e) {
783             LOGGER.error("Error while starting Transaction " + e);
784         }
785         if (!modifiedGroups.isEmpty()) {
786             if (buildAndGenerateJarFile()) {
787                 sendNotification(controllers);
788             }
789         }
790         if (im != null) {
791             im.endTransaction();
792         }
793     }
794
795     /**
796      * Removes a Rule from Rule Projects.
797      */
798     public void removeRule(final String name) {
799         final String controllerName = getGroupName(name);
800         if (controllerName == null) {
801             LOGGER.info("Error finding the controllerName for the given Policy: " + name);
802             return;
803         }
804         syncProject(controllerName);
805         getNameAndSetRemove(controllerName, name);
806     }
807
808     private Boolean buildAndGenerateJarFile() throws PolicyException {
809         Boolean flag = false;
810         for (final Map.Entry<String, String> entry : modifiedGroups.entrySet()) {
811             InvocationResult result = null;
812             final String group = entry.getKey();
813             try {
814                 LOGGER.info("PushRules: ModifiedGroups, Key: " + group + ", Value: " + entry.getValue());
815                 final InvocationRequest request = new DefaultInvocationRequest();
816                 setVersion(group);
817                 createPom(group);
818                 request.setPomFile(new File(
819                         PROJECTSLOCATION + File.separator + getArtifactId(group) + File.separator + POM_XML_FILE));
820                 request.setGoals(Arrays.asList(GOALS));
821                 final Invoker invoker = new DefaultInvoker();
822                 result = invoker.execute(request);
823                 if (result.getExecutionException() != null) {
824                     LOGGER.error(result.getExecutionException());
825                 } else if (result.getExitCode() != 0) {
826                     LOGGER.error("Maven Invocation failure..!");
827                 }
828             } catch (final Exception e) {
829                 LOGGER.error(XACMLErrorConstants.ERROR_PROCESS_FLOW + "Maven Invocation issue for "
830                         + getArtifactId(group) + e.getMessage(), e);
831             }
832             if (result != null && result.getExitCode() == 0) {
833                 LOGGER.info("Build Completed..!");
834                 if (createFlag) {
835                     addNotification(group, "create");
836                 } else {
837                     addNotification(group, entry.getValue());
838                 }
839                 flag = true;
840             } else {
841                 throw new PolicyException(XACMLErrorConstants.ERROR_PROCESS_FLOW + "Maven Invocation failure!");
842             }
843         }
844         return flag;
845     }
846
847     private String getGroupName(final String name) {
848         if (policyMap.containsKey(name)) {
849             return policyMap.get(name);
850         } else {
851             syncGroupInfo();
852             return policyMap.containsKey(name) ? policyMap.get(name) : null;
853         }
854     }
855
856     private void addModifiedGroup(final String controllerName, final String operation) {
857         if (controllerName != null) {
858             modifiedGroups.put(controllerName, operation);
859         }
860     }
861
862     private void addNotification(final String controllerName, final String operation) {
863         final ControllerPojo controllerPojo = new ControllerPojo();
864         controllerPojo.setName(controllerName);
865         controllerPojo.setOperation(operation);
866         final HashMap<String, String> drools = new HashMap<>();
867         drools.put("groupId", getGroupId(controllerName));
868         drools.put("artifactId", getArtifactId(controllerName));
869         drools.put("version", getVersion(controllerName));
870         controllerPojo.setDrools(drools);
871         controllers.add(controllerPojo);
872         try {
873             LOGGER.debug("Notification added: " + PolicyUtils.objectToJsonString(controllerPojo));
874         } catch (final JsonProcessingException e) {
875             LOGGER.error(MessageCodes.ERROR_SCHEMA_INVALID + "Json Processing Error " + e);
876         }
877     }
878
879     private void removedRuleModifiedGroup(final String controllerName) {
880         // This will be sending Notification to PDPD directly to Lock
881         final ControllerPojo controllerPojo = new ControllerPojo();
882         controllerPojo.setName(controllerName);
883         controllerPojo.setOperation("lock");
884         final List<ControllerPojo> controllerPojos = new ArrayList<>();
885         controllerPojos.add(controllerPojo);
886         sendNotification(controllerPojos);
887     }
888
889     private void sendNotification(final List<ControllerPojo> controllers) {
890         final NotificationPojo notification = new NotificationPojo();
891         final String requestId = UUID.randomUUID().toString();
892         LOGGER.info("Generating notification RequestID : " + requestId);
893         notification.setRequestId(requestId);
894         notification.setEntity("controller");
895         notification.setControllers(controllers);
896         try {
897             final String notificationJson = PolicyUtils.objectToJsonString(notification);
898             LOGGER.info("Sending Notification :\n" + notificationJson);
899             sendMessage(notificationJson);
900         } catch (final Exception e) {
901             LOGGER.error(XACMLErrorConstants.ERROR_PROCESS_FLOW + "Error while sending notification to PDP-D "
902                     + e.getMessage(), e);
903         }
904     }
905
906     private void sendMessage(final String message) throws IOException, GeneralSecurityException, InterruptedException {
907
908         if ("dmaap".equalsIgnoreCase(notificationType)) {
909             // Sending Message through DMaaP Message Router
910             LOGGER.debug("DMAAP Publishing Message");
911
912             publisher.send("MyPartitionKey", message);
913
914             LOGGER.debug("Message Published on DMaaP :" + dmaapList.get(0) + "for Topic: " + pubTopic);
915
916             Thread.sleep(dmaapDelay);
917             publisher.close();
918         } else {
919             // Sending Message through UEB interface.
920             LOGGER.debug("UEB Publishing Message");
921
922             final CambriaBatchingPublisher pub = pubBuilder.build();
923             pub.send("MyPartitionKey", message);
924
925             final List<?> stuck = pub.close(uebDelay, TimeUnit.SECONDS);
926             if (!stuck.isEmpty()) {
927                 LOGGER.error(stuck.size() + " messages unsent");
928             } else {
929                 LOGGER.debug("Clean exit; Message Published on UEB : " + uebList + "for Topic: " + pubTopic);
930             }
931         }
932
933     }
934
935     private void createPom(final String name) {
936         final Model model = new Model();
937         model.setModelVersion("4.0.0");
938         model.setGroupId(getGroupId(name));
939         model.setArtifactId(getArtifactId(name));
940         model.setVersion(getVersion(name));
941         model.setName(name);
942         final DistributionManagement distributionManagement = new DistributionManagement();
943         final DeploymentRepository repository = new DeploymentRepository();
944         repository.setId(repId);
945         repository.setName(repName);
946         repository.setUrl(repUrlList.get(0));
947         distributionManagement.setRepository(repository);
948         model.setDistributionManagement(distributionManagement);
949         // Dependency Management goes here.
950         List<Dependency> dependencyList = new ArrayList<>();
951         if (groupMap.get(name).size() > 1) {
952             @SuppressWarnings("unchecked")
953             final ArrayList<PEDependency> dependencies = (ArrayList<PEDependency>) groupMap.get(name).get(1);
954             for (final PEDependency dependency : dependencies) {
955                 dependencyList.add(dependency.getDependency());
956             }
957         } else {
958             // Add Default dependencies.
959             dependencyList = getDependencies(name);
960         }
961         model.setDependencies(dependencyList);
962         Writer writer = null;
963         try {
964             writer = WriterFactory.newXmlWriter(
965                     new File(PROJECTSLOCATION + File.separator + getArtifactId(name) + File.separator + POM_XML_FILE));
966             final MavenXpp3Writer pomWriter = new MavenXpp3Writer();
967             pomWriter.write(writer, model);
968         } catch (final Exception e) {
969             LOGGER.error(XACMLErrorConstants.ERROR_PROCESS_FLOW + "Error while creating POM for " + getArtifactId(name)
970                     + e.getMessage(), e);
971         } finally {
972             IOUtil.close(writer);
973         }
974     }
975
976     private List<Dependency> getDependencies(final String controllerName) {
977         // Read the Dependency Information from property file.
978         final Path file = Paths.get(DEPENDENCY_FILE);
979         if (!Files.notExists(file)) {
980             try {
981                 final String dependencyJson = new String(Files.readAllBytes(file), StandardCharsets.UTF_8);
982                 final DependencyInfo dependencyInfo =
983                         PolicyUtils.jsonStringToObject(dependencyJson, DependencyInfo.class);
984                 String controller = "default";
985                 if (dependencyInfo.getDependencies().containsKey(controllerName)) {
986                     controller = controllerName;
987                 }
988                 final List<Dependency> dependencyList = new ArrayList<>();
989                 for (final PEDependency dependency : dependencyInfo.getDependencies().get(controller)) {
990                     dependencyList.add(dependency.getDependency());
991                 }
992                 return dependencyList;
993             } catch (IOException | NullPointerException e) {
994                 LOGGER.error(XACMLErrorConstants.ERROR_PROCESS_FLOW
995                         + "Error while getting dependecy Information for controller: " + controllerName
996                         + e.getMessage(), e);
997             }
998         }
999         return defaultDependencies(controllerName);
1000     }
1001
1002     /**
1003      * Default Dependency Section. Can be changed as required.
1004      *
1005      * @param controllerName the controller name
1006      * @return changed dependency list
1007      */
1008     public List<Dependency> defaultDependencies(final String controllerName) {
1009
1010         final List<Dependency> dependencyList = new ArrayList<>();
1011         final String version = StringEscapeUtils.escapeJava(brmsdependencyversion);
1012
1013         final Dependency demoDependency = new Dependency();
1014         demoDependency.setGroupId(DROOLS_APPS_TEMPLATE_GROUP);
1015         demoDependency.setArtifactId("template.demo");
1016         demoDependency.setVersion(version);
1017         dependencyList.add(demoDependency);
1018
1019         final Dependency controlloopDependency = new Dependency();
1020         controlloopDependency.setGroupId(DROOLS_APPS_MODEL_GROUP);
1021         controlloopDependency.setArtifactId("events");
1022         controlloopDependency.setVersion(version);
1023         dependencyList.add(controlloopDependency);
1024
1025         final Dependency restDependency = new Dependency();
1026         restDependency.setGroupId(DROOLS_APPS_MODEL_GROUP);
1027         restDependency.setArtifactId("controlloop.common.model-impl.rest");
1028         restDependency.setVersion(version);
1029         dependencyList.add(restDependency);
1030
1031         final Dependency appcDependency = new Dependency();
1032         appcDependency.setGroupId(DROOLS_APPS_MODEL_GROUP);
1033         appcDependency.setArtifactId("controlloop.common.model-impl.appc");
1034         appcDependency.setVersion(version);
1035         dependencyList.add(appcDependency);
1036
1037         final Dependency aaiDependency = new Dependency();
1038         aaiDependency.setGroupId(DROOLS_APPS_MODEL_GROUP);
1039         aaiDependency.setArtifactId("controlloop.common.model-impl.aai");
1040         aaiDependency.setVersion(version);
1041         dependencyList.add(aaiDependency);
1042
1043         final Dependency msoDependency = new Dependency();
1044         msoDependency.setGroupId(DROOLS_APPS_MODEL_GROUP);
1045         msoDependency.setArtifactId("controlloop.common.model-impl.so");
1046         msoDependency.setVersion(version);
1047         dependencyList.add(msoDependency);
1048
1049         final Dependency trafficgeneratorDependency = new Dependency();
1050         trafficgeneratorDependency.setGroupId(DROOLS_APPS_MODEL_GROUP);
1051         trafficgeneratorDependency.setArtifactId("controlloop.common.model-impl.trafficgenerator");
1052         trafficgeneratorDependency.setVersion(version);
1053         dependencyList.add(trafficgeneratorDependency);
1054         return dependencyList;
1055     }
1056
1057     private void createProject(final String path, final String ksessionName) {
1058         new File(path + File.separator + RULES).mkdirs();
1059         new File(path + File.separator + META_INF).mkdirs();
1060         if (!Files.exists(Paths.get(path + File.separator + META_INF + File.separator + KMODULE_XML_FILE))) {
1061             // Hard coding XML for PDP Drools to accept our Rules.
1062             final String xml = "<?xml version=\"1.0\" encoding=\"UTF-8\"?>" + "\n"
1063                     + "<kmodule xmlns=\"http://jboss.org/kie/6.0.0/kmodule\">" + "\n"
1064                     + "<kbase name=\"rules\" packages=\"rules\">" + "\n" + "<ksession name=\"" + ksessionName + "\"/>"
1065                     + "\n" + "</kbase></kmodule>";
1066             copyDataToFile(path + File.separator + META_INF + File.separator + KMODULE_XML_FILE, xml);
1067         }
1068     }
1069
1070     private void copyDataToFile(final String file, final String rule) {
1071         try {
1072             FileUtils.writeStringToFile(new File(file), rule);
1073         } catch (final Exception e) {
1074             LOGGER.error(
1075                     XACMLErrorConstants.ERROR_PROCESS_FLOW + "Error while creating Rule for " + file + e.getMessage(),
1076                     e);
1077         }
1078     }
1079
1080     private void readGroups(final Properties config) throws PolicyException {
1081         String[] groupNames;
1082         final String groupNamesError = "groupNames property is missing or empty from the property file ";
1083         if (!config.containsKey(GROUP_NAMES) || config.getProperty(GROUP_NAMES) == null) {
1084             throw new PolicyException(XACMLErrorConstants.ERROR_DATA_ISSUE + groupNamesError);
1085         }
1086         if (config.getProperty(GROUP_NAMES).contains(",")) {
1087             groupNames = config.getProperty(GROUP_NAMES).replaceAll(" ", "").split(",");
1088         } else {
1089             groupNames = new String[] { config.getProperty(GROUP_NAMES).replaceAll(" ", "") };
1090         }
1091         if (groupNames == null || groupNames.length == 0) {
1092             LOGGER.error(XACMLErrorConstants.ERROR_DATA_ISSUE + groupNamesError);
1093             throw new PolicyException(XACMLErrorConstants.ERROR_DATA_ISSUE + groupNamesError);
1094         }
1095         groupMap = new HashMap<>();
1096         for (int counter = 0; counter < groupNames.length; counter++) {
1097             final String name = groupNames[counter];
1098             final String groupId = config.getProperty(name + ".groupID");
1099             if (groupId == null) {
1100                 LOGGER.error(XACMLErrorConstants.ERROR_DATA_ISSUE + name
1101                         + ".groupID property is missing from the property file ");
1102                 throw new PolicyException(XACMLErrorConstants.ERROR_DATA_ISSUE + name
1103                         + ".groupID property is missing from the property file ");
1104             }
1105             final String artifactId = config.getProperty(name + ".artifactID");
1106             if (artifactId == null) {
1107                 LOGGER.error(XACMLErrorConstants.ERROR_DATA_ISSUE + name
1108                         + ".artifactID property is missing from the property file ");
1109                 throw new PolicyException(XACMLErrorConstants.ERROR_DATA_ISSUE + name
1110                         + ".artifactID property is missing from the property file ");
1111             }
1112             final PEDependency dependency = new PEDependency();
1113             dependency.setArtifactId(artifactId);
1114             dependency.setGroupId(groupId);
1115             // Add to list if we got all
1116             addToGroup(name, dependency);
1117         }
1118     }
1119
1120     private void addToGroup(final String name, final PEDependency dependency) {
1121         final EntityTransaction et = em.getTransaction();
1122         try {
1123             et.begin();
1124             final TypedQuery<BrmsGroupInfo> query = em
1125                     .createQuery("select b from BrmsGroupInfo as b where b.controllerName = :cn", BrmsGroupInfo.class);
1126             query.setParameter("cn", name);
1127             final List<BrmsGroupInfo> groupList = query.getResultList();
1128             BrmsGroupInfo brmsGroupInfo = null;
1129             if (!groupList.isEmpty()) {
1130                 LOGGER.info("Controller name already Existing in DB. Will be updating the DB Values" + name);
1131                 brmsGroupInfo = groupList.get(0);
1132             }
1133             if (brmsGroupInfo == null) {
1134                 brmsGroupInfo = new BrmsGroupInfo();
1135             }
1136             brmsGroupInfo.setControllerName(name);
1137             brmsGroupInfo.setGroupId(dependency.getGroupId());
1138             brmsGroupInfo.setArtifactId(dependency.getArtifactId());
1139             brmsGroupInfo.setVersion(dependency.getVersion());
1140             em.persist(brmsGroupInfo);
1141             em.flush();
1142             et.commit();
1143
1144             final ArrayList<Object> values = new ArrayList<>();
1145             values.add(dependency);
1146             groupMap.put(name, values);
1147         } catch (final Exception exception) {
1148             LOGGER.error("Unable add/update policy group to database for controller name: " + name, exception);
1149             et.rollback();
1150             throw exception;
1151         }
1152     }
1153
1154     private String getArtifactId(final String name) {
1155         return ((PEDependency) groupMap.get(name).get(0)).getArtifactId();
1156     }
1157
1158     private String getGroupId(final String name) {
1159         return ((PEDependency) groupMap.get(name).get(0)).getGroupId();
1160     }
1161
1162     private String getVersion(final String name) {
1163         return ((PEDependency) groupMap.get(name).get(0)).getVersion();
1164     }
1165
1166     private void getNameAndSetRemove(final String controllerName, final String policyName) {
1167         final String artifactName = getArtifactId(controllerName);
1168         final String ruleFolder = PROJECTSLOCATION + File.separator + artifactName + File.separator + "src"
1169                 + File.separator + "main" + File.separator + RESOURCES + File.separator + RULES;
1170         final File file = new File(ruleFolder + File.separator + policyName + ".drl");
1171         if (file.delete()) {
1172             LOGGER.info("Deleted File.. " + file.getAbsolutePath());
1173             removePolicyFromGroup(policyName, controllerName);
1174         }
1175         if (new File(ruleFolder).listFiles().length == 0) {
1176             removedRuleModifiedGroup(controllerName);
1177         } else {
1178             // This is an update in terms of PDPD.
1179             addModifiedGroup(controllerName, "update");
1180         }
1181     }
1182
1183     // Removes Policy from Memory and Database.
1184     private void removePolicyFromGroup(final String policyName, final String controllerName) {
1185         final EntityTransaction et = em.getTransaction();
1186         try {
1187             et.begin();
1188             final TypedQuery<BrmsPolicyInfo> query =
1189                     em.createQuery("select b from BrmsPolicyInfo as b where b.policyName = :pn", BrmsPolicyInfo.class);
1190             query.setParameter("pn", policyName);
1191             final List<BrmsPolicyInfo> pList = query.getResultList();
1192             BrmsPolicyInfo brmsPolicyInfo;
1193             if (!pList.isEmpty()) {
1194                 // Already exists.
1195                 brmsPolicyInfo = pList.get(0);
1196                 if (brmsPolicyInfo.getControllerName().getControllerName().equals(controllerName)) {
1197                     em.remove(brmsPolicyInfo);
1198                     em.flush();
1199                 }
1200             }
1201             et.commit();
1202             policyMap.remove(policyName);
1203         } catch (final Exception exception) {
1204             LOGGER.error("Unable remove policy from group to database for policy name: " + policyName, exception);
1205             et.rollback();
1206             throw exception;
1207         }
1208     }
1209
1210     private void setVersion(final String selectedName) {
1211         String newVersion = VERSION_0_1_0;
1212         createFlag = false;
1213         final NexusArtifact artifact = getLatestArtifactFromNexus(selectedName);
1214         if (artifact != null) {
1215             newVersion = incrementVersion(artifact.getVersion());
1216         }
1217         if (VERSION_0_1_0.equals(newVersion)) {
1218             createFlag = true;
1219         }
1220         setVersion(newVersion, selectedName);
1221         LOGGER.info("Controller: " + selectedName + "is on version: " + newVersion);
1222     }
1223
1224     private void setVersion(final String newVersion, final String controllerName) {
1225         final PEDependency userController = (PEDependency) groupMap.get(controllerName).get(0);
1226         userController.setVersion(newVersion);
1227         groupMap.get(controllerName).set(0, userController);
1228     }
1229
1230     // Return BackUpMonitor
1231     public static BackUpMonitor getBackUpMonitor() {
1232         return bm;
1233     }
1234
1235     /**
1236      * Rotate URLs list.
1237      */
1238     public void rotateUrls() {
1239         if (repUrlList != null) {
1240             Collections.rotate(repUrlList, -1);
1241         }
1242     }
1243
1244     /**
1245      * Get URL List Size.
1246      *
1247      * @return URL list size
1248      */
1249     public int urlListSize() {
1250         return repUrlList != null ? repUrlList.size() : 0;
1251     }
1252 }