Method CreateOrganization

runner/organizations.go:31–95

(ctx context.Context, param params.CreateOrgParams)

)

func (r *Runner) CreateOrganization(ctx context.Context, param params.CreateOrgParams) (org params.Organization, err error) {
	if !auth.IsAdmin(ctx) {
		return org, runnerErrors.ErrUnauthorized
	}

	if err := param.Validate(); err != nil {
		return params.Organization{}, fmt.Errorf("error validating params: %w", err)
	}

	var creds params.ForgeCredentials
	switch param.ForgeType {
	case params.GithubEndpointType:
		slog.DebugContext(ctx, "getting github credentials")
		creds, err = r.store.GetGithubCredentialsByName(ctx, param.CredentialsName, true)
	case params.GiteaEndpointType:
		slog.DebugContext(ctx, "getting gitea credentials")
		creds, err = r.store.GetGiteaCredentialsByName(ctx, param.CredentialsName, true)
	default:
		creds, err = r.ResolveForgeCredentialByName(ctx, param.CredentialsName)
	}

	if err != nil {
		return params.Organization{}, runnerErrors.NewBadRequestError("credentials %s not defined", param.CredentialsName)
	}

	_, err = r.store.GetOrganization(ctx, param.Name, creds.Endpoint.Name)
	if err != nil {
		if !errors.Is(err, runnerErrors.ErrNotFound) {
			return params.Organization{}, fmt.Errorf("error fetching org: %w", err)
		}
	} else {
		return params.Organization{}, runnerErrors.NewConflictError("organization %s already exists", param.Name)
	}

	org, err = r.store.CreateOrganization(ctx, param.Name, creds, param.WebhookSecret, param.PoolBalancerType, param.AgentMode)
	if err != nil {
		return params.Organization{}, fmt.Errorf("error creating organization: %w", err)
	}

	defer func() {
		if err != nil {
			if deleteErr := r.store.DeleteOrganization(ctx, org.ID); deleteErr != nil {
				slog.With(slog.Any("error", deleteErr)).ErrorContext(
					ctx, "failed to delete org",
					"org_id", org.ID)
			}
		}
	}()

	// Use the admin context in the pool manager. Any access control is already done above when
	// updating the store.
	poolMgr, err := r.poolManagerCtrl.CreateOrgPoolManager(r.ctx, org, r.providers, r.store)
	if err != nil {
		return params.Organization{}, fmt.Errorf("error creating org pool manager: %w", err)
	}
	if err := poolMgr.Start(); err != nil {
		if deleteErr := r.poolManagerCtrl.DeleteOrgPoolManager(org); deleteErr != nil {
			slog.With(slog.Any("error", deleteErr)).ErrorContext(