Identity.by_username_and_domain has more awareness of Domain (#303)

This commit is contained in:
Michael Manfre 2022-12-28 12:52:39 -05:00 committed by GitHub
parent 5780068213
commit f17f9df27e
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
3 changed files with 31 additions and 6 deletions

View File

@ -44,7 +44,7 @@ class SearchService:
if self.identity is not None:
# Allow authenticated users to fetch remote
identity = Identity.by_username_and_domain(
username, domain, fetch=True
username, domain_instance or domain, fetch=True
)
if identity and identity.state == IdentityStates.outdated:
async_to_sync(identity.fetch_actor)()

View File

@ -303,9 +303,33 @@ class Identity(StatorModel):
### Alternate constructors/fetchers ###
@classmethod
def by_username_and_domain(cls, username, domain, fetch=False, local=False):
def by_username_and_domain(
cls,
username: str,
domain: str | Domain,
fetch: bool = False,
local: bool = False,
):
"""
Get an Identity by username and domain.
When fetch is True, a failed lookup will do a webfinger lookup to attempt to do
a lookup by actor_uri, creating an Identity record if one does not exist. When
local is True, lookups will be restricted to local domains.
If domain is a Domain, domain.local is used instead of passsed local.
"""
if username.startswith("@"):
raise ValueError("Username must not start with @")
domain_instance = None
if isinstance(domain, Domain):
domain_instance = domain
local = domain.local
domain = domain.domain
else:
domain = domain.lower()
try:
if local:
@ -333,11 +357,12 @@ class Identity(StatorModel):
pass
# OK, make one
username, domain = handle.split("@")
domain = Domain.get_remote_domain(domain)
if not domain_instance:
domain_instance = Domain.get_remote_domain(domain)
return cls.objects.create(
actor_uri=actor_uri,
username=username,
domain_id=domain,
domain_id=domain_instance,
local=False,
)
return None

View File

@ -25,7 +25,7 @@ def by_handle_or_404(request, handle, local=True, fetch=False) -> Identity:
domain = domain_instance.domain
identity = Identity.by_username_and_domain(
username,
domain,
domain_instance,
local=local,
fetch=fetch,
)