Method handlePutAttachment

rest/doc_api.go:416–482

HTTP handler for a PUT of an attachment

()

// HTTP handler for a PUT of an attachment
func (h *handler) handlePutAttachment() error {

	if h.isReadOnlyGuest() {
		return base.HTTPErrorf(http.StatusForbidden, auth.GuestUserReadOnly)
	}

	docid := h.PathVar("docid")
	attachmentName := h.PathVar("attach")
	attachmentContentType := h.rq.Header.Get("Content-Type")
	if attachmentContentType == "" {
		attachmentContentType = "application/octet-stream"
	}

	occValue, occValueType, err := h.getOCCValue(nil)
	if err != nil {
		return err
	}

	attachmentData, err := h.readBody()
	if err != nil {
		return err
	}

	body, err := h.collection.Get1xRevBody(h.ctx(), docid, occValue, false, nil)
	if err != nil {
		if base.IsDocNotFoundError(err) {
			bodyKey, err := bodyKeyForOCCVersionType(occValueType)
			if err != nil {
				return base.HTTPErrorf(http.StatusBadRequest, "Invalid OCC version type: %v", err)
			}
			// couchdb creates empty body on attachment PUT for non-existent doc id
			body = db.Body{bodyKey: occValue}
		} else if err != nil {
			return err
		}
	} else if body != nil {
		if occValue == "" {
			// If a revid is not specified and an active revision was found,
			// return a conflict now, rather than letting db.Put do it further down...
			return base.HTTPErrorf(http.StatusConflict, "Cannot modify attachments without a specific rev ID")
		}
	}

	// find attachment (if it existed)
	attachments := db.GetBodyAttachments(body)
	if attachments == nil {
		attachments = make(map[string]interface{})
	}

	// create new attachment
	attachment := make(map[string]interface{})
	attachment["data"] = attachmentData
	attachment["content_type"] = attachmentContentType

	// attach it
	attachments[attachmentName] = attachment
	body[db.BodyAttachments] = attachments