Data-Coupler/DataConnection/CredentialManagement/Interfaces/IDataConnectionCredentialService.cs

using CredentialManager.Models;
using CredentialManager.Services;

namespace DataConnection.CredentialManagement.Interfaces;

/// <summary>
/// Interfaccia per la gestione delle credenziali integrate con DataConnection
/// </summary>
public interface IDataConnectionCredentialService
{
    // Database credentials
    Task<DatabaseCredential?> GetDatabaseCredentialAsync(string name);
    Task<DatabaseCredential?> GetDatabaseCredentialAsync(int id);
    Task<List<DatabaseCredential>> GetAllDatabaseCredentialsAsync();
    Task<int> SaveDatabaseCredentialAsync(DatabaseCredential credential);
    Task<bool> DeleteDatabaseCredentialAsync(int id);
    Task<bool> DeleteDatabaseCredentialAsync(string name);

    // REST API credentials
    Task<RestApiCredential?> GetRestApiCredentialAsync(string name);
    Task<RestApiCredential?> GetRestApiCredentialAsync(int id);
    Task<List<RestApiCredential>> GetAllRestApiCredentialsAsync();
    Task<int> SaveRestApiCredentialAsync(RestApiCredential credential);
    Task<bool> DeleteRestApiCredentialAsync(int id);
    Task<bool> DeleteRestApiCredentialAsync(string name);

    // SAP B1 Service Layer credentials
    Task<SapB1ServiceLayerCredential?> GetSapB1CredentialAsync(string name);
    Task<SapB1ServiceLayerCredential?> GetSapB1CredentialAsync(int id);
    Task<List<SapB1ServiceLayerCredential>> GetAllSapB1CredentialsAsync();
    Task<int> SaveSapB1CredentialAsync(SapB1ServiceLayerCredential credential);
    Task<bool> DeleteSapB1CredentialAsync(int id);
    Task<bool> DeleteSapB1CredentialAsync(string name);

    // Salesforce credentials
    Task<SalesforceCredential?> GetSalesforceCredentialAsync(string name);
    Task<SalesforceCredential?> GetSalesforceCredentialAsync(int id);
    Task<List<SalesforceCredential>> GetAllSalesforceCredentialsAsync();
    Task<int> SaveSalesforceCredentialAsync(SalesforceCredential credential);
    Task<bool> DeleteSalesforceCredentialAsync(int id);
    Task<bool> DeleteSalesforceCredentialAsync(string name);

    // DataConnection specific operations
    Task<string> GetConnectionStringAsync(string credentialName);
    Task<string> GetConnectionStringAsync(int credentialId);
    Task<DataConnection.EF.DbManagerOptions> GetDbManagerOptionsAsync(string credentialName);
    Task<DataConnection.EF.DbManagerOptions> GetDbManagerOptionsAsync(int credentialId);
    Task<DataConnection.REST.Configuration.RestServiceOptions> GetRestServiceOptionsAsync(string credentialName);
    Task<DataConnection.REST.Configuration.RestServiceOptions> GetRestServiceOptionsAsync(int credentialId);
    
    // Helper methods
    Task<int?> GetCredentialIdByNameAsync(string name, CredentialManager.Models.CredentialType type);
    
    // Connection testing
    Task<(bool Success, string Message)> TestDatabaseConnectionAsync(string credentialName);
    Task<(bool Success, string Message)> TestDatabaseConnectionAsync(DatabaseCredential credential);
    Task<(bool Success, string Message)> TestRestApiConnectionAsync(string credentialName);
    Task<(bool Success, string Message)> TestRestApiConnectionAsync(RestApiCredential credential);
    Task<(bool Success, string Message)> TestSapB1ConnectionAsync(string credentialName);
    Task<(bool Success, string Message)> TestSapB1ConnectionAsync(SapB1ServiceLayerCredential credential);
    Task<(bool Success, string Message)> TestSalesforceConnectionAsync(string credentialName);
    Task<(bool Success, string Message)> TestSalesforceConnectionAsync(SalesforceCredential credential);

    // Key associations
    Task<int> SaveKeyAssociationAsync(KeyAssociation association);
    Task<int> SaveKeyAssociationParallelAsync(KeyAssociation association);
    Task<KeyAssociation?> FindKeyAssociationByValueAsync(string keyValue, string destinationEntity, string restCredentialName);
    Task<KeyAssociation?> FindKeyAssociationByValueAsync(string keyValue);
    Task<List<KeyAssociation>> GetKeyAssociationsByDestinationAsync(string destinationEntity, string restCredentialName);
    Task<List<KeyAssociation>> GetAllActiveKeyAssociationsAsync();
    Task<List<KeyAssociation>> GetAllKeyAssociationsAsync();
    Task<bool> UpdateKeyAssociationAsync(KeyAssociation association);
    Task<bool> DeactivateKeyAssociationAsync(int id);
    Task<bool> DeleteKeyAssociationAsync(int id);
    Task<int> ClearKeyAssociationsAsync(string destinationEntity, string restCredentialName);
    Task<int> ClearAllKeyAssociationsAsync();
    Task<List<KeyAssociation>> GetInvalidKeyAssociationsAsync(string destinationEntity, string restCredentialName);
    Task<int> CleanupInvalidKeyAssociationsAsync(string destinationEntity, string restCredentialName);
    Task<bool> UpdateKeyAssociationLastVerifiedAsync(int id);
    Task<AssociationStatistics> GetKeyAssociationStatisticsAsync();
    
    // Parallel key association operations
    Task<bool> SaveKeyAssociationParallelAsync(string keyValue, string destinationEntity, string destinationId, string restCredentialName);
    Task<KeyAssociation?> FindKeyAssociationByValueParallelAsync(string keyValue, string destinationEntity, string restCredentialName);
    Task<KeyAssociation?> FindKeyAssociationByValueParallelAsync(string keyValue);
    Task<bool> DeleteKeyAssociationParallelAsync(int id);

    /// <summary>
    /// Bulk lookup associazioni - una sola query SQLite per N chiavi.
    /// </summary>
    Task<Dictionary<string, KeyAssociation>> FindKeyAssociationsByValuesBulkAsync(
        IEnumerable<string> keyValues,
        string destinationEntity,
        string restCredentialName);

    // Deletion synchronization operations
    Task<int> MarkDeletedAssociationsAsync(List<string> sourceKeyValues, string destinationEntity, string restCredentialName);
    Task<List<KeyAssociation>> GetPendingDeletionsAsync(string destinationEntity, string restCredentialName);
    Task<bool> MarkDeletionSyncedAsync(int associationId);
    Task<List<KeyAssociation>> GetDeletedAssociationsAsync(string destinationEntity, string restCredentialName);
    
    // Cascade delete operations
    Task<bool> DeleteCredentialCascadeAsync(string name);
    Task<bool> DeleteCredentialCascadeAsync(int id);
}