Method handleChanges

rest/changes_api.go:166–368

Top-level handler for _changes feed requests. Accepts GET or POST requests.

()

// Top-level handler for _changes feed requests. Accepts GET or POST requests.
func (h *handler) handleChanges() error {
	// http://wiki.apache.org/couchdb/HTTP_database_API#Changes
	// http://docs.couchdb.org/en/latest/api/database/changes.html

	var feed string
	var options db.ChangesOptions
	var filter string
	var channelsArray []string
	var docIdsArray []string

	if h.rq.Method == "GET" {
		// GET request has parameters in URL:
		feed = h.getQuery("feed")
		var err error
		if options.Since, err = db.ParsePlainSequenceID(h.getJSONStringQuery("since")); err != nil {
			return err
		}
		options.Limit = int(h.getIntQuery("limit", 0))
		options.Conflicts = h.getQuery("style") == "all_docs"
		options.ActiveOnly = h.getBoolQuery("active_only")
		options.IncludeDocs = h.getBoolQuery("include_docs")
		options.Revocations = h.getBoolQuery("revocations")
		options.VersionType, err = db.ParseChangesVersionType(h.getQuery("version_type"))
		if err != nil {
			return base.HTTPErrorf(http.StatusBadRequest, "Invalid version_type: %v", err)
		}

		if options.Conflicts && options.VersionType == db.ChangesVersionTypeCV {
			return base.HTTPErrorf(http.StatusBadRequest, "Cannot use 'style=all_docs' with 'version_type=cv'")
		}

		useRequestPlus, _ := h.getOptBoolQuery("request_plus", h.db.Options.ChangesRequestPlus)
		if useRequestPlus && feed != feedTypeContinuous {
			var seqErr error
			options.RequestPlusSeq, seqErr = h.db.GetRequestPlusSequence()
			if seqErr != nil {
				return base.HTTPErrorf(http.StatusServiceUnavailable, "Unable to retrieve requestPlus sequence")
			}

		}
		filter = h.getQuery("filter")
		channelsParam := h.getQuery("channels")
		if channelsParam != "" {
			channelsArray = strings.Split(channelsParam, ",")
		}

		docidsParam := h.getQuery("doc_ids")
		if docidsParam != "" {
			var docidKeys []string
			err := base.JSONUnmarshal([]byte(docidsParam), &docidKeys)
			if err == nil {
				if len(docidKeys) > 0 {
					docIdsArray = docidKeys
				}
			} else {
				// This is not a JSON array so treat as a simple
				// comma separated list of doc id's
				docIdsArray = strings.Split(docidsParam, ",")