Method Resolve

core/http.go:230–320

(
	ctx context.Context,
	query *Query,
	checksum dagql.Optional[dagql.String],
	permissions int,
	name string,
)

}

func (state *HTTPState) Resolve(
	ctx context.Context,
	query *Query,
	checksum dagql.Optional[dagql.String],
	permissions int,
	name string,
) (_ *HTTPFetchResult, rerr error) {
	state.mu.Lock()
	defer state.mu.Unlock()

	expectedChecksum, err := parseOptionalChecksum(checksum)
	if err != nil {
		return nil, fmt.Errorf("invalid checksum %q: %w", checksum.Value, err)
	}

	if state.snapshot == nil && state.snapshotID != "" {
		snapshot, err := query.SnapshotManager().GetBySnapshotID(ctx, state.snapshotID, bkcache.NoUpdateLastUsed)
		if err != nil {
			return nil, fmt.Errorf("reopen http state snapshot %q: %w", state.snapshotID, err)
		}
		state.snapshot = snapshot
	}

	req, err := http.NewRequestWithContext(ctx, http.MethodGet, state.URL, nil)
	if err != nil {
		return nil, err
	}
	req.Header.Set("Accept-Encoding", "identity")
	if state.ETag != "" {
		req.Header.Set("If-None-Match", state.ETag)
	} else if state.LastModified != "" {
		req.Header.Set("If-Modified-Since", state.LastModified)
	}

	dns, err := DNSConfig(ctx)
	if err != nil {
		return nil, err
	}
	client := http.Client{
		Transport: netconfhttp.NewTransport(http.DefaultTransport, dns),
	}
	resp, err := client.Do(req)
	if err != nil {
		return nil, err
	}
	defer resp.Body.Close()
	if resp.StatusCode != http.StatusOK && resp.StatusCode != http.StatusNotModified {
		return nil, fmt.Errorf("invalid response status %s", resp.Status)
	}

	if resp.StatusCode == http.StatusNotModified {
		if state.snapshot == nil {
			return nil, fmt.Errorf("http state %q returned 304 without a cached snapshot", state.URL)
		}
		if etag := etagValue(resp.Header.Get("ETag")); etag != "" {
			state.ETag = etag
		}
		if lastModified := resp.Header.Get("Last-Modified"); lastModified != "" {