Skip to content

Commit 8efc4ca

Browse files
authored
Refactor packages (func name & UI) (#34773)
1. Use `OpenXxx` instead of `GetXxx` because the returned readers should be correctly closed, and clarify the behaviors of the functions: they increase the download counter 2. Use `packages-content` styles instead of `issue-content`
1 parent 46a1d52 commit 8efc4ca

File tree

29 files changed

+73
-51
lines changed

29 files changed

+73
-51
lines changed

routers/api/packages/alpine/alpine.go

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -68,7 +68,7 @@ func GetRepositoryFile(ctx *context.Context) {
6868
return
6969
}
7070

71-
s, u, pf, err := packages_service.GetFileStreamByPackageVersion(
71+
s, u, pf, err := packages_service.OpenFileForDownloadByPackageVersion(
7272
ctx,
7373
pv,
7474
&packages_service.PackageFileInfo{
@@ -216,7 +216,7 @@ func DownloadPackageFile(ctx *context.Context) {
216216
}
217217
}
218218

219-
s, u, pf, err := packages_service.GetPackageFileStream(ctx, pfs[0])
219+
s, u, pf, err := packages_service.OpenFileForDownload(ctx, pfs[0])
220220
if err != nil {
221221
if errors.Is(err, util.ErrNotExist) {
222222
apiError(ctx, http.StatusNotFound, err)

routers/api/packages/arch/arch.go

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -239,7 +239,7 @@ func GetPackageOrRepositoryFile(ctx *context.Context) {
239239
return
240240
}
241241

242-
s, u, pf, err := packages_service.GetPackageFileStream(ctx, pfs[0])
242+
s, u, pf, err := packages_service.OpenFileForDownload(ctx, pfs[0])
243243
if err != nil {
244244
if errors.Is(err, util.ErrNotExist) {
245245
apiError(ctx, http.StatusNotFound, err)

routers/api/packages/cargo/cargo.go

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -165,7 +165,7 @@ func ListOwners(ctx *context.Context) {
165165

166166
// DownloadPackageFile serves the content of a package
167167
func DownloadPackageFile(ctx *context.Context) {
168-
s, u, pf, err := packages_service.GetFileStreamByPackageNameAndVersion(
168+
s, u, pf, err := packages_service.OpenFileForDownloadByPackageNameAndVersion(
169169
ctx,
170170
&packages_service.PackageInfo{
171171
Owner: ctx.Package.Owner,

routers/api/packages/chef/chef.go

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -343,7 +343,7 @@ func DownloadPackage(ctx *context.Context) {
343343

344344
pf := pd.Files[0].File
345345

346-
s, u, _, err := packages_service.GetPackageFileStream(ctx, pf)
346+
s, u, _, err := packages_service.OpenFileForDownload(ctx, pf)
347347
if err != nil {
348348
apiError(ctx, http.StatusInternalServerError, err)
349349
return

routers/api/packages/composer/composer.go

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -160,7 +160,7 @@ func PackageMetadata(ctx *context.Context) {
160160

161161
// DownloadPackageFile serves the content of a package
162162
func DownloadPackageFile(ctx *context.Context) {
163-
s, u, pf, err := packages_service.GetFileStreamByPackageNameAndVersion(
163+
s, u, pf, err := packages_service.OpenFileForDownloadByPackageNameAndVersion(
164164
ctx,
165165
&packages_service.PackageInfo{
166166
Owner: ctx.Package.Owner,

routers/api/packages/conan/conan.go

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -480,7 +480,7 @@ func downloadFile(ctx *context.Context, fileFilter container.Set[string], fileKe
480480
return
481481
}
482482

483-
s, u, pf, err := packages_service.GetFileStreamByPackageNameAndVersion(
483+
s, u, pf, err := packages_service.OpenFileForDownloadByPackageNameAndVersion(
484484
ctx,
485485
&packages_service.PackageInfo{
486486
Owner: ctx.Package.Owner,

routers/api/packages/conda/conda.go

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -293,7 +293,7 @@ func DownloadPackageFile(ctx *context.Context) {
293293

294294
pf := pfs[0]
295295

296-
s, u, _, err := packages_service.GetPackageFileStream(ctx, pf)
296+
s, u, _, err := packages_service.OpenFileForDownload(ctx, pf)
297297
if err != nil {
298298
apiError(ctx, http.StatusInternalServerError, err)
299299
return

routers/api/packages/container/container.go

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -705,7 +705,7 @@ func DeleteManifest(ctx *context.Context) {
705705
func serveBlob(ctx *context.Context, pfd *packages_model.PackageFileDescriptor) {
706706
serveDirectReqParams := make(url.Values)
707707
serveDirectReqParams.Set("response-content-type", pfd.Properties.GetByName(container_module.PropertyMediaType))
708-
s, u, _, err := packages_service.GetPackageBlobStream(ctx, pfd.File, pfd.Blob, serveDirectReqParams)
708+
s, u, _, err := packages_service.OpenBlobForDownload(ctx, pfd.File, pfd.Blob, serveDirectReqParams)
709709
if err != nil {
710710
apiError(ctx, http.StatusInternalServerError, err)
711711
return

routers/api/packages/cran/cran.go

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -250,7 +250,7 @@ func downloadPackageFile(ctx *context.Context, opts *cran_model.SearchOptions) {
250250
return
251251
}
252252

253-
s, u, _, err := packages_service.GetPackageFileStream(ctx, pf)
253+
s, u, _, err := packages_service.OpenFileForDownload(ctx, pf)
254254
if err != nil {
255255
if errors.Is(err, util.ErrNotExist) {
256256
apiError(ctx, http.StatusNotFound, err)

routers/api/packages/debian/debian.go

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -59,7 +59,7 @@ func GetRepositoryFile(ctx *context.Context) {
5959
key += "|" + component + "|" + architecture
6060
}
6161

62-
s, u, pf, err := packages_service.GetFileStreamByPackageVersion(
62+
s, u, pf, err := packages_service.OpenFileForDownloadByPackageVersion(
6363
ctx,
6464
pv,
6565
&packages_service.PackageFileInfo{
@@ -106,7 +106,7 @@ func GetRepositoryFileByHash(ctx *context.Context) {
106106
return
107107
}
108108

109-
s, u, pf, err := packages_service.GetPackageFileStream(ctx, pfs[0])
109+
s, u, pf, err := packages_service.OpenFileForDownload(ctx, pfs[0])
110110
if err != nil {
111111
if errors.Is(err, util.ErrNotExist) {
112112
apiError(ctx, http.StatusNotFound, err)
@@ -210,7 +210,7 @@ func DownloadPackageFile(ctx *context.Context) {
210210
name := ctx.PathParam("name")
211211
version := ctx.PathParam("version")
212212

213-
s, u, pf, err := packages_service.GetFileStreamByPackageNameAndVersion(
213+
s, u, pf, err := packages_service.OpenFileForDownloadByPackageNameAndVersion(
214214
ctx,
215215
&packages_service.PackageInfo{
216216
Owner: ctx.Package.Owner,

0 commit comments

Comments
 (0)