Method postAsset

internal/attachments/client.go:127–175

postAsset does the request and reads the asset URL back. It takes the file rather than the UserAsset, because nothing about sending the bytes depends on how they render. It is separate so every way it can fail picks up the same explanation on the way out.

(ctx context.Context, a asset)

// how they render. It is separate so every way it can fail picks up the same
// explanation on the way out.
func (u *Uploader) postAsset(ctx context.Context, a asset) (string, error) {
	url, err := safeurl.JoinPathWithHostPrefix(ghinstance.UserAssetUploadPrefix(u.host), "user-attachments", "assets")
	if err != nil {
		return "", err
	}
	url.SetQuery("name", filepath.Base(a.path))
	url.SetQuery("content_type", a.contentType)
	url.SetQuery("repository_id", strconv.FormatInt(u.targetRepository, 10))

	open := func() (io.ReadCloser, error) { return openFile(a.path) }

	f, err := open()
	if err != nil {
		return "", err
	}
	defer f.Close()

	req, err := http.NewRequestWithContext(ctx, "POST", url.String(), f)
	if err != nil {
		return "", err
	}
	req.ContentLength = a.info.Size()
	req.Header.Set("Content-Type", "application/octet-stream")
	req.Header.Set("Accept", "application/vnd.github+json")
	// Without GetBody a redirect re-reads an exhausted reader.
	req.GetBody = open

	resp, err := u.httpClient.Do(req)
	if err != nil {
		return "", err
	}
	defer resp.Body.Close()

	if resp.StatusCode < 200 || resp.StatusCode > 299 {
		return "", api.HandleHTTPError(resp)
	}

	var asset struct {
		URL string `json:"url"`
	}
	if err := json.NewDecoder(resp.Body).Decode(&asset); err != nil {
		return "", err
	}
	if asset.URL == "" {
		return "", errors.New("the server returned no asset URL")
	}

	return asset.URL, nil
}

// newUploadError captures the status code so the message can name what the
// endpoint refused.