goreleaser/internal/pipe/upload/upload.go

// Package upload provides a Pipe that push using HTTP
package upload

import (
	h "net/http"

	"github.com/goreleaser/goreleaser/internal/deprecate"

	"github.com/goreleaser/goreleaser/internal/http"
	"github.com/goreleaser/goreleaser/internal/pipe"
	"github.com/goreleaser/goreleaser/pkg/context"
	"github.com/pkg/errors"
)

// Pipe for http publishing
type Pipe struct{}

// String returns the description of the pipe
func (Pipe) String() string {
	return "http upload"
}

// Default sets the pipe defaults
func (Pipe) Default(ctx *context.Context) error {
	if len(ctx.Config.Puts) > 0 {
		deprecate.Notice("puts")
		ctx.Config.Uploads = append(ctx.Config.Uploads, ctx.Config.Puts...)
	}
	return http.Defaults(ctx.Config.Uploads)
}

// Publish artifacts
func (Pipe) Publish(ctx *context.Context) error {
	if len(ctx.Config.Uploads) == 0 {
		return pipe.Skip("uploads section is not configured")
	}

	// Check requirements for every instance we have configured.
	// If not fulfilled, we can skip this pipeline
	for _, instance := range ctx.Config.Uploads {
		instance := instance
		if skip := http.CheckConfig(ctx, &instance, "upload"); skip != nil {
			return pipe.Skip(skip.Error())
		}
	}

	return http.Upload(ctx, ctx.Config.Uploads, "upload", func(res *h.Response) error {
		if c := res.StatusCode; c < 200 || 299 < c {
			return errors.Errorf("unexpected http response status: %s", res.Status)
		}
		return nil
	})
}