@@ -17,6 +17,7 @@ import (
17
17
user_model "code.gitea.io/gitea/models/user"
18
18
"code.gitea.io/gitea/modules/json"
19
19
"code.gitea.io/gitea/modules/log"
20
+ "code.gitea.io/gitea/modules/notification"
20
21
packages_module "code.gitea.io/gitea/modules/packages"
21
22
container_module "code.gitea.io/gitea/modules/packages/container"
22
23
"code.gitea.io/gitea/modules/util"
@@ -71,11 +72,9 @@ func processManifest(mci *manifestCreationInfo, buf *packages_module.HashedBuffe
71
72
}
72
73
73
74
if isImageManifestMediaType (mci .MediaType ) {
74
- d , err := processImageManifest (mci , buf )
75
- return d , err
75
+ return processImageManifest (mci , buf )
76
76
} else if isImageIndexMediaType (mci .MediaType ) {
77
- d , err := processImageManifestIndex (mci , buf )
78
- return d , err
77
+ return processImageManifestIndex (mci , buf )
79
78
}
80
79
return "" , errManifestInvalid
81
80
}
@@ -182,6 +181,10 @@ func processImageManifest(mci *manifestCreationInfo, buf *packages_module.Hashed
182
181
return err
183
182
}
184
183
184
+ if err := notifyPackageCreate (mci .Creator , pv ); err != nil {
185
+ return err
186
+ }
187
+
185
188
manifestDigest = digest
186
189
187
190
return nil
@@ -271,6 +274,10 @@ func processImageManifestIndex(mci *manifestCreationInfo, buf *packages_module.H
271
274
return err
272
275
}
273
276
277
+ if err := notifyPackageCreate (mci .Creator , pv ); err != nil {
278
+ return err
279
+ }
280
+
274
281
manifestDigest = digest
275
282
276
283
return nil
@@ -282,6 +289,17 @@ func processImageManifestIndex(mci *manifestCreationInfo, buf *packages_module.H
282
289
return manifestDigest , nil
283
290
}
284
291
292
+ func notifyPackageCreate (doer * user_model.User , pv * packages_model.PackageVersion ) error {
293
+ pd , err := packages_model .GetPackageDescriptor (db .DefaultContext , pv )
294
+ if err != nil {
295
+ return err
296
+ }
297
+
298
+ notification .NotifyPackageCreate (db .DefaultContext , doer , pd )
299
+
300
+ return nil
301
+ }
302
+
285
303
func createPackageAndVersion (ctx context.Context , mci * manifestCreationInfo , metadata * container_module.Metadata ) (* packages_model.PackageVersion , error ) {
286
304
created := true
287
305
p := & packages_model.Package {
0 commit comments