Update OpenTrafficPipeline.conf

Author: Chris Wiechmann

logstash/pipelines/OpenTrafficPipeline.conf

@@ -27,26 +27,28 @@ filter {
   # Create a cache key for the API either on the complete received request path or if configured, only using a specific part of the path.
   # This prevents API requests with path parameters from not being cached efficiently due to their variable parameter.
   # Example: API-Request: /v1/get/pet/687687678, Configured-Path: /v1/get/pet - API-Details cached based on Configured-Path (/v1/get/pet)
-  ruby {
-    id => "Set API-Cache-Key prefix"
-    code => '
-      cacheAPIPaths = event.get("[@metadata][cacheAPIPaths]");
-      apiRequestPath = event.get("[transactionSummary][path]");
-      if (cacheAPIPaths.nil? || cacheAPIPaths.empty?) 
+  if([transactionSummary] and [transactionSummary][path]) { # Only if a path is given (not given for instance for Scheduled-Policies)
+    ruby {
+      id => "Set API-Cache-Key prefix"
+      code => '
+        cacheAPIPaths = event.get("[@metadata][cacheAPIPaths]");
+        apiRequestPath = event.get("[transactionSummary][path]");
+        if (cacheAPIPaths.nil? || cacheAPIPaths.empty?) 
+          event.set("[@metadata][apiCacheKeyPrefix]", apiRequestPath);
+          return;
+        end
+        apiName = event.get("[transactionSummary][serviceContext][service]");
+        logger.debug("Configured paths and current API-Request path: ", { "configuredPaths" => cacheAPIPaths, "apiRequestPath" => apiRequestPath } );
         event.set("[@metadata][apiCacheKeyPrefix]", apiRequestPath);
-        return;
-      end
-      apiName = event.get("[transactionSummary][serviceContext][service]");
-      logger.debug("Configured paths and current API-Request path: ", { "configuredPaths" => cacheAPIPaths, "apiRequestPath" => apiRequestPath } );
-      event.set("[@metadata][apiCacheKeyPrefix]", apiRequestPath);
-      for configuredPath in cacheAPIPaths.split(",") do
-        if(apiRequestPath.start_with?(configuredPath) ) 
-          logger.debug("Using configured path as primary cache key because it matches to request path. ", { "configuredPath" => configuredPath, "apiRequestPath" => apiRequestPath });
-          event.set("[@metadata][apiCacheKeyPrefix]", configuredPath);
-          break;
+        for configuredPath in cacheAPIPaths.split(",") do
+          if(apiRequestPath.start_with?(configuredPath) ) 
+            logger.debug("Using configured path as primary cache key because it matches to request path. ", { "configuredPath" => configuredPath, "apiRequestPath" => apiRequestPath });
+            event.set("[@metadata][apiCacheKeyPrefix]", configuredPath);
+            break;
+          end
         end
-      end
-    '
+      '
+    }
   }
   # First, is to check if the document should be ignored/dropped (configured based on the apiPath or PolicyName)
   if([transactionSummary] and [transactionSummary][path]) { # Only if a path is given (not given for instance for Scheduled-Policies)