Skip to content

Commit

Permalink
refactor(publish): Clarify which SourceId is being used
Browse files Browse the repository at this point in the history
Ran into confusion on this when updating rust-lang#11062 to be on top of rust-lang#10907.
This now threads both types of sources through which comments explaining
each so callers will always have to explicitly acknowledge which they
are dealing with.
  • Loading branch information
epage committed Oct 11, 2022
1 parent e691e18 commit e7333a7
Showing 1 changed file with 25 additions and 14 deletions.
39 changes: 25 additions & 14 deletions src/cargo/ops/registry.rs
Original file line number Diff line number Diff line change
Expand Up @@ -142,15 +142,15 @@ pub fn publish(ws: &Workspace<'_>, opts: &PublishOpts<'_>) -> CargoResult<()> {
}
}

let (mut registry, _reg_cfg, reg_id) = registry(
let (mut registry, _reg_cfg, reg_ids) = registry(
opts.config,
opts.token.clone(),
opts.index.as_deref(),
publish_registry.as_deref(),
true,
!opts.dry_run,
)?;
verify_dependencies(pkg, &registry, reg_id)?;
verify_dependencies(pkg, &registry, reg_ids.original)?;

// Prepare a tarball, with a non-suppressible warning if metadata
// is missing since this is being put online.
Expand Down Expand Up @@ -180,7 +180,7 @@ pub fn publish(ws: &Workspace<'_>, opts: &PublishOpts<'_>) -> CargoResult<()> {
pkg,
tarball.file(),
&mut registry,
reg_id,
reg_ids.original,
opts.dry_run,
)?;

Expand Down Expand Up @@ -456,12 +456,12 @@ fn registry(
registry: Option<&str>,
force_update: bool,
validate_token: bool,
) -> CargoResult<(Registry, RegistryConfig, SourceId)> {
let (sid, sid_no_replacement) = get_source_id(config, index, registry)?;
) -> CargoResult<(Registry, RegistryConfig, PublishSourceIds)> {
let source_ids = get_source_id(config, index, registry)?;
let reg_cfg = registry_configuration(config, registry)?;
let api_host = {
let _lock = config.acquire_package_cache_lock()?;
let mut src = RegistrySource::remote(sid, &HashSet::new(), config)?;
let mut src = RegistrySource::remote(source_ids.replacement, &HashSet::new(), config)?;
// Only update the index if the config is not available or `force` is set.
if force_update {
src.invalidate_cache()
Expand All @@ -470,13 +470,14 @@ fn registry(
match src.config()? {
Poll::Pending => src
.block_until_ready()
.with_context(|| format!("failed to update {}", sid))?,
.with_context(|| format!("failed to update {}", source_ids.replacement))?,
Poll::Ready(cfg) => break cfg,
}
};

cfg.and_then(|cfg| cfg.api)
.ok_or_else(|| format_err!("{} does not support API commands", sid))?
cfg.and_then(|cfg| cfg.api).ok_or_else(|| {
format_err!("{} does not support API commands", source_ids.replacement)
})?
};
let token = if validate_token {
if index.is_some() {
Expand All @@ -495,7 +496,7 @@ fn registry(
Ok((
Registry::new_handle(api_host, token, handle),
reg_cfg,
sid_no_replacement,
source_ids,
))
}

Expand Down Expand Up @@ -919,7 +920,7 @@ fn get_source_id(
config: &Config,
index: Option<&str>,
reg: Option<&str>,
) -> CargoResult<(SourceId, SourceId)> {
) -> CargoResult<PublishSourceIds> {
let sid = match (reg, index) {
(None, None) => SourceId::crates_io(config)?,
(Some(r), None) => SourceId::alt_registry(config, r)?,
Expand All @@ -943,18 +944,28 @@ fn get_source_id(
bail!("crates-io is replaced with non-remote-registry source {replacement_sid};\ninclude `--registry crates-io` to use crates.io");
}
} else {
Ok((builtin_replacement_sid, sid))
Ok(PublishSourceIds {
original: sid,
replacement: builtin_replacement_sid,
})
}
}

struct PublishSourceIds {
/// Use when looking up the auth token, or writing out `Cargo.lock`
original: SourceId,
/// Use when interacting with the source (querying / publishing , etc)
replacement: SourceId,
}

pub fn search(
query: &str,
config: &Config,
index: Option<String>,
limit: u32,
reg: Option<String>,
) -> CargoResult<()> {
let (mut registry, _, source_id) =
let (mut registry, _, source_ids) =
registry(config, None, index.as_deref(), reg.as_deref(), false, false)?;
let (crates, total_crates) = registry.search(query, limit).with_context(|| {
format!(
Expand Down Expand Up @@ -1011,7 +1022,7 @@ pub fn search(
&ColorSpec::new(),
);
} else if total_crates > limit && limit >= search_max_limit {
let extra = if source_id.is_crates_io() {
let extra = if source_ids.original.is_crates_io() {
format!(
" (go to https://crates.io/search?q={} to see more)",
percent_encode(query.as_bytes(), NON_ALPHANUMERIC)
Expand Down

0 comments on commit e7333a7

Please sign in to comment.