Method create_ai

libs/@local/graph/postgres-store/src/permissions/mod.rs:315–345

Creates a new AI with the given ID, or generates a new UUID if none is provided. # Errors - [`PrincipalAlreadyExists`] if an AI with the given ID already exists - [`StoreError`] if a database error occurs [`PrincipalAlreadyExists`]: PrincipalError::PrincipalAlreadyExists [`StoreError`]: PrincipalError::StoreError

(
        &mut self,
        id: Option<Uuid>,
        identifier: &str,
    )

    /// [`PrincipalAlreadyExists`]: PrincipalError::PrincipalAlreadyExists
    /// [`StoreError`]: PrincipalError::StoreError
    pub async fn create_ai(
        &mut self,
        id: Option<Uuid>,
        identifier: &str,
    ) -> Result<AiId, Report<PrincipalError>> {
        let ai_id = AiId::new(id.unwrap_or_else(Uuid::new_v4));
        if let Err(error) = self
            .as_mut_client()
            .execute(
                "INSERT INTO ai_actor (id, identifier) VALUES ($1, $2)",
                &[&ai_id, &identifier],
            )
            .instrument(tracing::info_span!(
                "INSERT",
                otel.kind = "client",
                db.system = "postgresql",
                peer.service = "Postgres",
            ))
            .await
        {
            return if error.code() == Some(&SqlState::UNIQUE_VIOLATION) {
                Err(error).change_context(PrincipalError::PrincipalAlreadyExists {
                    id: PrincipalId::Actor(ActorId::Ai(ai_id)),
                })
            } else {
                Err(error).change_context(PrincipalError::StoreError)
            };
        }

        Ok(ai_id)
    }

    /// Checks if an AI with the given ID exists.
    ///