Skip to content

Commit c91c1d9

Browse files
committed
chore(acp-nats-agent): remove duplicate JS dispatch tests
Signed-off-by: Yordis Prieto <yordis.prieto@gmail.com>
1 parent b661780 commit c91c1d9

1 file changed

Lines changed: 0 additions & 29 deletions

File tree

rsworkspace/crates/acp-nats-agent/src/connection.rs

Lines changed: 0 additions & 29 deletions
Original file line numberDiff line numberDiff line change
@@ -1390,18 +1390,6 @@ mod tests {
13901390
.await;
13911391
}
13921392

1393-
#[tokio::test]
1394-
async fn dispatch_js_message_success_publishes_to_response_subject() {
1395-
let nats = MockNatsClient::new();
1396-
let agent = MockAgent::new();
1397-
let payload = serialize(&LoadSessionRequest::new("s1", "/tmp"));
1398-
let js_msg = make_js_msg("acp.session.s1.agent.load", &payload, None);
1399-
1400-
dispatch_js_message(js_msg, &agent, &nats, &test_prefix()).await;
1401-
1402-
assert_js_response_method_not_found(&nats, "acp.session.s1.agent.response.req-1");
1403-
}
1404-
14051393
#[tokio::test]
14061394
async fn dispatch_js_message_unknown_subject_terms() {
14071395
let nats = MockNatsClient::new();
@@ -1792,23 +1780,6 @@ mod tests {
17921780
assert_js_response_method_not_found(&nats, "acp.session.s1.agent.response.req-1");
17931781
}
17941782

1795-
#[tokio::test]
1796-
async fn dispatch_js_message_prompt_publishes_response_with_stop_reason() {
1797-
let nats = MockNatsClient::new();
1798-
let agent = MockAgent::new();
1799-
let payload = serialize(&PromptRequest::new("s1", vec![]));
1800-
let js_msg = make_js_msg("acp.session.s1.agent.prompt", &payload, None);
1801-
1802-
dispatch_js_message(js_msg, &agent, &nats, &test_prefix()).await;
1803-
1804-
assert_eq!(
1805-
nats.published_messages(),
1806-
vec!["acp.session.s1.agent.prompt.response.req-1"]
1807-
);
1808-
let response: PromptResponse = published_response(&nats);
1809-
assert_eq!(response.stop_reason, StopReason::EndTurn);
1810-
}
1811-
18121783
#[tokio::test]
18131784
async fn dispatch_js_message_reply_failure_acks() {
18141785
let nats = trogon_nats::AdvancedMockNatsClient::new();

0 commit comments

Comments
 (0)