Method insert_team

libs/@local/graph/postgres-store/src/permissions/mod.rs:445–514

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

(
        &mut self,
        id: Option<Uuid>,
        parent_id: ActorGroupId,
        name: &str,
    )

    /// [`PrincipalAlreadyExists`]: PrincipalError::PrincipalAlreadyExists
    /// [`StoreError`]: PrincipalError::StoreError
    pub async fn insert_team(
        &mut self,
        id: Option<Uuid>,
        parent_id: ActorGroupId,
        name: &str,
    ) -> Result<TeamId, Report<PrincipalError>> {
        let id = id.unwrap_or_else(Uuid::new_v4);
        let transaction = self
            .as_mut_client()
            .transaction()
            .await
            .change_context(PrincipalError::StoreError)?;

        // First create the team
        transaction
            .execute(
                "INSERT INTO team (id, parent_id, name) VALUES ($1, $2, $3)",
                &[&id, &parent_id, &name],
            )
            .instrument(tracing::info_span!(
                "INSERT",
                otel.kind = "client",
                db.system = "postgresql",
                peer.service = "Postgres",
            ))
            .await
            .map_err(Report::new)
            .map_err(|error| match error.current_context().code() {
                Some(&SqlState::UNIQUE_VIOLATION) => {
                    error.change_context(PrincipalError::PrincipalAlreadyExists {
                        id: PrincipalId::ActorGroup(ActorGroupId::Team(TeamId::new(id))),
                    })
                }
                Some(&SqlState::FOREIGN_KEY_VIOLATION) => {
                    error.change_context(PrincipalError::PrincipalNotFound {
                        id: PrincipalId::ActorGroup(parent_id),
                    })
                }
                _ => error.change_context(PrincipalError::StoreError),
            })?;

        // Set up all parent-child relationships in a single query
        // First row creates the direct relationship with depth 1
        // Remaining rows create transitive relationships with proper depths
        transaction
            .execute(
                "INSERT INTO team_hierarchy (parent_id, child_id, depth)
                SELECT $1::uuid, $2::uuid, 1
                UNION ALL
                SELECT parent_id, $2::uuid, depth + 1
                  FROM team_hierarchy
                 WHERE child_id = $1::uuid",
                &[&parent_id, &id],
            )
            .instrument(tracing::info_span!(
                "INSERT",
                otel.kind = "client",
                db.system = "postgresql",