Method create_web

libs/@local/graph/postgres-store/src/store/postgres/mod.rs:816–938

(
        &mut self,
        actor: ActorId,
        parameter: CreateWebParameter,
    )

    #[expect(clippy::too_many_lines)]
    async fn create_web(
        &mut self,
        actor: ActorId,
        parameter: CreateWebParameter,
    ) -> Result<CreateWebResponse, Report<WebCreationError>> {
        let policy_components = PolicyComponents::builder(self)
            .with_actor(actor)
            .with_action(ActionName::CreateWeb, MergePolicies::No)
            .await
            .change_context(WebCreationError::BuildPolicyComponents)?;

        let web_id = WebId::new(parameter.id.unwrap_or_else(Uuid::new_v4));

        match policy_components
            .build_policy_set([ActionName::CreateWeb])
            .change_context(WebCreationError::PolicySetCreation)?
            .evaluate(
                &Request {
                    actor: policy_components.actor_id(),
                    action: ActionName::CreateWeb,
                    resource: &ResourceId::Web(web_id),
                    context: RequestContext::default(),
                },
                policy_components.context(),
            )
            .change_context(WebCreationError::StoreError)?
        {
            Authorized::Always => {}
            Authorized::Never => {
                return Err(Report::new(WebCreationError::NotAuthorized))
                    .attach(StatusCode::PermissionDenied);
            }
        }

        let mut transaction = self
            .transaction()
            .await
            .change_context(WebCreationError::StoreError)?;

        transaction
            .as_client()
            .execute(
                "INSERT INTO web (id, shortname) VALUES ($1, $2)",
                &[&web_id, &parameter.shortname],
            )
            .instrument(tracing::info_span!(
                "INSERT",
                otel.kind = "client",
                db.system = "postgresql",
                peer.service = "Postgres",
            ))
            .await
            .map_err(|error| match error.code() {
                Some(&SqlState::UNIQUE_VIOLATION) => {
                    Report::new(error).change_context(WebCreationError::AlreadyExists { web_id })
                }
                _ => Report::new(error).change_context(WebCreationError::StoreError),
            })?;