BotSharp/src/Infrastructure/BotSharp.Core/Repository/BotSharpDbContext.cs

using BotSharp.Abstraction.Loggers.Models;
using BotSharp.Abstraction.Plugins.Models;
using BotSharp.Abstraction.Repositories.Models;
using BotSharp.Abstraction.Tasks.Models;
using BotSharp.Abstraction.Users.Models;
using Microsoft.EntityFrameworkCore.Infrastructure;

namespace BotSharp.Core.Repository;

public class BotSharpDbContext : Database, IBotSharpRepository
{
    public IQueryable<User> Users => throw new NotImplementedException();

    public IQueryable<Agent> Agents => throw new NotImplementedException();

    public IQueryable<UserAgent> UserAgents => throw new NotImplementedException();

    public IQueryable<Conversation> Conversations => throw new NotImplementedException();

    public int Transaction<TTableInterface>(Action action)
    {
        DatabaseFacade database = base.GetMaster(typeof(TTableInterface)).Database;
        int num = 0;
        if (database.CurrentTransaction == null)
        {
            using (Microsoft.EntityFrameworkCore.Storage.IDbContextTransaction dbContextTransaction = database.BeginTransaction())
            {
                try
                {
                    action();
                    num = base.SaveChanges();
                    dbContextTransaction.Commit();
                    return num;
                }
                catch (Exception ex)
                {
                    dbContextTransaction.Rollback();
                    if (ex.Message.Contains("See the inner exception for details"))
                    {
                        throw ex.InnerException;
                    }

                    throw ex;
                }
            }
        }

        try
        {
            action();
            return base.SaveChanges();
        }
        catch (Exception ex2)
        {
            if (database.CurrentTransaction != null)
            {
                database.CurrentTransaction.Rollback();
            }

            if (ex2.Message.Contains("See the inner exception for details"))
            {
                throw ex2.InnerException;
            }

            throw ex2;
        }
    }

    #region Plugin
    public PluginConfig GetPluginConfig() => throw new NotImplementedException(); 
    public void SavePluginConfig(PluginConfig config) => throw new NotImplementedException();
    #endregion

    #region Agent
    public Agent GetAgent(string agentId)
    {
        throw new NotImplementedException();
    }

    public List<Agent> GetAgents(AgentFilter filter)
    {
        throw new NotImplementedException();
    }

    public List<Agent> GetAgentsByUser(string userId)
    {
        throw new NotImplementedException();
    }

    public void UpdateAgent(Agent agent, AgentField field)
    {
        throw new NotImplementedException();
    }

    public string GetAgentTemplate(string agentId, string templateName)
    {
        throw new NotImplementedException();
    }

    public List<string> GetAgentResponses(string agentId, string prefix, string intent)
    {
        throw new NotImplementedException();
    }

    public void BulkInsertAgents(List<Agent> agents)
    {
        throw new NotImplementedException();
    }

    public void BulkInsertUserAgents(List<UserAgent> userAgents)
    {
        throw new NotImplementedException();
    }

    public bool DeleteAgents()
    {
        throw new NotImplementedException();
    }
    #endregion

    #region Agent Task
    public PagedItems<AgentTask> GetAgentTasks(AgentTaskFilter filter)
    {
        throw new NotImplementedException();
    }

    public AgentTask? GetAgentTask(string agentId, string taskId)
    {
        throw new NotImplementedException();
    }

    public void InsertAgentTask(AgentTask task)
    {
        throw new NotImplementedException();
    }

    public void BulkInsertAgentTasks(List<AgentTask> tasks)
    {
        throw new NotImplementedException();
    }

    public void UpdateAgentTask(AgentTask task, AgentTaskField field)
    {
        throw new NotImplementedException();
    }

    public bool DeleteAgentTask(string agentId, string taskId)
    {
        throw new NotImplementedException();
    }

    public bool DeleteAgentTasks()
    {
        throw new NotImplementedException();
    }
    #endregion

    #region Conversation
    public void CreateNewConversation(Conversation conversation)
    {
        throw new NotImplementedException();
    }

    public bool DeleteConversations(IEnumerable<string> conversationIds)
    {
        throw new NotImplementedException();
    }

    public Conversation GetConversation(string conversationId)
    {
        throw new NotImplementedException();
    }

    public PagedItems<Conversation> GetConversations(ConversationFilter filter)
    {
        throw new NotImplementedException();
    }

    public List<Conversation> GetLastConversations()
    {
        throw new NotImplementedException();
    }

    public List<string> GetIdleConversations(int batchSize, int messageLimit, int bufferHours)
    {
        throw new NotImplementedException();
    }

    public List<DialogElement> GetConversationDialogs(string conversationId)
    {
        throw new NotImplementedException();
    }

    public void UpdateConversationDialogElements(string conversationId, List<DialogContentUpdateModel> updateElements)
    {
        throw new NotImplementedException();
    }

    public ConversationState GetConversationStates(string conversationId)
    {
        throw new NotImplementedException();
    }

    public void AppendConversationDialogs(string conversationId, List<DialogElement> dialogs)
    {
        throw new NotImplementedException();
    }
    public void UpdateConversationTitle(string conversationId, string title)
    {
        throw new NotImplementedException();
    }
    public void UpdateConversationStates(string conversationId, List<StateKeyValue> states)
    {
        throw new NotImplementedException();
    }

    public void UpdateConversationStatus(string conversationId, string status)
    {
        throw new NotImplementedException();
    }

    public bool TruncateConversation(string conversationId, string messageId, bool cleanLog = false)
    {
        throw new NotImplementedException();
    }
    #endregion
    
    #region User
    public User? GetUserByEmail(string email) 
        => throw new NotImplementedException();

    public User? GetUserById(string id) 
        => throw new NotImplementedException();

    public User? GetUserByUserName(string userName) 
        => throw new NotImplementedException();

    public void CreateUser(User user) 
        => throw new NotImplementedException();
    #endregion

    #region Execution Log
    public void AddExecutionLogs(string conversationId, List<string> logs)
    {
        throw new NotImplementedException();
    }

    public List<string> GetExecutionLogs(string conversationId)
    {
        throw new NotImplementedException();
    }
    #endregion

    #region LLM Completion Log
    public void SaveLlmCompletionLog(LlmCompletionLog log)
    {
        throw new NotImplementedException();
    }
    #endregion

    #region Conversation Content Log
    public void SaveConversationContentLog(ContentLogOutputModel log)
    {
        throw new NotImplementedException();
    }

    public List<ContentLogOutputModel> GetConversationContentLogs(string conversationId)
    {
        throw new NotImplementedException();
    }
    #endregion

    #region Conversation State Log
    public void SaveConversationStateLog(ConversationStateLogModel log)
    {
        throw new NotImplementedException();
    }

    public List<ConversationStateLogModel> GetConversationStateLogs(string conversationId)
    {
        throw new NotImplementedException();
    }
    #endregion

    #region Stats
    public void IncrementConversationCount()
    {
        throw new NotImplementedException();
    }
    #endregion
}