Method handleBulkGet

rest/bulk_api.go:397–520

HTTP handler for a POST to _bulk_get Request looks like POST /db/_bulk_get?revs=___&attachments=___ where the boolean ?revs parameter adds a revision history to each doc and the boolean ?attachments parameter includes attachment bodies. The body of the request is JSON and looks like: { "docs":

()

//		 ]
//	}
func (h *handler) handleBulkGet() error {

	includeAttachments := h.getBoolQuery("attachments")
	showExp := h.getBoolQuery("show_exp")

	showRevs := h.getBoolQuery("revs")
	globalRevsLimit := int(h.getIntQuery("revs_limit", math.MaxInt32))

	// If a client passes the HTTP header "Accept-Encoding: gzip" then the header "X-Accept-Part-Encoding: gzip" will be
	// ignored and the entire HTTP response will be gzip compressed.  (aside from exception mentioned below for issue 1419)
	acceptGzipPartEncoding := strings.Contains(h.rq.Header.Get("X-Accept-Part-Encoding"), "gzip")
	acceptGzipEncoding := strings.Contains(h.rq.Header.Get("Accept-Encoding"), "gzip")
	canCompressParts := acceptGzipPartEncoding && !acceptGzipEncoding

	// Exception: if the user agent is empty or earlier than 1.2, and X-Accept-Part-Encoding=gzip, then we actually
	// DO want to compress the parts since the full response will not be gzipped, since those clients can't handle it.
	// See https://github.com/couchbase/sync_gateway/issues/1419 and encoded_response_writer.go
	userAgentVersion := NewUserAgentVersion(h.rq.Header.Get(base.HTTPHeaderUserAgent))
	if userAgentVersion.IsBefore(1, 2) && acceptGzipPartEncoding {
		canCompressParts = true
	}

	body, err := h.readJSON()
	if err != nil {
		return err
	}

	docs, ok := body["docs"].([]interface{})
	if !ok {
		return base.HTTPErrorf(http.StatusBadRequest, "missing 'docs' property")
	}

	return h.writeMultipart("mixed", func(writer *multipart.Writer) error {
		for _, item := range docs {
			var body db.Body
			var revsFrom, attsSince []string
			var docRevsLimit int
			var err error

			doc := item.(map[string]interface{})
			docid, _ := doc["id"].(string)
			revOrCV := ""
			revok := true
			if doc["rev"] != nil {
				revOrCV, revok = doc["rev"].(string)
			}
			if docid == "" || !revok {
				err = base.HTTPErrorf(http.StatusBadRequest, "Invalid doc/rev ID in _bulk_get")
			} else {
				attsSince, err = db.GetStringArrayProperty(doc, "atts_since")

				if showRevs {
					docRevsLimit = globalRevsLimit

					// Try to pull out a per-doc revs limit that can override the global one.
					if raw, isSet := doc["revs_limit"]; isSet {
						if val, ok := base.ToInt64(raw); ok && val >= 0 {
							docRevsLimit = int(val)