summaryrefslogtreecommitdiff
path: root/cli/ops/testing.rs
diff options
context:
space:
mode:
Diffstat (limited to 'cli/ops/testing.rs')
-rw-r--r--cli/ops/testing.rs11
1 files changed, 9 insertions, 2 deletions
diff --git a/cli/ops/testing.rs b/cli/ops/testing.rs
index 450f55a41..826a4eb7a 100644
--- a/cli/ops/testing.rs
+++ b/cli/ops/testing.rs
@@ -1,3 +1,4 @@
+use crate::tools::test_runner::TestEvent;
use crate::tools::test_runner::TestMessage;
use deno_core::error::generic_error;
use deno_core::error::AnyError;
@@ -5,6 +6,7 @@ use deno_core::serde_json;
use deno_core::serde_json::json;
use deno_core::serde_json::Value;
use deno_core::JsRuntime;
+use deno_core::ModuleSpecifier;
use deno_core::OpState;
use deno_core::ZeroCopyBuf;
use deno_runtime::ops::worker_host::create_worker_permissions;
@@ -81,9 +83,14 @@ fn op_post_test_message(
_zero_copy: Option<ZeroCopyBuf>,
) -> Result<Value, AnyError> {
let args: PostTestMessageArgs = serde_json::from_value(args)?;
- let sender = state.borrow::<Sender<TestMessage>>().clone();
+ let origin = state.borrow::<ModuleSpecifier>().to_string();
+ let message = args.message;
- if sender.send(args.message).is_err() {
+ let event = TestEvent { origin, message };
+
+ let sender = state.borrow::<Sender<TestEvent>>().clone();
+
+ if sender.send(event).is_err() {
Ok(json!(false))
} else {
Ok(json!(true))