Method handleDeleteDoc

rest/doc_api.go:800–839

HTTP handler for a DELETE of a document

()

// HTTP handler for a DELETE of a document
func (h *handler) handleDeleteDoc() error {
	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.")
		}
	}

	docid := h.PathVar("docid")

	// occValue is the optimistic concurrency control value, which can be either the current rev ID or CV - used to prevent lost updates.
	// we grab occValue from either query param, Etag header, or request body (in that order)
	occValue, occValueType, err := h.getOCCValue(nil)
	if err != nil {
		return fmt.Errorf("couldn't get OCC value from request: %w", err)
	}

	docVersion, err := docVersionFromOCCValue(occValue, occValueType)
	if err != nil {
		return fmt.Errorf("couldn't build document version from OCC value: %w", err)
	}

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

	respBody := []byte(`{"id":` + base.ConvertToJSONString(docid) + `,"ok":true,"rev":"` + newRev + `"}`)
	if doc != nil {
		respBody, err = base.InjectJSONProperties(respBody, base.KVPair{Key: "cv", Val: doc.HLV.GetCurrentVersionString()})
		if err != nil {
			base.AssertfCtx(h.ctx(), "Failed to inject JSON properties: %v", err)
			// safe to continue - we'll just have no deleted in response
		}
	}

	h.writeRawJSONStatus(http.StatusOK, respBody)
	return nil
}

// ////// LOCAL DOCS: