Method handlePostDoc

rest/doc_api.go:745–781

HTTP handler for a POST to a database (creating a document)

()

// HTTP handler for a POST to a database (creating a document)
func (h *handler) handlePostDoc() error {
	if h.isReadOnlyGuest() {
		return base.HTTPErrorf(http.StatusForbidden, auth.GuestUserReadOnly)
	}

	if h.db.DatabaseContext.Options.UnsupportedOptions != nil && h.db.DatabaseContext.Options.UnsupportedOptions.RejectWritesWithSkippedSequences {
		// if we are in slow broadcast mode reject write with 503 and increment rejected writes stat
		if h.db.BroadcastSlowMode.Load() {
			h.db.DbStats.DatabaseStats.NumDocWritesRejected.Add(1)
			return base.HTTPErrorf(http.StatusServiceUnavailable, "Database cache is behind and cannot accept writes at this time. Please try again later.")
		}
	}

	roundTrip := h.getBoolQuery("roundtrip")
	body, err := h.readDocument()
	if err != nil {
		return err
	}

	docid, newRev, doc, err := h.collection.Post(h.ctx(), body)
	if err != nil {
		return err
	}

	if doc != nil && roundTrip {
		err := h.collection.WaitForSequenceNotSkipped(h.ctx(), doc.Sequence)
		if err != nil {
			return err
		}
	}

	h.setHeader("Location", docid)
	h.setEtag(newRev)

	h.writeRawJSONStatus(http.StatusOK, []byte(`{"id":`+base.ConvertToJSONString(docid)+`,"ok":true,"rev":"`+newRev+`","cv":"`+doc.HLV.GetCurrentVersionString()+`"}`))
	return nil
}

// docVersionFromOCCValue converts an OCC value and type into a DocVersion struct.
func docVersionFromOCCValue(occValue string, occValueType occVersionType) (docVersion db.DocVersion, err error) {