mirror of
https://github.com/woodpecker-ci/woodpecker.git
synced 2024-11-22 01:41:02 +00:00
Add godot linter to harmonitze toplevel comments (#3650)
This commit is contained in:
parent
83eba294c7
commit
89e100cfd1
144 changed files with 302 additions and 302 deletions
|
@ -108,7 +108,7 @@ linters-settings:
|
||||||
- standard
|
- standard
|
||||||
- default
|
- default
|
||||||
- prefix(go.woodpecker-ci.org/woodpecker)
|
- prefix(go.woodpecker-ci.org/woodpecker)
|
||||||
gomnd:
|
mnd:
|
||||||
ignored-numbers:
|
ignored-numbers:
|
||||||
- '0o600'
|
- '0o600'
|
||||||
- '0o660'
|
- '0o660'
|
||||||
|
@ -121,6 +121,13 @@ linters-settings:
|
||||||
- strings.Split
|
- strings.Split
|
||||||
- callerName
|
- callerName
|
||||||
- securecookie.GenerateRandomKey
|
- securecookie.GenerateRandomKey
|
||||||
|
godot:
|
||||||
|
scope: toplevel
|
||||||
|
period: true
|
||||||
|
capital: true
|
||||||
|
exclude:
|
||||||
|
- '^\s*cSpell:'
|
||||||
|
- '^\s*TODO:'
|
||||||
|
|
||||||
linters:
|
linters:
|
||||||
disable-all: true
|
disable-all: true
|
||||||
|
@ -166,13 +173,14 @@ linters:
|
||||||
- contextcheck
|
- contextcheck
|
||||||
- forcetypeassert
|
- forcetypeassert
|
||||||
- gci
|
- gci
|
||||||
- gomnd
|
- mnd
|
||||||
|
- godot
|
||||||
|
|
||||||
issues:
|
issues:
|
||||||
exclude-rules:
|
exclude-rules:
|
||||||
- path: 'fixtures|cmd/agent/flags.go|cmd/server/flags.go|pipeline/backend/kubernetes/flags.go|_test.go'
|
- path: 'fixtures|cmd/agent/flags.go|cmd/server/flags.go|pipeline/backend/kubernetes/flags.go|_test.go'
|
||||||
linters:
|
linters:
|
||||||
- gomnd
|
- mnd
|
||||||
|
|
||||||
run:
|
run:
|
||||||
timeout: 15m
|
timeout: 15m
|
||||||
|
|
|
@ -10,7 +10,7 @@ repos:
|
||||||
- id: end-of-file-fixer
|
- id: end-of-file-fixer
|
||||||
- id: trailing-whitespace
|
- id: trailing-whitespace
|
||||||
- repo: https://github.com/golangci/golangci-lint
|
- repo: https://github.com/golangci/golangci-lint
|
||||||
rev: v1.57.2
|
rev: v1.58.1
|
||||||
hooks:
|
hooks:
|
||||||
- id: golangci-lint
|
- id: golangci-lint
|
||||||
- repo: https://github.com/igorshubovych/markdownlint-cli
|
- repo: https://github.com/igorshubovych/markdownlint-cli
|
||||||
|
|
|
@ -40,7 +40,7 @@ func NewAuthGrpcClient(conn *grpc.ClientConn, agentToken string, agentID int64)
|
||||||
}
|
}
|
||||||
|
|
||||||
func (c *AuthClient) Auth() (string, int64, error) {
|
func (c *AuthClient) Auth() (string, int64, error) {
|
||||||
ctx, cancel := context.WithTimeout(context.Background(), 5*time.Second) //nolint: gomnd
|
ctx, cancel := context.WithTimeout(context.Background(), 5*time.Second) //nolint:mnd
|
||||||
defer cancel()
|
defer cancel()
|
||||||
|
|
||||||
req := &proto.AuthRequest{
|
req := &proto.AuthRequest{
|
||||||
|
|
|
@ -23,13 +23,13 @@ import (
|
||||||
"google.golang.org/grpc/metadata"
|
"google.golang.org/grpc/metadata"
|
||||||
)
|
)
|
||||||
|
|
||||||
// AuthInterceptor is a client interceptor for authentication
|
// AuthInterceptor is a client interceptor for authentication.
|
||||||
type AuthInterceptor struct {
|
type AuthInterceptor struct {
|
||||||
authClient *AuthClient
|
authClient *AuthClient
|
||||||
accessToken string
|
accessToken string
|
||||||
}
|
}
|
||||||
|
|
||||||
// NewAuthInterceptor returns a new auth interceptor
|
// NewAuthInterceptor returns a new auth interceptor.
|
||||||
func NewAuthInterceptor(
|
func NewAuthInterceptor(
|
||||||
authClient *AuthClient,
|
authClient *AuthClient,
|
||||||
refreshDuration time.Duration,
|
refreshDuration time.Duration,
|
||||||
|
@ -46,7 +46,7 @@ func NewAuthInterceptor(
|
||||||
return interceptor, nil
|
return interceptor, nil
|
||||||
}
|
}
|
||||||
|
|
||||||
// Unary returns a client interceptor to authenticate unary RPC
|
// Unary returns a client interceptor to authenticate unary RPC.
|
||||||
func (interceptor *AuthInterceptor) Unary() grpc.UnaryClientInterceptor {
|
func (interceptor *AuthInterceptor) Unary() grpc.UnaryClientInterceptor {
|
||||||
return func(
|
return func(
|
||||||
ctx context.Context,
|
ctx context.Context,
|
||||||
|
@ -60,7 +60,7 @@ func (interceptor *AuthInterceptor) Unary() grpc.UnaryClientInterceptor {
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
// Stream returns a client interceptor to authenticate stream RPC
|
// Stream returns a client interceptor to authenticate stream RPC.
|
||||||
func (interceptor *AuthInterceptor) Stream() grpc.StreamClientInterceptor {
|
func (interceptor *AuthInterceptor) Stream() grpc.StreamClientInterceptor {
|
||||||
return func(
|
return func(
|
||||||
ctx context.Context,
|
ctx context.Context,
|
||||||
|
|
|
@ -31,7 +31,7 @@ import (
|
||||||
"go.woodpecker-ci.org/woodpecker/v2/pipeline/rpc/proto"
|
"go.woodpecker-ci.org/woodpecker/v2/pipeline/rpc/proto"
|
||||||
)
|
)
|
||||||
|
|
||||||
// set grpc version on compile time to compare against server version response
|
// Set grpc version on compile time to compare against server version response.
|
||||||
const ClientGrpcVersion int32 = proto.Version
|
const ClientGrpcVersion int32 = proto.Version
|
||||||
|
|
||||||
type client struct {
|
type client struct {
|
||||||
|
@ -54,12 +54,12 @@ func (c *client) Close() error {
|
||||||
func (c *client) newBackOff() backoff.BackOff {
|
func (c *client) newBackOff() backoff.BackOff {
|
||||||
b := backoff.NewExponentialBackOff()
|
b := backoff.NewExponentialBackOff()
|
||||||
b.MaxElapsedTime = 0
|
b.MaxElapsedTime = 0
|
||||||
b.MaxInterval = 10 * time.Second //nolint: gomnd
|
b.MaxInterval = 10 * time.Second //nolint:mnd
|
||||||
b.InitialInterval = 10 * time.Millisecond //nolint: gomnd
|
b.InitialInterval = 10 * time.Millisecond //nolint:mnd
|
||||||
return b
|
return b
|
||||||
}
|
}
|
||||||
|
|
||||||
// Version returns the server- & grpc-version
|
// Version returns the server- & grpc-version.
|
||||||
func (c *client) Version(ctx context.Context) (*rpc.Version, error) {
|
func (c *client) Version(ctx context.Context) (*rpc.Version, error) {
|
||||||
res, err := c.client.Version(ctx, &proto.Empty{})
|
res, err := c.client.Version(ctx, &proto.Empty{})
|
||||||
if err != nil {
|
if err != nil {
|
||||||
|
@ -242,7 +242,7 @@ func (c *client) Done(ctx context.Context, id string, state rpc.State) (err erro
|
||||||
return nil
|
return nil
|
||||||
}
|
}
|
||||||
|
|
||||||
// Extend extends the workflow deadline
|
// Extend extends the workflow deadline.
|
||||||
func (c *client) Extend(ctx context.Context, id string) (err error) {
|
func (c *client) Extend(ctx context.Context, id string) (err error) {
|
||||||
retry := c.newBackOff()
|
retry := c.newBackOff()
|
||||||
req := new(proto.ExtendRequest)
|
req := new(proto.ExtendRequest)
|
||||||
|
|
|
@ -198,12 +198,10 @@ func (r *Runner) Run(runnerCtx context.Context) error { //nolint:contextcheck
|
||||||
return nil
|
return nil
|
||||||
}
|
}
|
||||||
|
|
||||||
// extract repository name from the configuration
|
|
||||||
func extractRepositoryName(config *backend.Config) string {
|
func extractRepositoryName(config *backend.Config) string {
|
||||||
return config.Stages[0].Steps[0].Environment["CI_REPO"]
|
return config.Stages[0].Steps[0].Environment["CI_REPO"]
|
||||||
}
|
}
|
||||||
|
|
||||||
// extract pipeline number from the configuration
|
|
||||||
func extractPipelineNumber(config *backend.Config) string {
|
func extractPipelineNumber(config *backend.Config) string {
|
||||||
return config.Stages[0].Steps[0].Environment["CI_PIPELINE_NUMBER"]
|
return config.Stages[0].Steps[0].Environment["CI_PIPELINE_NUMBER"]
|
||||||
}
|
}
|
||||||
|
|
|
@ -40,7 +40,7 @@ func (r *Runner) createTracer(ctxmeta context.Context, logger zerolog.Logger, wo
|
||||||
StepUUID: state.Pipeline.Step.UUID,
|
StepUUID: state.Pipeline.Step.UUID,
|
||||||
Exited: state.Process.Exited,
|
Exited: state.Process.Exited,
|
||||||
ExitCode: state.Process.ExitCode,
|
ExitCode: state.Process.ExitCode,
|
||||||
Started: time.Now().Unix(), // TODO do not do this
|
Started: time.Now().Unix(), // TODO: do not do this
|
||||||
Finished: time.Now().Unix(),
|
Finished: time.Now().Unix(),
|
||||||
}
|
}
|
||||||
if state.Process.Error != nil {
|
if state.Process.Error != nil {
|
||||||
|
|
|
@ -65,7 +65,7 @@ var GlobalFlags = append([]cli.Flag{
|
||||||
}, logger.GlobalLoggerFlags...)
|
}, logger.GlobalLoggerFlags...)
|
||||||
|
|
||||||
// FormatFlag return format flag with value set based on template
|
// FormatFlag return format flag with value set based on template
|
||||||
// if hidden value is set, flag will be hidden
|
// if hidden value is set, flag will be hidden.
|
||||||
func FormatFlag(tmpl string, hidden ...bool) *cli.StringFlag {
|
func FormatFlag(tmpl string, hidden ...bool) *cli.StringFlag {
|
||||||
return &cli.StringFlag{
|
return &cli.StringFlag{
|
||||||
Name: "format",
|
Name: "format",
|
||||||
|
|
|
@ -67,7 +67,7 @@ func cronList(c *cli.Context) error {
|
||||||
return nil
|
return nil
|
||||||
}
|
}
|
||||||
|
|
||||||
// template for pipeline list information
|
// tTemplate for pipeline list information.
|
||||||
var tmplCronList = "\x1b[33m{{ .Name }} \x1b[0m" + `
|
var tmplCronList = "\x1b[33m{{ .Name }} \x1b[0m" + `
|
||||||
ID: {{ .ID }}
|
ID: {{ .ID }}
|
||||||
Branch: {{ .Branch }}
|
Branch: {{ .Branch }}
|
||||||
|
|
|
@ -126,7 +126,7 @@ func deploy(c *cli.Context) error {
|
||||||
return tmpl.Execute(os.Stdout, deploy)
|
return tmpl.Execute(os.Stdout, deploy)
|
||||||
}
|
}
|
||||||
|
|
||||||
// template for deployment information
|
// Template for deployment information.
|
||||||
var tmplDeployInfo = `Number: {{ .Number }}
|
var tmplDeployInfo = `Number: {{ .Number }}
|
||||||
Status: {{ .Status }}
|
Status: {{ .Status }}
|
||||||
Commit: {{ .Commit }}
|
Commit: {{ .Commit }}
|
||||||
|
|
|
@ -263,7 +263,7 @@ func convertPathForWindows(path string) string {
|
||||||
base := filepath.VolumeName(path)
|
base := filepath.VolumeName(path)
|
||||||
|
|
||||||
// Check if path is volume name like C:
|
// Check if path is volume name like C:
|
||||||
//nolint: gomnd
|
//nolint:mnd
|
||||||
if len(base) == 2 {
|
if len(base) == 2 {
|
||||||
path = strings.TrimPrefix(path, base)
|
path = strings.TrimPrefix(path, base)
|
||||||
base = strings.ToLower(strings.TrimSuffix(base, ":"))
|
base = strings.ToLower(strings.TrimSuffix(base, ":"))
|
||||||
|
|
|
@ -52,6 +52,6 @@ func info(c *cli.Context) error {
|
||||||
return tmpl.Execute(os.Stdout, user)
|
return tmpl.Execute(os.Stdout, user)
|
||||||
}
|
}
|
||||||
|
|
||||||
// template for user information
|
// Template for user information.
|
||||||
var tmplInfo = `User: {{ .Login }}
|
var tmplInfo = `User: {{ .Login }}
|
||||||
Email: {{ .Email }}`
|
Email: {{ .Email }}`
|
||||||
|
|
|
@ -45,7 +45,7 @@ func logPurge(c *cli.Context) (err error) {
|
||||||
return err
|
return err
|
||||||
}
|
}
|
||||||
|
|
||||||
stepArg := c.Args().Get(2) //nolint: gomnd
|
stepArg := c.Args().Get(2) //nolint:mnd
|
||||||
// TODO: Add lookup by name: stepID, err := internal.ParseStep(client, repoID, stepIDOrName)
|
// TODO: Add lookup by name: stepID, err := internal.ParseStep(client, repoID, stepIDOrName)
|
||||||
var stepID int64
|
var stepID int64
|
||||||
if len(stepArg) != 0 {
|
if len(stepArg) != 0 {
|
||||||
|
|
|
@ -22,7 +22,7 @@ import (
|
||||||
"go.woodpecker-ci.org/woodpecker/v2/woodpecker-go/woodpecker"
|
"go.woodpecker-ci.org/woodpecker/v2/woodpecker-go/woodpecker"
|
||||||
)
|
)
|
||||||
|
|
||||||
//nolint:gomnd
|
//nolint:mnd
|
||||||
var pipelineListCmd = &cli.Command{
|
var pipelineListCmd = &cli.Command{
|
||||||
Name: "ls",
|
Name: "ls",
|
||||||
Usage: "show pipeline history",
|
Usage: "show pipeline history",
|
||||||
|
|
|
@ -83,7 +83,7 @@ func pipelinePs(c *cli.Context) error {
|
||||||
return nil
|
return nil
|
||||||
}
|
}
|
||||||
|
|
||||||
// template for pipeline ps information
|
// Template for pipeline ps information.
|
||||||
var tmplPipelinePs = "\x1b[33mStep #{{ .PID }} \x1b[0m" + `
|
var tmplPipelinePs = "\x1b[33mStep #{{ .PID }} \x1b[0m" + `
|
||||||
Step: {{ .Name }}
|
Step: {{ .Name }}
|
||||||
State: {{ .State }}
|
State: {{ .State }}
|
||||||
|
|
|
@ -62,7 +62,7 @@ func pipelineQueue(c *cli.Context) error {
|
||||||
return nil
|
return nil
|
||||||
}
|
}
|
||||||
|
|
||||||
// template for pipeline list information
|
// Template for pipeline list information.
|
||||||
var tmplPipelineQueue = "\x1b[33m{{ .FullName }} #{{ .Number }} \x1b[0m" + `
|
var tmplPipelineQueue = "\x1b[33m{{ .FullName }} #{{ .Number }} \x1b[0m" + `
|
||||||
Status: {{ .Status }}
|
Status: {{ .Status }}
|
||||||
Event: {{ .Event }}
|
Event: {{ .Event }}
|
||||||
|
|
|
@ -67,7 +67,7 @@ func registryList(c *cli.Context) error {
|
||||||
return nil
|
return nil
|
||||||
}
|
}
|
||||||
|
|
||||||
// template for registry list information
|
// Template for registry list information.
|
||||||
var tmplRegistryList = "\x1b[33m{{ .Address }} \x1b[0m" + `
|
var tmplRegistryList = "\x1b[33m{{ .Address }} \x1b[0m" + `
|
||||||
Username: {{ .Username }}
|
Username: {{ .Username }}
|
||||||
Email: {{ .Email }}
|
Email: {{ .Email }}
|
||||||
|
|
|
@ -55,7 +55,7 @@ func repoInfo(c *cli.Context) error {
|
||||||
return tmpl.Execute(os.Stdout, repo)
|
return tmpl.Execute(os.Stdout, repo)
|
||||||
}
|
}
|
||||||
|
|
||||||
// template for repo information
|
// tTemplate for repo information.
|
||||||
var tmplRepoInfo = `Owner: {{ .Owner }}
|
var tmplRepoInfo = `Owner: {{ .Owner }}
|
||||||
Repo: {{ .Name }}
|
Repo: {{ .Name }}
|
||||||
URL: {{ .ForgeURL }}
|
URL: {{ .ForgeURL }}
|
||||||
|
|
|
@ -66,5 +66,5 @@ func repoList(c *cli.Context) error {
|
||||||
return nil
|
return nil
|
||||||
}
|
}
|
||||||
|
|
||||||
// template for repository list items
|
// Template for repository list items.
|
||||||
var tmplRepoList = "\x1b[33m{{ .FullName }}\x1b[0m (id: {{ .ID }}, forgeRemoteID: {{ .ForgeRemoteID }})"
|
var tmplRepoList = "\x1b[33m{{ .FullName }}\x1b[0m (id: {{ .ID }}, forgeRemoteID: {{ .ForgeRemoteID }})"
|
||||||
|
|
|
@ -86,7 +86,7 @@ func secretList(c *cli.Context) error {
|
||||||
return nil
|
return nil
|
||||||
}
|
}
|
||||||
|
|
||||||
// template for secret list items
|
// Template for secret list items.
|
||||||
var tmplSecretList = "\x1b[33m{{ .Name }} \x1b[0m" + `
|
var tmplSecretList = "\x1b[33m{{ .Name }} \x1b[0m" + `
|
||||||
Events: {{ list .Events }}
|
Events: {{ list .Events }}
|
||||||
{{- if .Images }}
|
{{- if .Images }}
|
||||||
|
|
|
@ -56,6 +56,6 @@ func userInfo(c *cli.Context) error {
|
||||||
return tmpl.Execute(os.Stdout, user)
|
return tmpl.Execute(os.Stdout, user)
|
||||||
}
|
}
|
||||||
|
|
||||||
// template for user information
|
// Template for user information.
|
||||||
var tmplUserInfo = `User: {{ .Login }}
|
var tmplUserInfo = `User: {{ .Login }}
|
||||||
Email: {{ .Email }}`
|
Email: {{ .Email }}`
|
||||||
|
|
|
@ -55,5 +55,5 @@ func userList(c *cli.Context) error {
|
||||||
return nil
|
return nil
|
||||||
}
|
}
|
||||||
|
|
||||||
// template for user list items
|
// Template for user list items.
|
||||||
var tmplUserList = `{{ .Login }}`
|
var tmplUserList = `{{ .Login }}`
|
||||||
|
|
|
@ -89,7 +89,7 @@ func run(c *cli.Context, backends []types.Backend) error {
|
||||||
|
|
||||||
agentToken := c.String("grpc-token")
|
agentToken := c.String("grpc-token")
|
||||||
authClient := agentRpc.NewAuthGrpcClient(authConn, agentToken, agentConfig.AgentID)
|
authClient := agentRpc.NewAuthGrpcClient(authConn, agentToken, agentConfig.AgentID)
|
||||||
authInterceptor, err := agentRpc.NewAuthInterceptor(authClient, 30*time.Minute) //nolint: gomnd
|
authInterceptor, err := agentRpc.NewAuthInterceptor(authClient, 30*time.Minute) //nolint:mnd
|
||||||
if err != nil {
|
if err != nil {
|
||||||
return err
|
return err
|
||||||
}
|
}
|
||||||
|
|
|
@ -22,7 +22,7 @@ import (
|
||||||
"github.com/urfave/cli/v2"
|
"github.com/urfave/cli/v2"
|
||||||
)
|
)
|
||||||
|
|
||||||
//nolint:gomnd
|
//nolint:mnd
|
||||||
var flags = []cli.Flag{
|
var flags = []cli.Flag{
|
||||||
&cli.StringFlag{
|
&cli.StringFlag{
|
||||||
EnvVars: []string{"WOODPECKER_SERVER"},
|
EnvVars: []string{"WOODPECKER_SERVER"},
|
||||||
|
|
|
@ -27,7 +27,7 @@ import (
|
||||||
"go.woodpecker-ci.org/woodpecker/v2/version"
|
"go.woodpecker-ci.org/woodpecker/v2/version"
|
||||||
)
|
)
|
||||||
|
|
||||||
// the file implements some basic healthcheck logic based on the
|
// The file implements some basic healthcheck logic based on the
|
||||||
// following specification:
|
// following specification:
|
||||||
// https://github.com/mozilla-services/Dockerflow
|
// https://github.com/mozilla-services/Dockerflow
|
||||||
|
|
||||||
|
@ -74,7 +74,7 @@ type versionResp struct {
|
||||||
Source string `json:"source"`
|
Source string `json:"source"`
|
||||||
}
|
}
|
||||||
|
|
||||||
// default statistics counter
|
// Default statistics counter.
|
||||||
var counter = &agent.State{
|
var counter = &agent.State{
|
||||||
Metadata: map[string]agent.Info{},
|
Metadata: map[string]agent.Info{},
|
||||||
}
|
}
|
||||||
|
|
|
@ -17,7 +17,7 @@ package core
|
||||||
import (
|
import (
|
||||||
"os"
|
"os"
|
||||||
|
|
||||||
// Load config from .env
|
// Load config from .env file.
|
||||||
_ "github.com/joho/godotenv/autoload"
|
_ "github.com/joho/godotenv/autoload"
|
||||||
"github.com/rs/zerolog/log"
|
"github.com/rs/zerolog/log"
|
||||||
"github.com/urfave/cli/v2"
|
"github.com/urfave/cli/v2"
|
||||||
|
|
|
@ -19,7 +19,7 @@ import (
|
||||||
"go.woodpecker-ci.org/woodpecker/v2/version"
|
"go.woodpecker-ci.org/woodpecker/v2/version"
|
||||||
)
|
)
|
||||||
|
|
||||||
// generate docs/swagger.json via:
|
// Generate docs/swagger.json via:
|
||||||
//go:generate go run woodpecker_docs_gen.go swagger.go
|
//go:generate go run woodpecker_docs_gen.go swagger.go
|
||||||
//go:generate go run github.com/go-swagger/go-swagger/cmd/swagger@latest validate ../../docs/swagger.json
|
//go:generate go run github.com/go-swagger/go-swagger/cmd/swagger@latest validate ../../docs/swagger.json
|
||||||
|
|
||||||
|
|
|
@ -22,7 +22,7 @@ import (
|
||||||
)
|
)
|
||||||
|
|
||||||
// generateScriptPosix is a helper function that generates a step script
|
// generateScriptPosix is a helper function that generates a step script
|
||||||
// for a linux container using the given
|
// for a linux container using the given.
|
||||||
func generateScriptPosix(commands []string) string {
|
func generateScriptPosix(commands []string) string {
|
||||||
var buf bytes.Buffer
|
var buf bytes.Buffer
|
||||||
|
|
||||||
|
|
|
@ -6,7 +6,7 @@ import (
|
||||||
backend "go.woodpecker-ci.org/woodpecker/v2/pipeline/backend/types"
|
backend "go.woodpecker-ci.org/woodpecker/v2/pipeline/backend/types"
|
||||||
)
|
)
|
||||||
|
|
||||||
// BackendOptions defines all the advanced options for the kubernetes backend
|
// BackendOptions defines all the advanced options for the kubernetes backend.
|
||||||
type BackendOptions struct {
|
type BackendOptions struct {
|
||||||
Resources Resources `mapstructure:"resources"`
|
Resources Resources `mapstructure:"resources"`
|
||||||
RuntimeClassName *string `mapstructure:"runtimeClassName"`
|
RuntimeClassName *string `mapstructure:"runtimeClassName"`
|
||||||
|
@ -18,13 +18,13 @@ type BackendOptions struct {
|
||||||
SecurityContext *SecurityContext `mapstructure:"securityContext"`
|
SecurityContext *SecurityContext `mapstructure:"securityContext"`
|
||||||
}
|
}
|
||||||
|
|
||||||
// Resources defines two maps for kubernetes resource definitions
|
// Resources defines two maps for kubernetes resource definitions.
|
||||||
type Resources struct {
|
type Resources struct {
|
||||||
Requests map[string]string `mapstructure:"requests"`
|
Requests map[string]string `mapstructure:"requests"`
|
||||||
Limits map[string]string `mapstructure:"limits"`
|
Limits map[string]string `mapstructure:"limits"`
|
||||||
}
|
}
|
||||||
|
|
||||||
// Toleration defines Kubernetes toleration
|
// Toleration defines Kubernetes toleration.
|
||||||
type Toleration struct {
|
type Toleration struct {
|
||||||
Key string `mapstructure:"key"`
|
Key string `mapstructure:"key"`
|
||||||
Operator TolerationOperator `mapstructure:"operator"`
|
Operator TolerationOperator `mapstructure:"operator"`
|
||||||
|
|
|
@ -32,8 +32,7 @@ import (
|
||||||
"k8s.io/client-go/informers"
|
"k8s.io/client-go/informers"
|
||||||
"k8s.io/client-go/kubernetes"
|
"k8s.io/client-go/kubernetes"
|
||||||
"k8s.io/client-go/kubernetes/scheme"
|
"k8s.io/client-go/kubernetes/scheme"
|
||||||
// To authenticate to GCP K8s clusters
|
_ "k8s.io/client-go/plugin/pkg/client/auth/gcp" // To authenticate to GCP K8s clusters
|
||||||
_ "k8s.io/client-go/plugin/pkg/client/auth/gcp"
|
|
||||||
"k8s.io/client-go/rest"
|
"k8s.io/client-go/rest"
|
||||||
"k8s.io/client-go/tools/cache"
|
"k8s.io/client-go/tools/cache"
|
||||||
|
|
||||||
|
@ -42,7 +41,7 @@ import (
|
||||||
|
|
||||||
const (
|
const (
|
||||||
EngineName = "kubernetes"
|
EngineName = "kubernetes"
|
||||||
// TODO 5 seconds is against best practice, k3s didn't work otherwise
|
// TODO: 5 seconds is against best practice, k3s didn't work otherwise
|
||||||
defaultResyncDuration = 5 * time.Second
|
defaultResyncDuration = 5 * time.Second
|
||||||
)
|
)
|
||||||
|
|
||||||
|
@ -268,7 +267,7 @@ func (e *kube) WaitStep(ctx context.Context, step *types.Step, taskUUID string)
|
||||||
si.Start(stop)
|
si.Start(stop)
|
||||||
defer close(stop)
|
defer close(stop)
|
||||||
|
|
||||||
// TODO Cancel on ctx.Done
|
// TODO: Cancel on ctx.Done
|
||||||
<-finished
|
<-finished
|
||||||
|
|
||||||
pod, err := e.client.CoreV1().Pods(e.config.Namespace).Get(ctx, podName, metav1.GetOptions{})
|
pod, err := e.client.CoreV1().Pods(e.config.Namespace).Get(ctx, podName, metav1.GetOptions{})
|
||||||
|
|
|
@ -268,7 +268,7 @@ func containerPort(port types.Port) v1.ContainerPort {
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
// Here is the service IPs (placed in /etc/hosts in the Pod)
|
// Here is the service IPs (placed in /etc/hosts in the Pod).
|
||||||
func hostAliases(extraHosts []types.HostAlias) []v1.HostAlias {
|
func hostAliases(extraHosts []types.HostAlias) []v1.HostAlias {
|
||||||
var hostAliases []v1.HostAlias
|
var hostAliases []v1.HostAlias
|
||||||
for _, extraHost := range extraHosts {
|
for _, extraHost := range extraHosts {
|
||||||
|
|
|
@ -65,7 +65,7 @@ func isImagePullBackOffState(pod *v1.Pod) bool {
|
||||||
return false
|
return false
|
||||||
}
|
}
|
||||||
|
|
||||||
// getClientOutOfCluster returns a k8s clientset to the request from outside of cluster
|
// getClientOutOfCluster returns a k8s clientset to the request from outside of cluster.
|
||||||
func getClientOutOfCluster() (kubernetes.Interface, error) {
|
func getClientOutOfCluster() (kubernetes.Interface, error) {
|
||||||
kubeConfigPath := os.Getenv("KUBECONFIG")
|
kubeConfigPath := os.Getenv("KUBECONFIG")
|
||||||
if kubeConfigPath == "" {
|
if kubeConfigPath == "" {
|
||||||
|
@ -81,7 +81,7 @@ func getClientOutOfCluster() (kubernetes.Interface, error) {
|
||||||
return kubernetes.NewForConfig(config)
|
return kubernetes.NewForConfig(config)
|
||||||
}
|
}
|
||||||
|
|
||||||
// getClient returns a k8s clientset to the request from inside of cluster
|
// getClient returns a k8s clientset to the request from inside of cluster.
|
||||||
func getClientInsideOfCluster() (kubernetes.Interface, error) {
|
func getClientInsideOfCluster() (kubernetes.Interface, error) {
|
||||||
config, err := rest.InClusterConfig()
|
config, err := rest.InClusterConfig()
|
||||||
if err != nil {
|
if err != nil {
|
||||||
|
|
|
@ -30,13 +30,13 @@ import (
|
||||||
"go.woodpecker-ci.org/woodpecker/v2/pipeline/backend/types"
|
"go.woodpecker-ci.org/woodpecker/v2/pipeline/backend/types"
|
||||||
)
|
)
|
||||||
|
|
||||||
// checkGitCloneCap check if we have the git binary on hand
|
// checkGitCloneCap check if we have the git binary on hand.
|
||||||
func checkGitCloneCap() error {
|
func checkGitCloneCap() error {
|
||||||
_, err := exec.LookPath("git")
|
_, err := exec.LookPath("git")
|
||||||
return err
|
return err
|
||||||
}
|
}
|
||||||
|
|
||||||
// loadClone on backend start determine if there is a global plugin-git binary
|
// loadClone on backend start determine if there is a global plugin-git binary.
|
||||||
func (e *local) loadClone() {
|
func (e *local) loadClone() {
|
||||||
binary, err := exec.LookPath("plugin-git")
|
binary, err := exec.LookPath("plugin-git")
|
||||||
if err != nil || binary == "" {
|
if err != nil || binary == "" {
|
||||||
|
@ -46,7 +46,7 @@ func (e *local) loadClone() {
|
||||||
e.pluginGitBinary = binary
|
e.pluginGitBinary = binary
|
||||||
}
|
}
|
||||||
|
|
||||||
// setupClone prepare the clone environment before exec
|
// setupClone prepare the clone environment before exec.
|
||||||
func (e *local) setupClone(state *workflowState) error {
|
func (e *local) setupClone(state *workflowState) error {
|
||||||
if e.pluginGitBinary != "" {
|
if e.pluginGitBinary != "" {
|
||||||
state.pluginGitBinary = e.pluginGitBinary
|
state.pluginGitBinary = e.pluginGitBinary
|
||||||
|
@ -61,7 +61,7 @@ func (e *local) setupClone(state *workflowState) error {
|
||||||
return e.downloadLatestGitPluginBinary(state.pluginGitBinary)
|
return e.downloadLatestGitPluginBinary(state.pluginGitBinary)
|
||||||
}
|
}
|
||||||
|
|
||||||
// execClone executes a clone-step locally
|
// execClone executes a clone-step locally.
|
||||||
func (e *local) execClone(ctx context.Context, step *types.Step, state *workflowState, env []string) error {
|
func (e *local) execClone(ctx context.Context, step *types.Step, state *workflowState, env []string) error {
|
||||||
if scm := step.Environment["CI_REPO_SCM"]; scm != "git" {
|
if scm := step.Environment["CI_REPO_SCM"]; scm != "git" {
|
||||||
return fmt.Errorf("local backend can only clone from git repos, but this repo use '%s'", scm)
|
return fmt.Errorf("local backend can only clone from git repos, but this repo use '%s'", scm)
|
||||||
|
@ -113,7 +113,7 @@ func (e *local) execClone(ctx context.Context, step *types.Step, state *workflow
|
||||||
return cmd.Start()
|
return cmd.Start()
|
||||||
}
|
}
|
||||||
|
|
||||||
// writeNetRC write a netrc file into the home dir of a given workflow state
|
// writeNetRC write a netrc file into the home dir of a given workflow state.
|
||||||
func (e *local) writeNetRC(step *types.Step, state *workflowState) (string, error) {
|
func (e *local) writeNetRC(step *types.Step, state *workflowState) (string, error) {
|
||||||
if step.Environment["CI_NETRC_MACHINE"] == "" {
|
if step.Environment["CI_NETRC_MACHINE"] == "" {
|
||||||
log.Trace().Msg("no netrc to write")
|
log.Trace().Msg("no netrc to write")
|
||||||
|
@ -132,7 +132,7 @@ func (e *local) writeNetRC(step *types.Step, state *workflowState) (string, erro
|
||||||
}
|
}
|
||||||
|
|
||||||
// downloadLatestGitPluginBinary download the latest plugin-git binary based on runtime OS and Arch
|
// downloadLatestGitPluginBinary download the latest plugin-git binary based on runtime OS and Arch
|
||||||
// and saves it to dest
|
// and saves it to dest.
|
||||||
func (e *local) downloadLatestGitPluginBinary(dest string) error {
|
func (e *local) downloadLatestGitPluginBinary(dest string) error {
|
||||||
type asset struct {
|
type asset struct {
|
||||||
Name string
|
Name string
|
||||||
|
|
|
@ -19,7 +19,7 @@ import (
|
||||||
"fmt"
|
"fmt"
|
||||||
)
|
)
|
||||||
|
|
||||||
// notAllowedEnvVarOverwrites are all env vars that cannot be overwritten by step config
|
// notAllowedEnvVarOverwrites are all env vars that cannot be overwritten by step config.
|
||||||
var notAllowedEnvVarOverwrites = []string{
|
var notAllowedEnvVarOverwrites = []string{
|
||||||
"CI_NETRC_MACHINE",
|
"CI_NETRC_MACHINE",
|
||||||
"CI_NETRC_USERNAME",
|
"CI_NETRC_USERNAME",
|
||||||
|
|
|
@ -147,10 +147,10 @@ func (e *local) StartStep(ctx context.Context, step *types.Step, taskUUID string
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
// execCommands use step.Image as shell and run the commands in it
|
// execCommands use step.Image as shell and run the commands in it.
|
||||||
func (e *local) execCommands(ctx context.Context, step *types.Step, state *workflowState, env []string) error {
|
func (e *local) execCommands(ctx context.Context, step *types.Step, state *workflowState, env []string) error {
|
||||||
// Prepare commands
|
// Prepare commands
|
||||||
// TODO support `entrypoint` from pipeline config
|
// TODO: support `entrypoint` from pipeline config
|
||||||
args, err := e.genCmdByShell(step.Image, step.Commands)
|
args, err := e.genCmdByShell(step.Image, step.Commands)
|
||||||
if err != nil {
|
if err != nil {
|
||||||
return fmt.Errorf("could not convert commands into args: %w", err)
|
return fmt.Errorf("could not convert commands into args: %w", err)
|
||||||
|
@ -176,7 +176,7 @@ func (e *local) execCommands(ctx context.Context, step *types.Step, state *workf
|
||||||
return cmd.Start()
|
return cmd.Start()
|
||||||
}
|
}
|
||||||
|
|
||||||
// execPlugin use step.Image as exec binary
|
// execPlugin use step.Image as exec binary.
|
||||||
func (e *local) execPlugin(ctx context.Context, step *types.Step, state *workflowState, env []string) error {
|
func (e *local) execPlugin(ctx context.Context, step *types.Step, state *workflowState, env []string) error {
|
||||||
binary, err := exec.LookPath(step.Image)
|
binary, err := exec.LookPath(step.Image)
|
||||||
if err != nil {
|
if err != nil {
|
||||||
|
|
|
@ -56,7 +56,7 @@ type Backend interface {
|
||||||
DestroyWorkflow(ctx context.Context, conf *Config, taskUUID string) error
|
DestroyWorkflow(ctx context.Context, conf *Config, taskUUID string) error
|
||||||
}
|
}
|
||||||
|
|
||||||
// BackendInfo represents the reported information of a loaded backend
|
// BackendInfo represents the reported information of a loaded backend.
|
||||||
type BackendInfo struct {
|
type BackendInfo struct {
|
||||||
Platform string
|
Platform string
|
||||||
}
|
}
|
||||||
|
|
|
@ -22,7 +22,7 @@ type Config struct {
|
||||||
Secrets []*Secret `json:"secrets"` // secret definitions
|
Secrets []*Secret `json:"secrets"` // secret definitions
|
||||||
}
|
}
|
||||||
|
|
||||||
// CliContext is the context key to pass cli context to backends if needed
|
// CliContext is the context key to pass cli context to backends if needed.
|
||||||
var CliContext ContextKey
|
var CliContext ContextKey
|
||||||
|
|
||||||
// ContextKey is just an empty struct. It exists so CliContext can be
|
// ContextKey is just an empty struct. It exists so CliContext can be
|
||||||
|
|
|
@ -14,7 +14,7 @@
|
||||||
|
|
||||||
package types
|
package types
|
||||||
|
|
||||||
// Secret defines a runtime secret
|
// Secret defines a runtime secret.
|
||||||
type Secret struct {
|
type Secret struct {
|
||||||
Name string `json:"name,omitempty"`
|
Name string `json:"name,omitempty"`
|
||||||
Value string `json:"value,omitempty"`
|
Value string `json:"value,omitempty"`
|
||||||
|
|
|
@ -49,7 +49,7 @@ type Step struct {
|
||||||
BackendOptions map[string]any `json:"backend_options,omitempty"`
|
BackendOptions map[string]any `json:"backend_options,omitempty"`
|
||||||
}
|
}
|
||||||
|
|
||||||
// StepType identifies the type of step
|
// StepType identifies the type of step.
|
||||||
type StepType string
|
type StepType string
|
||||||
|
|
||||||
const (
|
const (
|
||||||
|
|
|
@ -26,9 +26,11 @@ const (
|
||||||
EventManual = "manual"
|
EventManual = "manual"
|
||||||
)
|
)
|
||||||
|
|
||||||
// Different ways to handle failure states
|
// Different ways to handle failure states.
|
||||||
const (
|
const (
|
||||||
FailureIgnore = "ignore"
|
FailureIgnore = "ignore"
|
||||||
FailureFail = "fail"
|
FailureFail = "fail"
|
||||||
// FailureCancel = "cancel" // Not implemented yet
|
//nolint:godot
|
||||||
|
// TODO: Not implemented yet.
|
||||||
|
// FailureCancel = "cancel"
|
||||||
)
|
)
|
||||||
|
|
|
@ -38,7 +38,7 @@ func (m *Metadata) Environ() map[string]string {
|
||||||
)
|
)
|
||||||
|
|
||||||
branchParts := strings.Split(m.Curr.Commit.Refspec, ":")
|
branchParts := strings.Split(m.Curr.Commit.Refspec, ":")
|
||||||
if len(branchParts) == 2 { //nolint: gomnd
|
if len(branchParts) == 2 { //nolint:mnd
|
||||||
sourceBranch = branchParts[0]
|
sourceBranch = branchParts[0]
|
||||||
targetBranch = branchParts[1]
|
targetBranch = branchParts[1]
|
||||||
}
|
}
|
||||||
|
@ -124,7 +124,7 @@ func (m *Metadata) Environ() map[string]string {
|
||||||
"CI_FORGE_TYPE": m.Forge.Type,
|
"CI_FORGE_TYPE": m.Forge.Type,
|
||||||
"CI_FORGE_URL": m.Forge.URL,
|
"CI_FORGE_URL": m.Forge.URL,
|
||||||
|
|
||||||
// TODO Deprecated, remove in 3.x
|
// TODO: Deprecated, remove in 3.x
|
||||||
"CI_COMMIT_URL": m.Curr.ForgeURL,
|
"CI_COMMIT_URL": m.Curr.ForgeURL,
|
||||||
}
|
}
|
||||||
if m.Curr.Event == EventTag || m.Curr.Event == EventRelease || strings.HasPrefix(m.Curr.Commit.Ref, "refs/tags/") {
|
if m.Curr.Event == EventTag || m.Curr.Event == EventRelease || strings.HasPrefix(m.Curr.Commit.Ref, "refs/tags/") {
|
||||||
|
|
|
@ -93,7 +93,7 @@ type (
|
||||||
Number int `json:"number,omitempty"`
|
Number int `json:"number,omitempty"`
|
||||||
}
|
}
|
||||||
|
|
||||||
// Secret defines a runtime secret
|
// Secret defines a runtime secret.
|
||||||
Secret struct {
|
Secret struct {
|
||||||
Name string `json:"name,omitempty"`
|
Name string `json:"name,omitempty"`
|
||||||
Value string `json:"value,omitempty"`
|
Value string `json:"value,omitempty"`
|
||||||
|
@ -110,13 +110,13 @@ type (
|
||||||
Version string `json:"version,omitempty"`
|
Version string `json:"version,omitempty"`
|
||||||
}
|
}
|
||||||
|
|
||||||
// Forge defines runtime metadata about the forge that host the repo
|
// Forge defines runtime metadata about the forge that host the repo.
|
||||||
Forge struct {
|
Forge struct {
|
||||||
Type string `json:"type,omitempty"`
|
Type string `json:"type,omitempty"`
|
||||||
URL string `json:"url,omitempty"`
|
URL string `json:"url,omitempty"`
|
||||||
}
|
}
|
||||||
|
|
||||||
// ServerForge represent the needed func of a server forge to get its metadata
|
// ServerForge represent the needed func of a server forge to get its metadata.
|
||||||
ServerForge interface {
|
ServerForge interface {
|
||||||
// Name returns the string name of this driver
|
// Name returns the string name of this driver
|
||||||
Name() string
|
Name() string
|
||||||
|
|
|
@ -28,7 +28,7 @@ const (
|
||||||
defaultCloneName = "clone"
|
defaultCloneName = "clone"
|
||||||
)
|
)
|
||||||
|
|
||||||
// Registry represents registry credentials
|
// Registry represents registry credentials.
|
||||||
type Registry struct {
|
type Registry struct {
|
||||||
Hostname string
|
Hostname string
|
||||||
Username string
|
Username string
|
||||||
|
@ -89,7 +89,7 @@ type ResourceLimit struct {
|
||||||
CPUSet string
|
CPUSet string
|
||||||
}
|
}
|
||||||
|
|
||||||
// Compiler compiles the yaml
|
// Compiler compiles the yaml.
|
||||||
type Compiler struct {
|
type Compiler struct {
|
||||||
local bool
|
local bool
|
||||||
escalated []string
|
escalated []string
|
||||||
|
|
|
@ -122,7 +122,7 @@ func (c *Compiler) createProcess(container *yaml_types.Container, stepType backe
|
||||||
}
|
}
|
||||||
|
|
||||||
environment[requested.Target] = secretValue
|
environment[requested.Target] = secretValue
|
||||||
// TODO deprecated, remove in 3.x
|
// TODO: deprecated, remove in 3.x
|
||||||
environment[strings.ToUpper(requested.Target)] = secretValue
|
environment[strings.ToUpper(requested.Target)] = secretValue
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|
|
@ -150,7 +150,7 @@ func WithEnviron(env map[string]string) Option {
|
||||||
}
|
}
|
||||||
|
|
||||||
// WithNetworks configures the compiler with additional networks
|
// WithNetworks configures the compiler with additional networks
|
||||||
// to be connected to pipeline containers
|
// to be connected to pipeline containers.
|
||||||
func WithNetworks(networks ...string) Option {
|
func WithNetworks(networks ...string) Option {
|
||||||
return func(compiler *Compiler) {
|
return func(compiler *Compiler) {
|
||||||
compiler.networks = networks
|
compiler.networks = networks
|
||||||
|
@ -178,14 +178,14 @@ func WithDefaultCloneImage(cloneImage string) Option {
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
// WithTrusted configures the compiler with the trusted repo option
|
// WithTrusted configures the compiler with the trusted repo option.
|
||||||
func WithTrusted(trusted bool) Option {
|
func WithTrusted(trusted bool) Option {
|
||||||
return func(compiler *Compiler) {
|
return func(compiler *Compiler) {
|
||||||
compiler.trustedPipeline = trusted
|
compiler.trustedPipeline = trusted
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
// WithNetrcOnlyTrusted configures the compiler with the netrcOnlyTrusted repo option
|
// WithNetrcOnlyTrusted configures the compiler with the netrcOnlyTrusted repo option.
|
||||||
func WithNetrcOnlyTrusted(only bool) Option {
|
func WithNetrcOnlyTrusted(only bool) Option {
|
||||||
return func(compiler *Compiler) {
|
return func(compiler *Compiler) {
|
||||||
compiler.netrcOnlyTrusted = only
|
compiler.netrcOnlyTrusted = only
|
||||||
|
|
|
@ -42,7 +42,7 @@ func ParamsToEnv(from map[string]any, to map[string]string, prefix string, upper
|
||||||
return nil
|
return nil
|
||||||
}
|
}
|
||||||
|
|
||||||
// format the environment variable key
|
// sanitizeParamKey formats the environment variable key.
|
||||||
func sanitizeParamKey(prefix string, upper bool, k string) string {
|
func sanitizeParamKey(prefix string, upper bool, k string) string {
|
||||||
r := strings.ReplaceAll(strings.ReplaceAll(k, ".", "_"), "-", "_")
|
r := strings.ReplaceAll(strings.ReplaceAll(k, ".", "_"), "-", "_")
|
||||||
if upper {
|
if upper {
|
||||||
|
@ -51,7 +51,7 @@ func sanitizeParamKey(prefix string, upper bool, k string) string {
|
||||||
return prefix + r
|
return prefix + r
|
||||||
}
|
}
|
||||||
|
|
||||||
// indicate if a data type can be turned into string without encoding as json
|
// isComplex indicate if a data type can be turned into string without encoding as json.
|
||||||
func isComplex(t reflect.Kind) bool {
|
func isComplex(t reflect.Kind) bool {
|
||||||
switch t {
|
switch t {
|
||||||
case reflect.Bool,
|
case reflect.Bool,
|
||||||
|
@ -64,7 +64,7 @@ func isComplex(t reflect.Kind) bool {
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
// sanitizeParamValue returns the value of a setting as string prepared to be injected as environment variable
|
// sanitizeParamValue returns the value of a setting as string prepared to be injected as environment variable.
|
||||||
func sanitizeParamValue(v any, getSecretValue func(name string) (string, error)) (string, error) {
|
func sanitizeParamValue(v any, getSecretValue func(name string) (string, error)) (string, error) {
|
||||||
t := reflect.TypeOf(v)
|
t := reflect.TypeOf(v)
|
||||||
vv := reflect.ValueOf(v)
|
vv := reflect.ValueOf(v)
|
||||||
|
@ -141,7 +141,7 @@ func sanitizeParamValue(v any, getSecretValue func(name string) (string, error))
|
||||||
return handleComplex(vv.Interface(), getSecretValue)
|
return handleComplex(vv.Interface(), getSecretValue)
|
||||||
}
|
}
|
||||||
|
|
||||||
// handleComplex uses yaml2json to get json strings as values for environment variables
|
// handleComplex uses yaml2json to get json strings as values for environment variables.
|
||||||
func handleComplex(v any, getSecretValue func(name string) (string, error)) (string, error) {
|
func handleComplex(v any, getSecretValue func(name string) (string, error)) (string, error) {
|
||||||
v, err := injectSecretRecursive(v, getSecretValue)
|
v, err := injectSecretRecursive(v, getSecretValue)
|
||||||
if err != nil {
|
if err != nil {
|
||||||
|
@ -161,7 +161,7 @@ func handleComplex(v any, getSecretValue func(name string) (string, error)) (str
|
||||||
|
|
||||||
// injectSecret probes if a map is a from_secret request.
|
// injectSecret probes if a map is a from_secret request.
|
||||||
// If it's a from_secret request it either returns the secret value or an error if the secret was not found
|
// If it's a from_secret request it either returns the secret value or an error if the secret was not found
|
||||||
// else it just indicates to progress normally using the provided map as is
|
// else it just indicates to progress normally using the provided map as is.
|
||||||
func injectSecret(v map[string]any, getSecretValue func(name string) (string, error)) (string, bool, error) {
|
func injectSecret(v map[string]any, getSecretValue func(name string) (string, error)) (string, bool, error) {
|
||||||
if secretNameI, ok := v["from_secret"]; ok {
|
if secretNameI, ok := v["from_secret"]; ok {
|
||||||
if secretName, ok := secretNameI.(string); ok {
|
if secretName, ok := secretNameI.(string); ok {
|
||||||
|
@ -178,7 +178,7 @@ func injectSecret(v map[string]any, getSecretValue func(name string) (string, er
|
||||||
}
|
}
|
||||||
|
|
||||||
// injectSecretRecursive iterates over all types and if they contain elements
|
// injectSecretRecursive iterates over all types and if they contain elements
|
||||||
// it iterates recursively over them too, using injectSecret internally
|
// it iterates recursively over them too, using injectSecret internally.
|
||||||
func injectSecretRecursive(v any, getSecretValue func(name string) (string, error)) (any, error) {
|
func injectSecretRecursive(v any, getSecretValue func(name string) (string, error)) (any, error) {
|
||||||
t := reflect.TypeOf(v)
|
t := reflect.TypeOf(v)
|
||||||
|
|
||||||
|
|
|
@ -49,7 +49,7 @@ type (
|
||||||
Local yamlBaseTypes.BoolTrue
|
Local yamlBaseTypes.BoolTrue
|
||||||
Path Path
|
Path Path
|
||||||
Evaluate string `yaml:"evaluate,omitempty"`
|
Evaluate string `yaml:"evaluate,omitempty"`
|
||||||
// TODO change to StringOrSlice in 3.x
|
// TODO: change to StringOrSlice in 3.x
|
||||||
Event List
|
Event List
|
||||||
}
|
}
|
||||||
|
|
||||||
|
@ -122,7 +122,7 @@ func (when *When) IncludesStatusSuccess() bool {
|
||||||
return false
|
return false
|
||||||
}
|
}
|
||||||
|
|
||||||
// False if (any) non local
|
// False if (any) non local.
|
||||||
func (when *When) IsLocal() bool {
|
func (when *When) IsLocal() bool {
|
||||||
for _, c := range when.Constraints {
|
for _, c := range when.Constraints {
|
||||||
if !c.Local.Bool() {
|
if !c.Local.Bool() {
|
||||||
|
@ -206,7 +206,7 @@ func (c *Constraint) Match(m metadata.Metadata, global bool, env map[string]stri
|
||||||
return match, nil
|
return match, nil
|
||||||
}
|
}
|
||||||
|
|
||||||
// IsEmpty return true if a constraint has no conditions
|
// IsEmpty return true if a constraint has no conditions.
|
||||||
func (c List) IsEmpty() bool {
|
func (c List) IsEmpty() bool {
|
||||||
return len(c.Include) == 0 && len(c.Exclude) == 0
|
return len(c.Include) == 0 && len(c.Exclude) == 0
|
||||||
}
|
}
|
||||||
|
|
|
@ -29,7 +29,7 @@ import (
|
||||||
//go:embed schema.json
|
//go:embed schema.json
|
||||||
var schemaDefinition []byte
|
var schemaDefinition []byte
|
||||||
|
|
||||||
// Lint lints an io.Reader against the Woodpecker schema.json
|
// Lint lints an io.Reader against the Woodpecker `schema.json`.
|
||||||
func Lint(r io.Reader) ([]gojsonschema.ResultError, error) {
|
func Lint(r io.Reader) ([]gojsonschema.ResultError, error) {
|
||||||
schemaLoader := gojsonschema.NewBytesLoader(schemaDefinition)
|
schemaLoader := gojsonschema.NewBytesLoader(schemaDefinition)
|
||||||
|
|
||||||
|
|
|
@ -46,7 +46,7 @@ func (s *StringOrInt) UnmarshalYAML(unmarshal func(any) error) error {
|
||||||
}
|
}
|
||||||
|
|
||||||
// MemStringOrInt represents a string or an integer
|
// MemStringOrInt represents a string or an integer
|
||||||
// the String supports notations like 10m for then Megabyte of memory
|
// the String supports notations like 10m for then Megabyte of memory.
|
||||||
type MemStringOrInt int64
|
type MemStringOrInt int64
|
||||||
|
|
||||||
// UnmarshalYAML implements the Unmarshaler interface.
|
// UnmarshalYAML implements the Unmarshaler interface.
|
||||||
|
|
|
@ -20,7 +20,7 @@ import (
|
||||||
"strings"
|
"strings"
|
||||||
)
|
)
|
||||||
|
|
||||||
// SliceOrMap represents a map of strings, string slice are converted into a map
|
// SliceOrMap represents a map of strings, string slice are converted into a map.
|
||||||
type SliceOrMap map[string]any
|
type SliceOrMap map[string]any
|
||||||
|
|
||||||
// UnmarshalYAML implements the Unmarshaler interface.
|
// UnmarshalYAML implements the Unmarshaler interface.
|
||||||
|
|
|
@ -49,9 +49,9 @@ type (
|
||||||
Ports []string `yaml:"ports,omitempty"`
|
Ports []string `yaml:"ports,omitempty"`
|
||||||
DependsOn base.StringOrSlice `yaml:"depends_on,omitempty"`
|
DependsOn base.StringOrSlice `yaml:"depends_on,omitempty"`
|
||||||
|
|
||||||
// TODO make []string in 3.x
|
// TODO: make []string in 3.x
|
||||||
Secrets Secrets `yaml:"secrets,omitempty"`
|
Secrets Secrets `yaml:"secrets,omitempty"`
|
||||||
// TODO make map[string]any in 3.x
|
// TODO: make map[string]any in 3.x
|
||||||
Environment base.SliceOrMap `yaml:"environment,omitempty"`
|
Environment base.SliceOrMap `yaml:"environment,omitempty"`
|
||||||
|
|
||||||
// Docker and Kubernetes Specific
|
// Docker and Kubernetes Specific
|
||||||
|
|
|
@ -26,7 +26,7 @@ type Volumes struct {
|
||||||
Volumes []*Volume
|
Volumes []*Volume
|
||||||
}
|
}
|
||||||
|
|
||||||
// Volume represent a service volume
|
// Volume represent a service volume.
|
||||||
type Volume struct {
|
type Volume struct {
|
||||||
Source string `yaml:"-"`
|
Source string `yaml:"-"`
|
||||||
Destination string `yaml:"-"`
|
Destination string `yaml:"-"`
|
||||||
|
@ -68,7 +68,7 @@ func (v *Volumes) UnmarshalYAML(unmarshal func(any) error) error {
|
||||||
}
|
}
|
||||||
elts := strings.SplitN(name, ":", 3)
|
elts := strings.SplitN(name, ":", 3)
|
||||||
var vol *Volume
|
var vol *Volume
|
||||||
//nolint: gomnd
|
//nolint:mnd
|
||||||
switch {
|
switch {
|
||||||
case len(elts) == 1:
|
case len(elts) == 1:
|
||||||
vol = &Volume{
|
vol = &Volume{
|
||||||
|
|
|
@ -88,7 +88,7 @@ func (r *Runtime) MakeLogger() zerolog.Logger {
|
||||||
return logCtx.Logger()
|
return logCtx.Logger()
|
||||||
}
|
}
|
||||||
|
|
||||||
// Run starts the execution of a workflow and waits for it to complete
|
// Run starts the execution of a workflow and waits for it to complete.
|
||||||
func (r *Runtime) Run(runnerCtx context.Context) error {
|
func (r *Runtime) Run(runnerCtx context.Context) error {
|
||||||
logger := r.MakeLogger()
|
logger := r.MakeLogger()
|
||||||
logger.Debug().Msgf("executing %d stages, in order of:", len(r.spec.Stages))
|
logger.Debug().Msgf("executing %d stages, in order of:", len(r.spec.Stages))
|
||||||
|
@ -129,7 +129,7 @@ func (r *Runtime) Run(runnerCtx context.Context) error {
|
||||||
return r.err
|
return r.err
|
||||||
}
|
}
|
||||||
|
|
||||||
// Updates the current status of a step
|
// Updates the current status of a step.
|
||||||
func (r *Runtime) traceStep(processState *backend.State, err error, step *backend.Step) error {
|
func (r *Runtime) traceStep(processState *backend.State, err error, step *backend.Step) error {
|
||||||
if r.tracer == nil {
|
if r.tracer == nil {
|
||||||
// no tracer nothing to trace :)
|
// no tracer nothing to trace :)
|
||||||
|
@ -158,7 +158,7 @@ func (r *Runtime) traceStep(processState *backend.State, err error, step *backen
|
||||||
return err
|
return err
|
||||||
}
|
}
|
||||||
|
|
||||||
// Executes a set of parallel steps
|
// Executes a set of parallel steps.
|
||||||
func (r *Runtime) execAll(steps []*backend.Step) <-chan error {
|
func (r *Runtime) execAll(steps []*backend.Step) <-chan error {
|
||||||
var g errgroup.Group
|
var g errgroup.Group
|
||||||
done := make(chan error)
|
done := make(chan error)
|
||||||
|
|
|
@ -97,12 +97,12 @@ func (w *LineWriter) Write(p []byte) (n int, err error) {
|
||||||
return len(p), nil
|
return len(p), nil
|
||||||
}
|
}
|
||||||
|
|
||||||
// Lines returns the line history
|
// Lines returns the line history.
|
||||||
func (w *LineWriter) Lines() []*LogEntry {
|
func (w *LineWriter) Lines() []*LogEntry {
|
||||||
return w.lines
|
return w.lines
|
||||||
}
|
}
|
||||||
|
|
||||||
// Clear clears the line history
|
// Clear clears the line history.
|
||||||
func (w *LineWriter) Clear() {
|
func (w *LineWriter) Clear() {
|
||||||
w.lines = w.lines[:0]
|
w.lines = w.lines[:0]
|
||||||
}
|
}
|
||||||
|
|
|
@ -15,5 +15,5 @@
|
||||||
package proto
|
package proto
|
||||||
|
|
||||||
// Version is the version of the woodpecker.proto file,
|
// Version is the version of the woodpecker.proto file,
|
||||||
// !IMPORTANT! increased by 1 each time it get changed !IMPORTANT!
|
// IMPORTANT: increased by 1 each time it get changed.
|
||||||
const Version int32 = 7
|
const Version int32 = 7
|
||||||
|
|
|
@ -13,8 +13,6 @@
|
||||||
// WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
|
// WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
|
||||||
// See the License for the specific language governing permissions and
|
// See the License for the specific language governing permissions and
|
||||||
// limitations under the License.
|
// limitations under the License.
|
||||||
//
|
|
||||||
// This file has been modified by Informatyka Boguslawski sp. z o.o. sp.k.
|
|
||||||
|
|
||||||
package api
|
package api
|
||||||
|
|
||||||
|
|
|
@ -13,8 +13,6 @@
|
||||||
// WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
|
// WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
|
||||||
// See the License for the specific language governing permissions and
|
// See the License for the specific language governing permissions and
|
||||||
// limitations under the License.
|
// limitations under the License.
|
||||||
//
|
|
||||||
// This file has been modified by Informatyka Boguslawski sp. z o.o. sp.k.
|
|
||||||
|
|
||||||
package api
|
package api
|
||||||
|
|
||||||
|
|
|
@ -28,7 +28,7 @@ import (
|
||||||
// errInvalidToken is returned when the api request token is invalid.
|
// errInvalidToken is returned when the api request token is invalid.
|
||||||
var errInvalidToken = errors.New("invalid or missing token")
|
var errInvalidToken = errors.New("invalid or missing token")
|
||||||
|
|
||||||
// PromHandler will pass the call from /api/metrics/prometheus to prometheus
|
// PromHandler will pass the call from /api/metrics/prometheus to prometheus.
|
||||||
func PromHandler() gin.HandlerFunc {
|
func PromHandler() gin.HandlerFunc {
|
||||||
handler := promhttp.Handler()
|
handler := promhttp.Handler()
|
||||||
|
|
||||||
|
|
|
@ -13,8 +13,6 @@
|
||||||
// WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
|
// WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
|
||||||
// See the License for the specific language governing permissions and
|
// See the License for the specific language governing permissions and
|
||||||
// limitations under the License.
|
// limitations under the License.
|
||||||
//
|
|
||||||
// This file has been modified by Informatyka Boguslawski sp. z o.o. sp.k.
|
|
||||||
|
|
||||||
package api
|
package api
|
||||||
|
|
||||||
|
@ -551,7 +549,7 @@ func PostPipeline(c *gin.Context) {
|
||||||
pl.DeployTask = c.DefaultQuery("deploy_task", pl.DeployTask)
|
pl.DeployTask = c.DefaultQuery("deploy_task", pl.DeployTask)
|
||||||
|
|
||||||
// make Event overridable to deploy
|
// make Event overridable to deploy
|
||||||
// TODO refactor to use own proper API for deploy
|
// TODO: refactor to use own proper API for deploy
|
||||||
if event, ok := c.GetQuery("event"); ok {
|
if event, ok := c.GetQuery("event"); ok {
|
||||||
pl.Event = model.WebhookEvent(event)
|
pl.Event = model.WebhookEvent(event)
|
||||||
if pl.Event != model.EventDeploy {
|
if pl.Event != model.EventDeploy {
|
||||||
|
|
|
@ -24,7 +24,7 @@ var (
|
||||||
badgeNone = `<svg xmlns="http://www.w3.org/2000/svg" xmlns:xlink="http://www.w3.org/1999/xlink" width="90" height="20" role="img" aria-label="pipeline: none"><title>pipeline: none</title><linearGradient id="s" x2="0" y2="100%"><stop offset="0" stop-color="#bbb" stop-opacity=".1"/><stop offset="1" stop-opacity=".1"/></linearGradient><clipPath id="r"><rect width="90" height="20" rx="3" fill="#fff"/></clipPath><g clip-path="url(#r)"><rect width="53" height="20" fill="#555"/><rect x="53" width="37" height="20" fill="#9f9f9f"/><rect width="90" height="20" fill="url(#s)"/></g><g fill="#fff" text-anchor="middle" font-family="Verdana,Geneva,DejaVu Sans,sans-serif" text-rendering="geometricPrecision" font-size="110"><text aria-hidden="true" x="275" y="150" fill="#010101" fill-opacity=".3" transform="scale(.1)" textLength="430">pipeline</text><text x="275" y="140" transform="scale(.1)" fill="#fff" textLength="430">pipeline</text><text aria-hidden="true" x="705" y="150" fill="#010101" fill-opacity=".3" transform="scale(.1)" textLength="270">none</text><text x="705" y="140" transform="scale(.1)" fill="#fff" textLength="270">none</text></g></svg>`
|
badgeNone = `<svg xmlns="http://www.w3.org/2000/svg" xmlns:xlink="http://www.w3.org/1999/xlink" width="90" height="20" role="img" aria-label="pipeline: none"><title>pipeline: none</title><linearGradient id="s" x2="0" y2="100%"><stop offset="0" stop-color="#bbb" stop-opacity=".1"/><stop offset="1" stop-opacity=".1"/></linearGradient><clipPath id="r"><rect width="90" height="20" rx="3" fill="#fff"/></clipPath><g clip-path="url(#r)"><rect width="53" height="20" fill="#555"/><rect x="53" width="37" height="20" fill="#9f9f9f"/><rect width="90" height="20" fill="url(#s)"/></g><g fill="#fff" text-anchor="middle" font-family="Verdana,Geneva,DejaVu Sans,sans-serif" text-rendering="geometricPrecision" font-size="110"><text aria-hidden="true" x="275" y="150" fill="#010101" fill-opacity=".3" transform="scale(.1)" textLength="430">pipeline</text><text x="275" y="140" transform="scale(.1)" fill="#fff" textLength="430">pipeline</text><text aria-hidden="true" x="705" y="150" fill="#010101" fill-opacity=".3" transform="scale(.1)" textLength="270">none</text><text x="705" y="140" transform="scale(.1)" fill="#fff" textLength="270">none</text></g></svg>`
|
||||||
)
|
)
|
||||||
|
|
||||||
// Generate an SVG badge based on a pipeline
|
// Generate an SVG badge based on a pipeline.
|
||||||
func Generate(pipeline *model.Pipeline) string {
|
func Generate(pipeline *model.Pipeline) string {
|
||||||
if pipeline == nil {
|
if pipeline == nil {
|
||||||
return badgeNone
|
return badgeNone
|
||||||
|
|
|
@ -22,7 +22,7 @@ import (
|
||||||
"go.woodpecker-ci.org/woodpecker/v2/server/model"
|
"go.woodpecker-ci.org/woodpecker/v2/server/model"
|
||||||
)
|
)
|
||||||
|
|
||||||
// Generate an SVG badge based on a pipeline
|
// Generate an SVG badge based on a pipeline.
|
||||||
func TestGenerate(t *testing.T) {
|
func TestGenerate(t *testing.T) {
|
||||||
assert.Equal(t, badgeNone, Generate(nil))
|
assert.Equal(t, badgeNone, Generate(nil))
|
||||||
assert.Equal(t, badgeSuccess, Generate(&model.Pipeline{Status: model.StatusSuccess}))
|
assert.Equal(t, badgeSuccess, Generate(&model.Pipeline{Status: model.StatusSuccess}))
|
||||||
|
|
2
server/cache/membership.go
vendored
2
server/cache/membership.go
vendored
|
@ -41,7 +41,7 @@ type membershipCache struct {
|
||||||
// NewMembershipService creates a new membership service.
|
// NewMembershipService creates a new membership service.
|
||||||
func NewMembershipService(_store store.Store) MembershipService {
|
func NewMembershipService(_store store.Store) MembershipService {
|
||||||
return &membershipCache{
|
return &membershipCache{
|
||||||
ttl: 10 * time.Minute, //nolint: gomnd
|
ttl: 10 * time.Minute, //nolint:mnd
|
||||||
store: _store,
|
store: _store,
|
||||||
cache: ttlcache.New(ttlcache.WithDisableTouchOnHit[string, *model.OrgPerm]()),
|
cache: ttlcache.New(ttlcache.WithDisableTouchOnHit[string, *model.OrgPerm]()),
|
||||||
}
|
}
|
||||||
|
|
|
@ -12,8 +12,6 @@
|
||||||
// WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
|
// WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
|
||||||
// See the License for the specific language governing permissions and
|
// See the License for the specific language governing permissions and
|
||||||
// limitations under the License.
|
// limitations under the License.
|
||||||
//
|
|
||||||
// This file has been modified by Informatyka Boguslawski sp. z o.o. sp.k.
|
|
||||||
|
|
||||||
package server
|
package server
|
||||||
|
|
||||||
|
|
|
@ -30,14 +30,14 @@ import (
|
||||||
)
|
)
|
||||||
|
|
||||||
const (
|
const (
|
||||||
// checkTime specifies the interval woodpecker checks for new crons to exec
|
// Specifies the interval woodpecker checks for new crons to exec.
|
||||||
checkTime = 10 * time.Second
|
checkTime = 10 * time.Second
|
||||||
|
|
||||||
// checkItems specifies the batch size of crons to retrieve per check from database
|
// Specifies the batch size of crons to retrieve per check from database.
|
||||||
checkItems = 10
|
checkItems = 10
|
||||||
)
|
)
|
||||||
|
|
||||||
// Start starts the cron scheduler loop
|
// Start starts the cron scheduler loop.
|
||||||
func Start(ctx context.Context, store store.Store) error {
|
func Start(ctx context.Context, store store.Store) error {
|
||||||
for {
|
for {
|
||||||
select {
|
select {
|
||||||
|
@ -64,7 +64,7 @@ func Start(ctx context.Context, store store.Store) error {
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
// CalcNewNext parses a cron string and calculates the next exec time based on it
|
// CalcNewNext parses a cron string and calculates the next exec time based on it.
|
||||||
func CalcNewNext(schedule string, now time.Time) (time.Time, error) {
|
func CalcNewNext(schedule string, now time.Time) (time.Time, error) {
|
||||||
// remove local timezone
|
// remove local timezone
|
||||||
now = now.UTC()
|
now = now.UTC()
|
||||||
|
|
|
@ -90,7 +90,7 @@ type httpRequest struct {
|
||||||
Body []byte `json:"body"`
|
Body []byte `json:"body"`
|
||||||
}
|
}
|
||||||
|
|
||||||
// modelUser is an extension of model.User to marshal all fields to JSON
|
// modelUser is an extension of model.User to marshal all fields to JSON.
|
||||||
type modelUser struct {
|
type modelUser struct {
|
||||||
User *model.User `json:"user"`
|
User *model.User `json:"user"`
|
||||||
|
|
||||||
|
@ -129,7 +129,7 @@ func modelUserFromModel(u *model.User) *modelUser {
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
// modelRepo is an extension of model.Repo to marshal all fields to JSON
|
// modelRepo is an extension of model.Repo to marshal all fields to JSON.
|
||||||
type modelRepo struct {
|
type modelRepo struct {
|
||||||
Repo *model.Repo `json:"repo"`
|
Repo *model.Repo `json:"repo"`
|
||||||
UserID int64 `json:"user_id"`
|
UserID int64 `json:"user_id"`
|
||||||
|
|
|
@ -30,7 +30,7 @@ import (
|
||||||
"go.woodpecker-ci.org/woodpecker/v2/server/model"
|
"go.woodpecker-ci.org/woodpecker/v2/server/model"
|
||||||
)
|
)
|
||||||
|
|
||||||
// make sure RPC implements forge.Forge
|
// make sure RPC implements forge.Forge.
|
||||||
var _ forge.Forge = new(RPC)
|
var _ forge.Forge = new(RPC)
|
||||||
|
|
||||||
func Load(file string) (forge.Forge, error) {
|
func Load(file string) (forge.Forge, error) {
|
||||||
|
@ -44,7 +44,7 @@ func Load(file string) (forge.Forge, error) {
|
||||||
logger: log.With().Str("addon", file).Logger(),
|
logger: log.With().Str("addon", file).Logger(),
|
||||||
},
|
},
|
||||||
})
|
})
|
||||||
// TODO defer client.Kill()
|
// TODO: defer client.Kill()
|
||||||
|
|
||||||
rpcClient, err := client.Client()
|
rpcClient, err := client.Client()
|
||||||
if err != nil {
|
if err != nil {
|
||||||
|
|
|
@ -42,7 +42,7 @@ const (
|
||||||
pageSize = 100
|
pageSize = 100
|
||||||
)
|
)
|
||||||
|
|
||||||
// Opts are forge options for bitbucket
|
// Opts are forge options for bitbucket.
|
||||||
type Opts struct {
|
type Opts struct {
|
||||||
Client string
|
Client string
|
||||||
Secret string
|
Secret string
|
||||||
|
@ -67,12 +67,12 @@ func New(opts *Opts) (forge.Forge, error) {
|
||||||
// TODO: add checks
|
// TODO: add checks
|
||||||
}
|
}
|
||||||
|
|
||||||
// Name returns the string name of this driver
|
// Name returns the string name of this driver.
|
||||||
func (c *config) Name() string {
|
func (c *config) Name() string {
|
||||||
return "bitbucket"
|
return "bitbucket"
|
||||||
}
|
}
|
||||||
|
|
||||||
// URL returns the root url of a configured forge
|
// URL returns the root url of a configured forge.
|
||||||
func (c *config) URL() string {
|
func (c *config) URL() string {
|
||||||
return c.url
|
return c.url
|
||||||
}
|
}
|
||||||
|
@ -244,7 +244,7 @@ func (c *config) File(ctx context.Context, u *model.User, r *model.Repo, p *mode
|
||||||
return []byte(*config), nil
|
return []byte(*config), nil
|
||||||
}
|
}
|
||||||
|
|
||||||
// Dir fetches a folder from the bitbucket repository
|
// Dir fetches a folder from the bitbucket repository.
|
||||||
func (c *config) Dir(ctx context.Context, u *model.User, r *model.Repo, p *model.Pipeline, f string) ([]*forge_types.FileMeta, error) {
|
func (c *config) Dir(ctx context.Context, u *model.User, r *model.Repo, p *model.Pipeline, f string) ([]*forge_types.FileMeta, error) {
|
||||||
var page *string
|
var page *string
|
||||||
repoPathFiles := []*forge_types.FileMeta{}
|
repoPathFiles := []*forge_types.FileMeta{}
|
||||||
|
@ -375,7 +375,7 @@ func (c *config) Branches(ctx context.Context, u *model.User, r *model.Repo, p *
|
||||||
return branches, nil
|
return branches, nil
|
||||||
}
|
}
|
||||||
|
|
||||||
// BranchHead returns the sha of the head (latest commit) of the specified branch
|
// BranchHead returns the sha of the head (latest commit) of the specified branch.
|
||||||
func (c *config) BranchHead(ctx context.Context, u *model.User, r *model.Repo, branch string) (*model.Commit, error) {
|
func (c *config) BranchHead(ctx context.Context, u *model.User, r *model.Repo, branch string) (*model.Commit, error) {
|
||||||
commit, err := c.newClient(ctx, u).GetBranchHead(r.Owner, r.Name, branch)
|
commit, err := c.newClient(ctx, u).GetBranchHead(r.Owner, r.Name, branch)
|
||||||
if err != nil {
|
if err != nil {
|
||||||
|
@ -432,7 +432,7 @@ func (c *config) Org(ctx context.Context, u *model.User, owner string) (*model.O
|
||||||
}, nil
|
}, nil
|
||||||
}
|
}
|
||||||
|
|
||||||
// helper function to return the bitbucket oauth2 client
|
// helper function to return the bitbucket oauth2 client.
|
||||||
func (c *config) newClient(ctx context.Context, u *model.User) *internal.Client {
|
func (c *config) newClient(ctx context.Context, u *model.User) *internal.Client {
|
||||||
if u == nil {
|
if u == nil {
|
||||||
return c.newClientToken(ctx, "", "")
|
return c.newClientToken(ctx, "", "")
|
||||||
|
@ -440,7 +440,7 @@ func (c *config) newClient(ctx context.Context, u *model.User) *internal.Client
|
||||||
return c.newClientToken(ctx, u.Token, u.Secret)
|
return c.newClientToken(ctx, u.Token, u.Secret)
|
||||||
}
|
}
|
||||||
|
|
||||||
// helper function to return the bitbucket oauth2 client
|
// helper function to return the bitbucket oauth2 client.
|
||||||
func (c *config) newClientToken(ctx context.Context, token, secret string) *internal.Client {
|
func (c *config) newClientToken(ctx context.Context, token, secret string) *internal.Client {
|
||||||
return internal.NewClientToken(
|
return internal.NewClientToken(
|
||||||
ctx,
|
ctx,
|
||||||
|
@ -454,7 +454,7 @@ func (c *config) newClientToken(ctx context.Context, token, secret string) *inte
|
||||||
)
|
)
|
||||||
}
|
}
|
||||||
|
|
||||||
// helper function to return the bitbucket oauth2 config
|
// helper function to return the bitbucket oauth2 config.
|
||||||
func (c *config) newOAuth2Config() *oauth2.Config {
|
func (c *config) newOAuth2Config() *oauth2.Config {
|
||||||
return &oauth2.Config{
|
return &oauth2.Config{
|
||||||
ClientID: c.Client,
|
ClientID: c.Client,
|
||||||
|
|
|
@ -213,10 +213,10 @@ func convertPushHook(hook *internal.PushHook, change *internal.Change) *model.Pi
|
||||||
return pipeline
|
return pipeline
|
||||||
}
|
}
|
||||||
|
|
||||||
// regex for git author fields ("name <name@mail.tld>")
|
// regex for git author fields (r.g. "name <name@mail.tld>").
|
||||||
var reGitMail = regexp.MustCompile("<(.*)>")
|
var reGitMail = regexp.MustCompile("<(.*)>")
|
||||||
|
|
||||||
// extracts the email from a git commit author string
|
// extracts the email from a git commit author string.
|
||||||
func extractEmail(gitauthor string) (author string) {
|
func extractEmail(gitauthor string) (author string) {
|
||||||
matches := reGitMail.FindAllStringSubmatch(gitauthor, -1)
|
matches := reGitMail.FindAllStringSubmatch(gitauthor, -1)
|
||||||
if len(matches) == 1 {
|
if len(matches) == 1 {
|
||||||
|
|
|
@ -80,12 +80,12 @@ func New(opts Opts) (forge.Forge, error) {
|
||||||
return config, nil
|
return config, nil
|
||||||
}
|
}
|
||||||
|
|
||||||
// Name returns the string name of this driver
|
// Name returns the string name of this driver.
|
||||||
func (c *client) Name() string {
|
func (c *client) Name() string {
|
||||||
return "bitbucket_dc"
|
return "bitbucket_dc"
|
||||||
}
|
}
|
||||||
|
|
||||||
// URL returns the root url of a configured forge
|
// URL returns the root url of a configured forge.
|
||||||
func (c *client) URL() string {
|
func (c *client) URL() string {
|
||||||
return c.url
|
return c.url
|
||||||
}
|
}
|
||||||
|
|
|
@ -40,7 +40,7 @@ func NewClientWithToken(ctx context.Context, ts oauth2.TokenSource, url string)
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
// FindCurrentUser is returning the current user id - however it is not really part of the API so it is not part of the Bitbucket go client
|
// FindCurrentUser is returning the current user id - however it is not really part of the API so it is not part of the Bitbucket go client.
|
||||||
func (c *Client) FindCurrentUser(ctx context.Context) (string, error) {
|
func (c *Client) FindCurrentUser(ctx context.Context) (string, error) {
|
||||||
url := fmt.Sprintf(currentUserID, c.base)
|
url := fmt.Sprintf(currentUserID, c.base)
|
||||||
req, err := http.NewRequestWithContext(ctx, http.MethodGet, url, nil)
|
req, err := http.NewRequestWithContext(ctx, http.MethodGet, url, nil)
|
||||||
|
|
|
@ -14,7 +14,7 @@
|
||||||
|
|
||||||
package fixtures
|
package fixtures
|
||||||
|
|
||||||
// HookPush is a sample Gitea push hook
|
// HookPush is a sample Gitea push hook.
|
||||||
const HookPush = `
|
const HookPush = `
|
||||||
{
|
{
|
||||||
"ref": "refs/heads/main",
|
"ref": "refs/heads/main",
|
||||||
|
@ -75,7 +75,7 @@ const HookPush = `
|
||||||
}
|
}
|
||||||
`
|
`
|
||||||
|
|
||||||
// HookPushMulti push multible commits to a branch
|
// HookPushMulti push multible commits to a branch.
|
||||||
const HookPushMulti = `
|
const HookPushMulti = `
|
||||||
{
|
{
|
||||||
"ref": "refs/heads/main",
|
"ref": "refs/heads/main",
|
||||||
|
@ -272,7 +272,7 @@ const HookPushMulti = `
|
||||||
}
|
}
|
||||||
`
|
`
|
||||||
|
|
||||||
// HookPushBranch is a sample Gitea push hook where a new branch was created from an existing commit
|
// HookPushBranch is a sample Gitea push hook where a new branch was created from an existing commit.
|
||||||
const HookPushBranch = `
|
const HookPushBranch = `
|
||||||
{
|
{
|
||||||
"ref": "refs/heads/fdsafdsa",
|
"ref": "refs/heads/fdsafdsa",
|
||||||
|
@ -425,7 +425,7 @@ const HookPushBranch = `
|
||||||
}
|
}
|
||||||
}`
|
}`
|
||||||
|
|
||||||
// HookTag is a sample Gitea tag hook
|
// HookTag is a sample Gitea tag hook.
|
||||||
const HookTag = `{
|
const HookTag = `{
|
||||||
"sha": "ef98532add3b2feb7a137426bba1248724367df5",
|
"sha": "ef98532add3b2feb7a137426bba1248724367df5",
|
||||||
"secret": "l26Un7G7HXogLAvsyf2hOA4EMARSTsR3",
|
"secret": "l26Un7G7HXogLAvsyf2hOA4EMARSTsR3",
|
||||||
|
@ -468,7 +468,7 @@ const HookTag = `{
|
||||||
}
|
}
|
||||||
}`
|
}`
|
||||||
|
|
||||||
// HookPullRequest is a sample pull_request webhook payload
|
// HookPullRequest is a sample pull_request webhook payload.
|
||||||
const HookPullRequest = `{
|
const HookPullRequest = `{
|
||||||
"action": "opened",
|
"action": "opened",
|
||||||
"number": 1,
|
"number": 1,
|
||||||
|
|
|
@ -13,8 +13,6 @@
|
||||||
// WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
|
// WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
|
||||||
// See the License for the specific language governing permissions and
|
// See the License for the specific language governing permissions and
|
||||||
// limitations under the License.
|
// limitations under the License.
|
||||||
//
|
|
||||||
// This file has been modified by Informatyka Boguslawski sp. z o.o. sp.k.
|
|
||||||
|
|
||||||
package gitea
|
package gitea
|
||||||
|
|
||||||
|
@ -84,12 +82,12 @@ func New(opts Opts) (forge.Forge, error) {
|
||||||
}, nil
|
}, nil
|
||||||
}
|
}
|
||||||
|
|
||||||
// Name returns the string name of this driver
|
// Name returns the string name of this driver.
|
||||||
func (c *Gitea) Name() string {
|
func (c *Gitea) Name() string {
|
||||||
return "gitea"
|
return "gitea"
|
||||||
}
|
}
|
||||||
|
|
||||||
// URL returns the root url of a configured forge
|
// URL returns the root url of a configured forge.
|
||||||
func (c *Gitea) URL() string {
|
func (c *Gitea) URL() string {
|
||||||
return c.url
|
return c.url
|
||||||
}
|
}
|
||||||
|
@ -458,7 +456,7 @@ func (c *Gitea) Branches(ctx context.Context, u *model.User, r *model.Repo, p *m
|
||||||
return result, err
|
return result, err
|
||||||
}
|
}
|
||||||
|
|
||||||
// BranchHead returns the sha of the head (latest commit) of the specified branch
|
// BranchHead returns the sha of the head (latest commit) of the specified branch.
|
||||||
func (c *Gitea) BranchHead(ctx context.Context, u *model.User, r *model.Repo, branch string) (*model.Commit, error) {
|
func (c *Gitea) BranchHead(ctx context.Context, u *model.User, r *model.Repo, branch string) (*model.Commit, error) {
|
||||||
token := common.UserToken(ctx, r, u)
|
token := common.UserToken(ctx, r, u)
|
||||||
client, err := c.newClientToken(ctx, token)
|
client, err := c.newClientToken(ctx, token)
|
||||||
|
@ -585,7 +583,7 @@ func (c *Gitea) Org(ctx context.Context, u *model.User, owner string) (*model.Or
|
||||||
}, nil
|
}, nil
|
||||||
}
|
}
|
||||||
|
|
||||||
// helper function to return the Gitea client with Token
|
// newClientToken returns the Gitea client with Token.
|
||||||
func (c *Gitea) newClientToken(ctx context.Context, token string) (*gitea.Client, error) {
|
func (c *Gitea) newClientToken(ctx context.Context, token string) (*gitea.Client, error) {
|
||||||
httpClient := &http.Client{}
|
httpClient := &http.Client{}
|
||||||
if c.SkipVerify {
|
if c.SkipVerify {
|
||||||
|
|
|
@ -29,7 +29,7 @@ import (
|
||||||
"go.woodpecker-ci.org/woodpecker/v2/shared/utils"
|
"go.woodpecker-ci.org/woodpecker/v2/shared/utils"
|
||||||
)
|
)
|
||||||
|
|
||||||
// helper function that converts a Gitea repository to a Woodpecker repository.
|
// toRepo converts a Gitea repository to a Woodpecker repository.
|
||||||
func toRepo(from *gitea.Repository) *model.Repo {
|
func toRepo(from *gitea.Repository) *model.Repo {
|
||||||
name := strings.Split(from.FullName, "/")[1]
|
name := strings.Split(from.FullName, "/")[1]
|
||||||
avatar := expandAvatar(
|
avatar := expandAvatar(
|
||||||
|
@ -53,7 +53,7 @@ func toRepo(from *gitea.Repository) *model.Repo {
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
// helper function that converts a Gitea permission to a Woodpecker permission.
|
// toPerm converts a Gitea permission to a Woodpecker permission.
|
||||||
func toPerm(from *gitea.Permission) *model.Perm {
|
func toPerm(from *gitea.Permission) *model.Perm {
|
||||||
return &model.Perm{
|
return &model.Perm{
|
||||||
Pull: from.Pull,
|
Pull: from.Pull,
|
||||||
|
@ -62,7 +62,7 @@ func toPerm(from *gitea.Permission) *model.Perm {
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
// helper function that converts a Gitea team to a Woodpecker team.
|
// toTeam converts a Gitea team to a Woodpecker team.
|
||||||
func toTeam(from *gitea.Organization, link string) *model.Team {
|
func toTeam(from *gitea.Organization, link string) *model.Team {
|
||||||
return &model.Team{
|
return &model.Team{
|
||||||
Login: from.UserName,
|
Login: from.UserName,
|
||||||
|
@ -70,7 +70,7 @@ func toTeam(from *gitea.Organization, link string) *model.Team {
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
// helper function that extracts the Pipeline data from a Gitea push hook
|
// pipelineFromPush extracts the Pipeline data from a Gitea push hook.
|
||||||
func pipelineFromPush(hook *pushHook) *model.Pipeline {
|
func pipelineFromPush(hook *pushHook) *model.Pipeline {
|
||||||
avatar := expandAvatar(
|
avatar := expandAvatar(
|
||||||
hook.Repo.HTMLURL,
|
hook.Repo.HTMLURL,
|
||||||
|
@ -121,7 +121,7 @@ func getChangedFilesFromPushHook(hook *pushHook) []string {
|
||||||
return utils.DeduplicateStrings(files)
|
return utils.DeduplicateStrings(files)
|
||||||
}
|
}
|
||||||
|
|
||||||
// helper function that extracts the Pipeline data from a Gitea tag hook
|
// pipelineFromTag extracts the Pipeline data from a Gitea tag hook.
|
||||||
func pipelineFromTag(hook *pushHook) *model.Pipeline {
|
func pipelineFromTag(hook *pushHook) *model.Pipeline {
|
||||||
avatar := expandAvatar(
|
avatar := expandAvatar(
|
||||||
hook.Repo.HTMLURL,
|
hook.Repo.HTMLURL,
|
||||||
|
@ -143,7 +143,7 @@ func pipelineFromTag(hook *pushHook) *model.Pipeline {
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
// helper function that extracts the Pipeline data from a Gitea pull_request hook
|
// pipelineFromPullRequest extracts the Pipeline data from a Gitea pull_request hook.
|
||||||
func pipelineFromPullRequest(hook *pullRequestHook) *model.Pipeline {
|
func pipelineFromPullRequest(hook *pullRequestHook) *model.Pipeline {
|
||||||
avatar := expandAvatar(
|
avatar := expandAvatar(
|
||||||
hook.Repo.HTMLURL,
|
hook.Repo.HTMLURL,
|
||||||
|
@ -197,7 +197,7 @@ func pipelineFromRelease(hook *releaseHook) *model.Pipeline {
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
// helper function that parses a push hook from a read closer.
|
// parsePush parses a push hook from a read closer.
|
||||||
func parsePush(r io.Reader) (*pushHook, error) {
|
func parsePush(r io.Reader) (*pushHook, error) {
|
||||||
push := new(pushHook)
|
push := new(pushHook)
|
||||||
err := json.NewDecoder(r).Decode(push)
|
err := json.NewDecoder(r).Decode(push)
|
||||||
|
@ -216,8 +216,7 @@ func parseRelease(r io.Reader) (*releaseHook, error) {
|
||||||
return pr, err
|
return pr, err
|
||||||
}
|
}
|
||||||
|
|
||||||
// fixMalformedAvatar is a helper function that fixes an avatar url if malformed
|
// fixMalformedAvatar fixes an avatar url if malformed (currently a known bug with gitea).
|
||||||
// (currently a known bug with gitea)
|
|
||||||
func fixMalformedAvatar(url string) string {
|
func fixMalformedAvatar(url string) string {
|
||||||
index := strings.Index(url, "///")
|
index := strings.Index(url, "///")
|
||||||
if index != -1 {
|
if index != -1 {
|
||||||
|
@ -230,8 +229,7 @@ func fixMalformedAvatar(url string) string {
|
||||||
return url
|
return url
|
||||||
}
|
}
|
||||||
|
|
||||||
// expandAvatar is a helper function that converts a relative avatar URL to the
|
// expandAvatar converts a relative avatar URL to the absolute url.
|
||||||
// absolute url.
|
|
||||||
func expandAvatar(repo, rawurl string) string {
|
func expandAvatar(repo, rawurl string) string {
|
||||||
aurl, err := url.Parse(rawurl)
|
aurl, err := url.Parse(rawurl)
|
||||||
if err != nil {
|
if err != nil {
|
||||||
|
@ -252,7 +250,7 @@ func expandAvatar(repo, rawurl string) string {
|
||||||
return aurl.String()
|
return aurl.String()
|
||||||
}
|
}
|
||||||
|
|
||||||
// helper function to return matching hooks.
|
// matchingHooks return matching hooks.
|
||||||
func matchingHooks(hooks []*gitea.Hook, rawurl string) *gitea.Hook {
|
func matchingHooks(hooks []*gitea.Hook, rawurl string) *gitea.Hook {
|
||||||
link, err := url.Parse(rawurl)
|
link, err := url.Parse(rawurl)
|
||||||
if err != nil {
|
if err != nil {
|
||||||
|
|
|
@ -72,7 +72,7 @@ func parsePushHook(payload io.Reader) (repo *model.Repo, pipeline *model.Pipelin
|
||||||
return nil, nil, nil
|
return nil, nil, nil
|
||||||
}
|
}
|
||||||
|
|
||||||
// TODO is this even needed?
|
// TODO: is this even needed?
|
||||||
if push.RefType == refBranch {
|
if push.RefType == refBranch {
|
||||||
return nil, nil, nil
|
return nil, nil, nil
|
||||||
}
|
}
|
||||||
|
|
|
@ -84,12 +84,12 @@ type client struct {
|
||||||
OnlyPublic bool
|
OnlyPublic bool
|
||||||
}
|
}
|
||||||
|
|
||||||
// Name returns the string name of this driver
|
// Name returns the string name of this driver.
|
||||||
func (c *client) Name() string {
|
func (c *client) Name() string {
|
||||||
return "github"
|
return "github"
|
||||||
}
|
}
|
||||||
|
|
||||||
// URL returns the root url of a configured forge
|
// URL returns the root url of a configured forge.
|
||||||
func (c *client) URL() string {
|
func (c *client) URL() string {
|
||||||
return c.url
|
return c.url
|
||||||
}
|
}
|
||||||
|
@ -390,7 +390,7 @@ func (c *client) Org(ctx context.Context, u *model.User, owner string) (*model.O
|
||||||
}, nil
|
}, nil
|
||||||
}
|
}
|
||||||
|
|
||||||
// helper function to return the GitHub oauth2 context using an HTTPClient that
|
// newContext returns the GitHub oauth2 context using an HTTPClient that
|
||||||
// disables TLS verification if disabled in the forge settings.
|
// disables TLS verification if disabled in the forge settings.
|
||||||
func (c *client) newContext(ctx context.Context) context.Context {
|
func (c *client) newContext(ctx context.Context) context.Context {
|
||||||
if !c.SkipVerify {
|
if !c.SkipVerify {
|
||||||
|
@ -406,7 +406,7 @@ func (c *client) newContext(ctx context.Context) context.Context {
|
||||||
})
|
})
|
||||||
}
|
}
|
||||||
|
|
||||||
// helper function to return the GitHub oauth2 config
|
// newConfig returns the GitHub oauth2 config.
|
||||||
func (c *client) newConfig() *oauth2.Config {
|
func (c *client) newConfig() *oauth2.Config {
|
||||||
scopes := []string{"user:email", "read:org"}
|
scopes := []string{"user:email", "read:org"}
|
||||||
if c.OnlyPublic {
|
if c.OnlyPublic {
|
||||||
|
@ -427,7 +427,7 @@ func (c *client) newConfig() *oauth2.Config {
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
// helper function to return the GitHub oauth2 client
|
// newClientToken returns the GitHub oauth2 client.
|
||||||
func (c *client) newClientToken(ctx context.Context, token string) *github.Client {
|
func (c *client) newClientToken(ctx context.Context, token string) *github.Client {
|
||||||
ts := oauth2.StaticTokenSource(
|
ts := oauth2.StaticTokenSource(
|
||||||
&oauth2.Token{AccessToken: token},
|
&oauth2.Token{AccessToken: token},
|
||||||
|
@ -447,7 +447,7 @@ func (c *client) newClientToken(ctx context.Context, token string) *github.Clien
|
||||||
return client
|
return client
|
||||||
}
|
}
|
||||||
|
|
||||||
// helper function to return matching user email.
|
// matchingEmail returns matching user email.
|
||||||
func matchingEmail(emails []*github.UserEmail, rawURL string) *github.UserEmail {
|
func matchingEmail(emails []*github.UserEmail, rawURL string) *github.UserEmail {
|
||||||
for _, email := range emails {
|
for _, email := range emails {
|
||||||
if email.Email == nil || email.Primary == nil || email.Verified == nil {
|
if email.Email == nil || email.Primary == nil || email.Verified == nil {
|
||||||
|
@ -465,7 +465,7 @@ func matchingEmail(emails []*github.UserEmail, rawURL string) *github.UserEmail
|
||||||
return nil
|
return nil
|
||||||
}
|
}
|
||||||
|
|
||||||
// helper function to return matching hook.
|
// matchingHooks returns matching hook.
|
||||||
func matchingHooks(hooks []*github.Hook, rawurl string) *github.Hook {
|
func matchingHooks(hooks []*github.Hook, rawurl string) *github.Hook {
|
||||||
link, err := url.Parse(rawurl)
|
link, err := url.Parse(rawurl)
|
||||||
if err != nil {
|
if err != nil {
|
||||||
|
@ -493,7 +493,7 @@ func (c *client) Status(ctx context.Context, user *model.User, repo *model.Repo,
|
||||||
if pipeline.Event == model.EventDeploy {
|
if pipeline.Event == model.EventDeploy {
|
||||||
// Get id from url. If not found, skip.
|
// Get id from url. If not found, skip.
|
||||||
matches := reDeploy.FindStringSubmatch(pipeline.ForgeURL)
|
matches := reDeploy.FindStringSubmatch(pipeline.ForgeURL)
|
||||||
//nolint:gomnd
|
//nolint:mnd
|
||||||
if len(matches) != 2 {
|
if len(matches) != 2 {
|
||||||
return nil
|
return nil
|
||||||
}
|
}
|
||||||
|
@ -558,7 +558,7 @@ func (c *client) Branches(ctx context.Context, u *model.User, r *model.Repo, p *
|
||||||
return branches, nil
|
return branches, nil
|
||||||
}
|
}
|
||||||
|
|
||||||
// BranchHead returns the sha of the head (latest commit) of the specified branch
|
// BranchHead returns the sha of the head (latest commit) of the specified branch.
|
||||||
func (c *client) BranchHead(ctx context.Context, u *model.User, r *model.Repo, branch string) (*model.Commit, error) {
|
func (c *client) BranchHead(ctx context.Context, u *model.User, r *model.Repo, branch string) (*model.Commit, error) {
|
||||||
token := common.UserToken(ctx, r, u)
|
token := common.UserToken(ctx, r, u)
|
||||||
b, _, err := c.newClientToken(ctx, token).Repositories.GetBranch(ctx, r.Owner, r.Name, branch, 1)
|
b, _, err := c.newClientToken(ctx, token).Repositories.GetBranch(ctx, r.Owner, r.Name, branch, 1)
|
||||||
|
|
|
@ -53,7 +53,7 @@ type Opts struct {
|
||||||
SkipVerify bool // Skip ssl verification.
|
SkipVerify bool // Skip ssl verification.
|
||||||
}
|
}
|
||||||
|
|
||||||
// Gitlab implements "Forge" interface
|
// Gitlab implements "Forge" interface.
|
||||||
type GitLab struct {
|
type GitLab struct {
|
||||||
url string
|
url string
|
||||||
ClientID string
|
ClientID string
|
||||||
|
@ -75,12 +75,12 @@ func New(opts Opts) (forge.Forge, error) {
|
||||||
}, nil
|
}, nil
|
||||||
}
|
}
|
||||||
|
|
||||||
// Name returns the string name of this driver
|
// Name returns the string name of this driver.
|
||||||
func (g *GitLab) Name() string {
|
func (g *GitLab) Name() string {
|
||||||
return "gitlab"
|
return "gitlab"
|
||||||
}
|
}
|
||||||
|
|
||||||
// URL returns the root url of a configured forge
|
// URL returns the root url of a configured forge.
|
||||||
func (g *GitLab) URL() string {
|
func (g *GitLab) URL() string {
|
||||||
return g.url
|
return g.url
|
||||||
}
|
}
|
||||||
|
@ -176,7 +176,7 @@ func (g *GitLab) Refresh(ctx context.Context, user *model.User) (bool, error) {
|
||||||
return true, nil
|
return true, nil
|
||||||
}
|
}
|
||||||
|
|
||||||
// Auth authenticates the session and returns the forge user login for the given token
|
// Auth authenticates the session and returns the forge user login for the given token.
|
||||||
func (g *GitLab) Auth(ctx context.Context, token, _ string) (string, error) {
|
func (g *GitLab) Auth(ctx context.Context, token, _ string) (string, error) {
|
||||||
client, err := newClient(g.url, token, g.SkipVerify)
|
client, err := newClient(g.url, token, g.SkipVerify)
|
||||||
if err != nil {
|
if err != nil {
|
||||||
|
@ -381,7 +381,7 @@ func (g *GitLab) File(ctx context.Context, user *model.User, repo *model.Repo, p
|
||||||
return file, err
|
return file, err
|
||||||
}
|
}
|
||||||
|
|
||||||
// Dir fetches a folder from the forge repository
|
// Dir fetches a folder from the forge repository.
|
||||||
func (g *GitLab) Dir(ctx context.Context, user *model.User, repo *model.Repo, pipeline *model.Pipeline, path string) ([]*forge_types.FileMeta, error) {
|
func (g *GitLab) Dir(ctx context.Context, user *model.User, repo *model.Repo, pipeline *model.Pipeline, path string) ([]*forge_types.FileMeta, error) {
|
||||||
client, err := newClient(g.url, user.Token, g.SkipVerify)
|
client, err := newClient(g.url, user.Token, g.SkipVerify)
|
||||||
if err != nil {
|
if err != nil {
|
||||||
|
@ -605,7 +605,7 @@ func (g *GitLab) Branches(ctx context.Context, user *model.User, repo *model.Rep
|
||||||
return branches, nil
|
return branches, nil
|
||||||
}
|
}
|
||||||
|
|
||||||
// BranchHead returns the sha of the head (latest commit) of the specified branch
|
// BranchHead returns the sha of the head (latest commit) of the specified branch.
|
||||||
func (g *GitLab) BranchHead(ctx context.Context, u *model.User, r *model.Repo, branch string) (*model.Commit, error) {
|
func (g *GitLab) BranchHead(ctx context.Context, u *model.User, r *model.Repo, branch string) (*model.Commit, error) {
|
||||||
token := common.UserToken(ctx, r, u)
|
token := common.UserToken(ctx, r, u)
|
||||||
client, err := newClient(g.url, token, g.SkipVerify)
|
client, err := newClient(g.url, token, g.SkipVerify)
|
||||||
|
|
|
@ -40,7 +40,7 @@ func (ae *AuthError) Error() string {
|
||||||
return err
|
return err
|
||||||
}
|
}
|
||||||
|
|
||||||
// check interface
|
// Check interface implementation at compile time.
|
||||||
var _ error = new(AuthError)
|
var _ error = new(AuthError)
|
||||||
|
|
||||||
var ErrNotImplemented = errors.New("not implemented")
|
var ErrNotImplemented = errors.New("not implemented")
|
||||||
|
|
|
@ -16,7 +16,7 @@ package types
|
||||||
|
|
||||||
import "sort"
|
import "sort"
|
||||||
|
|
||||||
// FileMeta represents a file in version control
|
// FileMeta represents a file in version control.
|
||||||
type FileMeta struct {
|
type FileMeta struct {
|
||||||
Name string
|
Name string
|
||||||
Data []byte
|
Data []byte
|
||||||
|
|
|
@ -22,13 +22,13 @@ import (
|
||||||
"github.com/golang-jwt/jwt/v5"
|
"github.com/golang-jwt/jwt/v5"
|
||||||
)
|
)
|
||||||
|
|
||||||
// JWTManager is a JSON web token manager
|
// JWTManager is a JSON web token manager.
|
||||||
type JWTManager struct {
|
type JWTManager struct {
|
||||||
secretKey string
|
secretKey string
|
||||||
tokenDuration time.Duration
|
tokenDuration time.Duration
|
||||||
}
|
}
|
||||||
|
|
||||||
// UserClaims is a custom JWT claims that contains some user's information
|
// UserClaims is a custom JWT claims that contains some user's information.
|
||||||
type AgentTokenClaims struct {
|
type AgentTokenClaims struct {
|
||||||
jwt.RegisteredClaims
|
jwt.RegisteredClaims
|
||||||
AgentID int64 `json:"agent_id"`
|
AgentID int64 `json:"agent_id"`
|
||||||
|
@ -36,12 +36,12 @@ type AgentTokenClaims struct {
|
||||||
|
|
||||||
const jwtTokenDuration = 1 * time.Hour
|
const jwtTokenDuration = 1 * time.Hour
|
||||||
|
|
||||||
// NewJWTManager returns a new JWT manager
|
// NewJWTManager returns a new JWT manager.
|
||||||
func NewJWTManager(secretKey string) *JWTManager {
|
func NewJWTManager(secretKey string) *JWTManager {
|
||||||
return &JWTManager{secretKey, jwtTokenDuration}
|
return &JWTManager{secretKey, jwtTokenDuration}
|
||||||
}
|
}
|
||||||
|
|
||||||
// Generate generates and signs a new token for a user
|
// Generate generates and signs a new token for a user.
|
||||||
func (manager *JWTManager) Generate(agentID int64) (string, error) {
|
func (manager *JWTManager) Generate(agentID int64) (string, error) {
|
||||||
claims := AgentTokenClaims{
|
claims := AgentTokenClaims{
|
||||||
RegisteredClaims: jwt.RegisteredClaims{
|
RegisteredClaims: jwt.RegisteredClaims{
|
||||||
|
@ -60,7 +60,7 @@ func (manager *JWTManager) Generate(agentID int64) (string, error) {
|
||||||
return token.SignedString([]byte(manager.secretKey))
|
return token.SignedString([]byte(manager.secretKey))
|
||||||
}
|
}
|
||||||
|
|
||||||
// Verify verifies the access token string and return a user claim if the token is valid
|
// Verify verifies the access token string and return a user claim if the token is valid.
|
||||||
func (manager *JWTManager) Verify(accessToken string) (*AgentTokenClaims, error) {
|
func (manager *JWTManager) Verify(accessToken string) (*AgentTokenClaims, error) {
|
||||||
token, err := jwt.ParseWithClaims(
|
token, err := jwt.ParseWithClaims(
|
||||||
accessToken,
|
accessToken,
|
||||||
|
|
|
@ -13,8 +13,6 @@
|
||||||
// WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
|
// WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
|
||||||
// See the License for the specific language governing permissions and
|
// See the License for the specific language governing permissions and
|
||||||
// limitations under the License.
|
// limitations under the License.
|
||||||
//
|
|
||||||
// This file has been modified by Informatyka Boguslawski sp. z o.o. sp.k.
|
|
||||||
|
|
||||||
package grpc
|
package grpc
|
||||||
|
|
||||||
|
@ -50,7 +48,7 @@ type RPC struct {
|
||||||
pipelineCount *prometheus.CounterVec
|
pipelineCount *prometheus.CounterVec
|
||||||
}
|
}
|
||||||
|
|
||||||
// Next implements the rpc.Next function
|
// Next implements the rpc.Next function.
|
||||||
func (s *RPC) Next(c context.Context, agentFilter rpc.Filter) (*rpc.Workflow, error) {
|
func (s *RPC) Next(c context.Context, agentFilter rpc.Filter) (*rpc.Workflow, error) {
|
||||||
if hostname, err := s.getHostnameFromContext(c); err == nil {
|
if hostname, err := s.getHostnameFromContext(c); err == nil {
|
||||||
log.Debug().Msgf("agent connected: %s: polling", hostname)
|
log.Debug().Msgf("agent connected: %s: polling", hostname)
|
||||||
|
@ -88,17 +86,17 @@ func (s *RPC) Next(c context.Context, agentFilter rpc.Filter) (*rpc.Workflow, er
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
// Wait implements the rpc.Wait function
|
// Wait implements the rpc.Wait function.
|
||||||
func (s *RPC) Wait(c context.Context, id string) error {
|
func (s *RPC) Wait(c context.Context, id string) error {
|
||||||
return s.queue.Wait(c, id)
|
return s.queue.Wait(c, id)
|
||||||
}
|
}
|
||||||
|
|
||||||
// Extend implements the rpc.Extend function
|
// Extend implements the rpc.Extend function.
|
||||||
func (s *RPC) Extend(c context.Context, id string) error {
|
func (s *RPC) Extend(c context.Context, id string) error {
|
||||||
return s.queue.Extend(c, id)
|
return s.queue.Extend(c, id)
|
||||||
}
|
}
|
||||||
|
|
||||||
// Update implements the rpc.Update function
|
// Update implements the rpc.Update function.
|
||||||
func (s *RPC) Update(_ context.Context, id string, state rpc.State) error {
|
func (s *RPC) Update(_ context.Context, id string, state rpc.State) error {
|
||||||
workflowID, err := strconv.ParseInt(id, 10, 64)
|
workflowID, err := strconv.ParseInt(id, 10, 64)
|
||||||
if err != nil {
|
if err != nil {
|
||||||
|
@ -164,7 +162,7 @@ func (s *RPC) Update(_ context.Context, id string, state rpc.State) error {
|
||||||
return nil
|
return nil
|
||||||
}
|
}
|
||||||
|
|
||||||
// Init implements the rpc.Init function
|
// Init implements the rpc.Init function.
|
||||||
func (s *RPC) Init(c context.Context, id string, state rpc.State) error {
|
func (s *RPC) Init(c context.Context, id string, state rpc.State) error {
|
||||||
stepID, err := strconv.ParseInt(id, 10, 64)
|
stepID, err := strconv.ParseInt(id, 10, 64)
|
||||||
if err != nil {
|
if err != nil {
|
||||||
|
@ -230,7 +228,7 @@ func (s *RPC) Init(c context.Context, id string, state rpc.State) error {
|
||||||
return nil
|
return nil
|
||||||
}
|
}
|
||||||
|
|
||||||
// Done implements the rpc.Done function
|
// Done implements the rpc.Done function.
|
||||||
func (s *RPC) Done(c context.Context, id string, state rpc.State) error {
|
func (s *RPC) Done(c context.Context, id string, state rpc.State) error {
|
||||||
workflowID, err := strconv.ParseInt(id, 10, 64)
|
workflowID, err := strconv.ParseInt(id, 10, 64)
|
||||||
if err != nil {
|
if err != nil {
|
||||||
|
@ -319,7 +317,7 @@ func (s *RPC) Done(c context.Context, id string, state rpc.State) error {
|
||||||
return nil
|
return nil
|
||||||
}
|
}
|
||||||
|
|
||||||
// Log implements the rpc.Log function
|
// Log implements the rpc.Log function.
|
||||||
func (s *RPC) Log(c context.Context, _logEntry *rpc.LogEntry) error {
|
func (s *RPC) Log(c context.Context, _logEntry *rpc.LogEntry) error {
|
||||||
// convert rpc log_entry to model.log_entry
|
// convert rpc log_entry to model.log_entry
|
||||||
step, err := s.store.StepByUUID(_logEntry.StepUUID)
|
step, err := s.store.StepByUUID(_logEntry.StepUUID)
|
||||||
|
|
|
@ -21,15 +21,17 @@ import (
|
||||||
"go.woodpecker-ci.org/woodpecker/v2/server/model"
|
"go.woodpecker-ci.org/woodpecker/v2/server/model"
|
||||||
)
|
)
|
||||||
|
|
||||||
// TODO (bradrydzewski) writing to subscribers is currently a blocking
|
// TODO: (bradrydzewski) writing to subscribers is currently a blocking
|
||||||
// operation and does not protect against slow clients from locking
|
// operation and does not protect against slow clients from locking
|
||||||
// the stream. This should be resolved.
|
// the stream. This should be resolved.
|
||||||
|
|
||||||
// TODO (bradrydzewski) implement a mux.Info to fetch information and
|
//nolint:godot
|
||||||
|
// TODO: (bradrydzewski) implement a mux.Info to fetch information and
|
||||||
// statistics for the multiplexer. Streams, subscribers, etc
|
// statistics for the multiplexer. Streams, subscribers, etc
|
||||||
// mux.Info()
|
// mux.Info()
|
||||||
|
|
||||||
// TODO (bradrydzewski) refactor code to place publisher and subscriber
|
//nolint:godot
|
||||||
|
// TODO: (bradrydzewski) refactor code to place publisher and subscriber
|
||||||
// operations in separate files with more encapsulated logic.
|
// operations in separate files with more encapsulated logic.
|
||||||
// sub.push()
|
// sub.push()
|
||||||
// sub.join()
|
// sub.join()
|
||||||
|
|
|
@ -29,7 +29,7 @@ type Agent struct {
|
||||||
NoSchedule bool `json:"no_schedule" xorm:"no_schedule"`
|
NoSchedule bool `json:"no_schedule" xorm:"no_schedule"`
|
||||||
} // @name Agent
|
} // @name Agent
|
||||||
|
|
||||||
// TableName return database table name for xorm
|
// TableName return database table name for xorm.
|
||||||
func (Agent) TableName() string {
|
func (Agent) TableName() string {
|
||||||
return "agents"
|
return "agents"
|
||||||
}
|
}
|
||||||
|
|
|
@ -24,7 +24,7 @@ type Config struct {
|
||||||
Data []byte `json:"data" xorm:"LONGBLOB 'config_data'"`
|
Data []byte `json:"data" xorm:"LONGBLOB 'config_data'"`
|
||||||
} // @name Config
|
} // @name Config
|
||||||
|
|
||||||
// PipelineConfig is the n:n relation between Pipeline and Config
|
// PipelineConfig is the n:n relation between Pipeline and Config.
|
||||||
type PipelineConfig struct {
|
type PipelineConfig struct {
|
||||||
ConfigID int64 `json:"-" xorm:"UNIQUE(s) NOT NULL 'config_id'"`
|
ConfigID int64 `json:"-" xorm:"UNIQUE(s) NOT NULL 'config_id'"`
|
||||||
PipelineID int64 `json:"-" xorm:"UNIQUE(s) NOT NULL 'pipeline_id'"`
|
PipelineID int64 `json:"-" xorm:"UNIQUE(s) NOT NULL 'pipeline_id'"`
|
||||||
|
|
|
@ -50,7 +50,7 @@ func (s WebhookEvent) Validate() error {
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
// StatusValue represent pipeline states woodpecker know
|
// StatusValue represent pipeline states woodpecker know.
|
||||||
type StatusValue string // @name StatusValue
|
type StatusValue string // @name StatusValue
|
||||||
|
|
||||||
const (
|
const (
|
||||||
|
@ -66,7 +66,7 @@ const (
|
||||||
StatusCreated StatusValue = "created" // created / internal use only
|
StatusCreated StatusValue = "created" // created / internal use only
|
||||||
)
|
)
|
||||||
|
|
||||||
// SCMKind represent different version control systems
|
// SCMKind represent different version control systems.
|
||||||
type SCMKind string // @name SCMKind
|
type SCMKind string // @name SCMKind
|
||||||
|
|
||||||
const (
|
const (
|
||||||
|
@ -76,7 +76,7 @@ const (
|
||||||
RepoPerforce SCMKind = "perforce"
|
RepoPerforce SCMKind = "perforce"
|
||||||
)
|
)
|
||||||
|
|
||||||
// RepoVisibility represent to what state a repo in woodpecker is visible to others
|
// RepoVisibility represent to what state a repo in woodpecker is visible to others.
|
||||||
type RepoVisibility string // @name RepoVisibility
|
type RepoVisibility string // @name RepoVisibility
|
||||||
|
|
||||||
const (
|
const (
|
||||||
|
|
|
@ -31,12 +31,12 @@ type Cron struct {
|
||||||
Branch string `json:"branch"`
|
Branch string `json:"branch"`
|
||||||
} // @name Cron
|
} // @name Cron
|
||||||
|
|
||||||
// TableName returns the database table name for xorm
|
// TableName returns the database table name for xorm.
|
||||||
func (Cron) TableName() string {
|
func (Cron) TableName() string {
|
||||||
return "crons"
|
return "crons"
|
||||||
}
|
}
|
||||||
|
|
||||||
// Validate a cron
|
// Validate ensures cron has a valid name and schedule.
|
||||||
func (c *Cron) Validate() error {
|
func (c *Cron) Validate() error {
|
||||||
if c.Name == "" {
|
if c.Name == "" {
|
||||||
return fmt.Errorf("name is required")
|
return fmt.Errorf("name is required")
|
||||||
|
|
|
@ -24,7 +24,7 @@ type Org struct {
|
||||||
Private bool `json:"-" xorm:"private"`
|
Private bool `json:"-" xorm:"private"`
|
||||||
} // @name Org
|
} // @name Org
|
||||||
|
|
||||||
// TableName return database table name for xorm
|
// TableName return database table name for xorm.
|
||||||
func (Org) TableName() string {
|
func (Org) TableName() string {
|
||||||
return "orgs"
|
return "orgs"
|
||||||
}
|
}
|
||||||
|
|
|
@ -28,7 +28,7 @@ type Perm struct {
|
||||||
Updated int64 `json:"updated" xorm:"updated"`
|
Updated int64 `json:"updated" xorm:"updated"`
|
||||||
} // @name Perm
|
} // @name Perm
|
||||||
|
|
||||||
// TableName return database table name for xorm
|
// TableName return database table name for xorm.
|
||||||
func (Perm) TableName() string {
|
func (Perm) TableName() string {
|
||||||
return "perms"
|
return "perms"
|
||||||
}
|
}
|
||||||
|
|
|
@ -59,12 +59,12 @@ type PipelineFilter struct {
|
||||||
After int64
|
After int64
|
||||||
}
|
}
|
||||||
|
|
||||||
// TableName return database table name for xorm
|
// TableName return database table name for xorm.
|
||||||
func (Pipeline) TableName() string {
|
func (Pipeline) TableName() string {
|
||||||
return "pipelines"
|
return "pipelines"
|
||||||
}
|
}
|
||||||
|
|
||||||
// IsMultiPipeline checks if step list contain more than one parent step
|
// IsMultiPipeline checks if step list contain more than one parent step.
|
||||||
func (p Pipeline) IsMultiPipeline() bool {
|
func (p Pipeline) IsMultiPipeline() bool {
|
||||||
return len(p.Workflows) > 1
|
return len(p.Workflows) > 1
|
||||||
}
|
}
|
||||||
|
|
|
@ -53,7 +53,7 @@ type Repo struct {
|
||||||
NetrcOnlyTrusted bool `json:"netrc_only_trusted" xorm:"NOT NULL DEFAULT true 'netrc_only_trusted'"`
|
NetrcOnlyTrusted bool `json:"netrc_only_trusted" xorm:"NOT NULL DEFAULT true 'netrc_only_trusted'"`
|
||||||
} // @name Repo
|
} // @name Repo
|
||||||
|
|
||||||
// TableName return database table name for xorm
|
// TableName return database table name for xorm.
|
||||||
func (Repo) TableName() string {
|
func (Repo) TableName() string {
|
||||||
return "repos"
|
return "repos"
|
||||||
}
|
}
|
||||||
|
|
|
@ -14,7 +14,7 @@
|
||||||
|
|
||||||
package model
|
package model
|
||||||
|
|
||||||
// ResourceLimit is the resource limit to set on pipeline steps
|
// ResourceLimit is the resource limit to set on pipeline steps.
|
||||||
type ResourceLimit struct {
|
type ResourceLimit struct {
|
||||||
MemSwapLimit int64
|
MemSwapLimit int64
|
||||||
MemLimit int64
|
MemLimit int64
|
||||||
|
|
|
@ -54,12 +54,12 @@ type Secret struct {
|
||||||
Events []WebhookEvent `json:"events" xorm:"json 'secret_events'"`
|
Events []WebhookEvent `json:"events" xorm:"json 'secret_events'"`
|
||||||
} // @name Secret
|
} // @name Secret
|
||||||
|
|
||||||
// TableName return database table name for xorm
|
// TableName return database table name for xorm.
|
||||||
func (Secret) TableName() string {
|
func (Secret) TableName() string {
|
||||||
return "secrets"
|
return "secrets"
|
||||||
}
|
}
|
||||||
|
|
||||||
// BeforeInsert will sort events before inserted into database
|
// BeforeInsert will sort events before inserted into database.
|
||||||
func (s *Secret) BeforeInsert() {
|
func (s *Secret) BeforeInsert() {
|
||||||
s.Events = sortEvents(s.Events)
|
s.Events = sortEvents(s.Events)
|
||||||
}
|
}
|
||||||
|
|
|
@ -15,11 +15,13 @@
|
||||||
|
|
||||||
package model
|
package model
|
||||||
|
|
||||||
// Different ways to handle failure states
|
// Different ways to handle failure states.
|
||||||
const (
|
const (
|
||||||
FailureIgnore = "ignore"
|
FailureIgnore = "ignore"
|
||||||
FailureFail = "fail"
|
FailureFail = "fail"
|
||||||
// FailureCancel = "cancel" // Not implemented yet
|
//nolint:godot
|
||||||
|
// TODO: Not implemented yet.
|
||||||
|
// FailureCancel = "cancel"
|
||||||
)
|
)
|
||||||
|
|
||||||
// Step represents a process in the pipeline.
|
// Step represents a process in the pipeline.
|
||||||
|
@ -39,7 +41,7 @@ type Step struct {
|
||||||
Type StepType `json:"type,omitempty" xorm:"step_type"`
|
Type StepType `json:"type,omitempty" xorm:"step_type"`
|
||||||
} // @name Step
|
} // @name Step
|
||||||
|
|
||||||
// TableName return database table name for xorm
|
// TableName return database table name for xorm.
|
||||||
func (Step) TableName() string {
|
func (Step) TableName() string {
|
||||||
return "steps"
|
return "steps"
|
||||||
}
|
}
|
||||||
|
@ -54,7 +56,7 @@ func (p *Step) Failing() bool {
|
||||||
return p.Failure == FailureFail && (p.State == StatusError || p.State == StatusKilled || p.State == StatusFailure)
|
return p.Failure == FailureFail && (p.State == StatusError || p.State == StatusKilled || p.State == StatusFailure)
|
||||||
}
|
}
|
||||||
|
|
||||||
// StepType identifies the type of step
|
// StepType identifies the type of step.
|
||||||
type StepType string // @name StepType
|
type StepType string // @name StepType
|
||||||
|
|
||||||
const (
|
const (
|
||||||
|
|
|
@ -30,7 +30,7 @@ type Task struct {
|
||||||
AgentID int64 `json:"agent_id" xorm:"'agent_id'"`
|
AgentID int64 `json:"agent_id" xorm:"'agent_id'"`
|
||||||
} // @name Task
|
} // @name Task
|
||||||
|
|
||||||
// TableName return database table name for xorm
|
// TableName return database table name for xorm.
|
||||||
func (Task) TableName() string {
|
func (Task) TableName() string {
|
||||||
return "tasks"
|
return "tasks"
|
||||||
}
|
}
|
||||||
|
@ -41,7 +41,7 @@ func (t *Task) String() string {
|
||||||
return sb.String()
|
return sb.String()
|
||||||
}
|
}
|
||||||
|
|
||||||
// ShouldRun tells if a task should be run or skipped, based on dependencies
|
// ShouldRun tells if a task should be run or skipped, based on dependencies.
|
||||||
func (t *Task) ShouldRun() bool {
|
func (t *Task) ShouldRun() bool {
|
||||||
if t.runsOnFailure() && t.runsOnSuccess() {
|
if t.runsOnFailure() && t.runsOnSuccess() {
|
||||||
return true
|
return true
|
||||||
|
|
|
@ -20,7 +20,7 @@ import (
|
||||||
"regexp"
|
"regexp"
|
||||||
)
|
)
|
||||||
|
|
||||||
// validate a username (e.g. from github)
|
// Validate a username (e.g. from github).
|
||||||
var reUsername = regexp.MustCompile("^[a-zA-Z0-9-_.]+$")
|
var reUsername = regexp.MustCompile("^[a-zA-Z0-9-_.]+$")
|
||||||
|
|
||||||
var errUserLoginInvalid = errors.New("invalid user login")
|
var errUserLoginInvalid = errors.New("invalid user login")
|
||||||
|
@ -73,7 +73,7 @@ type User struct {
|
||||||
OrgID int64 `json:"org_id" xorm:"user_org_id"`
|
OrgID int64 `json:"org_id" xorm:"user_org_id"`
|
||||||
} // @name User
|
} // @name User
|
||||||
|
|
||||||
// TableName return database table name for xorm
|
// TableName return database table name for xorm.
|
||||||
func (User) TableName() string {
|
func (User) TableName() string {
|
||||||
return "users"
|
return "users"
|
||||||
}
|
}
|
||||||
|
|
|
@ -32,7 +32,7 @@ type Workflow struct {
|
||||||
Children []*Step `json:"children,omitempty" xorm:"-"`
|
Children []*Step `json:"children,omitempty" xorm:"-"`
|
||||||
}
|
}
|
||||||
|
|
||||||
// TableName return database table name for xorm
|
// TableName return database table name for xorm.
|
||||||
func (Workflow) TableName() string {
|
func (Workflow) TableName() string {
|
||||||
return "workflows"
|
return "workflows"
|
||||||
}
|
}
|
||||||
|
@ -47,7 +47,7 @@ func (p *Workflow) Failing() bool {
|
||||||
return p.State == StatusError || p.State == StatusKilled || p.State == StatusFailure
|
return p.State == StatusError || p.State == StatusKilled || p.State == StatusFailure
|
||||||
}
|
}
|
||||||
|
|
||||||
// IsThereRunningStage determine if it contains workflows running or pending to run
|
// IsThereRunningStage determine if it contains workflows running or pending to run.
|
||||||
// TODO: return false based on depends_on (https://github.com/woodpecker-ci/woodpecker/pull/730#discussion_r795681697)
|
// TODO: return false based on depends_on (https://github.com/woodpecker-ci/woodpecker/pull/730#discussion_r795681697)
|
||||||
func IsThereRunningStage(workflows []*Workflow) bool {
|
func IsThereRunningStage(workflows []*Workflow) bool {
|
||||||
for _, p := range workflows {
|
for _, p := range workflows {
|
||||||
|
@ -58,7 +58,7 @@ func IsThereRunningStage(workflows []*Workflow) bool {
|
||||||
return false
|
return false
|
||||||
}
|
}
|
||||||
|
|
||||||
// PipelineStatus determine pipeline status based on corresponding workflow list
|
// PipelineStatus determine pipeline status based on corresponding workflow list.
|
||||||
func PipelineStatus(workflows []*Workflow) StatusValue {
|
func PipelineStatus(workflows []*Workflow) StatusValue {
|
||||||
status := StatusSuccess
|
status := StatusSuccess
|
||||||
|
|
||||||
|
@ -71,7 +71,7 @@ func PipelineStatus(workflows []*Workflow) StatusValue {
|
||||||
return status
|
return status
|
||||||
}
|
}
|
||||||
|
|
||||||
// WorkflowStatus determine workflow status based on corresponding step list
|
// WorkflowStatus determine workflow status based on corresponding step list.
|
||||||
func WorkflowStatus(steps []*Step) StatusValue {
|
func WorkflowStatus(steps []*Step) StatusValue {
|
||||||
status := StatusSuccess
|
status := StatusSuccess
|
||||||
|
|
||||||
|
|
|
@ -27,7 +27,7 @@ import (
|
||||||
)
|
)
|
||||||
|
|
||||||
// Approve update the status to pending for a blocked pipeline because of a gated repo
|
// Approve update the status to pending for a blocked pipeline because of a gated repo
|
||||||
// and start them afterward
|
// and start them afterward.
|
||||||
func Approve(ctx context.Context, store store.Store, currentPipeline *model.Pipeline, user *model.User, repo *model.Repo) (*model.Pipeline, error) {
|
func Approve(ctx context.Context, store store.Store, currentPipeline *model.Pipeline, user *model.User, repo *model.Repo) (*model.Pipeline, error) {
|
||||||
if currentPipeline.Status != model.StatusBlocked {
|
if currentPipeline.Status != model.StatusBlocked {
|
||||||
return nil, ErrBadRequest{Msg: fmt.Sprintf("cannot approve a pipeline with status %s", currentPipeline.Status)}
|
return nil, ErrBadRequest{Msg: fmt.Sprintf("cannot approve a pipeline with status %s", currentPipeline.Status)}
|
||||||
|
|
|
@ -32,7 +32,7 @@ import (
|
||||||
|
|
||||||
var skipPipelineRegex = regexp.MustCompile(`\[(?i:ci *skip|skip *ci)\]`)
|
var skipPipelineRegex = regexp.MustCompile(`\[(?i:ci *skip|skip *ci)\]`)
|
||||||
|
|
||||||
// Create a new pipeline and start it
|
// Create a new pipeline and start it.
|
||||||
func Create(ctx context.Context, _store store.Store, repo *model.Repo, pipeline *model.Pipeline) (*model.Pipeline, error) {
|
func Create(ctx context.Context, _store store.Store, repo *model.Repo, pipeline *model.Pipeline) (*model.Pipeline, error) {
|
||||||
repoUser, err := _store.GetUser(repo.UserID)
|
repoUser, err := _store.GetUser(repo.UserID)
|
||||||
if err != nil {
|
if err != nil {
|
||||||
|
|
|
@ -25,7 +25,7 @@ import (
|
||||||
"go.woodpecker-ci.org/woodpecker/v2/server/store"
|
"go.woodpecker-ci.org/woodpecker/v2/server/store"
|
||||||
)
|
)
|
||||||
|
|
||||||
// Decline updates the status to declined for blocked pipelines because of a gated repo
|
// Decline updates the status to declined for blocked pipelines because of a gated repo.
|
||||||
func Decline(ctx context.Context, store store.Store, pipeline *model.Pipeline, user *model.User, repo *model.Repo) (*model.Pipeline, error) {
|
func Decline(ctx context.Context, store store.Store, pipeline *model.Pipeline, user *model.User, repo *model.Repo) (*model.Pipeline, error) {
|
||||||
forge, err := server.Config.Services.Manager.ForgeFromRepo(repo)
|
forge, err := server.Config.Services.Manager.ForgeFromRepo(repo)
|
||||||
if err != nil {
|
if err != nil {
|
||||||
|
|
|
@ -117,7 +117,7 @@ func createPipelineItems(c context.Context, forge forge.Forge, store store.Store
|
||||||
|
|
||||||
// setPipelineStepsOnPipeline is the link between pipeline representation in "pipeline package" and server
|
// setPipelineStepsOnPipeline is the link between pipeline representation in "pipeline package" and server
|
||||||
// to be specific this func currently is used to convert the pipeline.Item list (crafted by StepBuilder.Build()) into
|
// to be specific this func currently is used to convert the pipeline.Item list (crafted by StepBuilder.Build()) into
|
||||||
// a pipeline that can be stored in the database by the server
|
// a pipeline that can be stored in the database by the server.
|
||||||
func setPipelineStepsOnPipeline(pipeline *model.Pipeline, pipelineItems []*stepbuilder.Item) *model.Pipeline {
|
func setPipelineStepsOnPipeline(pipeline *model.Pipeline, pipelineItems []*stepbuilder.Item) *model.Pipeline {
|
||||||
var pidSequence int
|
var pidSequence int
|
||||||
for _, item := range pipelineItems {
|
for _, item := range pipelineItems {
|
||||||
|
|
|
@ -27,7 +27,7 @@ import (
|
||||||
"go.woodpecker-ci.org/woodpecker/v2/server/store"
|
"go.woodpecker-ci.org/woodpecker/v2/server/store"
|
||||||
)
|
)
|
||||||
|
|
||||||
// Restart a pipeline by creating a new one out of the old and start it
|
// Restart a pipeline by creating a new one out of the old and start it.
|
||||||
func Restart(ctx context.Context, store store.Store, lastPipeline *model.Pipeline, user *model.User, repo *model.Repo, envs map[string]string) (*model.Pipeline, error) {
|
func Restart(ctx context.Context, store store.Store, lastPipeline *model.Pipeline, user *model.User, repo *model.Repo, envs map[string]string) (*model.Pipeline, error) {
|
||||||
forge, err := server.Config.Services.Manager.ForgeFromRepo(repo)
|
forge, err := server.Config.Services.Manager.ForgeFromRepo(repo)
|
||||||
if err != nil {
|
if err != nil {
|
||||||
|
|
Some files were not shown because too many files have changed in this diff Show more
Loading…
Reference in a new issue