Method ResetMemory

internal/api/core/memory.go:647–704

(c *gin.Context)

}

func (h *BaseHandlers) ResetMemory(c *gin.Context) {
	if h.MemoryStore == nil {
		h.respondMemoryError(c, http.StatusInternalServerError, errors.New("memory store is not configured"), nil)
		return
	}
	var req contract.MemoryResetRequest
	if err := c.ShouldBindJSON(&req); err != nil && !errors.Is(err, io.EOF) {
		h.respondMemoryError(
			c,
			http.StatusBadRequest,
			fmt.Errorf("%s: decode memory reset request: %w", h.transportName(), err),
			nil,
		)
		return
	}
	if !req.Confirm {
		c.JSON(http.StatusOK, contract.MemoryResetResponse{
			ResetAt:     h.nowUTC(),
			DerivedOnly: req.DerivedOnly,
		})
		return
	}
	if !req.DerivedOnly {
		err := NewMemoryValidationError(errors.New("only derived memory reset is supported in Slice 1"))
		h.respondMemoryError(c, StatusForMemoryError(err), err, nil)
		return
	}
	selector, err := h.resolveMemorySelector(c.Request.Context(), memorySelector{
		Scope:       req.Scope,
		WorkspaceID: req.WorkspaceID,
		AgentName:   req.AgentName,
		AgentTier:   req.AgentTier,
	}, false)
	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
	}
	result, err := store.ResetDerived(c.Request.Context(), memcontract.ReindexOptions{
		Scope:     selector.Scope,
		Workspace: selector.Workspace,
	})
	if err != nil {
		h.respondMemoryError(c, StatusForMemoryError(err), err, nil)
		return
	}
	c.JSON(http.StatusOK, contract.MemoryResetResponse{
		ResetAt:      result.ResetAt.UTC(),
		DerivedOnly:  true,
		DeletedRows:  result.DeletedRows,
		DeletedFiles: 0,
	})
}