Skip to content

Commit 56db7b7

Browse files
authored
Merge branch 'main' into inline-align
2 parents d6a0001 + a14db5c commit 56db7b7

File tree

35 files changed

+485
-255
lines changed

35 files changed

+485
-255
lines changed

go.mod

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -91,7 +91,7 @@ require (
9191
github.com/minio/minio-go/v7 v7.0.91
9292
github.com/msteinert/pam v1.2.0
9393
github.com/nektos/act v0.2.63
94-
github.com/niklasfasching/go-org v1.7.0
94+
github.com/niklasfasching/go-org v1.8.0
9595
github.com/olivere/elastic/v7 v7.0.32
9696
github.com/opencontainers/go-digest v1.0.0
9797
github.com/opencontainers/image-spec v1.1.1

go.sum

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -551,8 +551,8 @@ github.com/msteinert/pam v1.2.0 h1:mYfjlvN2KYs2Pb9G6nb/1f/nPfAttT/Jee5Sq9r3bGE=
551551
github.com/msteinert/pam v1.2.0/go.mod h1:d2n0DCUK8rGecChV3JzvmsDjOY4R7AYbsNxAT+ftQl0=
552552
github.com/munnerz/goautoneg v0.0.0-20191010083416-a7dc8b61c822 h1:C3w9PqII01/Oq1c1nUAm88MOHcQC9l5mIlSMApZMrHA=
553553
github.com/munnerz/goautoneg v0.0.0-20191010083416-a7dc8b61c822/go.mod h1:+n7T8mK8HuQTcFwEeznm/DIxMOiR9yIdICNftLE1DvQ=
554-
github.com/niklasfasching/go-org v1.7.0 h1:vyMdcMWWTe/XmANk19F4k8XGBYg0GQ/gJGMimOjGMek=
555-
github.com/niklasfasching/go-org v1.7.0/go.mod h1:WuVm4d45oePiE0eX25GqTDQIt/qPW1T9DGkRscqLW5o=
554+
github.com/niklasfasching/go-org v1.8.0 h1:WyGLaajLLp8JbQzkmapZ1y0MOzKuKV47HkZRloi+HGY=
555+
github.com/niklasfasching/go-org v1.8.0/go.mod h1:e2A9zJs7cdONrEGs3gvxCcaAEpwwPNPG7csDpXckMNg=
556556
github.com/nwaples/rardecode v1.1.0/go.mod h1:5DzqNKiOdpKKBH87u8VlvAnPZMXcGRhxWkRpHbbfGS0=
557557
github.com/nwaples/rardecode v1.1.3 h1:cWCaZwfM5H7nAD6PyEdcVnczzV8i/JtotnyW/dD9lEc=
558558
github.com/nwaples/rardecode v1.1.3/go.mod h1:5DzqNKiOdpKKBH87u8VlvAnPZMXcGRhxWkRpHbbfGS0=

models/activities/action.go

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -191,7 +191,7 @@ func (a *Action) LoadActUser(ctx context.Context) {
191191
return
192192
}
193193
var err error
194-
a.ActUser, err = user_model.GetUserByID(ctx, a.ActUserID)
194+
a.ActUser, err = user_model.GetPossibleUserByID(ctx, a.ActUserID)
195195
if err == nil {
196196
return
197197
} else if user_model.IsErrUserNotExist(err) {

models/issues/pull.go

Lines changed: 0 additions & 6 deletions
Original file line numberDiff line numberDiff line change
@@ -649,12 +649,6 @@ func GetAllUnmergedAgitPullRequestByPoster(ctx context.Context, uid int64) ([]*P
649649
return pulls, err
650650
}
651651

652-
// Update updates all fields of pull request.
653-
func (pr *PullRequest) Update(ctx context.Context) error {
654-
_, err := db.GetEngine(ctx).ID(pr.ID).AllCols().Update(pr)
655-
return err
656-
}
657-
658652
// UpdateCols updates specific fields of pull request.
659653
func (pr *PullRequest) UpdateCols(ctx context.Context, cols ...string) error {
660654
_, err := db.GetEngine(ctx).ID(pr.ID).Cols(cols...).Update(pr)

models/issues/pull_test.go

Lines changed: 0 additions & 13 deletions
Original file line numberDiff line numberDiff line change
@@ -248,19 +248,6 @@ func TestGetPullRequestByIssueID(t *testing.T) {
248248
assert.True(t, issues_model.IsErrPullRequestNotExist(err))
249249
}
250250

251-
func TestPullRequest_Update(t *testing.T) {
252-
assert.NoError(t, unittest.PrepareTestDatabase())
253-
pr := unittest.AssertExistsAndLoadBean(t, &issues_model.PullRequest{ID: 1})
254-
pr.BaseBranch = "baseBranch"
255-
pr.HeadBranch = "headBranch"
256-
pr.Update(db.DefaultContext)
257-
258-
pr = unittest.AssertExistsAndLoadBean(t, &issues_model.PullRequest{ID: pr.ID})
259-
assert.Equal(t, "baseBranch", pr.BaseBranch)
260-
assert.Equal(t, "headBranch", pr.HeadBranch)
261-
unittest.CheckConsistencyFor(t, pr)
262-
}
263-
264251
func TestPullRequest_UpdateCols(t *testing.T) {
265252
assert.NoError(t, unittest.PrepareTestDatabase())
266253
pr := &issues_model.PullRequest{

models/packages/container/search.go

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -44,7 +44,7 @@ func (opts *BlobSearchOptions) toConds() builder.Cond {
4444
cond = cond.And(builder.Eq{"package_version.lower_version": strings.ToLower(opts.Tag)})
4545
}
4646
if opts.IsManifest {
47-
cond = cond.And(builder.Eq{"package_file.lower_name": ManifestFilename})
47+
cond = cond.And(builder.Eq{"package_file.lower_name": container_module.ManifestFilename})
4848
}
4949
if opts.OnlyLead {
5050
cond = cond.And(builder.Eq{"package_file.is_lead": true})
@@ -235,7 +235,7 @@ func SearchImageTags(ctx context.Context, opts *ImageTagsSearchOptions) ([]*pack
235235
func SearchExpiredUploadedBlobs(ctx context.Context, olderThan time.Duration) ([]*packages.PackageFile, error) {
236236
var cond builder.Cond = builder.Eq{
237237
"package_version.is_internal": true,
238-
"package_version.lower_version": UploadVersion,
238+
"package_version.lower_version": container_module.UploadVersion,
239239
"package.type": packages.TypeContainer,
240240
}
241241
cond = cond.And(builder.Lt{"package_file.created_unix": time.Now().Add(-olderThan).Unix()})

models/packages/descriptor.go

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -103,10 +103,10 @@ func (pd *PackageDescriptor) CalculateBlobSize() int64 {
103103

104104
// GetPackageDescriptor gets the package description for a version
105105
func GetPackageDescriptor(ctx context.Context, pv *PackageVersion) (*PackageDescriptor, error) {
106-
return getPackageDescriptor(ctx, pv, cache.NewEphemeralCache())
106+
return GetPackageDescriptorWithCache(ctx, pv, cache.NewEphemeralCache())
107107
}
108108

109-
func getPackageDescriptor(ctx context.Context, pv *PackageVersion, c *cache.EphemeralCache) (*PackageDescriptor, error) {
109+
func GetPackageDescriptorWithCache(ctx context.Context, pv *PackageVersion, c *cache.EphemeralCache) (*PackageDescriptor, error) {
110110
p, err := cache.GetWithEphemeralCache(ctx, c, "package", pv.PackageID, GetPackageByID)
111111
if err != nil {
112112
return nil, err
@@ -270,7 +270,7 @@ func GetPackageDescriptors(ctx context.Context, pvs []*PackageVersion) ([]*Packa
270270
func getPackageDescriptors(ctx context.Context, pvs []*PackageVersion, c *cache.EphemeralCache) ([]*PackageDescriptor, error) {
271271
pds := make([]*PackageDescriptor, 0, len(pvs))
272272
for _, pv := range pvs {
273-
pd, err := getPackageDescriptor(ctx, pv, c)
273+
pd, err := GetPackageDescriptorWithCache(ctx, pv, c)
274274
if err != nil {
275275
return nil, err
276276
}

models/repo/release.go

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -180,7 +180,7 @@ func AddReleaseAttachments(ctx context.Context, releaseID int64, attachmentUUIDs
180180
}
181181
attachments[i].ReleaseID = releaseID
182182
// No assign value could be 0, so ignore AllCols().
183-
if _, err = db.GetEngine(ctx).ID(attachments[i].ID).Update(attachments[i]); err != nil {
183+
if _, err = db.GetEngine(ctx).ID(attachments[i].ID).Cols("release_id").Update(attachments[i]); err != nil {
184184
return fmt.Errorf("update attachment [%d]: %w", attachments[i].ID, err)
185185
}
186186
}

models/repo/update.go

Lines changed: 6 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -42,12 +42,18 @@ func UpdateRepositoryUpdatedTime(ctx context.Context, repoID int64, updateTime t
4242

4343
// UpdateRepositoryColsWithAutoTime updates repository's columns
4444
func UpdateRepositoryColsWithAutoTime(ctx context.Context, repo *Repository, cols ...string) error {
45+
if len(cols) == 0 {
46+
return nil
47+
}
4548
_, err := db.GetEngine(ctx).ID(repo.ID).Cols(cols...).Update(repo)
4649
return err
4750
}
4851

4952
// UpdateRepositoryColsNoAutoTime updates repository's columns and but applies time change automatically
5053
func UpdateRepositoryColsNoAutoTime(ctx context.Context, repo *Repository, cols ...string) error {
54+
if len(cols) == 0 {
55+
return nil
56+
}
5157
_, err := db.GetEngine(ctx).ID(repo.ID).Cols(cols...).NoAutoTime().Update(repo)
5258
return err
5359
}

modules/git/commit_info_nogogit.go

Lines changed: 5 additions & 30 deletions
Original file line numberDiff line numberDiff line change
@@ -7,8 +7,6 @@ package git
77

88
import (
99
"context"
10-
"fmt"
11-
"io"
1210
"path"
1311
"sort"
1412

@@ -124,48 +122,25 @@ func GetLastCommitForPaths(ctx context.Context, commit *Commit, treePath string,
124122
return nil, err
125123
}
126124

127-
batchStdinWriter, batchReader, cancel, err := commit.repo.CatFileBatch(ctx)
128-
if err != nil {
129-
return nil, err
130-
}
131-
defer cancel()
132-
133125
commitsMap := map[string]*Commit{}
134126
commitsMap[commit.ID.String()] = commit
135127

136128
commitCommits := map[string]*Commit{}
137129
for path, commitID := range revs {
138-
c, ok := commitsMap[commitID]
139-
if ok {
140-
commitCommits[path] = c
130+
if len(commitID) == 0 {
141131
continue
142132
}
143133

144-
if len(commitID) == 0 {
134+
c, ok := commitsMap[commitID]
135+
if ok {
136+
commitCommits[path] = c
145137
continue
146138
}
147139

148-
_, err := batchStdinWriter.Write([]byte(commitID + "\n"))
149-
if err != nil {
150-
return nil, err
151-
}
152-
_, typ, size, err := ReadBatchLine(batchReader)
140+
c, err := commit.repo.GetCommit(commitID) // Ensure the commit exists in the repository
153141
if err != nil {
154142
return nil, err
155143
}
156-
if typ != "commit" {
157-
if err := DiscardFull(batchReader, size+1); err != nil {
158-
return nil, err
159-
}
160-
return nil, fmt.Errorf("unexpected type: %s for commit id: %s", typ, commitID)
161-
}
162-
c, err = CommitFromReader(commit.repo, MustIDFromString(commitID), io.LimitReader(batchReader, size))
163-
if err != nil {
164-
return nil, err
165-
}
166-
if _, err := batchReader.Discard(1); err != nil {
167-
return nil, err
168-
}
169144
commitCommits[path] = c
170145
}
171146

0 commit comments

Comments
 (0)