Skip to content

Commit 5c2625a

Browse files
fix typo and errors
1 parent d7373b5 commit 5c2625a

File tree

3 files changed

+13
-8
lines changed

3 files changed

+13
-8
lines changed

modules/packages/arch/metadata.go

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -140,6 +140,7 @@ func ParsePackage(r *packages.HashedBuffer) (*Package, error) {
140140
case ".PKGINFO":
141141
pkg, err = ParsePackageInfo(tarballType, f)
142142
if err != nil {
143+
_ = f.Close()
143144
return nil, err
144145
}
145146
case ".MTREE":

services/packages/arch/repository.go

Lines changed: 9 additions & 8 deletions
Original file line numberDiff line numberDiff line change
@@ -175,15 +175,18 @@ func createDB(ctx context.Context, ownerID int64, group, arch string) (*packages
175175
if err != nil {
176176
return nil, err
177177
}
178+
defer db.Close()
178179
gw := gzip.NewWriter(db)
180+
defer gw.Close()
179181
tw := tar.NewWriter(gw)
182+
defer tw.Close()
180183
count := 0
181184
for _, pkg := range pkgs {
182185
versions, err := packages_model.GetVersionsByPackageName(
183186
ctx, ownerID, packages_model.TypeArch, pkg.Name,
184187
)
185188
if err != nil {
186-
return nil, errors.Join(tw.Close(), gw.Close(), db.Close(), err)
189+
return nil, err
187190
}
188191
sort.Slice(versions, func(i, j int) bool {
189192
return versions[i].CreatedUnix > versions[j].CreatedUnix
@@ -192,7 +195,7 @@ func createDB(ctx context.Context, ownerID int64, group, arch string) (*packages
192195
for _, ver := range versions {
193196
files, err := packages_model.GetFilesByVersionID(ctx, ver.ID)
194197
if err != nil {
195-
return nil, errors.Join(tw.Close(), gw.Close(), db.Close(), err)
198+
return nil, err
196199
}
197200
var pf *packages_model.PackageFile
198201
for _, file := range files {
@@ -215,7 +218,7 @@ func createDB(ctx context.Context, ownerID int64, group, arch string) (*packages
215218
ctx, packages_model.PropertyTypeFile, pf.ID, arch_module.PropertyDescription,
216219
)
217220
if err != nil {
218-
return nil, errors.Join(tw.Close(), gw.Close(), db.Close(), err)
221+
return nil, err
219222
}
220223
if len(pps) >= 1 {
221224
meta := []byte(pps[0].Value)
@@ -225,20 +228,18 @@ func createDB(ctx context.Context, ownerID int64, group, arch string) (*packages
225228
Mode: int64(os.ModePerm),
226229
}
227230
if err = tw.WriteHeader(header); err != nil {
228-
return nil, errors.Join(tw.Close(), gw.Close(), db.Close(), err)
231+
return nil, err
229232
}
230233
if _, err := tw.Write(meta); err != nil {
231-
return nil, errors.Join(tw.Close(), gw.Close(), db.Close(), err)
234+
return nil, err
232235
}
233236
count++
234237
break
235238
}
236239
}
237240
}
238-
defer gw.Close()
239-
defer tw.Close()
240241
if count == 0 {
241-
return nil, errors.Join(db.Close(), io.EOF)
242+
return nil, io.EOF
242243
}
243244
return db, nil
244245
}

tests/integration/api_packages_arch_test.go

Lines changed: 3 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -332,6 +332,9 @@ func getProperty(data, key string) string {
332332

333333
func listTarGzFiles(data []byte) (fstest.MapFS, error) {
334334
reader, err := gzip.NewReader(bytes.NewBuffer(data))
335+
if err != nil {
336+
return nil, err
337+
}
335338
defer reader.Close()
336339
if err != nil {
337340
return nil, err

0 commit comments

Comments
 (0)