Skip to content

Commit 073e2f6

Browse files
committed
fixup! Warn when javascript module and config are not consistent
1 parent 6aafcac commit 073e2f6

File tree

1 file changed

+4
-2
lines changed

1 file changed

+4
-2
lines changed

crates/extensions/tedge_gen_mapper/src/js_filter.rs

Lines changed: 4 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -325,7 +325,8 @@ mod tests {
325325
async fn error_filter() {
326326
let script = r#"export function process(t,msg) { throw new Error("Cannot process that message"); };"#;
327327
let mut runtime = JsRuntime::try_new().await.unwrap();
328-
let filter = JsFilter::new("err.toml".into(), 1, "err.js".into());
328+
let mut filter = JsFilter::new("err.toml".into(), 1, "err.js".into());
329+
filter.no_js_process = false;
329330
runtime.load_js(filter.module_name(), script).await.unwrap();
330331

331332
let input = Message::new("te/main/device///m/", "hello world");
@@ -361,7 +362,8 @@ export function process (timestamp, message, config) {
361362
}
362363
"#;
363364
let mut runtime = JsRuntime::try_new().await.unwrap();
364-
let filter = JsFilter::new("collectd.toml".into(), 1, "collectd.js".into());
365+
let mut filter = JsFilter::new("collectd.toml".into(), 1, "collectd.js".into());
366+
filter.no_js_process = false;
365367
runtime.load_js(filter.module_name(), script).await.unwrap();
366368

367369
let input = Message::new(

0 commit comments

Comments
 (0)