Update for scheduler support (fixes)

Author: dariol83

eu.dariolucia.reatmetric.driver.spacecraft.test/src/main/java/eu/dariolucia/reatmetric/driver/spacecraft/test/SpacecraftModel.java

@@ -186,7 +186,6 @@ private void sample() {
                 lastSampleGenerationTime = genTime;
                 double numPacketsPerSecond = (numPackets / (millis/1000.0));
                 double numFramesPerSecond = (numFrames / (millis/1000.0));
-                // FIXME: Decomment once investigation finished
                 System.out.println("Frames per second: " + (int) numFramesPerSecond + ", packets per second: " + numPacketsPerSecond);
             }
         }

eu.dariolucia.reatmetric.driver.spacecraft/src/main/java/eu/dariolucia/reatmetric/driver/spacecraft/packet/TmPacketProcessor.java

@@ -100,7 +100,7 @@ public Instant toObt(Instant utc) {
         Thread t = new Thread(r, "TM Packet Processing - Decoder");
         t.setDaemon(true);
         return t;
-    }); // TODO: make it configurable
+    });
     private final ExecutorService notifierService = Executors.newFixedThreadPool(1, (r) -> {
         Thread t = new Thread(r, "TM Packet Processing - Notifier");
         t.setDaemon(true);

eu.dariolucia.reatmetric.persist/src/main/java/eu/dariolucia/reatmetric/persist/services/ScheduledActivityDataArchive.java

@@ -173,7 +173,7 @@ protected String buildRetrieveQuery(Instant startTime, IUniqueId internalId, int
                 List<String> resourcesList = new ArrayList<>(filter.getResourceList());
                 query.append("AND (");
                 for(int i = 0; i < resourcesList.size(); ++i) {
-                    query.append("Resources LIKE '").append("% ").append(resourcesList.get(i)).append(" %'"); // TODO check if there is a contains function
+                    query.append("Resources LIKE '").append("% ").append(resourcesList.get(i)).append(" %'");
                     if(i != resourcesList.size() - 1) {
                         query.append(" OR ");
                     }
@@ -284,7 +284,7 @@ private List<ScheduledActivityData> doRetrieve(Connection connection, Instant ti
                 List<String> resourcesList = new ArrayList<>(filter.getResourceList());
                 query.append("AND (");
                 for(int i = 0; i < resourcesList.size(); ++i) {
-                    query.append("Resources LIKE '").append("% ").append(resourcesList.get(i)).append(" %'"); // TODO check if there is a contains function
+                    query.append("Resources LIKE '").append("% ").append(resourcesList.get(i)).append(" %'");
                     if(i != resourcesList.size() - 1) {
                         query.append(" OR ");
                     }
@@ -344,7 +344,7 @@ protected String getRemoveQuery(IUniqueId id) {
     protected String getRemoveQuery(ScheduledActivityDataFilter filter) {
         StringBuilder query = new StringBuilder("DELETE " +
                 "FROM SCHEDULED_ACTIVITY_DATA_TABLE " +
-                "WHERE TRUE "); // TODO check if it works
+                "WHERE TRUE "); // Use to simplify the cascade of conditions
         // process filter
         if(filter != null && !filter.isClear()) {
             if(filter.getParentPath() != null) {
@@ -366,7 +366,7 @@ protected String getRemoveQuery(ScheduledActivityDataFilter filter) {
                 List<String> resourcesList = new ArrayList<>(filter.getResourceList());
                 query.append("AND (");
                 for(int i = 0; i < resourcesList.size(); ++i) {
-                    query.append("Resources LIKE '").append("% ").append(resourcesList.get(i)).append(" %'"); // TODO check if there is a contains function
+                    query.append("Resources LIKE '").append("% ").append(resourcesList.get(i)).append(" %'");
                     if(i != resourcesList.size() - 1) {
                         query.append(" OR ");
                     }

eu.dariolucia.reatmetric.processing/src/main/java/eu/dariolucia/reatmetric/processing/impl/processors/EventProcessor.java

@@ -167,17 +167,17 @@ public List<AbstractDataItem> process(EventOccurrence newValue) {
                     // Replace the state
                     this.state = this.builder.build(new LongUniqueId(processor.getNextId(EventData.class)));
                     generatedStates.add(this.state);
-                    // Log the event // FIXME: decomment once testing is done
+                    // Log the event
                     switch(definition.getSeverity()) {
                         case ALARM:
                         case ERROR:
-                            // LOG.log(Level.SEVERE, "Event " + getPath() + " raised: " + getDefinition().getDescription() + " - Source: " + this.state.getSource());
+                            LOG.log(Level.SEVERE, "Event " + getPath() + " raised: " + getDefinition().getDescription() + " - Source: " + this.state.getSource());
                             break;
                         case WARN:
-                            // LOG.log(Level.WARNING, "Event " + getPath() + " raised: " + getDefinition().getDescription() + " - Source: " + this.state.getSource());
+                            LOG.log(Level.WARNING, "Event " + getPath() + " raised: " + getDefinition().getDescription() + " - Source: " + this.state.getSource());
                             break;
                         case INFO:
-                            // LOG.log(Level.INFO, "Event " + getPath() + " raised: " + getDefinition().getDescription() + " - Source: " + this.state.getSource());
+                            LOG.log(Level.INFO, "Event " + getPath() + " raised: " + getDefinition().getDescription() + " - Source: " + this.state.getSource());
                             break;
                     }
                 }