test: Fix broken mcp-stdio module imports in unit tests
This commit is contained in:
1 parent
368f28e593
commit
4fe6ed7791
2 files changed
+17
-3
No files matched your search
@@ -836,7 +836,8 @@ mod tests {
|
|||||||
async fn test_read_message_jsonl() {
|
async fn test_read_message_jsonl() {
|
||||||
let input = "{\"jsonrpc\": \"2.0\", \"id\": 1, \"method\": \"test\"}\n";
|
let input = "{\"jsonrpc\": \"2.0\", \"id\": 1, \"method\": \"test\"}\n";
|
||||||
let mut reader = BufReader::new(input.as_bytes());
|
let mut reader = BufReader::new(input.as_bytes());
|
||||||
let req = read_message(&mut reader).await.unwrap();
|
let raw = mcp_stdio::read_mcp_message(&mut reader).await.unwrap();
|
||||||
|
let req: JsonRpcRequest = serde_json::from_str(&raw).unwrap();
|
||||||
assert_eq!(req.method, "test");
|
assert_eq!(req.method, "test");
|
||||||
}
|
}
|
||||||
|
|
||||||
@@ -845,7 +846,8 @@ mod tests {
|
|||||||
let payload = "{\"jsonrpc\": \"2.0\", \"id\": 2, \"method\": \"test2\"}";
|
let payload = "{\"jsonrpc\": \"2.0\", \"id\": 2, \"method\": \"test2\"}";
|
||||||
let input = format!("Content-Length: {}\r\n\r\n{}", payload.len(), payload);
|
let input = format!("Content-Length: {}\r\n\r\n{}", payload.len(), payload);
|
||||||
let mut reader = BufReader::new(input.as_bytes());
|
let mut reader = BufReader::new(input.as_bytes());
|
||||||
let req = read_message(&mut reader).await.unwrap();
|
let raw = mcp_stdio::read_mcp_message(&mut reader).await.unwrap();
|
||||||
|
let req: JsonRpcRequest = serde_json::from_str(&raw).unwrap();
|
||||||
assert_eq!(req.method, "test2");
|
assert_eq!(req.method, "test2");
|
||||||
}
|
}
|
||||||
|
|
||||||
@@ -853,7 +855,7 @@ mod tests {
|
|||||||
async fn test_read_message_malformed() {
|
async fn test_read_message_malformed() {
|
||||||
let input = "Content-Length: abc\r\n\r\n{}";
|
let input = "Content-Length: abc\r\n\r\n{}";
|
||||||
let mut reader = BufReader::new(input.as_bytes());
|
let mut reader = BufReader::new(input.as_bytes());
|
||||||
let req = read_message(&mut reader).await;
|
let req = mcp_stdio::read_mcp_message(&mut reader).await;
|
||||||
assert!(req.is_none());
|
assert!(req.is_none());
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|||||||
@@ -0,0 +1,12 @@
|
|||||||
|
import re
|
||||||
|
|
||||||
|
with open('C:\\Users\\reazul.ashraf\\workspace\\rust\\mcp-memory\\nvim-core\\src\\lib.rs', 'r', encoding='utf-8') as f:
|
||||||
|
content = f.read()
|
||||||
|
|
||||||
|
content = content.replace('read_message(&mut reader)', 'mcp_stdio::read_mcp_message(&mut reader)')
|
||||||
|
content = content.replace('let req = mcp_stdio::read_mcp_message(&mut reader).await.unwrap();', 'let raw = mcp_stdio::read_mcp_message(&mut reader).await.unwrap();\n let req: JsonRpcRequest = serde_json::from_str(&raw).unwrap();')
|
||||||
|
content = content.replace('let req = mcp_stdio::read_mcp_message(&mut reader).await;', 'let req = mcp_stdio::read_mcp_message(&mut reader).await;')
|
||||||
|
|
||||||
|
with open('C:\\Users\\reazul.ashraf\\workspace\\rust\\mcp-memory\\nvim-core\\src\\lib.rs', 'w', encoding='utf-8') as f:
|
||||||
|
f.write(content)
|
||||||
|
print("Patched tests")
|
||||||
Reference in new issue
Block a user