Function apiSnapshotsCreate

api/snapshot.go:158–250

@Summary Snapshot Packages @Description **Create a snapshot from package refs** @Description @Description Refs can be obtained from snapshots, local repos, or mirrors @Tags Snapshots @Param request body snapshotsCreateParams true "Parameters" @Param _async query bool false "Run in background and ret

(c *gin.Context)

// @Failure 500 {object} Error "Internal Server Error"
// @Router /api/snapshots [post]
func apiSnapshotsCreate(c *gin.Context) {
	var (
		err      error
		snapshot *deb.Snapshot
		b        snapshotsCreateParams
	)

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

	if b.Description == "" {
		if len(b.SourceSnapshots)+len(b.PackageRefs) == 0 {
			b.Description = "Created as empty"
		}
	}

	// Phase 1: Pre-task validation (shallow load for 404 checks only)
	collectionFactory := context.NewCollectionFactory()
	snapshotCollection := collectionFactory.SnapshotCollection()
	var resources []string

	sources := make([]*deb.Snapshot, len(b.SourceSnapshots))

	for i := range b.SourceSnapshots {
		sources[i], err = snapshotCollection.ByName(b.SourceSnapshots[i])
		if err != nil {
			AbortWithJSONError(c, 404, err)
			return
		}

		resources = append(resources, string(sources[i].Key()))
	}

	maybeRunTaskInBackground(c, "Create snapshot "+b.Name, resources, func(_ aptly.Progress, _ *task.Detail) (*task.ProcessReturnValue, error) {
		// Phase 2: Inside task lock - create fresh factory
		taskCollectionFactory := context.NewCollectionFactory()
		taskSnapshotCollection := taskCollectionFactory.SnapshotCollection()
		taskPackageCollection := taskCollectionFactory.PackageCollection()

		// Fresh load of all sources after lock acquired
		freshSources := make([]*deb.Snapshot, len(b.SourceSnapshots))
		for i := range b.SourceSnapshots {
			freshSources[i], err = taskSnapshotCollection.ByName(b.SourceSnapshots[i])
			if err != nil {
				return &task.ProcessReturnValue{Code: http.StatusInternalServerError, Value: nil}, err
			}
			// LoadComplete on fresh copy
			err = taskSnapshotCollection.LoadComplete(freshSources[i])
			if err != nil {
				return &task.ProcessReturnValue{Code: http.StatusInternalServerError, Value: nil}, err
			}
		}

		// Merge packages from all source snapshots
		var refList *deb.PackageRefList
		if len(freshSources) > 0 {
			refList = freshSources[0].RefList()