Function putDocWithRevision

db/special_docs.go:69–113

Updates or deletes a document with BodyRev-based version control.

(dataStore base.DataStore, docID string, matchRev string, body Body, expirySecs int)

// Updates or deletes a document with BodyRev-based version control.
func putDocWithRevision(dataStore base.DataStore, docID string, matchRev string, body Body, expirySecs int) (newRevID string, isNewDoc bool, err error) {
	var revid string

	var expiry uint32
	if expirySecs > 0 {
		expiry = base.SecondsToCbsExpiry(expirySecs)
	}

	// isNewDoc is set to false if the update is being applied on top of an existing document.
	isNewDoc = true

	_, err = dataStore.Update(docID, expiry, func(value []byte) ([]byte, *uint32, bool, error) {
		if len(value) == 0 {
			if matchRev != "" || body == nil {
				return nil, nil, false, base.HTTPErrorf(http.StatusNotFound, "No previous revision to replace")
			}
		} else {
			isNewDoc = false
			prevBody := Body{}
			if err := prevBody.Unmarshal(value); err != nil {
				return nil, nil, false, err
			}
			if matchRev != prevBody[BodyRev] {
				return nil, nil, false, base.HTTPErrorf(http.StatusConflict, "Document update conflict")
			}
		}

		if body != nil {
			// Updating:
			var generation uint
			if matchRev != "" {
				_, _ = fmt.Sscanf(matchRev, "0-%d", &generation)
			}
			revid = fmt.Sprintf("0-%d", generation+1)
			body[BodyRev] = revid
			bodyBytes, marshalErr := base.JSONMarshal(body)
			return bodyBytes, nil, false, marshalErr
		} else {
			// Deleting:
			return nil, nil, true, nil
		}
	})

	return revid, isNewDoc, err
}

func putSpecial(dataStore base.DataStore, doctype string, docid string, matchRev string, body Body, localDocExpirySecs int) (revID string, isNewDoc bool, err error) {
	key := RealSpecialDocID(doctype, docid)