diff options
| author | Yarden Shoham <hrsi88@gmail.com> | 2023-02-18 15:54:22 +0200 |
|---|---|---|
| committer | GitHub <noreply@github.com> | 2023-02-18 21:54:22 +0800 |
| commit | b2e58edd74f8d9bb530335e9b1ee2e356d4dacb4 (patch) | |
| tree | c643628c110b0c77781ae24f38d39aec1a745d3d | |
| parent | 98b7714c3b2ee2109206327f774cd035e231fe64 (diff) | |
| download | gitea-b2e58edd74f8d9bb530335e9b1ee2e356d4dacb4.tar.gz gitea-b2e58edd74f8d9bb530335e9b1ee2e356d4dacb4.zip | |
Notify on container image create (#22806) (#22965)
Backport #22806
Fixes #22791
---------
Signed-off-by: Yarden Shoham <hrsi88@gmail.com>
Co-authored-by: KN4CK3R <admin@oldschoolhack.me>
Co-authored-by: Lunny Xiao <xiaolunwen@gmail.com>
| -rw-r--r-- | routers/api/packages/container/manifest.go | 26 |
1 files changed, 22 insertions, 4 deletions
diff --git a/routers/api/packages/container/manifest.go b/routers/api/packages/container/manifest.go index dd5b650d0c..468cfd40a1 100644 --- a/routers/api/packages/container/manifest.go +++ b/routers/api/packages/container/manifest.go @@ -18,6 +18,7 @@ import ( user_model "code.gitea.io/gitea/models/user" "code.gitea.io/gitea/modules/json" "code.gitea.io/gitea/modules/log" + "code.gitea.io/gitea/modules/notification" packages_module "code.gitea.io/gitea/modules/packages" container_module "code.gitea.io/gitea/modules/packages/container" "code.gitea.io/gitea/modules/util" @@ -72,11 +73,9 @@ func processManifest(mci *manifestCreationInfo, buf *packages_module.HashedBuffe } if isImageManifestMediaType(mci.MediaType) { - d, err := processImageManifest(mci, buf) - return d, err + return processImageManifest(mci, buf) } else if isImageIndexMediaType(mci.MediaType) { - d, err := processImageManifestIndex(mci, buf) - return d, err + return processImageManifestIndex(mci, buf) } return "", errManifestInvalid } @@ -183,6 +182,10 @@ func processImageManifest(mci *manifestCreationInfo, buf *packages_module.Hashed return err } + if err := notifyPackageCreate(mci.Creator, pv); err != nil { + return err + } + manifestDigest = digest return nil @@ -272,6 +275,10 @@ func processImageManifestIndex(mci *manifestCreationInfo, buf *packages_module.H return err } + if err := notifyPackageCreate(mci.Creator, pv); err != nil { + return err + } + manifestDigest = digest return nil @@ -283,6 +290,17 @@ func processImageManifestIndex(mci *manifestCreationInfo, buf *packages_module.H return manifestDigest, nil } +func notifyPackageCreate(doer *user_model.User, pv *packages_model.PackageVersion) error { + pd, err := packages_model.GetPackageDescriptor(db.DefaultContext, pv) + if err != nil { + return err + } + + notification.NotifyPackageCreate(doer, pd) + + return nil +} + func createPackageAndVersion(ctx context.Context, mci *manifestCreationInfo, metadata *container_module.Metadata) (*packages_model.PackageVersion, error) { created := true p := &packages_model.Package{ |