Method buildObjectResponse

component/git_http.go:254–295

(ctx context.Context, req types.BatchRequest, pointer types.Pointer, download, upload bool, err *types.ObjectError)

}

func (c *GitHTTPComponent) buildObjectResponse(ctx context.Context, req types.BatchRequest, pointer types.Pointer, download, upload bool, err *types.ObjectError) *types.ObjectResponse {
	rep := &types.ObjectResponse{Pointer: pointer}
	if err != nil {
		rep.Error = err
	} else {
		rep.Actions = make(map[string]*types.Link)

		header := make(map[string]string)

		if len(req.Authorization) > 0 {
			header["Authorization"] = req.Authorization
		}

		if download {
			var link *types.Link
			reqParams := make(url.Values)
			objectKey := path.Join("lfs", pointer.RelativePath())
			url, err := c.s3Client.PresignedGetObject(ctx, c.config.S3.Bucket, objectKey, ossFileExpireSeconds, reqParams)
			if url != nil && err == nil {
				delete(header, "Authorization")
				link = &types.Link{Href: url.String(), Header: header}
			}
			if link == nil {
				link = &types.Link{Href: c.buildDownloadLink(req, pointer), Header: header}
			}
			rep.Actions["download"] = link
		}
		if upload {
			rep.Actions["upload"] = &types.Link{Href: c.buildUploadLink(req, pointer), Header: header}

			verifyHeader := make(map[string]string)
			for key, value := range header {
				verifyHeader[key] = value
			}

			verifyHeader["Accept"] = types.LfsMediaType

			rep.Actions["verify"] = &types.Link{Href: c.buildVerifyLink(req), Header: verifyHeader}
		}
	}
	return rep
}

func (c *GitHTTPComponent) LfsUpload(ctx context.Context, body io.ReadCloser, req types.UploadRequest) error {
	var exists bool