From 4f01100473ba7e24655918f5e28fb77ccabff99a Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?=D0=9E=D0=BB=D0=B5=D0=B3=20=D0=91=D0=BE=D1=80=D0=BE=D0=B4?= =?UTF-8?q?=D0=B8=D0=BD?= Date: Thu, 5 Feb 2026 22:18:01 +0200 Subject: [PATCH] working commit --- app/operator/manifest.go | 82 ++++++++++++++++++++++++++++++++++++++++ 1 file changed, 82 insertions(+) diff --git a/app/operator/manifest.go b/app/operator/manifest.go index 17f3816..dd30d8b 100644 --- a/app/operator/manifest.go +++ b/app/operator/manifest.go @@ -272,3 +272,85 @@ func (oper *Operator) GetManifest(ctx context.Context, params *GetManifestParams return res, http.StatusOK, err } + +type DeleteManifestParams struct { + Name string + Reference string +} +type DeleteManifestResult struct{} + +func (oper *Operator) DeleteManifest(ctx context.Context, params *DeleteManifestParams) (*DeleteManifestResult, int, error) { + var err error + res := &DeleteManifestResult{} + manifestDescr := descr.Manifest{} + var exists bool + var reference string + // Check manifest by digest as name + if stringLikeSHADigest(params.Reference) { + digest := normalizeSHADigest(params.Reference) + exists, manifestDescr, err = oper.mdb.GetManifestByDigest(ctx, params.Name, digest) + if err != nil { + return res, http.StatusInternalServerError, err + } + if !exists { + return res, http.StatusNotFound, err + } + reference = manifestDescr.Reference + } else { + // Check manifest by name and reference + exists, manifestDescr, err = oper.mdb.GetManifestByReference(ctx, params.Name, params.Reference) + if err != nil { + return res, http.StatusInternalServerError, err + } + if !exists { + return res, http.StatusNotFound, err + } + reference = params.Reference + } + // Get blobs associated with the name + err = oper.deleteManifestObjects(ctx, params.Name, reference) + if err != nil { + return res, http.StatusInternalServerError, err + } + return res, http.StatusAccepted, err +} + +func (oper *Operator) deleteManifestObjects(ctx context.Context, name, reference string) error { + var err error + // Get blobs associated with the name + layers, err := oper.mdb.GetBlobsByReferense(ctx, name, reference) + if err != nil { + return err + } + for _, blob := range layers { + // Delete descr record + err = oper.mdb.DeleteBlobByNameDigest(ctx, blob.Name, blob.Digest) + if err != nil { + return err + } + // Check blob file + exists, _, err := oper.store.BlobExists(blob.Digest) + if err != nil { + return err + } + if exists { + // Check blob usage + blobUsage, err := oper.mdb.GetBlobUsage(ctx, blob.Digest) + if err != nil { + return err + } + // Delete if blob useless + if blobUsage == 0 { + err = oper.store.DeleteBlob(blob.Digest) + if err != nil { + return err + } + } + } + } + err = oper.mdb.DeleteManifest(ctx, name, reference) + if err != nil { + return err + } + return err +}