Function apiMirrorsDrop

api/mirror.go:215–264

@Summary Delete Mirror @Description **Delete a mirror** @Tags Mirrors @Param name path string true "mirror name" @Param force query int true "force: 1 to enable" @Param _async query bool false "Run in background and return task object" @Produce json @Success 200 {object} task.ProcessReturnValue @Fai

(c *gin.Context)

// @Failure 500 {object} Error "Unable to delete"
// @Router /api/mirrors/{name} [delete]
func apiMirrorsDrop(c *gin.Context) {
	name := c.Params.ByName("name")
	force := c.Request.URL.Query().Get("force") == "1"

	// Phase 1: Pre-task validation (shallow load for 404 check only)
	collectionFactory := context.NewCollectionFactory()
	mirrorCollection := collectionFactory.RemoteRepoCollection()

	repo, err := mirrorCollection.ByName(name)
	if err != nil {
		AbortWithJSONError(c, 404, fmt.Errorf("unable to drop: %s", err))
		return
	}

	resources := []string{string(repo.Key())}
	taskName := fmt.Sprintf("Delete mirror %s", name)

	maybeRunTaskInBackground(c, taskName, resources, func(_ aptly.Progress, _ *task.Detail) (*task.ProcessReturnValue, error) {
		// Phase 2: Inside task lock - create fresh collections
		taskCollectionFactory := context.NewCollectionFactory()
		taskMirrorCollection := taskCollectionFactory.RemoteRepoCollection()
		taskSnapshotCollection := taskCollectionFactory.SnapshotCollection()

		// Fresh load after lock acquired
		repo, err := taskMirrorCollection.ByName(name)
		if err != nil {
			return &task.ProcessReturnValue{Code: http.StatusInternalServerError, Value: nil}, fmt.Errorf("unable to drop: %v", err)
		}

		err = repo.CheckLock()
		if err != nil {
			return &task.ProcessReturnValue{Code: http.StatusInternalServerError, Value: nil}, fmt.Errorf("unable to drop: %v", err)
		}

		if !force {
			// Fresh checks with current collections
			snapshots := taskSnapshotCollection.ByRemoteRepoSource(repo)

			if len(snapshots) > 0 {
				return &task.ProcessReturnValue{Code: http.StatusForbidden, Value: nil}, fmt.Errorf("won't delete mirror with snapshots, use 'force=1' to override")
			}
		}

		err = taskMirrorCollection.Drop(repo)
		if err != nil {
			return &task.ProcessReturnValue{Code: http.StatusInternalServerError, Value: nil}, fmt.Errorf("unable to drop: %v", err)
		}
		return &task.ProcessReturnValue{Code: http.StatusNoContent, Value: nil}, nil
	})
}

// @Summary Get Mirror Info
// @Description **Get mirror information by name**