Method execute

handlers/processing/request.go:36–144

execute handles the actual processing logic

()

// execute handles the actual processing logic
func (r *request) execute() *server.Error {
	outFormat := options.Get(r.opts, keys.Format, imagetype.Unknown)

	// Check if we can save the resulting image
	canSave := vips.SupportsSave(outFormat) ||
		outFormat == imagetype.Unknown ||
		outFormat == imagetype.SVG

	if !canSave {
		return server.NewError(handlers.NewCantSaveError(outFormat), handlers.ErrCategoryPathParsing)
	}

	ctx := r.req.Context()

	// Acquire worker
	releaseWorker, err := r.acquireWorker()
	if err != nil {
		return server.NewError(err, handlers.ErrCategoryQueue)
	}
	defer releaseWorker()

	// Deal with processing image counter
	r.Monitoring().Stats().IncImagesInProgress()
	defer r.Monitoring().Stats().DecImagesInProgress()

	// Response status code is OK by default
	statusCode := http.StatusOK

	// Request headers
	imgRequestHeaders := r.makeImageRequestHeaders()

	// create download options
	do, err := r.makeDownloadOptions(imgRequestHeaders)
	if err != nil {
		return server.NewError(err, handlers.ErrCategoryDownload)
	}

	// Fetch image actual
	originData, originHeaders, err := r.fetchImage(do)
	if originData != nil {
		defer originData.Close() // if any originData has been opened, we need to close it
	}

	// Check that image detection didn't take too long
	if terr := server.CheckTimeout(ctx); terr != nil {
		return server.NewError(terr, handlers.ErrCategoryTimeout)
	}

	// Respond with NotModified if image was not modified
	var nmErr fetcher.NotModifiedError

	if errors.As(err, &nmErr) {
		r.rw.SetOriginHeaders(nmErr.Headers())
		r.ch.SetOriginHeaders(nmErr.Headers())

		r.respondWithNotModified()

		return nil