Function apiPublishDrop

api/publish.go:630–667

@Summary Delete Published Repository @Description **Delete a published repository** @Description @Description Delete a distribution of a published repository and remove associated files. @Description @Description If no other published repositories share the same prefix, all files inside the prefix w

(c *gin.Context)

// @Failure 500 {object} Error "Internal Error"
// @Router /api/publish/{prefix}/{distribution} [delete]
func apiPublishDrop(c *gin.Context) {
	param := slashEscape(c.Params.ByName("prefix"))
	storage, prefix := deb.ParsePrefix(param)
	distribution := slashEscape(c.Params.ByName("distribution"))

	force := c.Request.URL.Query().Get("force") == "1"
	skipCleanup := c.Request.URL.Query().Get("SkipCleanup") == "1"

	collectionFactory := context.NewCollectionFactory()
	collection := collectionFactory.PublishedRepoCollection()

	published, err := collection.ByStoragePrefixDistribution(storage, prefix, distribution)
	if err != nil {
		AbortWithJSONError(c, http.StatusNotFound, fmt.Errorf("unable to drop: %s", err))
		return
	}

	resources := []string{string(published.Key())}
	// Non-MultiDist distributions share a single pool/ directory under the
	// prefix.  Acquire the prefix-level pool lock so that a drop cannot race
	// with a concurrent update or drop of a sibling distribution during cleanup.
	if !published.MultiDist {
		resources = append(resources, deb.PrefixPoolLockKey(published.StoragePrefix()))
	}
	taskName := fmt.Sprintf("Delete published %s repository %s/%s", published.SourceKind, published.StoragePrefix(), published.Distribution)
	maybeRunTaskInBackground(c, taskName, resources, func(out aptly.Progress, _ *task.Detail) (*task.ProcessReturnValue, error) {
		taskCollectionFactory := context.NewCollectionFactory()
		taskCollection := taskCollectionFactory.PublishedRepoCollection()

		err := taskCollection.Remove(context, storage, prefix, distribution,
			taskCollectionFactory, out, force, skipCleanup)
		if err != nil {
			return &task.ProcessReturnValue{Code: http.StatusInternalServerError, Value: nil}, fmt.Errorf("unable to drop: %s", err)
		}

		return &task.ProcessReturnValue{Code: http.StatusOK, Value: gin.H{}}, nil
	})
}

// @Summary Add Source Component
// @Description **Add a source component to a published repo**