Add onLogstashEntryCreate interception point, add mode to saveAll

ModuleConfig.cfc

@@ -75,7 +75,8 @@ component {
 		interceptorSettings = {
 			customInterceptionPoints : [
 				"cbElasticsearchPreSave",
-				"cbElasticsearchPostSave"
+				"cbElasticsearchPostSave",
+				"onLogstashEntryCreate"
 			]
 		};
 

box.json

@@ -1,6 +1,6 @@
 {
     "name":"Elasticsearch for the Coldbox Framework",
-    "author":"Ortus Solutions <info@ortussolutions.com",
+    "author":"Ortus Solutions <info@ortussolutions.com>",
     "location":"https://downloads.ortussolutions.com/ortussolutions/coldbox-modules/cbelasticsearch/@build.version@/cbelasticsearch-@build.version@+@build.number@.zip",
     "version":"3.4.2",
     "slug":"cbelasticsearch",

changelog.md

@@ -9,6 +9,11 @@ and this project adheres to [Semantic Versioning](https://semver.org/spec/v2.0.0
 
 ## [Unreleased]
 
+### Added
+
+- Add `onLogstashEntryCreate` interception point, to allow influencing and additions to final log object
+- Add `mode` argument to client `saveAll` method to allow for a `create` mode to be used for data streams
+
 ## [3.4.1] - 2024-09-26
 
 ### Added

models/io/HyperClient.cfc

@@ -1230,7 +1230,8 @@ component accessors="true" threadSafe singleton {
 	array function saveAll(
 		required array documents,
 		boolean throwOnError = false,
-		struct params        = {}
+		struct params        = {},
+		string mode = "update"
 	){
 		var requests = [];
 
@@ -1259,10 +1260,22 @@ component accessors="true" threadSafe singleton {
 				}
 			}
 
+			var opAction = { "#mode#" : { "_index" : doc.getIndex() } };
+
+			if( if( !isNull( doc.getId() ) ) ){
+				opAction[ mode ][ "_id" ] = doc.getId();
+			}
+
+			var docAction = { "doc" : memento };
+
+			if( mode == "update" ){
+				docAction[ "doc_as_upsert" ] = true;
+			}
+
 			requests.append(
 				[
-					{ "update" : { "_index" : doc.getIndex(), "_id" : doc.getId() } },
-					{ "doc" : memento, "doc_as_upsert" : true }
+					opAction,
+					docAction
 				],
 				true
 			);

models/util/Util.cfc

@@ -1,6 +1,7 @@
 component accessors="true" singleton {
 
 	property name="appEnvironment" inject="box:setting:environment";
+	property name="interceptorService" inject="coldbox:InterceptorService";
 
 	/**
 	 * Ensures a CF native struct is returned ( allowing for dot-notation )
@@ -158,6 +159,8 @@ component accessors="true" singleton {
 		}
 
 		generateLogEntrySignature( logObj );
+
+		interceptorService.announce( "onLogstashEntryCreate", { "entry" : logObj } );
 	}
 
 	/**