Method determine_actor

libs/@local/graph/postgres-store/src/store/postgres/mod.rs:1207–1242

(
        &self,
        actor_entity_uuid: ActorEntityUuid,
    )

    #[tracing::instrument(skip(self))]
    async fn determine_actor(
        &self,
        actor_entity_uuid: ActorEntityUuid,
    ) -> Result<Option<ActorId>, Report<DetermineActorError>> {
        if actor_entity_uuid.is_public_actor() {
            return Ok(None);
        }

        let row = self
            .as_client()
            .query_opt(
                "SELECT principal_type FROM actor WHERE id = $1",
                &[&actor_entity_uuid],
            )
            .instrument(tracing::info_span!(
                "SELECT",
                otel.kind = "client",
                db.system = "postgresql",
                peer.service = "Postgres",
            ))
            .await
            .change_context(DetermineActorError::StoreError)?
            .ok_or(DetermineActorError::ActorNotFound { actor_entity_uuid })?;

        Ok(Some(match row.get(0) {
            PrincipalType::User => ActorId::User(UserId::new(actor_entity_uuid)),
            PrincipalType::Machine => ActorId::Machine(MachineId::new(actor_entity_uuid)),
            PrincipalType::Ai => ActorId::Ai(AiId::new(actor_entity_uuid)),
            principal_type @ (PrincipalType::Web
            | PrincipalType::Team
            | PrincipalType::WebRole
            | PrincipalType::TeamRole) => {
                unreachable!("Unexpected actor type: {principal_type:?}")
            }
        }))
    }

    #[tracing::instrument(level = "info", skip(self, context_builder))]
    async fn build_principal_context(