mirror of
https://github.com/woodpecker-ci/woodpecker.git
synced 2024-11-26 20:01:02 +00:00
52d3652f2e
Use IDs of the forge to fetch repositories instead of their names and owner names. This improves handling of renamed and transferred repos.
TODO
- [ ] try to support as many forges as possible
- [x] Gogs (no API)
- [ ] Bitbucket Server
- [x] Coding (no API?)
- [x] update repo every time it is fetched or received from the forge
- [x] if repo remote IDs are not available, use owner / name to get it
- [x] handle redirections (redirect a renamed repo to its new path)
- [x] ~~pull all repos once during migration to update ID (?)~~ issue fixed by on-demand loading of remote IDs
- [x] handle redirections in web UI
- [ ] improve handling of hooks after a repo was renamed (currently it checks for a redirection to the repo)
- [x] tests
- [x] `UNIQUE` constraint for remote IDs after migration shouldn't work (all repos have an empty string as remote ID)
close #854
close #648 partial
close https://codeberg.org/Codeberg-CI/feedback/issues/46
Possible follow-up PRs
- apply the same scheme on everything fetched from the remote (currently only users)
Co-authored-by: 6543 <6543@obermui.de>
112 lines
5 KiB
Go
112 lines
5 KiB
Go
// Copyright 2021 Woodpecker Authors
|
|
// Copyright 2018 Drone.IO Inc.
|
|
//
|
|
// Licensed under the Apache License, Version 2.0 (the "License");
|
|
// you may not use this file except in compliance with the License.
|
|
// You may obtain a copy of the License at
|
|
//
|
|
// http://www.apache.org/licenses/LICENSE-2.0
|
|
//
|
|
// Unless required by applicable law or agreed to in writing, software
|
|
// distributed under the License is distributed on an "AS IS" BASIS,
|
|
// WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
|
|
// See the License for the specific language governing permissions and
|
|
// limitations under the License.
|
|
|
|
package model
|
|
|
|
import (
|
|
"fmt"
|
|
"strings"
|
|
)
|
|
|
|
// Repo represents a repository.
|
|
//
|
|
// swagger:model repo
|
|
type Repo struct {
|
|
ID int64 `json:"id,omitempty" xorm:"pk autoincr 'repo_id'"`
|
|
UserID int64 `json:"-" xorm:"repo_user_id"`
|
|
RemoteID RemoteID `json:"-" xorm:"'remote_id'"`
|
|
Owner string `json:"owner" xorm:"UNIQUE(name) 'repo_owner'"`
|
|
Name string `json:"name" xorm:"UNIQUE(name) 'repo_name'"`
|
|
FullName string `json:"full_name" xorm:"UNIQUE 'repo_full_name'"`
|
|
Avatar string `json:"avatar_url,omitempty" xorm:"varchar(500) 'repo_avatar'"`
|
|
Link string `json:"link_url,omitempty" xorm:"varchar(1000) 'repo_link'"`
|
|
Clone string `json:"clone_url,omitempty" xorm:"varchar(1000) 'repo_clone'"`
|
|
Branch string `json:"default_branch,omitempty" xorm:"varchar(500) 'repo_branch'"`
|
|
SCMKind SCMKind `json:"scm,omitempty" xorm:"varchar(50) 'repo_scm'"`
|
|
Timeout int64 `json:"timeout,omitempty" xorm:"repo_timeout"`
|
|
Visibility RepoVisibly `json:"visibility" xorm:"varchar(10) 'repo_visibility'"`
|
|
IsSCMPrivate bool `json:"private" xorm:"repo_private"`
|
|
IsTrusted bool `json:"trusted" xorm:"repo_trusted"`
|
|
IsStarred bool `json:"starred,omitempty" xorm:"-"`
|
|
IsGated bool `json:"gated" xorm:"repo_gated"`
|
|
IsActive bool `json:"active" xorm:"repo_active"`
|
|
AllowPull bool `json:"allow_pr" xorm:"repo_allow_pr"`
|
|
Config string `json:"config_file" xorm:"varchar(500) 'repo_config_path'"`
|
|
Hash string `json:"-" xorm:"varchar(500) 'repo_hash'"`
|
|
Perm *Perm `json:"-" xorm:"-"`
|
|
CancelPreviousPipelineEvents []WebhookEvent `json:"cancel_previous_pipeline_events" xorm:"json 'cancel_previous_pipeline_events'"`
|
|
}
|
|
|
|
// TableName return database table name for xorm
|
|
func (Repo) TableName() string {
|
|
return "repos"
|
|
}
|
|
|
|
func (r *Repo) ResetVisibility() {
|
|
r.Visibility = VisibilityPublic
|
|
if r.IsSCMPrivate {
|
|
r.Visibility = VisibilityPrivate
|
|
}
|
|
}
|
|
|
|
// ParseRepo parses the repository owner and name from a string.
|
|
func ParseRepo(str string) (user, repo string, err error) {
|
|
parts := strings.Split(str, "/")
|
|
if len(parts) != 2 {
|
|
err = fmt.Errorf("Error: Invalid or missing repository. eg octocat/hello-world")
|
|
return
|
|
}
|
|
user = parts[0]
|
|
repo = parts[1]
|
|
return
|
|
}
|
|
|
|
// Update updates the repository with values from the given Repo.
|
|
func (r *Repo) Update(from *Repo) {
|
|
r.RemoteID = from.RemoteID
|
|
r.Owner = from.Owner
|
|
r.Name = from.Name
|
|
r.FullName = from.FullName
|
|
r.Avatar = from.Avatar
|
|
r.Link = from.Link
|
|
r.SCMKind = from.SCMKind
|
|
r.Clone = from.Clone
|
|
r.Branch = from.Branch
|
|
if from.IsSCMPrivate != r.IsSCMPrivate {
|
|
if from.IsSCMPrivate {
|
|
r.Visibility = VisibilityPrivate
|
|
} else {
|
|
r.Visibility = VisibilityPublic
|
|
}
|
|
}
|
|
r.IsSCMPrivate = from.IsSCMPrivate
|
|
}
|
|
|
|
// RepoPatch represents a repository patch object.
|
|
type RepoPatch struct {
|
|
Config *string `json:"config_file,omitempty"`
|
|
IsTrusted *bool `json:"trusted,omitempty"`
|
|
IsGated *bool `json:"gated,omitempty"`
|
|
Timeout *int64 `json:"timeout,omitempty"`
|
|
Visibility *string `json:"visibility,omitempty"`
|
|
AllowPull *bool `json:"allow_pr,omitempty"`
|
|
CancelPreviousPipelineEvents *[]WebhookEvent `json:"cancel_previous_pipeline_events"`
|
|
}
|
|
|
|
type RemoteID string
|
|
|
|
func (r RemoteID) IsValid() bool {
|
|
return r != "" && r != "0"
|
|
}
|