Method WriteMemory

internal/api/core/memory.go:323–369

WriteMemory creates or proposes one Memory v2 entry.

(c *gin.Context)

// WriteMemory creates or proposes one Memory v2 entry.
func (h *BaseHandlers) WriteMemory(c *gin.Context) {
	var req contract.MemoryCreateRequest
	if err := c.ShouldBindJSON(&req); err != nil {
		h.respondMemoryError(
			c,
			http.StatusBadRequest,
			fmt.Errorf("%s: decode memory write request: %w", h.transportName(), err),
			nil,
		)
		return
	}
	if err := validateMemoryCreateRequest(req); err != nil {
		h.respondMemoryError(c, StatusForMemoryError(err), err, nil)
		return
	}

	selector, err := h.resolveMemoryCreateSelector(c.Request.Context(), req)
	if err != nil {
		h.respondMemoryError(c, StatusForMemoryError(err), err, nil)
		return
	}
	selector.Scope = defaultMemorySelectorScope(selector)
	store, err := h.memoryRecallStoreForSelector(c.Request.Context(), selector)
	if err != nil {
		h.respondMemoryError(c, StatusForMemoryError(err), err, nil)
		return
	}

	decision, err := store.ProposeCandidate(
		c.Request.Context(),
		h.memoryCandidateFromCreate(selector, req),
	)
	if err != nil {
		h.respondMemoryError(c, StatusForMemoryError(err), err, nil)
		return
	}
	if decision.Op == memcontract.OpReject {
		h.respondDecisionRejected(c, decision)
		return
	}

	c.JSON(http.StatusOK, contract.MemoryMutationDecisionResponse{
		Decision: MemoryDecisionPayload(decision, nil),
		Applied:  memoryDecisionApplied(decision),
		DryRun:   req.DryRun,
	})
}

// EditMemory edits one memory document through the controller.
func (h *BaseHandlers) EditMemory(c *gin.Context) {