Method CreateGiteaEndpoint

database/sql/gitea.go:31–71

(_ context.Context, param params.CreateGiteaEndpointParams)

)

func (s *sqlDatabase) CreateGiteaEndpoint(_ context.Context, param params.CreateGiteaEndpointParams) (ghEndpoint params.ForgeEndpoint, err error) {
	if param.ToolsMetadataURL == "" {
		param.ToolsMetadataURL = appdefaults.GiteaRunnerReleasesURL
	}
	defer func() {
		if err == nil {
			s.sendNotify(common.GithubEndpointEntityType, common.CreateOperation, ghEndpoint)
		}
	}()
	var endpoint GithubEndpoint
	err = s.conn.Transaction(func(tx *gorm.DB) error {
		if err := tx.Where("name = ?", param.Name).First(&endpoint).Error; err == nil {
			return fmt.Errorf("gitea endpoint already exists: %w", runnerErrors.ErrDuplicateEntity)
		}
		endpoint = GithubEndpoint{
			Name:             param.Name,
			Description:      param.Description,
			APIBaseURL:       param.APIBaseURL,
			BaseURL:          param.BaseURL,
			CACertBundle:     param.CACertBundle,
			EndpointType:     params.GiteaEndpointType,
			ToolsMetadataURL: param.ToolsMetadataURL,
		}
		if param.UseInternalToolsMetadata != nil {
			endpoint.UseInternalToolsMetadata = *param.UseInternalToolsMetadata
		}

		if err := tx.Create(&endpoint).Error; err != nil {
			return fmt.Errorf("error creating gitea endpoint: %w", err)
		}
		return nil
	})
	if err != nil {
		return params.ForgeEndpoint{}, fmt.Errorf("error creating gitea endpoint: %w", err)
	}
	ghEndpoint, err = s.sqlToCommonGithubEndpoint(endpoint)
	if err != nil {
		return params.ForgeEndpoint{}, fmt.Errorf("error converting gitea endpoint: %w", err)
	}
	return ghEndpoint, nil
}

func (s *sqlDatabase) ListGiteaEndpoints(_ context.Context) ([]params.ForgeEndpoint, error) {
	var endpoints []GithubEndpoint