Skip to content
Open
Show file tree
Hide file tree
Changes from 1 commit
Commits
File filter

Filter by extension

Filter by extension

Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
66 changes: 56 additions & 10 deletions pyrefly/lib/alt/narrow.rs
Original file line number Diff line number Diff line change
Expand Up @@ -21,6 +21,7 @@ use pyrefly_types::facet::UnresolvedFacetKind;
use pyrefly_types::simplify::intersect;
use pyrefly_types::simplify::simplify_tuples;
use pyrefly_types::type_info::JoinStyle;
use pyrefly_types::typed_dict::ExtraItems;
use pyrefly_util::prelude::SliceExt;
use pyrefly_util::visit::Visit;
use ruff_python_ast::Arguments;
Expand Down Expand Up @@ -678,6 +679,41 @@ impl<'a, Ans: LookupAnswer> AnswersSolver<'a, Ans> {
})
}

fn narrow_key_membership(&self, ty: &Type, key: &Name, present: bool) -> Type {
self.distribute_over_union(ty, |member| match member {
_ if self.behaves_like_any(member) => member.clone(),
Type::TypedDict(typed_dict) => {
let fields = self.typed_dict_fields(typed_dict);
match fields.get(key) {
Some(field) if present || !field.required => member.clone(),
Some(_) => self.heap.mk_never(),
None if matches!(
self.typed_dict_extra_items(typed_dict),
ExtraItems::Extra(_)
) =>
{
member.clone()
}
None if present => self.heap.mk_never(),
None => member.clone(),
}
}
_ if self.is_dict_like(member) => member.clone(),
_ => member.clone(),
})
}

fn has_dict_like_member(&self, ty: &Type) -> bool {
match ty {
ty if self.is_dict_like(ty) => true,
Type::Union(union) => union
.members
.iter()
.any(|member| self.has_dict_like_member(member)),
_ => false,
}
}

/// Narrow a union by keeping only members whose facet is identity-compatible with `right`.
fn narrow_facet_is(
&self,
Expand Down Expand Up @@ -1536,7 +1572,12 @@ impl<'a, Ans: LookupAnswer> AnswersSolver<'a, Ans> {
(Some(_), None) => return type_info.clone(),
(None, _) => self.force_for_narrowing(type_info.ty(), range, errors),
};
if self.is_dict_like(&base_ty) {
let narrowed_base = self.narrow_key_membership(&base_ty, key, true);
let mut narrowed = match &resolved_chain {
Some(chain) => type_info.with_narrow(chain.facets(), narrowed_base.clone()),
None => type_info.clone().with_ty(narrowed_base.clone()),
};
if self.has_dict_like_member(&narrowed_base) {
let key_facet = FacetKind::Key(key.to_string());
let facets = match resolved_chain {
Some(chain) => {
Expand All @@ -1546,13 +1587,14 @@ impl<'a, Ans: LookupAnswer> AnswersSolver<'a, Ans> {
}
None => Vec1::new(key_facet),
};
let chain = FacetChain::new(facets);
let chain = FacetChain::new(facets.clone());
// Apply a facet narrow w/ that key's type, so that the usual subscript inference
// code path which raises a warning for NotRequired keys does not execute later
let value_ty = self.get_facet_chain_type(type_info, &chain, range);
type_info.with_narrow(chain.facets(), value_ty)
let value_ty = self.get_facet_chain_type(&narrowed, &chain, range);
narrowed = narrowed.with_narrow(&facets, value_ty);
narrowed
} else {
type_info.clone()
narrowed
}
}
NarrowOp::Atomic(subject, AtomicNarrowOp::NotHasKey(key)) => {
Expand All @@ -1564,7 +1606,12 @@ impl<'a, Ans: LookupAnswer> AnswersSolver<'a, Ans> {
(Some(_), None) => return type_info.clone(),
(None, _) => self.force_for_narrowing(type_info.ty(), range, errors),
};
if self.is_dict_like(&base_ty) {
let narrowed_base = self.narrow_key_membership(&base_ty, key, false);
let mut narrowed = match &resolved_chain {
Some(chain) => type_info.with_narrow(chain.facets(), narrowed_base),
None => type_info.clone().with_ty(narrowed_base),
};
if self.has_dict_like_member(&base_ty) {
let key_facet = FacetKind::Key(key.to_string());
let facets = match resolved_chain {
Some(chain) => {
Expand All @@ -1575,11 +1622,10 @@ impl<'a, Ans: LookupAnswer> AnswersSolver<'a, Ans> {
None => Vec1::new(key_facet),
};
// Invalidate existing facet narrows
let mut type_info = type_info.clone();
type_info.update_for_assignment(&facets, None);
type_info
narrowed.update_for_assignment(&facets, None);
narrowed
} else {
type_info.clone()
narrowed
}
}
NarrowOp::Atomic(subject, AtomicNarrowOp::HasAttr(attr)) => {
Expand Down
21 changes: 21 additions & 0 deletions pyrefly/lib/test/typed_dict.rs
Original file line number Diff line number Diff line change
Expand Up @@ -2288,6 +2288,27 @@ def test_empty_not_in(e: Empty, k: str):
"#,
);

testcase!(
test_typed_dict_union_subject_contains_narrowing,
r#"
from typing import TypedDict, assert_type

class Foo(TypedDict):
a: int

class Bar(TypedDict):
b: int

def test(foo: Foo | Bar) -> None:
if "a" in foo:
assert_type(foo, Foo)
assert_type(foo["a"], int)
else:
assert_type(foo, Bar)
assert_type(foo["b"], int)
"#,
);

testcase!(
test_illegal_unpacking_in_def,
r#"
Expand Down
Loading