Remove unnecessary condition in CEL

chemamartinez · chemamartinez · commit 5036d69bddab · 2025-03-21T14:29:52.000+01:00
diff --git a/packages/checkpoint_harmony_endpoint/data_stream/antibot/agent/stream/cel.yml.hbs b/packages/checkpoint_harmony_endpoint/data_stream/antibot/agent/stream/cel.yml.hbs
@@ -70,9 +70,9 @@ program: |
   				timestamp(now() - duration(state.initial_interval)).format(time_layout.RFC3339)
   			),
   			"endTime": state.?cursor.next_endTime.orValue(null) == null ?
-  				optional.of(timestamp(now() - duration("1m")).format(time_layout.RFC3339))
+  				timestamp(now() - duration("1m")).format(time_layout.RFC3339)
   			:
-  				optional.of(state.cursor.next_endTime),
+  				state.cursor.next_endTime,
   		}.as(timeframe,
   			request("POST", state.url.trim_right("/") + "/app/laas-logs-api/api/logs_query").with(
   				{
diff --git a/packages/checkpoint_harmony_endpoint/data_stream/antimalware/agent/stream/cel.yml.hbs b/packages/checkpoint_harmony_endpoint/data_stream/antimalware/agent/stream/cel.yml.hbs
@@ -70,9 +70,9 @@ program: |
   				timestamp(now() - duration(state.initial_interval)).format(time_layout.RFC3339)
   			),
   			"endTime": state.?cursor.next_endTime.orValue(null) == null ?
-  				optional.of(timestamp(now() - duration("1m")).format(time_layout.RFC3339))
+  				timestamp(now() - duration("1m")).format(time_layout.RFC3339)
   			:
-  				optional.of(state.cursor.next_endTime),
+  				state.cursor.next_endTime,
   		}.as(timeframe,
   			request("POST", state.url.trim_right("/") + "/app/laas-logs-api/api/logs_query").with(
   				{
diff --git a/packages/checkpoint_harmony_endpoint/data_stream/forensics/agent/stream/cel.yml.hbs b/packages/checkpoint_harmony_endpoint/data_stream/forensics/agent/stream/cel.yml.hbs
@@ -70,9 +70,9 @@ program: |
   				timestamp(now() - duration(state.initial_interval)).format(time_layout.RFC3339)
   			),
   			"endTime": state.?cursor.next_endTime.orValue(null) == null ?
-  				optional.of(timestamp(now() - duration("1m")).format(time_layout.RFC3339))
+  				timestamp(now() - duration("1m")).format(time_layout.RFC3339)
   			:
-  				optional.of(state.cursor.next_endTime),
+  				state.cursor.next_endTime,
   		}.as(timeframe,
   			request("POST", state.url.trim_right("/") + "/app/laas-logs-api/api/logs_query").with(
   				{
diff --git a/packages/checkpoint_harmony_endpoint/data_stream/threatemulation/agent/stream/cel.yml.hbs b/packages/checkpoint_harmony_endpoint/data_stream/threatemulation/agent/stream/cel.yml.hbs
@@ -70,9 +70,9 @@ program: |
   				timestamp(now() - duration(state.initial_interval)).format(time_layout.RFC3339)
   			),
   			"endTime": state.?cursor.next_endTime.orValue(null) == null ?
-  				optional.of(timestamp(now() - duration("1m")).format(time_layout.RFC3339))
+  				timestamp(now() - duration("1m")).format(time_layout.RFC3339)
   			:
-  				optional.of(state.cursor.next_endTime),
+  				state.cursor.next_endTime,
   		}.as(timeframe,
   			request("POST", state.url.trim_right("/") + "/app/laas-logs-api/api/logs_query").with(
   				{
diff --git a/packages/checkpoint_harmony_endpoint/data_stream/threatextraction/agent/stream/cel.yml.hbs b/packages/checkpoint_harmony_endpoint/data_stream/threatextraction/agent/stream/cel.yml.hbs
@@ -70,9 +70,9 @@ program: |
   				timestamp(now() - duration(state.initial_interval)).format(time_layout.RFC3339)
   			),
   			"endTime": state.?cursor.next_endTime.orValue(null) == null ?
-  				optional.of(timestamp(now() - duration("1m")).format(time_layout.RFC3339))
+  				timestamp(now() - duration("1m")).format(time_layout.RFC3339)
   			:
-  				optional.of(state.cursor.next_endTime),
+  				state.cursor.next_endTime,
   		}.as(timeframe,
   			request("POST", state.url.trim_right("/") + "/app/laas-logs-api/api/logs_query").with(
   				{
diff --git a/packages/checkpoint_harmony_endpoint/data_stream/urlfiltering/agent/stream/cel.yml.hbs b/packages/checkpoint_harmony_endpoint/data_stream/urlfiltering/agent/stream/cel.yml.hbs
@@ -70,9 +70,9 @@ program: |
   				timestamp(now() - duration(state.initial_interval)).format(time_layout.RFC3339)
   			),
   			"endTime": state.?cursor.next_endTime.orValue(null) == null ?
-  				optional.of(timestamp(now() - duration("1m")).format(time_layout.RFC3339))
+  				timestamp(now() - duration("1m")).format(time_layout.RFC3339)
   			:
-  				optional.of(state.cursor.next_endTime),
+  				state.cursor.next_endTime,
   		}.as(timeframe,
   			request("POST", state.url.trim_right("/") + "/app/laas-logs-api/api/logs_query").with(
   				{
diff --git a/packages/checkpoint_harmony_endpoint/data_stream/zerophishing/agent/stream/cel.yml.hbs b/packages/checkpoint_harmony_endpoint/data_stream/zerophishing/agent/stream/cel.yml.hbs
@@ -70,9 +70,9 @@ program: |
   				timestamp(now() - duration(state.initial_interval)).format(time_layout.RFC3339)
   			),
   			"endTime": state.?cursor.next_endTime.orValue(null) == null ?
-  				optional.of(timestamp(now() - duration("1m")).format(time_layout.RFC3339))
+  				timestamp(now() - duration("1m")).format(time_layout.RFC3339)
   			:
-  				optional.of(state.cursor.next_endTime),
+  				state.cursor.next_endTime,
   		}.as(timeframe,
   			request("POST", state.url.trim_right("/") + "/app/laas-logs-api/api/logs_query").with(
   				{

Original file line number	Diff line number	Diff line change
`@@ -70,9 +70,9 @@ program: \|`
`70`	`70`	`timestamp(now() - duration(state.initial_interval)).format(time_layout.RFC3339)`
`71`	`71`	`),`
`72`	`72`	`"endTime": state.?cursor.next_endTime.orValue(null) == null ?`
`73`		`- optional.of(timestamp(now() - duration("1m")).format(time_layout.RFC3339))`
	`73`	`+ timestamp(now() - duration("1m")).format(time_layout.RFC3339)`
`74`	`74`	`:`
`75`		`- optional.of(state.cursor.next_endTime),`
	`75`	`+ state.cursor.next_endTime,`
`76`	`76`	`}.as(timeframe,`
`77`	`77`	`request("POST", state.url.trim_right("/") + "/app/laas-logs-api/api/logs_query").with(`
`78`	`78`	`{`