mirrors/codex
1
0
Fork 0
mirror of https://github.com/openai/codex.git synced 2026-05-05 13:51:29 +03:00
Code Issues Packages Projects Releases Wiki Activity

Run cargo +nightly fmt

Browse Source
This commit is contained in:
Josh McKinney
2025-11-05 17:32:52 -08:00
parent c67908ba17
commit 6fc8a9308a
424 changed files with 3097 additions and 5253 deletions
Download Patch File Download Diff File Expand all files Collapse all files

56
codex-rs/app-server/tests/common/mcp_process.rs
View File

@@ -1,50 +1,22 @@
use std::collections::VecDeque;
use std::path::Path;
use std::process::Stdio;
use std::sync::atomic::AtomicI64;
use std::sync::atomic::Ordering;
use tokio::io::AsyncBufReadExt;
use tokio::io::AsyncWriteExt;
use tokio::io::BufReader;
use tokio::process::Child;
use tokio::process::ChildStdin;
use tokio::process::ChildStdout;
use std::process::{Command as StdCommand, Stdio};
use std::sync::atomic::{AtomicI64, Ordering};
use anyhow::Context;
use assert_cmd::prelude::*;
use codex_app_server_protocol::AddConversationListenerParams;
use codex_app_server_protocol::ArchiveConversationParams;
use codex_app_server_protocol::CancelLoginAccountParams;
use codex_app_server_protocol::CancelLoginChatGptParams;
use codex_app_server_protocol::ClientInfo;
use codex_app_server_protocol::ClientNotification;
use codex_app_server_protocol::FeedbackUploadParams;
use codex_app_server_protocol::GetAuthStatusParams;
use codex_app_server_protocol::InitializeParams;
use codex_app_server_protocol::InterruptConversationParams;
use codex_app_server_protocol::ListConversationsParams;
use codex_app_server_protocol::LoginApiKeyParams;
use codex_app_server_protocol::ModelListParams;
use codex_app_server_protocol::NewConversationParams;
use codex_app_server_protocol::RemoveConversationListenerParams;
use codex_app_server_protocol::ResumeConversationParams;
use codex_app_server_protocol::SendUserMessageParams;
use codex_app_server_protocol::SendUserTurnParams;
use codex_app_server_protocol::ServerRequest;
use codex_app_server_protocol::SetDefaultModelParams;
use codex_app_server_protocol::ThreadArchiveParams;
use codex_app_server_protocol::ThreadListParams;
use codex_app_server_protocol::ThreadResumeParams;
use codex_app_server_protocol::ThreadStartParams;
use codex_app_server_protocol::JSONRPCError;
use codex_app_server_protocol::JSONRPCMessage;
use codex_app_server_protocol::JSONRPCNotification;
use codex_app_server_protocol::JSONRPCRequest;
use codex_app_server_protocol::JSONRPCResponse;
use codex_app_server_protocol::RequestId;
use std::process::Command as StdCommand;
use tokio::process::Command;
use codex_app_server_protocol::{
AddConversationListenerParams, ArchiveConversationParams, CancelLoginAccountParams,
CancelLoginChatGptParams, ClientInfo, ClientNotification, FeedbackUploadParams,
GetAuthStatusParams, InitializeParams, InterruptConversationParams, JSONRPCError,
JSONRPCMessage, JSONRPCNotification, JSONRPCRequest, JSONRPCResponse, ListConversationsParams,
LoginApiKeyParams, ModelListParams, NewConversationParams, RemoveConversationListenerParams,
RequestId, ResumeConversationParams, SendUserMessageParams, SendUserTurnParams, ServerRequest,
SetDefaultModelParams, ThreadArchiveParams, ThreadListParams, ThreadResumeParams,
ThreadStartParams,
};
use tokio::io::{AsyncBufReadExt, AsyncWriteExt, BufReader};
use tokio::process::{Child, ChildStdin, ChildStdout, Command};
pub struct McpProcess {
next_request_id: AtomicI64,