[backend] perf(stream): update exclusion with connector instance log (#4976)

Author: guillaumejparis

openaev-api/src/main/java/io/openaev/rest/stream/StreamApi.java

@@ -67,14 +67,15 @@ private void sendStreamEvent(FluxSink<Object> flux, BaseEvent event) {
     flux.next(message);
   }
 
-  private static final EnumSet<ResourceType> RESOURCES_STREAM_BLACKLIST =
-      EnumSet.of(ResourceType.VULNERABILITY, ResourceType.PAYLOAD);
+  private static final EnumSet<ResourceType> RESOURCES_STREAM_EXCLUSION =
+      EnumSet.of(
+          ResourceType.VULNERABILITY, ResourceType.PAYLOAD, ResourceType.CONNECTOR_INSTANCE_LOG);
 
   @Async("streamExecutor")
   @Transactional
   @TransactionalEventListener
   public void listenDatabaseUpdate(BaseEvent event) {
-    if (RESOURCES_STREAM_BLACKLIST.contains(event.getInstance().getResourceType())
+    if (RESOURCES_STREAM_EXCLUSION.contains(event.getInstance().getResourceType())
         || !event.isListened()) {
       return;
     }

openaev-model/src/main/java/io/openaev/database/model/ConnectorInstanceLog.java

@@ -44,4 +44,8 @@ public class ConnectorInstanceLog implements Base {
   @JsonProperty("connector_instance_log_created_at")
   @Schema(description = "Connector instance log created at")
   private Instant connector_instance_log_created_at = Instant.now();
+
+  @Getter(onMethod_ = @JsonIgnore)
+  @Transient
+  private final ResourceType resourceType = ResourceType.CONNECTOR_INSTANCE_LOG;
 }

openaev-model/src/main/java/io/openaev/database/model/ResourceType.java

@@ -42,6 +42,7 @@ public enum ResourceType {
   OBJECTIVE,
   EVALUATION,
   CATALOG,
+  CONNECTOR_INSTANCE_LOG,
   // Special resource types
   UNKNOWN,
   SIMULATION_OR_SCENARIO, // Used to represent either a simulation or a scenario.