Function apiPublishUpdate

api/publish.go:1133–1275

@Summary Update Published Repository @Description **Update a published repository** @Description @Description Publish pending source component changes which were added with `Add/Remove/Replace Source Components` @Description @Description See also: `aptly publish update` @Tags Publish @Param prefix p

(c *gin.Context)

// @Failure 500 {object} Error "Internal Error"
// @Router /api/publish/{prefix}/{distribution}/update [post]
func apiPublishUpdate(c *gin.Context) {
	var b publishedRepoUpdateParams

	param := slashEscape(c.Params.ByName("prefix"))
	storage, prefix := deb.ParsePrefix(param)
	distribution := slashEscape(c.Params.ByName("distribution"))

	if c.Bind(&b) != nil {
		return
	}

	signer, err := getSigner(&b.Signing)
	if err != nil {
		AbortWithJSONError(c, http.StatusInternalServerError, fmt.Errorf("unable to initialize GPG signer: %s", err))
		return
	}

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

	// Load shallowly for 404 check, resource key, and task name.
	// Full load and field mutations happen inside the task.
	published, err := collection.ByStoragePrefixDistribution(storage, prefix, distribution)
	if err != nil {
		AbortWithJSONError(c, http.StatusNotFound, fmt.Errorf("unable to update: %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 concurrent updates
	// on sibling distributions are serialised and cannot race during cleanup.
	if !published.MultiDist {
		resources = append(resources, deb.PrefixPoolLockKey(published.StoragePrefix()))
	}

	// Lock source repos / snapshots the same way apiPublishUpdateSwitch does,
	// because published.Update() reads from them and concurrent modification
	// would produce an inconsistent view.
	snapshotCollection := collectionFactory.SnapshotCollection()
	localRepoCollection := collectionFactory.LocalRepoCollection()

	if published.SourceKind == deb.SourceLocalRepo {
		for _, uuid := range published.Sources {
			repo, err2 := localRepoCollection.ByUUID(uuid)
			if err2 != nil {
				AbortWithJSONError(c, http.StatusNotFound, err2)
				return
			}
			resources = append(resources, string(repo.Key()))
		}
	} else if published.SourceKind == deb.SourceSnapshot {
		for _, uuid := range published.Sources {
			snapshot, err2 := snapshotCollection.ByUUID(uuid)
			if err2 != nil {
				AbortWithJSONError(c, http.StatusNotFound, err2)
				return