Method SaveSession

server/handler_session.go:245–278

SaveSession saves the conversation history.

(ctx context.Context, req *pb.SaveSessionRequest)

// SaveSession saves the conversation history.
func (h *Handler) SaveSession(ctx context.Context, req *pb.SaveSessionRequest) (*pb.SaveSessionResponse, error) {
	if h.sessionManager == nil {
		return nil, status.Errorf(codes.Unavailable, "%s", i18n.T("server.session.mgmt_unavailable"))
	}

	if req.Name == "" {
		return nil, status.Errorf(codes.InvalidArgument, "%s", i18n.T("server.session.name_empty"))
	}

	// Prefer v2 if client sent session_data AND store supports v2
	if req.SessionData != nil {
		if v2Store, ok := h.sessionManager.(SessionStoreV2); ok {
			sd := protoSessionDataToModels(req.SessionData)
			if err := v2Store.SaveSessionV2(req.Name, sd); err != nil {
				return nil, status.Errorf(codes.Internal, "%s", i18n.T("server.session.save_error", err))
			}
			if h.sessionMetrics != nil {
				h.sessionMetrics.OperationsTotal.WithLabelValues("save").Inc()
			}
			return &pb.SaveSessionResponse{Success: true}, nil
		}
	}

	// Fallback to v1
	history := protoToHistory(req.Messages)
	if err := h.sessionManager.SaveSession(req.Name, history); err != nil {
		return nil, status.Errorf(codes.Internal, "%s", i18n.T("server.session.save_error", err))
	}

	if h.sessionMetrics != nil {
		h.sessionMetrics.OperationsTotal.WithLabelValues("save").Inc()
	}
	return &pb.SaveSessionResponse{Success: true}, nil
}

// DeleteSession removes a saved session.
func (h *Handler) DeleteSession(ctx context.Context, req *pb.DeleteSessionRequest) (*pb.DeleteSessionResponse, error) {