Method createOrganization

pkg/public/server.go:892–994

(w http.ResponseWriter, r *http.Request)

}

func (s *Server) createOrganization(w http.ResponseWriter, r *http.Request) {
	account, ok := middleware.GetAccountFromContext(r.Context())
	if !ok {
		http.Error(w, "", http.StatusUnauthorized)
		return
	}

	body, err := io.ReadAll(r.Body)
	if err != nil {
		http.Error(w, "Invalid request body", http.StatusBadRequest)
		return
	}

	var req OrganizationCreationRequest
	err = json.Unmarshal(body, &req)
	if err != nil {
		http.Error(w, "Invalid request body", http.StatusBadRequest)
		return
	}

	if req.Name == "" {
		http.Error(w, "Name is required", http.StatusBadRequest)
		return
	}

	creationStatus, err := s.describeOrganizationCreationStatus(r.Context(), account.ID.String())
	if err != nil {
		// describeOrganizationCreationStatus already logs the underlying
		// error with stage-specific structured fields.
		log.WithField("account_id", account.ID.String()).
			Error("failed to check organization creation status before creating organization")
		http.Error(w, "Failed to create organization", http.StatusInternalServerError)
		return
	}

	if !creationStatus.Allowed {
		http.Error(w, creationStatus.Message, http.StatusTooManyRequests)
		return
	}

	//
	// Create the organization
	//
	tx := database.Conn().Begin()
	log.Infof("Creating organization %s for account %s", req.Name, account.Email)
	organization, err := models.CreateOrganizationInTransaction(tx, req.Name, "")

	if err != nil {
		tx.Rollback()

		if err.Error() == "name already used" {
			http.Error(w, "Organization name already in use", http.StatusConflict)
			return
		}

		log.Errorf("Error creating organization %s: %v", req.Name, err)
		http.Error(w, "Failed to create organization", http.StatusInternalServerError)
		return