mirror of
https://github.com/openai/codex.git
synced 2026-09-07 15:40:00 +00:00
83d015375e
## What changed - Add `codex queue --thread <THREAD> --message <TEXT>` to submit a text message through the `thread/queue/add` app-server API. - Resolve active sessions by UUID or exact name across interactive, exec, and custom sources, and reject ambiguous names. - Support local and explicit remote app servers while reporting incompatible servers and configuration overrides instead of silently changing the target. - Reject empty messages and image attachments. ## Testing - Add CLI coverage for remote submission, validation, unsupported servers, and local-daemon routing. - Add session lookup and queue tests for stale, non-interactive, custom, and duplicate session names. GitOrigin-RevId: 44c233f752b63a85c85b92fa6da303336e4ddeca
64 lines
1.8 KiB
Rust
64 lines
1.8 KiB
Rust
use clap::Parser;
|
|
use clap::builder::NonEmptyStringValueParser;
|
|
use codex_arg0::Arg0DispatchPaths;
|
|
use codex_tui::Cli as TuiCli;
|
|
use codex_utils_cli::CliConfigOverrides;
|
|
|
|
use crate::InteractiveRemoteOptions;
|
|
use crate::SessionArchiveConfigOverrides;
|
|
use crate::finalize_session_archive_interactive;
|
|
use crate::resolve_remote_endpoint;
|
|
|
|
#[derive(Debug, Parser)]
|
|
pub(crate) struct QueueCommand {
|
|
/// Session UUID or exact session name.
|
|
#[arg(long, value_name = "THREAD")]
|
|
thread: String,
|
|
|
|
/// Message text to queue.
|
|
#[arg(long, value_name = "TEXT", value_parser = NonEmptyStringValueParser::new())]
|
|
message: String,
|
|
|
|
#[clap(flatten)]
|
|
remote: InteractiveRemoteOptions,
|
|
|
|
#[clap(flatten)]
|
|
config_overrides: SessionArchiveConfigOverrides,
|
|
}
|
|
|
|
pub(crate) async fn run_queue_command(
|
|
command: QueueCommand,
|
|
interactive: TuiCli,
|
|
root_config_overrides: CliConfigOverrides,
|
|
root_remote: Option<String>,
|
|
root_remote_auth_token_env: Option<String>,
|
|
arg0_paths: Arg0DispatchPaths,
|
|
) -> anyhow::Result<String> {
|
|
let QueueCommand {
|
|
thread,
|
|
message,
|
|
remote,
|
|
config_overrides,
|
|
} = command;
|
|
let cli =
|
|
finalize_session_archive_interactive(interactive, root_config_overrides, config_overrides);
|
|
if !cli.images.is_empty() {
|
|
anyhow::bail!("`codex queue` does not support image attachments");
|
|
}
|
|
let explicit_remote_endpoint = resolve_remote_endpoint(
|
|
remote.remote.or(root_remote),
|
|
remote.remote_auth_token_env.or(root_remote_auth_token_env),
|
|
)?;
|
|
codex_tui::run_session_queue_command(
|
|
thread,
|
|
message,
|
|
codex_tui::SessionArchiveCommandOptions {
|
|
cli,
|
|
arg0_paths,
|
|
explicit_remote_endpoint,
|
|
},
|
|
)
|
|
.await
|
|
.map_err(|error| anyhow::anyhow!("{error:#}"))
|
|
}
|