backend.h

Go to the documentation of this file.

// SPDX-License-Identifier: Apache-2.0
#pragma once
 
#include <entropic/storage/database.h>
#include <entropic/storage/records.h>
 
#include <cstdint>
#include <optional>
#include <string>
#include <vector>
 
namespace entropic {
 
class SqliteStorageBackend {
public:
    explicit SqliteStorageBackend(const std::filesystem::path& db_path);
 
    bool initialize();
 
    void close();
 
    // ── Conversation CRUD ─────────────────────────────────
 
    std::string create_conversation(
        const std::string& title = "New Conversation",
        const std::optional<std::string>& project_path = std::nullopt,
        const std::optional<std::string>& model_id = std::nullopt);
 
    bool save_messages(const std::string& conversation_id,
                       const std::string& messages_json);
 
    bool load_conversation(const std::string& conversation_id,
                           std::string& result_json);
 
    bool list_conversations(int limit, int offset,
                            std::string& result_json);
 
    bool delete_conversation(const std::string& conversation_id);
 
    bool update_title(const std::string& conversation_id,
                      const std::string& title);
 
    // ── Search ────────────────────────────────────────────
 
    bool search_conversations(const std::string& query, int limit,
                              std::string& result_json);
 
    // ── Delegation storage ────────────────────────────────
 
    bool create_delegation(
        const std::string& parent_conversation_id,
        const std::string& delegating_tier,
        const std::string& target_tier,
        const std::string& task,
        int max_turns,
        std::string& delegation_id,
        std::string& child_conversation_id);
 
    bool complete_delegation(
        const std::string& delegation_id,
        const std::string& status,
        const std::optional<std::string>& result_summary = std::nullopt);
 
    bool get_delegations(const std::string& conversation_id,
                         std::string& result_json);
 
    bool get_delegation_by_id(const std::string& delegation_id,
                              std::string& result_json);
 
    bool search_delegations(const std::string& query, int max_results,
                            std::string& result_json);
 
    // ── Compaction snapshots ──────────────────────────────
 
    bool save_snapshot(const std::string& conversation_id,
                       const std::string& messages_json);
 
    // ── Statistics ────────────────────────────────────────
 
    bool get_stats(std::string& result_json);
 
private:
    SqliteDatabase db_; 
};
 
} // namespace entropic